diff options
author | 2017-03-15 17:15:39 -0700 | |
---|---|---|
committer | 2017-03-15 17:15:39 -0700 | |
commit | 94a4ed93a1bd88a29886bcc377e1eba48013c7ae (patch) | |
tree | 441ee68e7441283e4d660b607c596ca6c3097e31 /src/core/ext/transport | |
parent | 41373d0457a41801297e5fdd0ed03bfe94d26ff2 (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.c | 4 |
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); |