summaryrefslogtreecommitdiff
path: root/js/demo/Ice/throughput/browser/Client.js
diff options
context:
space:
mode:
Diffstat (limited to 'js/demo/Ice/throughput/browser/Client.js')
-rw-r--r--js/demo/Ice/throughput/browser/Client.js346
1 files changed, 0 insertions, 346 deletions
diff --git a/js/demo/Ice/throughput/browser/Client.js b/js/demo/Ice/throughput/browser/Client.js
deleted file mode 100644
index ce3dc361f33..00000000000
--- a/js/demo/Ice/throughput/browser/Client.js
+++ /dev/null
@@ -1,346 +0,0 @@
-// **********************************************************************
-//
-// Copyright (c) 2003-2015 ZeroC, Inc. All rights reserved.
-//
-// This copy of Ice is licensed to you under the terms described in the
-// ICE_LICENSE file included in this distribution.
-//
-// **********************************************************************
-
-(function(){
-
-var ThroughputPrx = Demo.ThroughputPrx;
-
-//
-// Initialize sequences.
-//
-var i;
-var byteSeq = new Uint8Array(Demo.ByteSeqSize);
-for(i = 0; i < Demo.ByteSeqSize; ++i)
-{
- byteSeq[i] = 0;
-}
-
-var stringSeq = [];
-for(i = 0; i < Demo.StringSeqSize; ++i)
-{
- stringSeq[i] = "hello";
-}
-
-var structSeq = [];
-for(i = 0; i < Demo.StringDoubleSeqSize; ++i)
-{
- structSeq[i] = new Demo.StringDouble();
- structSeq[i].s = "hello";
- structSeq[i].d = 3.14;
-}
-
-var fixedSeq = [];
-for(i = 0; i < Demo.FixedSeqSize; ++i)
-{
- fixedSeq[i] = new Demo.Fixed();
- fixedSeq[i].i = 0;
- fixedSeq[i].j = 0;
- fixedSeq[i].d = 0;
-}
-
-var communicator = Ice.initialize();
-
-//
-// Run the throughput test.
-//
-function run()
-{
- //
- // Create a proxy to the throughput object.
- //
- var hostname = document.location.hostname || "127.0.0.1";
- var secure = document.location.protocol.indexOf("https") != -1;
- var ref = secure ?
- "throughput:wss -h " + hostname + " -p 9090 -r /demowss" :
- "throughput:ws -h " + hostname + " -p 8080 -r /demows";
- var proxy = communicator.stringToProxy(ref);
-
- //
- // Down-cast the proxy to the Demo.Throughput interface.
- //
- return ThroughputPrx.checkedCast(proxy).then(
- function(twoway)
- {
- var oneway = twoway.ice_oneway();
-
- var seq;
- var seqSize;
- var wireSize;
- var proxy;
- var operation;
- var repetitions = 100;
-
- var data = $("#data").val();
- //
- // Get the sequence data
- //
- if(data == "byte-seq")
- {
- seq = byteSeq;
- seqSize = Demo.ByteSeqSize;
- seq = byteSeq;
- wireSize = 1;
- }
- else if(data == "string-seq")
- {
- seq = stringSeq;
- seqSize = Demo.StringSeqSize;
- seq = stringSeq;
- wireSize = seq[0].length;
- }
- else if(data == "struct-seq")
- {
- seq = structSeq;
- seqSize = Demo.StringDoubleSeqSize;
- seq = structSeq;
- wireSize = seq[0].s.length;
- //
- // Size of double on the wire.
- //
- wireSize += 8;
- }
- else if(data == "fixed-seq")
- {
- seq = fixedSeq;
- seqSize = Demo.FixedSeqSize;
- seq = fixedSeq;
- //
- // Size of two ints and a double on the wire.
- //
- wireSize = 16;
- }
-
- //
- // Get the proxy and operation
- //
- var test = $("#test").val();
- if(test == "twoway" || test == "oneway")
- {
- proxy = test == "twoway" ? twoway : oneway;
- if(data == "byte-seq")
- {
- operation = proxy.sendByteSeq;
- }
- else if(data == "string-seq")
- {
- operation = proxy.sendStringSeq;
- }
- else if(data == "struct-seq")
- {
- operation = proxy.sendStructSeq;
- }
- else if(data == "fixed-seq")
- {
- operation = proxy.sendFixedSeq;
- }
- write("sending");
- }
- else if(test == "receive")
- {
- proxy = twoway;
- if(data == "byte-seq")
- {
- operation = proxy.recvByteSeq;
- }
- else if(data == "string-seq")
- {
- operation = proxy.recvStringSeq;
- }
- else if(data == "struct-seq")
- {
- operation = proxy.recvStructSeq;
- }
- else if(data == "fixed-seq")
- {
- operation = proxy.recvFixedSeq;
- }
- write("receiving");
- }
- else if(test == "echo")
- {
- proxy = twoway;
- if(data == "byte-seq")
- {
- operation = proxy.echoByteSeq;
- }
- else if(data == "string-seq")
- {
- operation = proxy.echoStringSeq;
- }
- else if(data == "struct-seq")
- {
- operation = proxy.echoStructSeq;
- }
- else if(data == "fixed-seq")
- {
- operation = proxy.echoFixedSeq;
- }
- write("sending and receiving");
- }
-
- write(" " + repetitions);
- if(data == "byte-seq")
- {
- write(" byte");
- }
- else if(data == "string-seq")
- {
- write(" string");
- }
- else if(data == "struct-seq")
- {
- write(" variable-length struct");
- }
- else if(data == "fixed-seq")
- {
- write(" fixed-length struct");
- }
- write(" sequences of size " + seqSize);
- if(test == "oneway")
- {
- write(" as oneway");
- }
- writeLine("...");
-
- //
- // Invoke the test operation in a loop with the required
- // arguments.
- //
- // We chain the promises. A test operation is called only
- // once the promise for the previous operation is
- // fulfilled.
- //
- var start = new Date().getTime();
- var args = test != "receive" ? [seq] : [];
- return loop(
- function()
- {
- return operation.apply(proxy, args);
- },
- repetitions
- ).then(
- function()
- {
- //
- // Write the results.
- //
- var total = new Date().getTime() - start;
- writeLine("time for " + repetitions + " sequences: " + total + " ms");
- writeLine("time per sequence: " + total / repetitions + " ms");
-
- var mbit = repetitions * seqSize * wireSize * 8.0 / total / 1000.0;
- if(test == "echo")
- {
- mbit *= 2;
- }
- mbit = Math.round(mbit * 100) / 100;
- writeLine("throughput: " + mbit + " Mbps");
- });
- });
-}
-
-$("#run").click(
- function()
- {
- //
- // Run the throughput loop if not already running.
- //
- if(state !== State.Running)
- {
- setState(State.Running);
-
- Ice.Promise.try(
- function()
- {
- return run();
- }
- ).exception(
- function(ex)
- {
- $("#output").val(ex.toString());
- }
- ).finally(
- function()
- {
- setState(State.Idle);
- }
- );
- }
- return false;
- });
-
-//
-// Asynchronous loop: each call to the given function returns a
-// promise that when fulfilled runs the next iteration.
-//
-function loop(fn, repetitions)
-{
- var i = 0;
- var next = function()
- {
- if(i++ < repetitions)
- {
- return fn.call().then(next);
- }
- };
- return next();
-}
-
-//
-// Helper functions to write the output.
-//
-function write(msg)
-{
- $("#output").val($("#output").val() + msg);
-}
-
-function writeLine(msg)
-{
- write(msg + "\n");
- $("#output").scrollTop($("#output").get(0).scrollHeight);
-}
-
-//
-// Handle the client state.
-//
-var State = {
- Idle:0,
- Running: 1
-};
-var state;
-
-function setState(s, ex)
-{
- if(s != state)
- {
- switch(s)
- {
- case State.Running:
- {
- $("#output").val("");
- $("#run").addClass("disabled");
- $("#progress").show();
- $("body").addClass("waiting");
- break;
- }
- case State.Idle:
- {
- $("#run").removeClass("disabled");
- $("#progress").hide();
- $("body").removeClass("waiting");
- break;
- }
- }
- state = s;
- }
-}
-
-setState(State.Idle);
-
-}());
generated by cgit v1.2.3 (git 2.46.0) at 2025-08-03 22:23:00 +0000