From a4015bde81371a8b998361ccfb56d5fd714e3ec6 Mon Sep 17 00:00:00 2001
From: Determinant <ted.sybil@gmail.com>
Date: Tue, 26 Mar 2019 16:05:01 -0400
Subject: update atomic fences

---
 test/bench_network.cpp | 22 +++++++++++-----------
 1 file changed, 11 insertions(+), 11 deletions(-)

(limited to 'test')

diff --git a/test/bench_network.cpp b/test/bench_network.cpp
index be90e2a..bb2193b 100644
--- a/test/bench_network.cpp
+++ b/test/bench_network.cpp
@@ -48,7 +48,7 @@ using std::placeholders::_2;
 using opcode_t = uint8_t;
 
 struct MsgBytes {
-    static const opcode_t opcode = 0x0;
+    static const opcode_t opcode = 0xa;
     DataStream serialized;
     bytearray_t bytes;
     MsgBytes(size_t size) {
@@ -79,7 +79,7 @@ struct MyNet: public MsgNetworkByteOp {
             const std::string name,
             const NetAddr &peer,
             double stat_timeout = -1):
-            MsgNetworkByteOp(ec, MsgNetworkByteOp::Config()),
+            MsgNetworkByteOp(ec, MsgNetworkByteOp::Config().burst_size(1000)),
             name(name),
             peer(peer),
             ev_period_stat(ec, [this, stat_timeout](TimerEvent &) {
@@ -161,17 +161,17 @@ int main() {
         MyNet bob(ec, "Bob", alice_addr);
         bob.start();
         bob.connect(alice_addr);
-        try {
+        //try {
             ec.dispatch();
-        } catch (std::exception &) {}
-        SALTICIDAE_LOG_INFO("exiting");
+        //} catch (std::exception &) {}
+        //SALTICIDAE_LOG_INFO("exiting");
     });
-    try {
+    //try {
         ec.dispatch();
-    } catch (std::exception &e) {
-        pthread_kill(bob_thread.native_handle(), SIGTERM);
-        bob_thread.join();
-        SALTICIDAE_LOG_INFO("exception: %s", e.what());
-    }
+    //} catch (std::exception &e) {
+    //    pthread_kill(bob_thread.native_handle(), SIGTERM);
+    //    bob_thread.join();
+    //    SALTICIDAE_LOG_INFO("exception: %s", e.what());
+    //}
     return 0;
 }
-- 
cgit v1.2.3