/* $OpenLDAP: pkg/ldap/servers/slurpd/reject.c,v 1.18.2.4 2007/01/02 21:44:11 kurt Exp $ */ /* This work is part of OpenLDAP Software . * * Copyright 1998-2007 The OpenLDAP Foundation. * All rights reserved. * * Redistribution and use in source and binary forms, with or without * modification, are permitted only as authorized by the OpenLDAP * Public License. * * A copy of this license is available in file LICENSE in the * top-level directory of the distribution or, alternatively, at * . */ /* Portions Copyright (c) 1996 Regents of the University of Michigan. * All rights reserved. * * Redistribution and use in source and binary forms are permitted * provided that this notice is preserved and that due credit is given * to the University of Michigan at Ann Arbor. The name of the University * may not be used to endorse or promote products derived from this * software without specific prior written permission. This software * is provided ``as is'' without express or implied warranty. */ /* ACKNOWLEDGEMENTS: * This work was originally developed by the University of Michigan * (as part of U-MICH LDAP). */ /* * reject.c - routines to write replication records to reject files. * An Re struct is writted to a reject file if it cannot be propagated * to a replica LDAP server. */ #include "portable.h" #include #include #include #include #include #include #include #include "slurp.h" #include "globals.h" #include "lber_pvt.h" #include "lutil.h" #ifdef _WIN32 #define PORTSEP "," #else #define PORTSEP ":" #endif /* * Write a replication record to a reject file. The reject file has the * same name as the replica's private copy of the file but with ".rej" * appended (e.g. "/usr/tmp/:.rej") * * If errmsg is non-NULL, use that as the error message in the reject * file. Otherwise, use ldap_err2string( lderr ). */ void write_reject( Ri *ri, Re *re, int lderr, char *errmsg ) { char rejfile[ MAXPATHLEN ]; FILE *rfp, *lfp; int rc; ldap_pvt_thread_mutex_lock( &sglob->rej_mutex ); snprintf( rejfile, sizeof rejfile, "%s" LDAP_DIRSEP "%s" PORTSEP "%d.rej", sglob->slurpd_rdir, ri->ri_hostname, ri->ri_port ); if ( access( rejfile, F_OK ) < 0 ) { /* Doesn't exist - try to create */ int rjfd; if (( rjfd = open( rejfile, O_RDWR|O_APPEND|O_CREAT|O_EXCL, S_IRUSR | S_IWUSR | S_IRGRP | S_IWGRP )) < 0 ) { Debug( LDAP_DEBUG_ANY, "Error: write_reject: Cannot create \"%s\": %s\n", rejfile, sys_errlist[ errno ], 0 ); ldap_pvt_thread_mutex_unlock( &sglob->rej_mutex ); return; } else { close( rjfd ); } } if (( rc = acquire_lock( rejfile, &rfp, &lfp )) < 0 ) { Debug( LDAP_DEBUG_ANY, "Error: cannot open reject file \"%s\"\n", rejfile, 0, 0 ); } else { struct berval bv = BER_BVNULL, errstrbv, errmsgbv = BER_BVNULL; char *ptr; ber_str2bv( ldap_err2string( lderr ), 0, 0, &errstrbv ); if ( errmsg && *errmsg ) { ber_str2bv( errmsg, 0, 0, &errmsgbv ); bv.bv_len = errstrbv.bv_len + STRLENOF( ": " ) + errmsgbv.bv_len; ptr = bv.bv_val = ber_memalloc( bv.bv_len + 1 ); ptr = lutil_strcopy( ptr, errstrbv.bv_val ); ptr = lutil_strcopy( ptr, ": " ); ptr = lutil_strcopy( ptr, errmsgbv.bv_val ); } else { bv = errstrbv; } fseek( rfp, 0, 2 ); ptr = ldif_put( LDIF_PUT_VALUE, ERROR_STR, bv.bv_val, bv.bv_len ); if ( bv.bv_val != errstrbv.bv_val ) { ber_memfree( bv.bv_val ); } if ( ptr == NULL ) { Debug( LDAP_DEBUG_ANY, "Error: cannot convert error message(s) \"%s%s%s\" " "into LDIF format\n", errstrbv.bv_val, BER_BVISNULL( &errmsgbv ) ? "" : ": ", BER_BVISNULL( &errmsgbv ) ? "" : errmsgbv.bv_val ); return; } fputs( ptr, rfp ); ber_memfree( ptr ); if ((rc = re->re_write( ri, re, rfp )) < 0 ) { Debug( LDAP_DEBUG_ANY, "Error: cannot write reject file \"%s\"\n", rejfile, 0, 0 ); } (void) relinquish_lock( rejfile, rfp, lfp ); Debug( LDAP_DEBUG_ANY, "Error: ldap operation failed, data written to \"%s\"\n", rejfile, 0, 0 ); } ldap_pvt_thread_mutex_unlock( &sglob->rej_mutex ); return; }