BUILD_TRANSLOG

    --enable-translog	  Transactions Log overlay no|yes|mod [no]

# OpenLDAP --enable-translog

	# Check whether --enable-translog or --disable-translog was given.

if test "${enable_translog+set}" = set; then

  enableval="$enable_translog"

	ol_arg=invalid

	for ol_val in no yes mod ; do

		if test "$enableval" = "$ol_val" ; then

			ol_arg="$ol_val"

		fi

	done

	if test "$ol_arg" = "invalid" ; then

		{ { echo "$as_me:$LINENO: error: bad value $enableval for --enable-translog" >&5

echo "$as_me: error: bad value $enableval for --enable-translog" >&2;}

   { (exit 1); exit 1; }; }

	fi

	ol_enable_translog="$ol_arg"

else

  	ol_enable_translog="no"

fi; # end --enable-translog

# OpenLDAP --enable-translog

	# Check whether --enable-translog or --disable-translog was given.

if test "${enable_translog+set}" = set; then

  enableval="$enable_translog"

	ol_arg=invalid

	for ol_val in no yes mod ; do

		if test "$enableval" = "$ol_val" ; then

			ol_arg="$ol_val"

		fi

	done

	if test "$ol_arg" = "invalid" ; then

		{ { echo "$as_me:$LINENO: error: bad value $enableval for --enable-translog" >&5

echo "$as_me: error: bad value $enableval for --enable-translog" >&2;}

   { (exit 1); exit 1; }; }

	fi

	ol_enable_translog="$ol_arg"

else

  	ol_enable_translog=${ol_enable_overlays:-no}

fi;

# end --enable-translog

BUILD_TRANSLOG=no

if test "$ol_enable_translog" != no ; then

	BUILD_TRANSLOG=$ol_enable_translog

	if test "$ol_enable_translog" = mod ; then

		MFLAG=SLAPD_MOD_DYNAMIC

		SLAPD_DYNAMIC_OVERLAYS="$SLAPD_DYNAMIC_OVERLAYS translog.la"

	else

		MFLAG=SLAPD_MOD_STATIC

		SLAPD_STATIC_OVERLAYS="$SLAPD_STATIC_OVERLAYS translog.o"

	fi

cat >>confdefs.h <<_ACEOF

#define SLAPD_OVER_TRANSLOG $MFLAG

_ACEOF

fi

OL_ARG_ENABLE(translog,[    --enable-translog      Transactions Log overlay],

	no, [no yes mod], ol_enable_overlays)

BUILD_TRANSLOG=no

if test "$ol_enable_translog" != no ; then

	BUILD_TRANSLOG=$ol_enable_translog

	if test "$ol_enable_translog" = mod ; then

		MFLAG=SLAPD_MOD_DYNAMIC

		SLAPD_DYNAMIC_OVERLAYS="$SLAPD_DYNAMIC_OVERLAYS translog.la"

	else

		MFLAG=SLAPD_MOD_STATIC

		SLAPD_STATIC_OVERLAYS="$SLAPD_STATIC_OVERLAYS translog.o"

	fi

	AC_DEFINE_UNQUOTED(SLAPD_OVER_TRANSLOG,$MFLAG,[define for Transactions Log overlay])

fi

  AC_SUBST(BUILD_TRANSLOG)

/* define for Translog overlay */

#undef SLAPD_OVER_TRANSLOG

translog.la : translog.lo

	$(LTLINK_MOD) -module -o $@ translog.lo version.lo $(LINK_LIBS)

/* translog.c - log modifications for replication purposes */

#include "portable.h"

#ifdef SLAPD_OVER_TRANSLOG

#include <stdio.h>

#include <unistd.h>

#include <ac/string.h>

#include <ac/ctype.h>

#include "slap.h"

//#define O_DEBUG		/* enable debug messages */

typedef struct translog_data {

	ldap_pvt_thread_mutex_t ad_mutex;

	char *ad_logfile;

} translog_data;

static const char LAST_ID[] = "/var/lib/univention-ldap/last_id";

