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
119
120
121
122
123
|
#!/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.WarnAboutServerExceptions --Ice.ServerIdleTime=30" + \
" --Ice.Security.Ssl.CertPath=TOPLEVELDIR/certs --Ice.Security.Ssl.Config=server_sslconfig.xml" + \
" --Ice.Protocol=" + protocol
clientOptions = \
" --Ice.Security.Ssl.CertPath=TOPLEVELDIR/certs --Ice.Security.Ssl.Config=client_sslconfig.xml" + \
" --Ice.Protocol=" + protocol
clientServerOptions = \
" --Ice.PrintProcessId --Ice.PrintAdapterReady --Ice.WarnAboutServerExceptions --Ice.ServerIdleTime=30" + \
" --Ice.Security.Ssl.CertPath=TOPLEVELDIR/certs --Ice.Security.Ssl.Config=sslconfig.xml --Ice.Protocol=" + protocol
collocatedOptions = \
" --Ice.Security.Ssl.CertPath=TOPLEVELDIR/certs --Ice.Security.Ssl.Config=sslconfig.xml --Ice.Protocol=" + protocol
serverPids = []
def killServers():
global serverPids
for pid in serverPids:
if sys.platform == "cygwin":
print "killServers(): not implemented for cygwin python"
sys.exit(1)
if sys.platform == "win32":
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.join(toplevel, "test", name)
server = os.path.join(testdir, "server")
client = os.path.join(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.join(toplevel, "test", name)
collocated = os.path.join(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
def cleanDbDir(path):
files = os.listdir(path)
for filename in files:
if filename != "CVS" and filename != ".dummy":
fullpath = os.path.join(path, filename);
os.remove(fullpath)
|
