mirror/openldap
2
0
Fork 0
mirror of https://git.openldap.org/openldap/openldap.git synced 2024-12-21 03:10:25 +08:00
Code Issues Packages Projects Releases Wiki Activity

ITS#3607, added Win32 lock support

Browse Source
This commit is contained in:
Howard Chu 2005-04-01 06:10:06 +00:00
parent af866c3b44
commit 18d1821b1f
1 changed files with 49 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

61
servers/slapd/back-bdb/alock.c
View File

@ -29,19 +29,26 @@
#include <ac/assert.h> #include <ac/assert.h>
#include <sys/types.h> #include <sys/types.h>
#include <sys/stat.h> #include <sys/stat.h>
#include <sys/file.h>
#include <fcntl.h> #include <fcntl.h>
#ifdef _WIN32
#include <stdio.h>
#include <io.h>
#include <sys/locking.h>
#endif
static int static int
alock_grab_lock ( int fd, int slot ) alock_grab_lock ( int fd, int slot )
{ {
int res; int res;
#ifdef HAVE_LOCKF #if defined( HAVE_LOCKF )
res = lseek (fd, (off_t) (ALOCK_SLOT_SIZE * slot), SEEK_SET); res = lseek (fd, (off_t) (ALOCK_SLOT_SIZE * slot), SEEK_SET);
if (res == -1) return -1; if (res == -1) return -1;
res = lockf (fd, F_LOCK, (off_t) ALOCK_SLOT_SIZE); res = lockf (fd, F_LOCK, (off_t) ALOCK_SLOT_SIZE);
#else #elif defined( HAVE_FCNTL )
# ifdef HAVE_FCNTL
struct flock lock_info; struct flock lock_info;
(void) memset ((void *) &lock_info, 0, sizeof (struct flock)); (void) memset ((void *) &lock_info, 0, sizeof (struct flock));
@ -51,9 +58,20 @@ alock_grab_lock ( int fd, int slot )
lock_info.l_len = (off_t) ALOCK_SLOT_SIZE; lock_info.l_len = (off_t) ALOCK_SLOT_SIZE;
res = fcntl (fd, F_SETLKW, &lock_info); res = fcntl (fd, F_SETLKW, &lock_info);
#elif defined( _WIN32 )
if( _lseek( fd, (ALOCK_SLOT_SIZE * slot), SEEK_SET ) < 0 )
return -1;
/*
* _lock will try for the lock once per second, returning EDEADLOCK
* after ten tries. We just loop until we either get the lock
* or some other error is returned.
*/
while((res = _locking( fd, _LK_LOCK, ALOCK_SLOT_SIZE )) < 0 ) {
if( errno != EDEADLOCK )
break;
}
#else #else
# error libalock needs lockf or fcntl # error alock needs lockf, fcntl, or _locking
# endif
#endif #endif
if (res == -1) { if (res == -1) {
assert (errno != EDEADLK); assert (errno != EDEADLK);
@ -67,13 +85,12 @@ alock_release_lock ( int fd, int slot )
{ {
int res; int res;
#ifdef HAVE_LOCKF #if defined( HAVE_LOCKF )
res = lseek (fd, (off_t) (ALOCK_SLOT_SIZE * slot), SEEK_SET); res = lseek (fd, (off_t) (ALOCK_SLOT_SIZE * slot), SEEK_SET);
if (res == -1) return -1; if (res == -1) return -1;
res = lockf (fd, F_ULOCK, (off_t) ALOCK_SLOT_SIZE); res = lockf (fd, F_ULOCK, (off_t) ALOCK_SLOT_SIZE);
if (res == -1) return -1; if (res == -1) return -1;
#else #elif defined ( HAVE_FCNTL )
# ifdef HAVE_FCNTL
struct flock lock_info; struct flock lock_info;
(void) memset ((void *) &lock_info, 0, sizeof (struct flock)); (void) memset ((void *) &lock_info, 0, sizeof (struct flock));
@ -84,9 +101,13 @@ alock_release_lock ( int fd, int slot )
res = fcntl (fd, F_SETLKW, &lock_info); res = fcntl (fd, F_SETLKW, &lock_info);
if (res == -1) return -1; if (res == -1) return -1;
#elif defined( _WIN32 )
res = _lseek (fd, (ALOCK_SLOT_SIZE * slot), SEEK_SET);
if (res == -1) return -1;
res = _locking( fd, _LK_UNLCK, ALOCK_SLOT_SIZE );
if (res == -1) return -1;
#else #else
# error libalock needs lockf or fcntl # error alock needs lockf, fcntl, or _locking
# endif
#endif #endif
return 0; return 0;
@ -97,7 +118,7 @@ alock_test_lock ( int fd, int slot )
{ {
int res; int res;
#ifdef HAVE_LOCKF #if defined( HAVE_LOCKF )
res = lseek (fd, (off_t) (ALOCK_SLOT_SIZE * slot), SEEK_SET); res = lseek (fd, (off_t) (ALOCK_SLOT_SIZE * slot), SEEK_SET);
if (res == -1) return -1; if (res == -1) return -1;
@ -109,8 +130,7 @@ alock_test_lock ( int fd, int slot )
return -1; return -1;
} }
} }
#else #elif defined( HAVE_FCNTL )
# ifdef HAVE_FCNTL
struct flock lock_info; struct flock lock_info;
(void) memset ((void *) &lock_info, 0, sizeof (struct flock)); (void) memset ((void *) &lock_info, 0, sizeof (struct flock));
@ -123,9 +143,20 @@ alock_test_lock ( int fd, int slot )
if (res == -1) return -1; if (res == -1) return -1;
if (lock_info.l_type != F_UNLCK) return ALOCK_LOCKED; if (lock_info.l_type != F_UNLCK) return ALOCK_LOCKED;
#elif defined( _WIN32 )
res = _lseek (fd, (ALOCK_SLOT_SIZE * slot), SEEK_SET);
if (res == -1) return -1;
res = _locking( fd, _LK_NBLCK, ALOCK_SLOT_SIZE );
_locking( fd, _LK_UNLCK, ALOCK_SLOT_SIZE );
if (res == -1) {
if( errno == EACCES ) {
return ALOCK_LOCKED;
} else {
return -1;
}
}
#else #else
# error libalock needs lockf or fcntl # error alock needs lockf, fcntl, or _locking
# endif
#endif #endif
return 0; return 0;