|
|
@ -202,7 +202,8 @@ static void test_max_concurrent_streams(grpc_end2end_test_config config) { |
|
|
|
GPR_ASSERT(ev->data.invoke_accepted == GRPC_OP_OK); |
|
|
|
GPR_ASSERT(ev->data.invoke_accepted == GRPC_OP_OK); |
|
|
|
/* The /alpha or /beta calls started above could be invoked (but NOT both);
|
|
|
|
/* The /alpha or /beta calls started above could be invoked (but NOT both);
|
|
|
|
* check this here */ |
|
|
|
* check this here */ |
|
|
|
live_call = (int)(gpr_intptr)ev->tag; |
|
|
|
/* We'll get tag 303 or 403, we want 300, 400 */ |
|
|
|
|
|
|
|
live_call = ((int)(gpr_intptr)ev->tag) - 3; |
|
|
|
grpc_event_finish(ev); |
|
|
|
grpc_event_finish(ev); |
|
|
|
|
|
|
|
|
|
|
|
cq_expect_server_rpc_new(v_server, &s1, tag(100), |
|
|
|
cq_expect_server_rpc_new(v_server, &s1, tag(100), |
|
|
|