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
|
import sys, os, string
def start(path):
pipein, pipeout = os.pipe()
pid = os.fork()
if(pid == 0):
os.close(pipein)
os.dup2(pipeout, sys.stdout.fileno())
os.execv(path, [])
else:
os.close(pipeout)
return os.fdopen(pipein), pid
pids = []
def terminate(status):
for pid in pids:
if(os.name == "nt"):
import win32api
handle = win32api.OpenProcess(1, 0, pid)
return (0 != win32api.TerminateProcess(handle, 0))
else:
os.kill(pid, 9)
sys.exit(status)
def server():
print "starting server...",
server, pid = start("./server")
pids.append(pid)
ready = string.strip(server.readline())
if ready != "ready":
print "failed!"
terminate(0)
else:
print "ok"
def client():
print "starting client...",
client, pid = start("./client")
pids.append(pid)
output = client.read()
if not output:
print "failed!"
terminate(0)
else:
print "ok"
print output,
def collocated():
print "starting collocated...",
client, pid = start("./collocated")
pids.append(pid)
output = client.read()
if not output:
print "failed!"
terminate(0)
else:
print "ok"
print output,
|
