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
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
|
/*
* Worldvisions Weaver Software:
* Copyright (C) 1997-2002 Net Integration Technologies, Inc.
*
* Declarations for wvcon, wvin, wvout, and wverr global streams.
*/
#include "wvfdstream.h"
#include "wvmoniker.h"
#include "wvlinkerhack.h"
WV_LINK(WvConStream);
// just like WvFDStream, but doesn't close the fd
class _WvConStream : public WvFDStream
{
public:
bool isopen;
_WvConStream(int _rfd, int _wfd, WvStringParm name = WvString::null);
virtual ~_WvConStream();
virtual void close();
virtual bool isok() const;
};
_WvConStream::_WvConStream(int _rfd, int _wfd,
WvStringParm name)
: WvFDStream(_rfd, _wfd)
{
isopen = true;
if (!name.isnull())
set_wsname(name);
}
_WvConStream::~_WvConStream()
{
close();
}
void _WvConStream::close()
{
isopen = false;
setfd(-1); // prevent WvFdStream from closing our fds
WvFDStream::close();
}
bool _WvConStream::isok() const
{
return isopen;
}
// console streams
#ifdef _WIN32
#include "streams.h"
SocketFromFDMaker _zero(_dup(0), fd2socket_fwd, false);
SocketFromFDMaker _one(1, socket2fd_fwd, true);
SocketFromFDMaker _two(2, socket2fd_fwd, true);
static _WvConStream _wvcon(_zero.GetSocket(), _one.GetSocket(), "wvcon");
static _WvConStream _wvin(_zero.GetSocket(), -1, "wvin");
static _WvConStream _wvout(-1, _one.GetSocket(), "wvout");
static _WvConStream _wverr(-1, _two.GetSocket(), "wverr");
#else // _WIN32
static _WvConStream _wvcon(0, 1, "wvcon");
static _WvConStream _wvin(0, -1, "wvin");
static _WvConStream _wvout(-1, 1, "wvout");
static _WvConStream _wverr(-1, 2, "wverr");
#endif // !_WIN32
WvStream *wvcon = &_wvcon;
WvStream *wvin = &_wvin;
WvStream *wvout = &_wvout;
WvStream *wverr = &_wverr;
static IWvStream *create_stdin(WvStringParm s, IObject*)
{
wvin->addRef();
return wvin;
}
static IWvStream *create_stdout(WvStringParm s, IObject*)
{
wvout->addRef();
return wvout;
}
static IWvStream *create_stderr(WvStringParm s, IObject*)
{
wverr->addRef();
return wverr;
}
static IWvStream *create_stdio(WvStringParm s, IObject*)
{
wvcon->addRef();
return wvcon;
}
static WvMoniker<IWvStream> reg0("stdin", create_stdin);
static WvMoniker<IWvStream> reg1("stdout", create_stdout);
static WvMoniker<IWvStream> reg2("stderr", create_stderr);
static WvMoniker<IWvStream> reg3("stdio", create_stdio);
|
