X-Git-Url: https://git.sur5r.net/?a=blobdiff_plain;f=servers%2Fslapd%2Frepl.c;h=0c3f04a7cf5a8072aae3ef5ce1e44a2ec0febbff;hb=63498d1a2199eeca1db4ca7d27e665cbd73cb095;hp=cd0198ebd754c2af46f35a0921029eeaae760224;hpb=b76c56ba3f45576b9c418ea9fe7f7b3440052904;p=openldap diff --git a/servers/slapd/repl.c b/servers/slapd/repl.c index cd0198ebd7..0c3f04a7cf 100644 --- a/servers/slapd/repl.c +++ b/servers/slapd/repl.c @@ -3,21 +3,17 @@ #include "portable.h" #include -#include -#include + +#include +#include +#include + +#ifdef HAVE_SYS_FILE_H #include -#include -#include "slap.h" +#endif -extern pthread_mutex_t replog_mutex; -extern pthread_mutex_t entry2str_mutex; -extern time_t currenttime; -extern char *replogfile; +#include "slap.h" -extern FILE *lock_fopen(); -extern int lock_fclose(); -extern char *ch_malloc(); -extern char *entry2str(); void replog( @@ -28,10 +24,9 @@ replog( int flag ) { - LDAPMod *mods; + LDAPModList *ml; Entry *e; char *newrdn, *tmp; - int deleteoldrdn; FILE *fp, *lfp; int len, i; @@ -39,10 +34,10 @@ replog( return; } - pthread_mutex_lock( &replog_mutex ); + ldap_pvt_thread_mutex_lock( &replog_mutex ); if ( (fp = lock_fopen( be->be_replogfile ? be->be_replogfile : replogfile, "a", &lfp )) == NULL ) { - pthread_mutex_unlock( &replog_mutex ); + ldap_pvt_thread_mutex_unlock( &replog_mutex ); return; } @@ -50,41 +45,41 @@ replog( i++ ) { fprintf( fp, "replica: %s\n", be->be_replica[i] ); } - fprintf( fp, "time: %ld\n", currenttime ); + fprintf( fp, "time: %ld\n", (long) slap_get_time() ); fprintf( fp, "dn: %s\n", dn ); switch ( optype ) { case LDAP_REQ_MODIFY: fprintf( fp, "changetype: modify\n" ); - mods = change; - for ( ; mods != NULL; mods = mods->mod_next ) { - switch ( mods->mod_op & ~LDAP_MOD_BVALUES ) { + ml = change; + for ( ; ml != NULL; ml = ml->ml_next ) { + switch ( ml->ml_op & ~LDAP_MOD_BVALUES ) { case LDAP_MOD_ADD: - fprintf( fp, "add: %s\n", mods->mod_type ); + fprintf( fp, "add: %s\n", ml->ml_type ); break; case LDAP_MOD_DELETE: - fprintf( fp, "delete: %s\n", mods->mod_type ); + fprintf( fp, "delete: %s\n", ml->ml_type ); break; case LDAP_MOD_REPLACE: - fprintf( fp, "replace: %s\n", mods->mod_type ); + fprintf( fp, "replace: %s\n", ml->ml_type ); break; } - for ( i = 0; mods->mod_bvalues != NULL && - mods->mod_bvalues[i] != NULL; i++ ) { + for ( i = 0; ml->ml_bvalues != NULL && + ml->ml_bvalues[i] != NULL; i++ ) { char *buf, *bufp; - len = strlen( mods->mod_type ); + len = strlen( ml->ml_type ); len = LDIF_SIZE_NEEDED( len, - mods->mod_bvalues[i]->bv_len ) + 1; - buf = ch_malloc( len ); + ml->ml_bvalues[i]->bv_len ) + 1; + buf = (char *) ch_malloc( len ); bufp = buf; - put_type_and_value( &bufp, mods->mod_type, - mods->mod_bvalues[i]->bv_val, - mods->mod_bvalues[i]->bv_len ); + ldif_put_type_and_value( &bufp, ml->ml_type, + ml->ml_bvalues[i]->bv_val, + ml->ml_bvalues[i]->bv_len ); *bufp = '\0'; fputs( buf, fp ); @@ -98,15 +93,15 @@ replog( case LDAP_REQ_ADD: e = change; fprintf( fp, "changetype: add\n" ); - pthread_mutex_lock( &entry2str_mutex ); + ldap_pvt_thread_mutex_lock( &entry2str_mutex ); tmp = entry2str( e, &len, 0 ); while ( (tmp = strchr( tmp, '\n' )) != NULL ) { tmp++; - if ( ! isspace( *tmp ) ) + if ( ! isspace( (unsigned char) *tmp ) ) break; } fprintf( fp, "%s", tmp ); - pthread_mutex_unlock( &entry2str_mutex ); + ldap_pvt_thread_mutex_unlock( &entry2str_mutex ); break; case LDAP_REQ_DELETE: @@ -122,5 +117,5 @@ replog( fprintf( fp, "\n" ); lock_fclose( fp, lfp ); - pthread_mutex_unlock( &replog_mutex ); + ldap_pvt_thread_mutex_unlock( &replog_mutex ); }