mirror of
https://git.openldap.org/openldap/openldap.git
synced 2025-01-18 11:05:48 +08:00
7e6ad5100c
Most function and variable definitions are now preceded by its extern definition, for error checking. Retyped a number of functions, usually to return void. Fixed a number of printf format errors. API changes (in ldap/include): Added avl_dup_ok, avl_prefixapply, removed ber_fatten (probably typo for ber_flatten), retyped ldap_sort_strcasecmp, grew lutil.h. A number of `extern' declarations are left (some added by protoize), to be cleaned away later. Mostly strdup(), strcasecmp(), mktemp(), optind, optarg, errno.
139 lines
3.3 KiB
C
139 lines
3.3 KiB
C
/* id.c - keep track of the next id to be given out */
|
|
|
|
#include "portable.h"
|
|
|
|
#include <stdio.h>
|
|
|
|
#include <ac/socket.h>
|
|
|
|
#ifdef HAVE_SYS_PARAM_H
|
|
#include <sys/param.h>
|
|
#endif
|
|
|
|
#include "slap.h"
|
|
#include "back-ldbm.h"
|
|
|
|
ID
|
|
next_id( Backend *be )
|
|
{
|
|
struct ldbminfo *li = (struct ldbminfo *) be->be_private;
|
|
char buf[MAXPATHLEN];
|
|
char buf2[20];
|
|
FILE *fp;
|
|
ID id;
|
|
|
|
sprintf( buf, "%s/NEXTID", li->li_directory );
|
|
|
|
pthread_mutex_lock( &li->li_nextid_mutex );
|
|
/* first time in here since startup - try to read the nexid */
|
|
if ( li->li_nextid == -1 ) {
|
|
if ( (fp = fopen( buf, "r" )) == NULL ) {
|
|
Debug( LDAP_DEBUG_ANY,
|
|
"next_id %lu: could not open \"%s\"\n",
|
|
li->li_nextid, buf, 0 );
|
|
li->li_nextid = 1;
|
|
} else {
|
|
if ( fgets( buf2, sizeof(buf2), fp ) != NULL ) {
|
|
li->li_nextid = atol( buf2 );
|
|
} else {
|
|
Debug( LDAP_DEBUG_ANY,
|
|
"next_id %lu: could not fgets nextid from \"%s\"\n",
|
|
li->li_nextid, buf2, 0 );
|
|
li->li_nextid = 1;
|
|
}
|
|
fclose( fp );
|
|
}
|
|
}
|
|
|
|
li->li_nextid++;
|
|
if ( (fp = fopen( buf, "w" )) == NULL ) {
|
|
Debug( LDAP_DEBUG_ANY, "next_id %lu: could not open \"%s\"\n",
|
|
li->li_nextid, buf, 0 );
|
|
} else {
|
|
if ( fprintf( fp, "%ld\n", li->li_nextid ) == EOF ) {
|
|
Debug( LDAP_DEBUG_ANY, "next_id %lu: cannot fprintf\n",
|
|
li->li_nextid, 0, 0 );
|
|
}
|
|
if( fclose( fp ) != 0 ) {
|
|
Debug( LDAP_DEBUG_ANY, "next_id %lu: cannot fclose\n",
|
|
li->li_nextid, 0, 0 );
|
|
}
|
|
}
|
|
id = li->li_nextid - 1;
|
|
pthread_mutex_unlock( &li->li_nextid_mutex );
|
|
|
|
return( id );
|
|
}
|
|
|
|
void
|
|
next_id_return( Backend *be, ID id )
|
|
{
|
|
struct ldbminfo *li = (struct ldbminfo *) be->be_private;
|
|
char buf[MAXPATHLEN];
|
|
FILE *fp;
|
|
|
|
pthread_mutex_lock( &li->li_nextid_mutex );
|
|
if ( id != li->li_nextid - 1 ) {
|
|
pthread_mutex_unlock( &li->li_nextid_mutex );
|
|
return;
|
|
}
|
|
|
|
sprintf( buf, "%s/NEXTID", li->li_directory );
|
|
|
|
li->li_nextid--;
|
|
if ( (fp = fopen( buf, "w" )) == NULL ) {
|
|
Debug( LDAP_DEBUG_ANY,
|
|
"next_id_return of %lu: could not open \"%s\" next id %lu\n",
|
|
id, buf, li->li_nextid );
|
|
} else {
|
|
if ( fprintf( fp, "%ld\n", li->li_nextid ) == EOF ) {
|
|
Debug( LDAP_DEBUG_ANY,
|
|
"next_id_return of %lu: cannot fprintf \"%s\" next id %lu\n",
|
|
id, buf, li->li_nextid );
|
|
}
|
|
if( fclose( fp ) != 0 ) {
|
|
Debug( LDAP_DEBUG_ANY,
|
|
"next_id_return of %lu: cannot fclose \"%s\" next id %lu\n",
|
|
id, buf, li->li_nextid );
|
|
}
|
|
}
|
|
pthread_mutex_unlock( &li->li_nextid_mutex );
|
|
}
|
|
|
|
ID
|
|
next_id_get( Backend *be )
|
|
{
|
|
struct ldbminfo *li = (struct ldbminfo *) be->be_private;
|
|
char buf[MAXPATHLEN];
|
|
char buf2[20];
|
|
FILE *fp;
|
|
ID id;
|
|
|
|
sprintf( buf, "%s/NEXTID", li->li_directory );
|
|
|
|
pthread_mutex_lock( &li->li_nextid_mutex );
|
|
/* first time in here since startup - try to read the nexid */
|
|
if ( li->li_nextid == -1 ) {
|
|
if ( (fp = fopen( buf, "r" )) == NULL ) {
|
|
Debug( LDAP_DEBUG_ANY,
|
|
"next_id %lu: could not open \"%s\"\n",
|
|
li->li_nextid, buf, 0 );
|
|
li->li_nextid = 1;
|
|
} else {
|
|
if ( fgets( buf2, sizeof(buf2), fp ) != NULL ) {
|
|
li->li_nextid = atol( buf2 );
|
|
} else {
|
|
Debug( LDAP_DEBUG_ANY,
|
|
"next_id %lu: cannot fgets nextid from \"%s\"\n",
|
|
li->li_nextid, buf2, 0 );
|
|
li->li_nextid = 1;
|
|
}
|
|
fclose( fp );
|
|
}
|
|
}
|
|
id = li->li_nextid;
|
|
pthread_mutex_unlock( &li->li_nextid_mutex );
|
|
|
|
return( id );
|
|
}
|