static const char LAST_ID_TMP[] = "/var/lib/univention-ldap/last_id.new";

static const char TRANSACTION[] = "/var/lib/univention-ldap/notify/transaction";

static FILE* fopen_lock(const char *name, const char *type, FILE **l_file)

{

	char buf[PATH_MAX];

	FILE *file;

	int fd;

	if (snprintf(buf, sizeof(buf), "%s.lock", name) >= sizeof(buf))

		return NULL;

	if ((*l_file = fopen(buf, type)) == NULL)

		return NULL;

	fd = fileno(*l_file);

	lockf(fd, F_LOCK, 0);

	if ((file = fopen(name, type)) == NULL) {

		fclose(*l_file);

		*l_file  = NULL;

	}

	return file;

}

static int fclose_lock(FILE **file, FILE **l_file)

{

	int ret = 0;

	if (*file != NULL) {

		ret = fclose(*file);

		*file = NULL;

	}

	if (*l_file != NULL) {

		fclose(*l_file);

		*l_file = NULL;

	}

	return ret;

}

static long from_lastid()

{

	/* if the file /var/lib/univention-ldap/last_id exists, we read the last id

	 * from this file

	 */

	FILE *f;

	long id = -1;

	if ((f = fopen(LAST_ID, "r")) != NULL) {

		int n = fscanf(f, "%ld", &id);

		fclose(f);

		if (n != 1)

			Debug(LDAP_DEBUG_ANY, "OVER: Failed to parse %s\n", LAST_ID, 0, 0);

	}

	return id;

}

static long from_translog(const char *filename)

{

	FILE *f;

	long off = 2;

	int c;

	long id = -1;

	if ((f = fopen(filename, "r")) == NULL) {

		Debug( LDAP_DEBUG_ANY, "OVER: unable to open file %s\n", filename, 0, 0);

		return -1;

	}

	do {

		off++;

		if (!fseek(f, -off, SEEK_END))

			Debug(LDAP_DEBUG_ANY, "OVER: seek failed on %s\n", filename, 0, 0);

		c = fgetc(f);

	} while (c != '\n' && c != EOF && ftell(f) != 1);

	if (c == EOF) {

		/* emty file */

		id = 0;

	} else {

		if (ftell(f) == 1) {

			/* only one entry */

			if (fseek(f, 0, SEEK_SET))

				Debug(LDAP_DEBUG_ANY, "OVER: seek failed on %s\n", filename, 0, 0);

		}

		int n = fscanf(f, "%ld", &id);

		if (n != 1)

			Debug(LDAP_DEBUG_ANY, "OVER: Failed to parse %s at %ld\n", filename, off, 0);

	}

	fclose(f);

	return id;

}

static long get_last_id(Operation *op)

{

	/* Get the last used Transaction ID from Transaction-Log file

	 * Returns:

	 * 	-1 und errors

	 * 	0 if Transaction-Log file is empty

	 * 	last Transaction ID if Transaction-Log file is nonempty

	 */

	long id;

	Debug( LDAP_DEBUG_TRACE, "OVER: get_last_id\n", 0, 0, 0);

	id = from_lastid();

	if (id >= 1)

		return id;

	/* File must be locked to prevent UDN from renaming it underneth */

	slap_overinst *on = (slap_overinst *)op->o_bd->bd_info;

	translog_data *ad = on->on_bi.bi_private;

	id = from_translog(ad->ad_logfile);

	if (id >= 1)

		return id;

	id = from_translog(TRANSACTION);

	return id;

}

