X-Git-Url: https://git.sur5r.net/?a=blobdiff_plain;f=servers%2Fslapd%2Flock.c;h=79017f23a0dc4bac923e78f995e5d112476a9d85;hb=27cb98d28d60b1f258ea12852b22bfdfec6380f6;hp=f634b220aa3026518a5e849b037b0a5c38df7dc8;hpb=b5494457d86d7b57b8de5fccda725e143c8e30bd;p=openldap diff --git a/servers/slapd/lock.c b/servers/slapd/lock.c index f634b220aa..79017f23a0 100644 --- a/servers/slapd/lock.c +++ b/servers/slapd/lock.c @@ -1,4 +1,9 @@ /* lock.c - routines to open and apply an advisory lock to a file */ +/* $OpenLDAP$ */ +/* + * Copyright 1998-2002 The OpenLDAP Foundation, All Rights Reserved. + * COPYING RESTRICTIONS APPLY, see COPYRIGHT file + */ #include "portable.h" @@ -9,41 +14,46 @@ #include #include +#ifdef HAVE_SYS_FILE_H #include -#include +#endif + +#include #include "slap.h" FILE * -lock_fopen( char *fname, char *type, FILE **lfp ) +lock_fopen( const char *fname, const char *type, FILE **lfp ) { FILE *fp; char buf[MAXPATHLEN]; /* open the lock file */ - strcpy( buf, fname ); - strcat( buf, ".lock" ); + snprintf( buf, sizeof buf, "%s.lock", fname ); + if ( (*lfp = fopen( buf, "w" )) == NULL ) { +#ifdef NEW_LOGGING + LDAP_LOG( OPERATION, ERR, + "lock_fopen: could not open lock file \"%s\".\n", buf, 0, 0); +#else Debug( LDAP_DEBUG_ANY, "could not open \"%s\"\n", buf, 0, 0 ); +#endif + return( NULL ); } /* acquire the lock */ -#ifdef HAVE_FLOCK - while ( flock( fileno( *lfp ), LOCK_EX ) != 0 ) { -#else - while ( lockf( fileno( *lfp ), F_LOCK, 0 ) != 0 ) { -#endif - ; /* NULL */ - } + ldap_lockf( fileno(*lfp) ); /* open the log file */ if ( (fp = fopen( fname, type )) == NULL ) { - Debug( LDAP_DEBUG_ANY, "could not open \"%s\"\n", fname, 0, 0 ); -#ifdef HAVE_FLOCK - flock( fileno( *lfp ), LOCK_UN ); +#ifdef NEW_LOGGING + LDAP_LOG( OPERATION, ERR, + "lock_fopen: could not open log file \"%s\".\n", buf, 0, 0); #else - lockf( fileno( *lfp ), F_ULOCK, 0 ); + Debug( LDAP_DEBUG_ANY, "could not open \"%s\"\n", fname, 0, 0 ); #endif + + ldap_unlockf( fileno(*lfp) ); fclose( *lfp ); *lfp = NULL; return( NULL ); @@ -56,11 +66,7 @@ int lock_fclose( FILE *fp, FILE *lfp ) { /* unlock */ -#ifdef HAVE_FLOCK - flock( fileno( lfp ), LOCK_UN ); -#else - lockf( fileno( lfp ), F_ULOCK, 0 ); -#endif + ldap_unlockf( fileno(lfp) ); fclose( lfp ); return( fclose( fp ) );