lichao
2021-05-10 77a6c3512a44dfe6540dde71946e6484fe4f173f
utest/api_test.cpp
@@ -118,6 +118,8 @@
   printf("maxsec: %ld\n", CountSeconds(max_time));
   // BHCleanup();
   // return;
   bool reg = false;
   for (int i = 0; i < 3 && !reg; ++i) {
      ProcInfo proc;
@@ -149,7 +151,7 @@
      bool r = BHRegisterTopics(s.data(), s.size(), &reply, &reply_len, 1000);
      BHFree(reply, reply_len);
      // printf("register topic : %s\n", r ? "ok" : "failed");
      Sleep(1s);
      // Sleep(1s);
   }
   { // Subscribe
@@ -282,7 +284,7 @@
   threads.Launch(hb, &run);
   threads.Launch(showStatus, &run);
   int ncli = 10;
   const uint64_t nreq = 1000 * 100;
   const int64_t nreq = 1000 * 100;
   for (int i = 0; i < ncli; ++i) {
      threads.Launch(asyncRequest, nreq);
   }