Function WaitForTrue

test/brpc_streaming_rpc_unittest.cpp:227–233

}

static bool WaitForTrue(const std::atomic<bool>& f, int timeout_ms) {
    const int64_t deadline_us = butil::gettimeofday_us() + (int64_t)timeout_ms * 1000L;
    while (!f.load(std::memory_order_acquire) && butil::gettimeofday_us() < deadline_us) {
        usleep(1000);
    }
    return f.load(std::memory_order_acquire);
}

TEST_F(StreamingRpcTest, sanity) {
    brpc::Server server;