Searched refs:server_try_cancel (Results 1 – 3 of 3) sorted by relevance
93 int server_try_cancel = GetIntValueFromMetadata( in Echo() local95 if (server_try_cancel > DO_NOT_CANCEL) { in Echo()181 int server_try_cancel = GetIntValueFromMetadata( in RequestStream() local187 if (server_try_cancel == CANCEL_BEFORE_PROCESSING) { in RequestStream()193 if (server_try_cancel == CANCEL_DURING_PROCESSING) { in RequestStream()210 if (server_try_cancel == CANCEL_AFTER_PROCESSING) { in RequestStream()231 int server_try_cancel = GetIntValueFromMetadata( in ResponseStream() local241 if (server_try_cancel == CANCEL_BEFORE_PROCESSING) { in ResponseStream()248 if (server_try_cancel == CANCEL_DURING_PROCESSING) { in ResponseStream()268 if (server_try_cancel == CANCEL_AFTER_PROCESSING) { in ResponseStream()[all …]
378 ServerTryCancelRequestPhase server_try_cancel, int num_msgs_to_send) { in TestRequestStreamServerCancel() argument386 grpc::to_string(server_try_cancel)); in TestRequestStreamServerCancel()409 switch (server_try_cancel) { in TestRequestStreamServerCancel()427 server_try_cancel); in TestRequestStreamServerCancel()428 EXPECT_TRUE(server_try_cancel > DO_NOT_CANCEL && in TestRequestStreamServerCancel()429 server_try_cancel <= CANCEL_AFTER_PROCESSING); in TestRequestStreamServerCancel()451 ServerTryCancelRequestPhase server_try_cancel) { in TestResponseStreamServerCancel() argument459 grpc::to_string(server_try_cancel)); in TestResponseStreamServerCancel()481 switch (server_try_cancel) { in TestResponseStreamServerCancel()503 server_try_cancel); in TestResponseStreamServerCancel()[all …]
1196 ServerTryCancelRequestPhase server_try_cancel) { in TestClientStreamingServerCancel() argument1226 if (server_try_cancel == CANCEL_BEFORE_PROCESSING) { in TestClientStreamingServerCancel()1239 (server_try_cancel == CANCEL_DURING_PROCESSING) || in TestClientStreamingServerCancel()1240 (server_try_cancel == CANCEL_BEFORE_PROCESSING); in TestClientStreamingServerCancel()1266 if (server_try_cancel == CANCEL_DURING_PROCESSING) { in TestClientStreamingServerCancel()1305 if (server_try_cancel == CANCEL_AFTER_PROCESSING) { in TestClientStreamingServerCancel()1352 ServerTryCancelRequestPhase server_try_cancel) { in TestServerStreamingServerCancel() argument1385 (server_try_cancel != CANCEL_BEFORE_PROCESSING); in TestServerStreamingServerCancel()1387 if (server_try_cancel == CANCEL_BEFORE_PROCESSING) { in TestServerStreamingServerCancel()1414 if (server_try_cancel == CANCEL_DURING_PROCESSING) { in TestServerStreamingServerCancel()[all …]