static int translog_response(Operation *op, SlapReply *rs) {

	/* Handel all requests and responses from and to database backend

	 * Returns:

	 * 	SLAP_CB_CONTINUE in all cases

	 */

	slap_overinst *on = (slap_overinst *)op->o_bd->bd_info;

	translog_data *ad = on->on_bi.bi_private;

	FILE *file, *l_file;

	char what;

	long lastid = -1;

	int failure = 0;

	if ( rs->sr_err != LDAP_SUCCESS ) {

		Debug( LDAP_DEBUG_TRACE, "OVER: rs->sr_err != LDAP_SUCCESS on \"%s\" ERR: 0x%02x\n", op->o_req_dn.bv_val, rs->sr_err, 0 );

		return SLAP_CB_CONTINUE;

	}

	if ( !op->o_bd || !ad->ad_logfile ) {

		Debug( LDAP_DEBUG_TRACE, "OVER: BackendDB or logfile not specified\n", 0, 0, 0 );

		return SLAP_CB_CONTINUE;

	}

	switch(op->o_tag) {

		case LDAP_REQ_MODRDN:	what = 'r';	break; /* 0x6cU == LDAP_REQ_MODDN == LDAP_REQ_RENAME */

		case LDAP_REQ_DELETE:	what = 'd';	break; /* 0x4aU */

		case LDAP_REQ_ADD:		what = 'a';	break; /* 0x68U */

		case LDAP_REQ_MODIFY:	what = 'm';	break; /* 0x66U */

		case LDAP_REQ_SEARCH:	return SLAP_CB_CONTINUE; /* 0x63U get rid of search debug messages */

		default:

			Debug( LDAP_DEBUG_TRACE, "OVER: SWITCH(o_tag) default, case was: \"%lu\"\n", (unsigned long) op->o_tag, 0, 0 );

			return SLAP_CB_CONTINUE;

	}

	ldap_pvt_thread_mutex_lock(&ad->ad_mutex);

	if ((file = fopen_lock(ad->ad_logfile, "a", &l_file)) == NULL) {

		Debug( LDAP_DEBUG_ANY, "OVER: Could not open translog file %s\n", ad->ad_logfile, 0, 0 );

		ldap_pvt_thread_mutex_unlock(&ad->ad_mutex);

		return SLAP_CB_CONTINUE;

	}

	lastid = get_last_id(op);

	if ( lastid > -1 ) {

		Debug( LDAP_DEBUG_TRACE, "OVER: Found ID \"%ld\"\n", lastid, 0, 0 );

		failure |= fprintf(file, "%ld %s %c\n", ++lastid, op->o_req_dn.bv_val, what) <= 0;

		if ( what == 'r' && op->orr_newSup ) {

			/* print newsuperior as add in translog file */

			failure |= fprintf(file, "%ld %s,%s a\n", ++lastid, op->orr_newrdn.bv_val, op->orr_newSup->bv_val) <= 0;

		} else if ( what == 'r' ) {

			struct berval   pdn;

			dnParent( &op->o_req_dn, &pdn );

			failure |= fprintf(file, "%ld %s,%s a\n", ++lastid, op->orr_newrdn.bv_val, pdn.bv_val) <= 0;

		}

	} else {

		Debug( LDAP_DEBUG_ANY, "OVER: Could not find last ID, lastid seems to be: \"%ld\"\n", lastid, 0, 0 );

		failure |= fprintf(file, "<TransID> %s %c\n", op->o_req_dn.bv_val, what) <= 0;

		if ( what == 'r' && op->orr_newSup ) {

			/* print newsuperior as add in translog file */

			failure |= fprintf(file, "<TransID> %s,%s a\n", op->orr_newrdn.bv_val, op->orr_newSup->bv_val) <= 0;

		} else if ( what == 'r' ) {

			struct berval   pdn;

			dnParent( &op->o_req_dn, &pdn );

			failure |= fprintf(file, "<TransID> %s,%s a\n", op->orr_newrdn.bv_val, pdn.bv_val) <= 0;

		}

	}

	failure |= fclose_lock(&file, &l_file) != 0;

	if (failure)

		Debug(LDAP_DEBUG_ANY, "OVER: Could not append file %s\n", ad->ad_logfile, 0, 0);

	if ((file = fopen(LAST_ID_TMP, "w")) == NULL ||

		fprintf(file, "%ld", lastid) <= 0 ||

		!fclose(file)) {

		Debug(LDAP_DEBUG_ANY, "OVER: Could not write file %s\n", LAST_ID_TMP, 0, 0);

	} else {

		if (rename(LAST_ID_TMP, LAST_ID))

			Debug(LDAP_DEBUG_ANY, "OVER: Could not rename file %s\n", LAST_ID_TMP, 0, 0);

	}

#ifdef O_DEBUG

	/* Test if the entry is in backend allready */

	int rc;

	Entry *e;

	/* set "real" backend as next backend */

	op->o_bd->bd_info = on->on_info->oi_orig;

	rc = be_entry_get_rw( op, &op->o_req_ndn, NULL, NULL, 0, &e );

	Debug( LDAP_DEBUG_TRACE, "OVER: Fetched Object, returncode was \"%d\"\n", rc, 0, 0);

	if ( e ) {

		Debug( LDAP_DEBUG_TRACE, "OVER: Fetched Object \"%s\"\n", e->e_ndn, 0, 0);

	}

	op->o_bd->bd_info = (BackendInfo *)on;

#endif

	ldap_pvt_thread_mutex_unlock(&ad->ad_mutex);

	return SLAP_CB_CONTINUE;

}

