Searched refs:reads_complete_ (Results 1 – 2 of 2) sorted by relevance
928 reads_complete_ == client_cancel_.ops_before_cancel) {939 EXPECT_EQ(reads_complete_, kServerDefaultResponseStreamsToSend); in OnReadDone()942 EXPECT_LE(reads_complete_, kServerDefaultResponseStreamsToSend); in OnReadDone()944 request_.message() + std::to_string(reads_complete_)); in OnReadDone()945 reads_complete_++; in OnReadDone()947 reads_complete_ == client_cancel_.ops_before_cancel) { in OnReadDone()956 gpr_log(GPR_INFO, "Read %d messages", reads_complete_); in OnDone()962 EXPECT_EQ(reads_complete_, kServerDefaultResponseStreamsToSend); in OnDone()964 EXPECT_GE(reads_complete_, client_cancel_.ops_before_cancel); in OnDone()965 EXPECT_LE(reads_complete_, kServerDefaultResponseStreamsToSend); in OnDone()[all …]
835 EXPECT_EQ(reads_complete_, 1); in TEST_P()837 EXPECT_EQ(reads_complete_++, 0); in TEST_P()849 std::atomic_int reads_complete_{0}; in TEST_P() member in grpc::testing::__anon3c9619430111::TEST_P::GenericEchoService::CreateReactor::Reactor