#include "db_config.h"
#include "db_int.h"
#include "dbinc/db_page.h"
#include "dbinc/db_am.h"
#include "dbinc/log.h"
static int __log_printf_int __P((DB_ENV *, DB_TXN *, const char *, va_list));
int
#ifdef STDC_HEADERS
__log_printf_capi(DB_ENV *dbenv, DB_TXN *txnid, const char *fmt, ...)
#else
__log_printf_capi(dbenv, txnid, fmt, va_alist)
DB_ENV *dbenv;
DB_TXN *txnid;
const char *fmt;
va_dcl
#endif
{
va_list ap;
int ret;
#ifdef STDC_HEADERS
va_start(ap, fmt);
#else
va_start(ap);
#endif
ret = __log_printf_pp(dbenv, txnid, fmt, ap);
va_end(ap);
return (ret);
}
int
__log_printf_pp(dbenv, txnid, fmt, ap)
DB_ENV *dbenv;
DB_TXN *txnid;
const char *fmt;
va_list ap;
{
DB_THREAD_INFO *ip;
int rep_check, ret, t_ret;
PANIC_CHECK(dbenv);
ENV_REQUIRES_CONFIG(dbenv,
dbenv->lg_handle, "DB_ENV->log_printf", DB_INIT_LOG);
ENV_ENTER(dbenv, ip);
rep_check = IS_ENV_REPLICATED(dbenv) ? 1 : 0;
if (rep_check && (ret = __env_rep_enter(dbenv, 0)) != 0)
return (ret);
ret = __log_printf_int(dbenv, txnid, fmt, ap);
if (rep_check && (t_ret = __env_db_rep_exit(dbenv)) != 0 && (ret) == 0)
ret = t_ret;
va_end(ap);
ENV_LEAVE(dbenv, ip);
return (ret);
}
int
#ifdef STDC_HEADERS
__log_printf(DB_ENV *dbenv, DB_TXN *txnid, const char *fmt, ...)
#else
__log_printf(dbenv, txnid, fmt, va_alist)
DB_ENV *dbenv;
DB_TXN *txnid;
const char *fmt;
va_dcl
#endif
{
va_list ap;
int ret;
#ifdef STDC_HEADERS
va_start(ap, fmt);
#else
va_start(ap);
#endif
ret = __log_printf_int(dbenv, txnid, fmt, ap);
va_end(ap);
return (ret);
}
static int
__log_printf_int(dbenv, txnid, fmt, ap)
DB_ENV *dbenv;
DB_TXN *txnid;
const char *fmt;
va_list ap;
{
DBT opdbt, msgdbt;
DB_LSN lsn;
char __logbuf[2048];
if (!DBENV_LOGGING(dbenv)) {
__db_errx(dbenv, "Logging not currently permitted");
return (EAGAIN);
}
memset(&opdbt, 0, sizeof(opdbt));
opdbt.data = "DIAGNOSTIC";
opdbt.size = sizeof("DIAGNOSTIC") - 1;
memset(&msgdbt, 0, sizeof(msgdbt));
msgdbt.data = __logbuf;
msgdbt.size = (u_int32_t)vsnprintf(__logbuf, sizeof(__logbuf), fmt, ap);
return (__db_debug_log(
dbenv, txnid, &lsn, 0, &opdbt, -1, &msgdbt, NULL, 0));
}