|
|
|
@ -55,9 +55,8 @@ static void init_ping_pong_request() {} |
|
|
|
|
static void step_ping_pong_request() { |
|
|
|
|
call = grpc_channel_create_call(channel, "/Reflector/reflectUnary", |
|
|
|
|
"localhost", gpr_inf_future); |
|
|
|
|
GPR_ASSERT(grpc_call_start_invoke(call, cq, (void *)1, (void *)1, (void *)1, |
|
|
|
|
GPR_ASSERT(grpc_call_invoke(call, cq, (void *)1, (void *)1, |
|
|
|
|
GRPC_WRITE_BUFFER_HINT) == GRPC_CALL_OK); |
|
|
|
|
grpc_event_finish(grpc_completion_queue_next(cq, gpr_inf_future)); |
|
|
|
|
GPR_ASSERT(grpc_call_start_write(call, the_buffer, (void *)1, |
|
|
|
|
GRPC_WRITE_BUFFER_HINT) == GRPC_CALL_OK); |
|
|
|
|
grpc_event_finish(grpc_completion_queue_next(cq, gpr_inf_future)); |
|
|
|
@ -66,7 +65,6 @@ static void step_ping_pong_request() { |
|
|
|
|
grpc_event_finish(grpc_completion_queue_next(cq, gpr_inf_future)); |
|
|
|
|
grpc_event_finish(grpc_completion_queue_next(cq, gpr_inf_future)); |
|
|
|
|
grpc_event_finish(grpc_completion_queue_next(cq, gpr_inf_future)); |
|
|
|
|
grpc_event_finish(grpc_completion_queue_next(cq, gpr_inf_future)); |
|
|
|
|
grpc_call_destroy(call); |
|
|
|
|
call = NULL; |
|
|
|
|
} |
|
|
|
@ -74,10 +72,9 @@ static void step_ping_pong_request() { |
|
|
|
|
static void init_ping_pong_stream() { |
|
|
|
|
call = grpc_channel_create_call(channel, "/Reflector/reflectStream", |
|
|
|
|
"localhost", gpr_inf_future); |
|
|
|
|
GPR_ASSERT(grpc_call_start_invoke(call, cq, (void *)1, (void *)1, (void *)1, |
|
|
|
|
GPR_ASSERT(grpc_call_invoke(call, cq, (void *)1, (void *)1, |
|
|
|
|
0) == GRPC_CALL_OK); |
|
|
|
|
grpc_event_finish(grpc_completion_queue_next(cq, gpr_inf_future)); |
|
|
|
|
grpc_event_finish(grpc_completion_queue_next(cq, gpr_inf_future)); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
static void step_ping_pong_stream() { |
|
|
|
|