Changeset 329e26a for benchmark/io/http/worker.cfa

Timestamp:

Jun 10, 2022, 5:02:03 PM (23 months ago)

Author:

Thierry Delisle <tdelisle@…>

Branches:

ADT, ast-experimental, master, pthread-emulation, qualifiedEnum

Children:

8419b76

Parents:

bf7c7ea

Message:

Re-instated the isolate/multi-cluster option.

File:

• benchmark/io/http/worker.cfa (modified) (3 diffs)

benchmark/io/http/worker.cfa

@@ -116 +116 @@
 //=============================================================================================
 void ?{}( AcceptWorker & this ) {
-        ((thread&)this){ "Server Worker Thread", *options.clopts.instance, 64000 };
-        options.clopts.thrd_cnt++;
+        size_t cli = rand() % options.clopts.cltr_cnt;
+        ((thread&)this){ "Server Worker Thread", *options.clopts.instance[cli], 64000 };
+        options.clopts.thrd_cnt[cli]++;
         this.done = false;
 }
@@ -150 +151 @@
 //=============================================================================================
 void ?{}( ChannelWorker & this ) {
-        ((thread&)this){ "Server Worker Thread", *options.clopts.instance, 64000 };
-        options.clopts.thrd_cnt++;
+        size_t cli = rand() % options.clopts.cltr_cnt;
+        ((thread&)this){ "Server Worker Thread", *options.clopts.instance[cli], 64000 };
+        options.clopts.thrd_cnt[cli]++;
         this.done = false;
 }
@@ -181 +183 @@
 }
 
-void ?{}( Acceptor & this ) {
-        ((thread&)this){ "Server Acceptor Thread", *options.clopts.instance, 64000 };
-        options.clopts.thrd_cnt++;
+void ?{}( Acceptor & this, int cli ) {
+        ((thread&)this){ "Server Acceptor Thread", *options.clopts.instance[cli], 64000 };
+        options.clopts.thrd_cnt[cli]++;
         this.done = false;
 }