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
|
/*-
* Copyright (c) 2014-2020 MongoDB, Inc.
* Copyright (c) 2008-2014 WiredTiger, Inc.
* All rights reserved.
*
* See the file LICENSE for redistribution information.
*/
#include "wt_internal.h"
/*
* __stdio_close --
* ANSI C close/fclose.
*/
static int
__stdio_close(WT_SESSION_IMPL *session, WT_FSTREAM *fs)
{
WT_RET_MSG(session, ENOTSUP, "%s: close", fs->name);
}
/*
* __stdio_flush --
* POSIX fflush.
*/
static int
__stdio_flush(WT_SESSION_IMPL *session, WT_FSTREAM *fs)
{
if (fflush(fs->fp) == 0)
return (0);
WT_RET_MSG(session, __wt_errno(), "%s: flush", fs->name);
}
/*
* __stdio_getline --
* ANSI C getline.
*/
static int
__stdio_getline(WT_SESSION_IMPL *session, WT_FSTREAM *fs, WT_ITEM *buf)
{
WT_UNUSED(buf);
WT_RET_MSG(session, ENOTSUP, "%s: getline", fs->name);
}
/*
* __stdio_printf --
* ANSI C vfprintf.
*/
static int
__stdio_printf(WT_SESSION_IMPL *session, WT_FSTREAM *fs, const char *fmt, va_list ap)
{
if (vfprintf(fs->fp, fmt, ap) >= 0)
return (0);
WT_RET_MSG(session, EIO, "%s: printf", fs->name);
}
/*
* __stdio_init --
* Initialize stdio functions.
*/
static void
__stdio_init(WT_FSTREAM *fs, const char *name, FILE *fp)
{
fs->name = name;
fs->fp = fp;
fs->close = __stdio_close;
fs->fstr_flush = __stdio_flush;
fs->fstr_getline = __stdio_getline;
fs->fstr_printf = __stdio_printf;
}
/*
* __wt_os_stdio --
* Initialize the stdio configuration.
*/
void
__wt_os_stdio(WT_SESSION_IMPL *session)
{
__stdio_init(WT_STDERR(session), "stderr", stderr);
__stdio_init(WT_STDOUT(session), "stdout", stdout);
}
|
