sin/samba-mirror
1
0
Fork 0
mirror of https://github.com/samba-team/samba.git synced 2025-02-02 09:47:23 +03:00
Code

s3:dbwrap_watch: only notify the first waiter

Browse Source 
In case of a highly contended record we will have a lot of watchers,
which will all race to get g_lock_lock() to finish.

If g_lock_unlock() wakes them all, e.g. 250 of them, we get a thundering
herd, were 249 will only find that one of them as able to get the lock
and re-add their watcher entry (not unlikely in a different order).

With this commit we only wake the first watcher and let it remove
itself once it no longer wants to monitor the record content
(at that time it will wake the new first watcher).

It means the woken watcher doesn't have to race with all others
and also means order of watchers is kept, which means that we
most likely get a fair latency distribution for all watchers.

The following test with 256 commections all looping with open/close
on the same inode (share root) is improved drastically:

  smbtorture //127.0.0.1/m -Uroot%test smb2.create.bench-path-contention-shared \
     --option='torture:bench_path=' \
     --option="torture:timelimit=60" \
     --option="torture:nprocs=256"

From some like this:

   open[num/s=80,avslat=2.793862,minlat=0.004097,maxlat=46.597053]
   close[num/s=80,avslat=2.387326,minlat=0.023875,maxlat=50.878165]

to:

   open[num/s=8800,avslat=0.021445,minlat=0.000095,maxlat=0.179786]
   close[num/s=8800,avslat=0.021658,minlat=0.000044,maxlat=0.179819]

BUG: https://bugzilla.samba.org/show_bug.cgi?id=15125

Signed-off-by: Stefan Metzmacher <metze@samba.org>
Reviewed-by: Jeremy Allison <jra@samba.org>
Reviewed-by: Ralph Boehme <slow@samba.org>
This commit is contained in:
Stefan Metzmacher 2022-06-26 12:57:06 +00:00 committed by Ralph Boehme
parent 6e701d02ee
commit 9d99911663
1 changed files with 72 additions and 33 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

105
source3/lib/dbwrap/dbwrap_watch.c
View File

