diff options
| author |  Craig Tiller <ctiller@google.com> | 2017-03-30 12:23:55 -0700 |
|---|---|---|
| committer | Craig Tiller <ctiller@google.com> | 2017-03-30 12:23:55 -0700 |
| commit | c3bafa808c49a58ad9c562c5cd3ad8d11f1c711c (patch) | |
| tree | 850c73ec1d62cde5793935e1570d688e5cbf090f /src/core/lib/channel/message_size_filter.c | |
| parent | e6a448ca9a08e2f2b1b8f40bc65a00dc14ffb0a2 (diff) | |
Fix bug
Diffstat (limited to 'src/core/lib/channel/message_size_filter.c')
| -rw-r--r-- | src/core/lib/channel/message_size_filter.c | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/core/lib/channel/message_size_filter.c b/src/core/lib/channel/message_size_filter.c index 0873d9c285..19eae7f683 100644 --- a/src/core/lib/channel/message_size_filter.c +++ b/src/core/lib/channel/message_size_filter.c @@ -132,7 +132,7 @@ static void recv_message_ready(grpc_exec_ctx* exec_ctx, void* user_data, gpr_free(message_string); } // Invoke the next callback. - grpc_closure_sched(exec_ctx, calld->next_recv_message_ready, error); + grpc_closure_run(exec_ctx, calld->next_recv_message_ready, error); } // Start transport stream op. @@ -157,7 +157,7 @@ static void start_transport_stream_op(grpc_exec_ctx* exec_ctx, return; } // Inject callback for receiving a message. - if (op->payload->recv_message.recv_message_ready != NULL) { + if (op->recv_message) { calld->next_recv_message_ready = op->payload->recv_message.recv_message_ready; calld->recv_message = op->payload->recv_message.recv_message; |