enhance bench req/rep (#208)

nats-io · Aug 16, 2023 · 0ac8abf · 0ac8abf
1 parent 6d1a993
commit 0ac8abf
Show file tree

Hide file tree

Showing 2 changed files with 20 additions and 4 deletions.
diff --git a/examples/bench.html b/examples/bench.html
@@ -39,9 +39,10 @@ <h3>Test</h3>
         <label><input class="form-check-input" type="radio" value="sub" id="sub" name="test">Subscribe</label>
     </div>
     <div class="radio-inline">
-        <label><input class="form-check-input" type="radio" value="sub" id="req" name="test">ReqRep</label>
+        <label><input class="form-check-input" type="radio" value="sub" id="reqrep" name="test">ReqReq</label>
     </div>
 
+
     <br/><br/>
     <button id="send" onclick="benchapp.run()" class="btn btn-primary">Start</button>
 </div>

diff --git a/examples/bench.js b/examples/bench.js
@@ -30,8 +30,8 @@ function getTestChoice() {
     return "pub";
   } else if (isChecked("sub")) {
     return "sub";
-  } else if (isChecked("req")) {
-    return "req";
+  } else if (isChecked("reqrep")) {
+    return "reqrep";
   }
 }
 
@@ -73,7 +73,8 @@ async function run() {
   t.subject = getString("subject");
   t.pub = kind === "pub" || kind === "pubsub";
   t.sub = kind === "sub" || kind === "pubsub";
-  t.req = kind === "req";
+  t.req = kind === "reqrep";
+  t.rep = kind === "reqrep";
 
   const bench = new Bench(nc, t);
   const m = await bench.run();
@@ -85,6 +86,10 @@ async function run() {
     reducer,
     new Metric("pubsub", 0),
   );
+  const reqrep = metrics.filter((m) => m.name === "reqrep").reduce(
+    reducer,
+    new Metric("reqrep", 0),
+  );
   const pub = metrics.filter((m) => m.name === "pub").reduce(
     reducer,
     new Metric("pub", 0),
@@ -97,12 +102,19 @@ async function run() {
     reducer,
     new Metric("req", 0),
   );
+  const rep = metrics.filter((m) => m.name === "rep").reduce(
+    reducer,
+    new Metric("rep", 0),
+  );
 
   const report = [];
 
   if (pubsub && pubsub.msgs) {
     report.push(pubsub.toString());
   }
+  if (reqrep && reqrep.msgs) {
+    report.push(reqrep.toString());
+  }
   if (pub && pub.msgs) {
     report.push(pub.toString());
   }
@@ -112,6 +124,9 @@ async function run() {
   if (req && req.msgs) {
     report.push(req.toString());
   }
+  if (rep && rep.msgs) {
+    report.push(rep.toString());
+  }
   updateResults(report.join("\n"));
 }