aboutsummaryrefslogtreecommitdiffhomepage
path: root/src/core/ext/transport
diff options
context:
space:
mode:
authorGravatar Muxi Yan <mxyan@google.com>2017-03-15 17:15:39 -0700
committerGravatar Muxi Yan <mxyan@google.com>2017-03-15 17:15:39 -0700
commit94a4ed93a1bd88a29886bcc377e1eba48013c7ae (patch)
tree441ee68e7441283e4d660b607c596ca6c3097e31 /src/core/ext/transport
parent41373d0457a41801297e5fdd0ed03bfe94d26ff2 (diff)
Fix the error in flush read that was causing jenkins timeout
Diffstat (limited to 'src/core/ext/transport')
-rw-r--r--src/core/ext/transport/cronet/transport/cronet_transport.c4
1 files changed, 2 insertions, 2 deletions
diff --git a/src/core/ext/transport/cronet/transport/cronet_transport.c b/src/core/ext/transport/cronet/transport/cronet_transport.c
index fabfaf8a27..6499eff3e9 100644
--- a/src/core/ext/transport/cronet/transport/cronet_transport.c
+++ b/src/core/ext/transport/cronet/transport/cronet_transport.c
@@ -62,7 +62,7 @@
} while (0)
/* TODO (makdharma): Hook up into the wider tracing mechanism */
-int grpc_cronet_trace = 0;
+int grpc_cronet_trace = 1;
enum e_op_result {
ACTION_TAKEN_WITH_CALLBACK,
@@ -272,7 +272,7 @@ static void maybe_flush_read(stream_obj *s) {
/* Whenever the evaluation of any of the two condition is changed, we check
* whether we should enter the flush read state. */
if (s->state.pending_recv_trailing_metadata && s->state.fail_state) {
- if (!s->state.flush_read) {
+ if (!s->state.flush_read && !s->state.rs.read_stream_closed) {
CRONET_LOG(GPR_DEBUG, "%p: Flush read", s);
s->state.flush_read = true;
null_and_maybe_free_read_buffer(s);