Searched refs:messages_processed (Results 1 – 1 of 1) sorted by relevance
523 std::atomic<int> messages_processed(0); in TEST() local524 auto incrementer = [&messages_processed, in TEST()531 messages_processed.fetch_add(1); in TEST()545 EXPECT_EQ(4, messages_processed.load(std::memory_order_acquire)); in TEST()