@ -25,6 +25,7 @@
#include "dbwrap_open.h"
#include "lib/util/util_tdb.h"
#include "lib/util/tevent_ntstatus.h"
#include "serverid.h"
#include "server_id_watch.h"
#include "lib/dbwrap/dbwrap_private.h"
@ -150,6 +151,7 @@ struct db_watched_record {
} backend;
bool force_fini_store;
struct dbwrap_watcher added;
bool removed_first;
struct {
/*
* The is the number of watcher records
@ -180,6 +182,9 @@ struct db_watched_record {
*/
bool alerted;
} watchers;
struct {
struct dbwrap_watcher watcher;
} wakeup;
};
static struct db_watched_record *db_record_get_watched_record(struct db_record *rec)
@ -396,9 +401,13 @@ static void db_watched_record_fini(struct db_watched_record *wrec)
/*
* We don't want to wake up others just because
* we added ourself as new watcher.
* we added ourself as new watcher. But if we
* removed outself from the first position
* we need to alert the next one.
*/
dbwrap_watched_watch_skip_alerting(rec);
if (!wrec->removed_first) {
dbwrap_watched_watch_skip_alerting(rec);
}
status = dbwrap_watched_record_storev(wrec, state.dbufs, state.num_dbufs, 0);
TALLOC_FREE(state.frame);
@ -474,7 +483,7 @@ static NTSTATUS dbwrap_watched_do_locked(struct db_context *db, TDB_DATA key,
return NT_STATUS_OK;
}
static void dbwrap_watched_record_wakeup(
static void dbwrap_watched_record_prepare_wakeup(
struct db_watched_record *wrec)
{
/*
@ -492,39 +501,74 @@ static void dbwrap_watched_record_wakeup(
}
while (wrec->watchers.count != 0) {
struct dbwrap_watcher watcher;
struct server_id_buf tmp;
uint8_t instance_buf[8];
NTSTATUS status;
bool exists;
dbwrap_watcher_get(&watcher, wrec->watchers.first);
DBG_DEBUG("Alerting %s:%"PRIu64"\n",
server_id_str_buf(watcher.pid, &tmp),
watcher.instance);
SBVAL(instance_buf, 0, watcher.instance);
status = messaging_send_buf(
wrec->msg_ctx,
watcher.pid,
MSG_DBWRAP_MODIFIED,
instance_buf,
sizeof(instance_buf));
if (!NT_STATUS_IS_OK(status)) {
DBG_DEBUG("messaging_send_buf to %s failed: %s\n",
server_id_str_buf(watcher.pid, &tmp),
nt_errstr(status));
dbwrap_watcher_get(&wrec->wakeup.watcher, wrec->watchers.first);
exists = serverid_exists(&wrec->wakeup.watcher.pid);
if (!exists) {
DBG_DEBUG("Discard non-existing waiter %s:%"PRIu64"\n",
server_id_str_buf(wrec->wakeup.watcher.pid, &tmp),
wrec->wakeup.watcher.instance);
wrec->watchers.first += DBWRAP_WATCHER_BUF_LENGTH;
wrec->watchers.count -= 1;
continue;
}
/*
* Watchers are only informed once for now...
* We will only wakeup the first waiter, via
* dbwrap_watched_trigger_wakeup(), but keep
* all (including the first one) in the list that
* will be flushed back to the backend record
* again. Waiters are removing their entries
* via dbwrap_watched_watch_remove_instance()
* when they no longer want to monitor the record.
*/
wrec->watchers.first += DBWRAP_WATCHER_BUF_LENGTH;
wrec->watchers.count -= 1;
DBG_DEBUG("Will alert first waiter %s:%"PRIu64"\n",
server_id_str_buf(wrec->wakeup.watcher.pid, &tmp),
wrec->wakeup.watcher.instance);
break;
}
}
static void dbwrap_watched_trigger_wakeup(struct messaging_context *msg_ctx,
struct dbwrap_watcher *watcher)
{
struct server_id_buf tmp;
uint8_t instance_buf[8];
NTSTATUS status;
if (watcher->instance == 0) {
DBG_DEBUG("No one to wakeup\n");
return;
}
DBG_DEBUG("Alerting %s:%"PRIu64"\n",
server_id_str_buf(watcher->pid, &tmp),
watcher->instance);
SBVAL(instance_buf, 0, watcher->instance);
status = messaging_send_buf(
msg_ctx,
watcher->pid,
MSG_DBWRAP_MODIFIED,
instance_buf,
sizeof(instance_buf));
if (!NT_STATUS_IS_OK(status)) {
DBG_WARNING("messaging_send_buf to %s failed: %s - ignoring...\n",
server_id_str_buf(watcher->pid, &tmp),
nt_errstr(status));
}
}
static void dbwrap_watched_record_wakeup(
struct db_watched_record *wrec)
{
dbwrap_watched_record_prepare_wakeup(wrec);
dbwrap_watched_trigger_wakeup(wrec->msg_ctx, &wrec->wakeup.watcher);
}
static NTSTATUS dbwrap_watched_record_storev(
struct db_watched_record *wrec,
const TDB_DATA *dbufs, int num_dbufs, int flags)
@ -951,6 +995,7 @@ void dbwrap_watched_watch_remove_instance(struct db_record *rec, uint64_t instan
wrec->watchers.count);
wrec->watchers.first += DBWRAP_WATCHER_BUF_LENGTH;
wrec->watchers.count -= 1;
wrec->removed_first = true;
return;
}
if (i == (wrec->watchers.count-1)) {
@ -1187,12 +1232,6 @@ static void dbwrap_watched_watch_done(struct tevent_req *subreq)
tevent_req_nterror(req, map_nt_error_from_unix(ret));
return;
}
/*
* No need to remove ourselves anymore, we've been removed by
* dbwrap_watched_record_wakeup().
*/
talloc_set_destructor(state, NULL);
state->watcher.instance = 0;
tevent_req_done(req);
}