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
|
#include "wvmoniker.h"
#include "wvistreamlist.h"
#include "wvstreamclone.h"
#include <assert.h>
static void httpget(WvStream &input, WvStream &output)
{
static int countdown = 6;
if (input.alarm_was_ticking)
{
if (!--countdown)
{
wvcon->print("...sending to TCP stream.\n");
input.print("GET / HTTP/1.0\r\n\r\n");
}
else
wvcon->print("[%s]", countdown);
}
WvStream::autoforward_callback(input, output);
input.alarm(1000);
}
int main()
{
IWvStream *con = wvcon;
// get streams from a component
IWvStream *ssl = wvcreate<IWvStream>("ssl:tcp:192.168.12.1:995");
IWvStream *tcp2 = wvcreate<IWvStream>("tcp:192.168.12.1:80");
// add handy WvStreams-style functionality by cloning them
WvStreamClone a((con->addRef(), con));
WvStreamClone b(ssl);
WvStreamClone c(tcp2);
// make them do something useful
a.autoforward(b);
b.autoforward(a);
c.setcallback(wv::bind(httpget, wv::ref(c), wv::ref(a)));
c.alarm(1*1000);
// create a list of them (in fact, we could use a WvStreamList here...)
// -- but we want to get rid of WvStreamLists and move over to WvIStreamList
WvIStreamList l;
WvIStreamList::globallist.append(&a, false, "a");
l.append(&b, false, "b");
l.append(&c, false, "c");
while (a.isok() && b.isok() && c.isok())
{
if (l.select(-1))
l.callback();
}
if (b.geterr())
wvcon->print("tcp1: %s\n", b.errstr());
if (c.geterr())
wvcon->print("tcp2: %s\n", c.errstr());
return 0;
}
|
