| 158 | }; |
| 159 | |
| 160 | void RunUpdateTask(void* data) { |
| 161 | TestCaseContext* context = (TestCaseContext*)data; |
| 162 | bool should_continue = context->Update(); |
| 163 | if (should_continue) { |
| 164 | bthread::get_global_timer_thread()->schedule(RunUpdateTask, data, |
| 165 | butil::microseconds_from_now(FLAGS_client_qps_change_interval_us)); |
| 166 | } else { |
| 167 | context->running.store(false, butil::memory_order_release); |
| 168 | } |
| 169 | } |
| 170 | |
| 171 | void RunCase(test::ControlService_Stub &cntl_stub, |
| 172 | const test::TestCase& test_case) { |
nothing calls this directly
no test coverage detected