static slap_overinst translog;

static int translog_db_init( BackendDB *be ) {

	Debug( LDAP_DEBUG_TRACE, "OVER: db_init\n", 0, 0, 0 );

	slap_overinst *on = (slap_overinst *)be->bd_info;

	translog_data *ad = ch_calloc(1, sizeof(translog_data));

	on->on_bi.bi_private = ad;

	ldap_pvt_thread_mutex_init( &ad->ad_mutex );

	return 0;

}

static int translog_db_close( BackendDB *be ) {

	Debug( LDAP_DEBUG_TRACE, "OVER: db_close\n", 0, 0, 0 );

	slap_overinst *on = (slap_overinst *)be->bd_info;

	translog_data *ad = on->on_bi.bi_private;

	free( ad->ad_logfile );

	ad->ad_logfile = NULL;

	return 0;

}

static int translog_db_destroy( BackendDB *be ) {

	Debug( LDAP_DEBUG_TRACE, "OVER: db_destroy\n", 0, 0, 0 );

	slap_overinst *on = (slap_overinst *)be->bd_info;

	translog_data *ad = on->on_bi.bi_private;

	ldap_pvt_thread_mutex_destroy( &ad->ad_mutex );

	free( ad );

	return 0;

}

static int translog_config( BackendDB *be, const char *fname, int lineno, int argc, char **argv ) {

	slap_overinst *on = (slap_overinst *) be->bd_info;

	translog_data *ad = on->on_bi.bi_private;

	Debug( LDAP_DEBUG_CONFIG|LDAP_DEBUG_TRACE, "OVER: Configuring Translog Overlay\n", 0, 0, 0 );

	/* log file */

	if ( strcasecmp( argv[0], "translog" ) == 0 ) {

		if ( argc < 2 ) {

			Debug( LDAP_DEBUG_ANY, "%s: line %d: missing filename in \"translog <filename>\" line\n", fname, lineno, 0 );

			return(1);

		}

		Debug(LDAP_DEBUG_CONFIG, "OVER: Configured Translog Overlay to use file \"%s\"\n", argv[1], 0, 0);

		/* save filename in translog_data */

		ad->ad_logfile = ch_strdup( argv[1] );

		return 0;

	}

	return SLAP_CONF_UNKNOWN;

}

int translog_init() {

	Debug( LDAP_DEBUG_TRACE, "OVER: Loading Translog Overlay\n", 0, 0, 0 );

	translog.on_bi.bi_type = "translog";

	translog.on_bi.bi_db_init = translog_db_init;

	translog.on_bi.bi_db_config = translog_config;

	translog.on_bi.bi_db_close = translog_db_close;

	translog.on_bi.bi_db_destroy = translog_db_destroy;

	translog.on_response = translog_response;

	return overlay_register(&translog);

}

#if SLAPD_OVER_TRANSLOG == SLAPD_MOD_DYNAMIC

int

init_module( int argc, char *argv[] )

{

	return translog_init();

}

#endif

#endif /* SLAPD_OVER_TRANSLOG */