diff options
author | Dwayne Boone <dwayne@zeroc.com> | 2005-03-02 14:11:09 +0000 |
---|---|---|
committer | Dwayne Boone <dwayne@zeroc.com> | 2005-03-02 14:11:09 +0000 |
commit | 048467a4d9283fe8f9c76b4ca1f0cf76d813cc8a (patch) | |
tree | c061d5bec413bbe49b6a5bd3f98d5dd5b01a96fb /py/demo/Ice/throughput/Server.py | |
parent | *** empty log message *** (diff) | |
download | ice-048467a4d9283fe8f9c76b4ca1f0cf76d813cc8a.tar.bz2 ice-048467a4d9283fe8f9c76b4ca1f0cf76d813cc8a.tar.xz ice-048467a4d9283fe8f9c76b4ca1f0cf76d813cc8a.zip |
Ported new throuhput demo
Diffstat (limited to 'py/demo/Ice/throughput/Server.py')
-rw-r--r-- | py/demo/Ice/throughput/Server.py | 42 |
1 files changed, 37 insertions, 5 deletions
diff --git a/py/demo/Ice/throughput/Server.py b/py/demo/Ice/throughput/Server.py index 6d1848de0f6..a43abd504d4 100644 --- a/py/demo/Ice/throughput/Server.py +++ b/py/demo/Ice/throughput/Server.py @@ -15,18 +15,50 @@ import Demo class ThroughputI(Demo.Throughput): def __init__(self): - self.seq = [] - self.seq[0:Demo.seqSize] = range(0, Demo.seqSize) - self.seq = [0 for x in self.seq] + self.byteSeq = [] + self.byteSeq[0:Demo.ByteSeqSize] = range(0, Demo.ByteSeqSize) + self.byteSeq = [0 for x in self.byteSeq] + + self.stringSeq = [] + self.stringSeq[0:Demo.StringSeqSize] = range(0, Demo.StringSeqSize) + self.stringSeq = ["hello" for x in self.stringSeq] + + self.structSeq = [] + self.structSeq[0:Demo.StringDoubleSeqSize] = range(0, Demo.StringDoubleSeqSize) + for i in range(0, Demo.StringDoubleSeqSize): + self.structSeq[i] = Demo.StringDouble() + self.structSeq[i].s = "hello" + self.structSeq[i].d = 3.14 def sendByteSeq(self, seq, current=None): pass def recvByteSeq(self, current=None): - return self.seq + return self.byteSeq def echoByteSeq(self, seq, current=None): - return self.seq + return seq + + def sendStringSeq(self, seq, current=None): + pass + + def recvStringSeq(self, current=None): + return self.stringSeq + + def echoStringSeq(self, seq, current=None): + return seq + + def sendStructSeq(self, seq, current=None): + pass + + def recvStructSeq(self, current=None): + return self.structSeq + + def echoStructSeq(self, seq, current=None): + return seq + + def shutdown(self, current=None): + current.adapter.getCommunicator().shutdown() def run(argv, communicator): adapter = communicator.createObjectAdapter("Throughput") |