diff options
author | Dwayne Boone <dwayne@zeroc.com> | 2005-08-08 13:33:04 +0000 |
---|---|---|
committer | Dwayne Boone <dwayne@zeroc.com> | 2005-08-08 13:33:04 +0000 |
commit | df8cf81989c083af7861b9bec0f05d40d9cd195b (patch) | |
tree | 2e0e0444e84444aa2620e55e78e2365554f2010d /cppe/demo/IceE/throughput/Client.cpp | |
parent | added missing files. (diff) | |
download | ice-df8cf81989c083af7861b9bec0f05d40d9cd195b.tar.bz2 ice-df8cf81989c083af7861b9bec0f05d40d9cd195b.tar.xz ice-df8cf81989c083af7861b9bec0f05d40d9cd195b.zip |
Ported throughput to WinCE
Diffstat (limited to 'cppe/demo/IceE/throughput/Client.cpp')
-rw-r--r-- | cppe/demo/IceE/throughput/Client.cpp | 35 |
1 files changed, 23 insertions, 12 deletions
diff --git a/cppe/demo/IceE/throughput/Client.cpp b/cppe/demo/IceE/throughput/Client.cpp index 4fcb338e6fb..eb2030171d5 100644 --- a/cppe/demo/IceE/throughput/Client.cpp +++ b/cppe/demo/IceE/throughput/Client.cpp @@ -39,6 +39,18 @@ menu() int run(int argc, char* argv[], const Ice::CommunicatorPtr& communicator) { + // + // Check if we need to run with small sequences + // + int reduce = 1; + for(int i = 0; i < argc; ++i) + { + if(strcmp(argv[i], "--small") == 0) + { + reduce = 100; + } + } + Ice::PropertiesPtr properties = communicator->getProperties(); const char* proxyProperty = "Throughput.Throughput"; std::string proxy = properties->getProperty(proxyProperty); @@ -57,20 +69,19 @@ run(int argc, char* argv[], const Ice::CommunicatorPtr& communicator) } ThroughputPrx throughputOneway = ThroughputPrx::uncheckedCast(throughput->ice_oneway()); - ByteSeq byteSeq(ByteSeqSize, 0); + ByteSeq byteSeq(ByteSeqSize / reduce, 0); - StringSeq stringSeq(StringSeqSize, "hello"); + StringSeq stringSeq(StringSeqSize / reduce, "hello"); - StringDoubleSeq structSeq(StringDoubleSeqSize); - int i; - for(i = 0; i < StringDoubleSeqSize; ++i) + StringDoubleSeq structSeq(StringDoubleSeqSize / reduce); + for(i = 0; i < StringDoubleSeqSize / reduce; ++i) { structSeq[i].s = "hello"; structSeq[i].d = 3.14; } - FixedSeq fixedSeq(FixedSeqSize); - for(i = 0; i < FixedSeqSize; ++i) + FixedSeq fixedSeq(FixedSeqSize / reduce); + for(i = 0; i < FixedSeqSize / reduce; ++i) { fixedSeq[i].i = 0; fixedSeq[i].j = 0; @@ -85,7 +96,7 @@ run(int argc, char* argv[], const Ice::CommunicatorPtr& communicator) // By default use byte sequence. // char currentType = '1'; - int seqSize = ByteSeqSize; + int seqSize = ByteSeqSize / reduce; char c = EOF; do @@ -110,28 +121,28 @@ run(int argc, char* argv[], const Ice::CommunicatorPtr& communicator) case '1': { printf("using byte sequences\n"); - seqSize = ByteSeqSize; + seqSize = ByteSeqSize / reduce; break; } case '2': { printf("using string sequences\n"); - seqSize = StringSeqSize; + seqSize = StringSeqSize / reduce; break; } case '3': { printf("using variable-length struct sequences\n"); - seqSize = StringDoubleSeqSize; + seqSize = StringDoubleSeqSize / reduce; break; } case '4': { printf("using fixed-length struct sequences\n"); - seqSize = FixedSeqSize; + seqSize = FixedSeqSize / reduce; break; } } |