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
|
#include <u.h>
#include <libc.h>
#include <bio.h>
#include <thread.h>
#include <draw.h>
#include <mouse.h>
#include <keyboard.h>
#include <geometry.h>
#include "dat.h"
#include "fns.h"
int debug;
void
serveproc(void *arg)
{
Biobuf *bin, *bout;
NetConnInfo *nci;
char *line;
int fd, linelen;
fd = *(int*)arg;
nci = getnetconninfo(nil, fd);
if(nci == nil)
sysfatal("getnetconninfo: %r");
threadsetname("serveproc %s", nci->raddr);
freenetconninfo(nci);
bin = Bfdopen(fd, OREAD);
bout = Bfdopen(fd, OWRITE);
if(bin == nil || bout == nil)
sysfatal("Bfdopen: %r");
while((line = Brdline(bin, '\n')) != nil){
linelen = Blinelen(bin);
Bwrite(bout, line, linelen);
Bflush(bout);
print("%.*s", linelen, line);
}
Bterm(bin);
Bterm(bout);
}
void
listenthread(void *arg)
{
char *addr, adir[40], ldir[40];
int acfd, lcfd, dfd;
addr = arg;
acfd = announce(addr, adir);
if(acfd < 0)
sysfatal("announce: %r");
if(debug)
fprint(2, "listening on %s\n", addr);
while((lcfd = listen(adir, ldir)) >= 0){
if((dfd = accept(lcfd, ldir)) >= 0){
proccreate(serveproc, &dfd, mainstacksize);
close(dfd);
}
close(lcfd);
}
threadexitsall("listen: %r");
}
void
usage(void)
{
fprint(2, "usage: %s [-d] [-a addr]\n", argv0);
threadexitsall("usage");
}
void
threadmain(int argc, char *argv[])
{
char *addr;
addr = "tcp!*!3047";
ARGBEGIN{
case 'd':
debug++;
break;
case 'a':
addr = EARGF(usage());
break;
}ARGEND
if(argc != 0)
usage();
threadcreate(listenthread, addr, mainstacksize);
yield();
}
|
