1: #line 700 "./lpsrc/flx_faio.pak"
2:
3:
4: include "flx_stream";
5: include "flx_socket";
6: open Flx_stream;
7: open Flx_socket;
8: open Flx_stream::TerminalIOByteStream[Flx_socket::socket_t];
9:
10: print "flx tcp stream test\n";
11:
12: var listener: socket_t;
13: var port = 0;
14:
15:
16:
17: mk_listener(&listener, &port, 1);
18:
19:
20:
21: print "spawning connector\n";
22:
23:
24:
25: spawn_fthread
26: {
27: {
28:
29: var c: socket_t;
30: connect(&c, c"127.0.0.1", port);
31: var st: string;
32:
33: get_line(c, &st);
34: print "connector got "; print st; endl;
35: write_string(c, "thanks\n");
36:
37: ioclose(c);
38: };
39: };
40:
41: var s: socket_t;
42: accept(listener, &s);
43: ioclose(listener);
44:
45: print "got connection\n";
46: write_string(s, "server says hi\n");
47:
48: var st: string;
49: get_line(s, &st);
50:
51: print "server got "; print st; endl;
52: ioclose(s);