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
|
#!/usr/bin/env python
# **********************************************************************
#
# Copyright (c) 2001
# MutableRealms, Inc.
# Huntsville, AL, USA
#
# All Rights Reserved
#
# **********************************************************************
import sys, os
protocol = "tcp"
serverOptions = " --Ice.PrintProcessId --Ice.PrintAdapterReady --Ice.ServerIdleTime=30" + \
" --Ice.Ssl.CertPath=TOPLEVELDIR/certs --Ice.Ssl.Config=server_sslconfig.xml --Ice.Protocol=" + \
protocol
clientOptions = " --Ice.Ssl.CertPath=TOPLEVELDIR/certs --Ice.Ssl.Config=client_sslconfig.xml --Ice.Protocol=" + \
protocol
collocatedOptions = " --Ice.Ssl.CertPath=TOPLEVELDIR/certs --Ice.Ssl.Config=sslconfig.xml --Ice.Protocol=" + \
protocol
serverPids = []
def killServers():
global serverPids
for pid in serverPids:
if os.name == "nt":
import win32api
handle = win32api.OpenProcess(1, 0, pid)
return (0 != win32api.TerminateProcess(handle, 0))
else:
os.kill(pid, 9)
serverPids = []
def getServerPid(serverPipe):
output = serverPipe.readline().strip()
if not output:
print "failed!"
killServers()
sys.exit(1)
serverPids.append(int(output))
def getAdapterReady(serverPipe):
output = serverPipe.readline().strip()
if not output:
print "failed!"
killServers()
sys.exit(1)
def clientServerTest(toplevel, name):
testdir = os.path.normpath(toplevel + "/test/" + name)
server = os.path.normpath(testdir + "/server")
client = os.path.normpath(testdir + "/client")
updatedServerOptions = serverOptions.replace("TOPLEVELDIR", toplevel)
updatedClientOptions = clientOptions.replace("TOPLEVELDIR", toplevel)
print "starting server...",
serverPipe = os.popen(server + updatedServerOptions)
getServerPid(serverPipe)
getAdapterReady(serverPipe)
print "ok"
print "starting client...",
clientPipe = os.popen(client + updatedClientOptions)
output = clientPipe.readline()
if not output:
print "failed!"
killServers()
sys.exit(1)
print "ok"
print output,
while 1:
output = clientPipe.readline()
if not output:
break;
print output,
def collocatedTest(toplevel, name):
testdir = os.path.normpath(toplevel + "/test/" + name)
collocated = os.path.normpath(testdir + "/collocated")
updatedCollocatedOptions = collocatedOptions.replace("TOPLEVELDIR", toplevel)
print "starting collocated...",
collocatedPipe = os.popen(collocated + updatedCollocatedOptions)
output = collocatedPipe.read().strip()
if not output:
print "failed!"
sys.exit(1)
print "ok"
print output
|
