MCPcopy Create free account
hub / github.com/apache/brpc / check_running_thread

Function check_running_thread

test/bthread_execution_queue_unittest.cpp:470–477  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

468}
469
470int check_running_thread(void* arg, bthread::TaskIterator<LongIntTask>& iter) {
471 if (iter.is_queue_stopped()) {
472 return 0;
473 }
474 for (; iter; ++iter) {}
475 EXPECT_EQ(pthread_self(), (pthread_t)arg);
476 return 0;
477}
478
479void test_in_place_task(bool use_pthread) {
480 pthread_t thread_id = pthread_self();

Callers

nothing calls this directly

Calls 1

is_queue_stoppedMethod · 0.80

Tested by

no test coverage detected