| | |
|---|
| | | |
|---|
| | | printf("maxsec: %ld\n", CountSeconds(max_time)); |
|---|
| | | |
|---|
| | | // BHCleanup(); |
|---|
| | | // return; |
|---|
| | | bool reg = false; |
|---|
| | | for (int i = 0; i < 3 && !reg; ++i) { |
|---|
| | | ProcInfo proc; |
|---|
| | |
|---|
| | | 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); |
|---|
| | | } |
|---|
| | |
|---|
| | | // } |
|---|
| | | |
|---|
| | | int same = 0; |
|---|
| | | int64_t last = 0; |
|---|
| | | uint64_t last = 0; |
|---|
| | | while (last < nreq * ncli && same < 2) { |
|---|
| | | Sleep(1s, false); |
|---|
| | | auto cur = Status().nreply_.load(); |
|---|
