diff options
| author |  Craig Tiller <ctiller@google.com> | 2017-03-31 08:27:28 -0700 |
|---|---|---|
| committer | Craig Tiller <ctiller@google.com> | 2017-03-31 08:27:28 -0700 |
| commit | dd36b15315cd691e86a94d4574bd9f3e3a33633f (patch) | |
| tree | 75bddf4bae42daf8b1c79eea61b678c31c0a20b4 /test/core/fling | |
| parent | 547631eaf89709ed2dcb30e9f8fdb617617c7aff (diff) | |
Call ref/unref, bugfixes
Diffstat (limited to 'test/core/fling')
| -rw-r--r-- | test/core/fling/client.c | 4 | ||||
| -rw-r--r-- | test/core/fling/server.c | 4 |
2 files changed, 4 insertions, 4 deletions
diff --git a/test/core/fling/client.c b/test/core/fling/client.c index 85bab6d431..7fa7563b93 100644 --- a/test/core/fling/client.c +++ b/test/core/fling/client.c @@ -99,7 +99,7 @@ static void step_ping_pong_request(void) { (size_t)(op - ops), (void *)1, NULL)); grpc_completion_queue_next(cq, gpr_inf_future(GPR_CLOCK_REALTIME), NULL); - grpc_call_destroy(call); + grpc_call_unref(call); grpc_byte_buffer_destroy(response_payload_recv); call = NULL; GPR_TIMER_END("ping_pong", 1); @@ -233,7 +233,7 @@ int main(int argc, char **argv) { grpc_profiler_stop(); if (call) { - grpc_call_destroy(call); + grpc_call_unref(call); } grpc_channel_destroy(channel); diff --git a/test/core/fling/server.c b/test/core/fling/server.c index 7ea54b1167..9488b0b5fc 100644 --- a/test/core/fling/server.c +++ b/test/core/fling/server.c @@ -294,7 +294,7 @@ int main(int argc, char **argv) { break; case FLING_SERVER_SEND_STATUS_FOR_STREAMING: /* Send status and close completed at server */ - grpc_call_destroy(call); + grpc_call_unref(call); if (!shutdown_started) request_call(); break; case FLING_SERVER_READ_FOR_UNARY: @@ -307,7 +307,7 @@ int main(int argc, char **argv) { /* Finished unary call. */ grpc_byte_buffer_destroy(payload_buffer); payload_buffer = NULL; - grpc_call_destroy(call); + grpc_call_unref(call); if (!shutdown_started) request_call(); break; } |