diff options
author | 2017-04-21 08:00:33 -0700 | |
---|---|---|
committer | 2017-04-21 08:00:33 -0700 | |
commit | f18f30e76017619b50a325ca3469c372c5fd387d (patch) | |
tree | 4647e26c6835b6ec43d9c6052575ed7908b11ea6 /src/core | |
parent | cdd9e568641985e25adf4b0b1977e2a53295f77e (diff) | |
parent | 77a4c52cbf3706191640e117b1f9bccddd64f1ac (diff) |
Merge github.com:grpc/grpc into c++compat2
Diffstat (limited to 'src/core')
-rw-r--r-- | src/core/ext/filters/message_size/message_size_filter.c | 2 | ||||
-rw-r--r-- | src/core/ext/transport/chttp2/transport/chttp2_transport.c | 1 |
2 files changed, 3 insertions, 0 deletions
diff --git a/src/core/ext/filters/message_size/message_size_filter.c b/src/core/ext/filters/message_size/message_size_filter.c index db0f011905..e3ffc41f90 100644 --- a/src/core/ext/filters/message_size/message_size_filter.c +++ b/src/core/ext/filters/message_size/message_size_filter.c @@ -130,6 +130,8 @@ static void recv_message_ready(grpc_exec_ctx* exec_ctx, void* user_data, GRPC_ERROR_UNREF(new_error); } gpr_free(message_string); + } else { + GRPC_ERROR_REF(error); } // Invoke the next callback. grpc_closure_run(exec_ctx, calld->next_recv_message_ready, error); diff --git a/src/core/ext/transport/chttp2/transport/chttp2_transport.c b/src/core/ext/transport/chttp2/transport/chttp2_transport.c index a4cee39104..5d74532ede 100644 --- a/src/core/ext/transport/chttp2/transport/chttp2_transport.c +++ b/src/core/ext/transport/chttp2/transport/chttp2_transport.c @@ -2603,6 +2603,7 @@ static bool incoming_byte_stream_next(grpc_exec_ctx *exec_ctx, (grpc_chttp2_incoming_byte_stream *)byte_stream; grpc_chttp2_stream *s = bs->stream; if (s->unprocessed_incoming_frames_buffer.length > 0) { + GPR_TIMER_END("incoming_byte_stream_next", 0); return true; } else { gpr_ref(&bs->refs); |