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
110
111
112
113
114
115
116
117
118
|
#include <u.h>
#include <libc.h>
#include <thread.h>
#include "dat.h"
#include "fns.h"
int debug;
double t, Δt;
static long
_iolisten(va_list *arg)
{
char *adir, *ldir;
adir = va_arg(*arg, char*);
ldir = va_arg(*arg, char*);
return listen(adir, ldir);
}
long
iolisten(Ioproc *io, char *adir, char *ldir)
{
return iocall(io, _iolisten, adir, ldir);
}
void
threadlisten(void *arg)
{
int lcfd;
char *adir, ldir[40];
Ioproc *io;
adir = arg;
io = ioproc();
for(;;){
lcfd = iolisten(io, adir, ldir);
if(lcfd < 0){
fprint(2, "iolisten: %r\n");
continue;
}
/*
* handle connection and allocate user on a seat, ready
* to play
*/
}
}
void
resetsim(void)
{
memset(&state, 0, sizeof(GameState));
state.x = 100;
state.stats.update = statsupdate;
t = 0;
}
void
threadsim(void *)
{
uvlong then, now;
double frametime, timeacc;
Δt = 0.01;
then = nanosec();
timeacc = 0;
resetsim();
for(;;){
now = nanosec();
frametime = now - then;
then = now;
timeacc += frametime/1e9;
while(timeacc >= Δt){
integrate(&state, t, Δt);
timeacc -= Δt;
t += Δt;
}
sleep(66);
}
}
void
usage(void)
{
fprint(2, "usage: %s [-d]\n", argv0);
threadexitsall("usage");
}
void
threadmain(int argc, char *argv[])
{
int acfd;
char adir[40];
ARGBEGIN{
case 'd':
debug++;
break;
default:
usage();
}ARGEND;
if(argc != 0)
usage();
acfd = announce("tcp!*!112", adir);
if(acfd < 0)
sysfatal("announce: %r");
threadcreate(threadlisten, adir, 1024);
threadcreate(threadsim, nil, 8192);
threadexits(nil);
}
|
