1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
|
/*-
* Copyright (c) 2008-2012 WiredTiger, Inc.
* All rights reserved.
*
* See the file LICENSE for redistribution information.
*/
#include "wt_internal.h"
static int
__log_record_size(WT_SESSION_IMPL *session,
size_t *sizep, WT_LOGREC_DESC *recdesc, va_list ap)
{
return (__wt_struct_sizev(session, sizep, recdesc->fmt, ap));
}
int
__wt_log_put(WT_SESSION_IMPL *session, WT_LOGREC_DESC *recdesc, ...)
{
WT_DECL_RET;
WT_ITEM *buf;
va_list ap;
size_t size;
buf = &session->logrec_buf;
va_start(ap, recdesc);
ret = __log_record_size(session, &size, recdesc, ap);
va_end(ap);
WT_RET(ret);
WT_RET(__wt_buf_initsize(session, buf, size));
va_start(ap, recdesc);
ret = __wt_struct_packv(session, buf->mem, size, recdesc->fmt, ap);
va_end(ap);
return (ret);
}
int
__wt_log_vprintf(WT_SESSION_IMPL *session, const char *fmt, va_list ap)
{
WT_CONNECTION_IMPL *conn;
WT_ITEM *buf;
va_list ap_copy;
size_t len;
conn = S2C(session);
if (conn->log_fh == NULL)
return (0);
buf = &session->logprint_buf;
va_copy(ap_copy, ap);
len = (size_t)vsnprintf(NULL, 0, fmt, ap_copy) + 2;
va_end(ap_copy);
WT_RET(__wt_buf_initsize(session, buf, len));
(void)vsnprintf(buf->mem, len, fmt, ap);
/*
* For now, just dump the text into the file. Later, we will use
* __wt_logput_debug to wrap this in a log header.
*/
#if 1
strcpy((char *)buf->mem + len - 2, "\n");
return ((write(conn->log_fh->fd, buf->mem, len - 1) ==
(ssize_t)len - 1) ? 0 : WT_ERROR);
#else
return (__wt_logput_debug(session, (char *)buf->mem));
#endif
}
int
__wt_log_printf(WT_SESSION_IMPL *session, const char *fmt, ...)
WT_GCC_FUNC_ATTRIBUTE((format (printf, 2, 3)))
{
WT_DECL_RET;
va_list ap;
va_start(ap, fmt);
ret = __wt_log_vprintf(session, fmt, ap);
va_end(ap);
return (ret);
}
|
