diff options
| author |  Craig Tiller <ctiller@google.com> | 2015-01-14 16:17:05 -0800 |
|---|---|---|
| committer | Craig Tiller <ctiller@google.com> | 2015-01-14 16:17:05 -0800 |
| commit | ca757968110a4ed0004a85e2357a2f277a0a54a6 (patch) | |
| tree | 5df10ed151e6f1d72e69dc4f676aa2ad3bf8d273 /test | |
| parent | 240d02c0760cdc67345c972b18d43aa1bfea9ccf (diff) | |
Fling test uses grpc_call_invoke
Diffstat (limited to 'test')
| -rw-r--r-- | test/core/fling/client.c | 7 |
1 files changed, 2 insertions, 5 deletions
diff --git a/test/core/fling/client.c b/test/core/fling/client.c index cc661c34c5..068565edc2 100644 --- a/test/core/fling/client.c +++ b/test/core/fling/client.c @@ -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() { |