diff options
| author | Jeremy Allison <jra@samba.org> | 2000-12-06 00:05:15 +0000 |
|---|---|---|
| committer | Jeremy Allison <jra@samba.org> | 2000-12-06 00:05:15 +0000 |
| commit | 7e4c4721b4fbfa71ce6712ec5b9f3e8e8a105147 (patch) | |
| tree | 2df359e8d49573fd79674cbb8cd592ce896a93d0 /source3/lib | |
| parent | 1cd8538b7abf0970082074d7a114bb9d013d00b2 (diff) | |
| download | samba-7e4c4721b4fbfa71ce6712ec5b9f3e8e8a105147.tar.gz samba-7e4c4721b4fbfa71ce6712ec5b9f3e8e8a105147.tar.bz2 samba-7e4c4721b4fbfa71ce6712ec5b9f3e8e8a105147.zip | |
Changed to sourceforge tdb code. This includes spinlocks (so we now have
a --with-spinlocks option to configure, this does mean the on-disk tdb
format has changed, so 2.2alphaX sites will need to re-create their
tdb's. The upside is no more tdb fragmentation and a +5% on netbench.
Swings and roundabouts....
Jeremy.
(This used to be commit 9dea7b7c257db487f8ced7dad3fce92fba03ea91)
Diffstat (limited to 'source3/lib')
| -rw-r--r-- | source3/lib/messages.c | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/source3/lib/messages.c b/source3/lib/messages.c index c30c389d49..e5aafcb646 100644 --- a/source3/lib/messages.c +++ b/source3/lib/messages.c @@ -174,7 +174,7 @@ BOOL message_send_pid(pid_t pid, int msg_type, void *buf, size_t len, BOOL dupli kbuf = message_key_pid(pid); /* lock the record for the destination */ - tdb_lockchain(tdb, kbuf); + tdb_chainlock(tdb, kbuf); dbuf = tdb_fetch(tdb, kbuf); @@ -208,7 +208,7 @@ BOOL message_send_pid(pid_t pid, int msg_type, void *buf, size_t len, BOOL dupli if (!len || (len && !memcmp( ptr + sizeof(rec), (char *)buf, len))) { DEBUG(10,("message_send_pid: discarding duplicate message.\n")); free(dbuf.dptr); - tdb_unlockchain(tdb, kbuf); + tdb_chainunlock(tdb, kbuf); return True; } } @@ -232,11 +232,11 @@ BOOL message_send_pid(pid_t pid, int msg_type, void *buf, size_t len, BOOL dupli free(dbuf.dptr); ok: - tdb_unlockchain(tdb, kbuf); + tdb_chainunlock(tdb, kbuf); return message_notify(pid); failed: - tdb_unlockchain(tdb, kbuf); + tdb_chainunlock(tdb, kbuf); return False; } @@ -253,7 +253,7 @@ static BOOL message_recv(int *msg_type, pid_t *src, void **buf, size_t *len) kbuf = message_key_pid(sys_getpid()); - tdb_lockchain(tdb, kbuf); + tdb_chainlock(tdb, kbuf); dbuf = tdb_fetch(tdb, kbuf); if (dbuf.dptr == NULL || dbuf.dsize == 0) goto failed; @@ -288,11 +288,11 @@ static BOOL message_recv(int *msg_type, pid_t *src, void **buf, size_t *len) tdb_store(tdb, kbuf, dbuf, TDB_REPLACE); free(dbuf.dptr); - tdb_unlockchain(tdb, kbuf); + tdb_chainunlock(tdb, kbuf); return True; failed: - tdb_unlockchain(tdb, kbuf); + tdb_chainunlock(tdb, kbuf); return False; } |