| | |
| | | |
| | | printf("maxsec: %ld\n", CountSeconds(max_time)); |
| | | |
| | | // BHCleanup(); |
| | | // return; |
| | | bool reg = false; |
| | | for (int i = 0; i < 3 && !reg; ++i) { |
| | | ProcInfo proc; |
| | |
| | | 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 |
| | |
| | | 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); |
| | | } |