|
|
|
@ -56,7 +56,7 @@ static void step_ping_pong_request() { |
|
|
|
|
call = grpc_channel_create_call(channel, "/Reflector/reflectUnary", |
|
|
|
|
"localhost", gpr_inf_future); |
|
|
|
|
GPR_ASSERT(grpc_call_invoke(call, cq, (void *)1, (void *)1, |
|
|
|
|
GRPC_WRITE_BUFFER_HINT) == GRPC_CALL_OK); |
|
|
|
|
GRPC_WRITE_BUFFER_HINT) == GRPC_CALL_OK); |
|
|
|
|
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)); |
|
|
|
@ -72,8 +72,8 @@ 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_invoke(call, cq, (void *)1, (void *)1, |
|
|
|
|
0) == GRPC_CALL_OK); |
|
|
|
|
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)); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|