mirror of
https://git.openldap.org/openldap/openldap.git
synced 2024-12-15 03:01:09 +08:00
b73b0c6158
ldapsearch:
use draft guidelines for determining when to use
-t only writes binary attributes to files
-tt writes all attributes to files
output now lists URL instead of path to such files
-T dir can be used to specify directory to create temp files in
-V urlprefix can be used to change the URL prefix
LDIF is now commented (can be disabled using -LL)
LDIF now contains version attribute (can be disabled with -LLL)
LDIF:
put interface changed to allow caller to specify how to encode
put interface uses draft guidelines for determine when to base64 encode
wrapping kludged to match old off by one bug
Tests:
removed trailing space from some attributes (to avoid base64 encoding)
enabled -LLL in defines.sh (should sed output to remove
wrapping/comments/redundant separators)
Misc:
updated codes outputting LDIF to use new put interface
TODO:
handling of version attribute on input
handling of URLs on input (ie: fetch URL)
126 lines
2.6 KiB
C
126 lines
2.6 KiB
C
/* repl.c - log modifications for replication purposes */
|
|
|
|
#include "portable.h"
|
|
|
|
#include <stdio.h>
|
|
|
|
#include <ac/string.h>
|
|
#include <ac/ctype.h>
|
|
#include <ac/socket.h>
|
|
|
|
#ifdef HAVE_SYS_FILE_H
|
|
#include <sys/file.h>
|
|
#endif
|
|
|
|
#include "slap.h"
|
|
|
|
|
|
void
|
|
replog(
|
|
Backend *be,
|
|
Operation *op,
|
|
char *dn,
|
|
void *change
|
|
)
|
|
{
|
|
LDAPModList *ml;
|
|
Entry *e;
|
|
struct replog_moddn *moddn;
|
|
char *tmp;
|
|
FILE *fp, *lfp;
|
|
int len, i;
|
|
|
|
if ( be->be_replogfile == NULL && replogfile == NULL ) {
|
|
return;
|
|
}
|
|
|
|
ldap_pvt_thread_mutex_lock( &replog_mutex );
|
|
if ( (fp = lock_fopen( be->be_replogfile ? be->be_replogfile :
|
|
replogfile, "a", &lfp )) == NULL ) {
|
|
ldap_pvt_thread_mutex_unlock( &replog_mutex );
|
|
return;
|
|
}
|
|
|
|
for ( i = 0; be->be_replica != NULL && be->be_replica[i] != NULL;
|
|
i++ ) {
|
|
fprintf( fp, "replica: %s\n", be->be_replica[i] );
|
|
}
|
|
fprintf( fp, "time: %ld\n", (long) slap_get_time() );
|
|
fprintf( fp, "dn: %s\n", dn );
|
|
|
|
switch ( op->o_tag ) {
|
|
case LDAP_REQ_MODIFY:
|
|
fprintf( fp, "changetype: modify\n" );
|
|
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", ml->ml_type );
|
|
break;
|
|
|
|
case LDAP_MOD_DELETE:
|
|
fprintf( fp, "delete: %s\n", ml->ml_type );
|
|
break;
|
|
|
|
case LDAP_MOD_REPLACE:
|
|
fprintf( fp, "replace: %s\n", ml->ml_type );
|
|
break;
|
|
}
|
|
|
|
for ( i = 0; ml->ml_bvalues != NULL &&
|
|
ml->ml_bvalues[i] != NULL; i++ ) {
|
|
char *buf, *bufp;
|
|
|
|
len = strlen( ml->ml_type );
|
|
len = LDIF_SIZE_NEEDED( len,
|
|
ml->ml_bvalues[i]->bv_len ) + 1;
|
|
buf = (char *) ch_malloc( len );
|
|
|
|
bufp = buf;
|
|
ldif_sput( &bufp, LDIF_PUT_VALUE,
|
|
ml->ml_type,
|
|
ml->ml_bvalues[i]->bv_val,
|
|
ml->ml_bvalues[i]->bv_len );
|
|
*bufp = '\0';
|
|
|
|
fputs( buf, fp );
|
|
|
|
free( buf );
|
|
}
|
|
fprintf( fp, "-\n" );
|
|
}
|
|
break;
|
|
|
|
case LDAP_REQ_ADD:
|
|
e = change;
|
|
fprintf( fp, "changetype: add\n" );
|
|
ldap_pvt_thread_mutex_lock( &entry2str_mutex );
|
|
tmp = entry2str( e, &len, 0 );
|
|
while ( (tmp = strchr( tmp, '\n' )) != NULL ) {
|
|
tmp++;
|
|
if ( ! isspace( (unsigned char) *tmp ) )
|
|
break;
|
|
}
|
|
fprintf( fp, "%s", tmp );
|
|
ldap_pvt_thread_mutex_unlock( &entry2str_mutex );
|
|
break;
|
|
|
|
case LDAP_REQ_DELETE:
|
|
fprintf( fp, "changetype: delete\n" );
|
|
break;
|
|
|
|
case LDAP_REQ_MODRDN:
|
|
moddn = change;
|
|
fprintf( fp, "changetype: modrdn\n" );
|
|
fprintf( fp, "newrdn: %s\n", moddn->newrdn );
|
|
fprintf( fp, "deleteoldrdn: %d\n", moddn->deloldrdn ? 1 : 0 );
|
|
if( moddn->newsup != NULL ) {
|
|
fprintf( fp, "newsuperior: %s\n", moddn->newsup );
|
|
}
|
|
}
|
|
fprintf( fp, "\n" );
|
|
|
|
lock_fclose( fp, lfp );
|
|
ldap_pvt_thread_mutex_unlock( &replog_mutex );
|
|
}
|