diff --git a/src/core/ext/transport/chttp2/transport/chttp2_transport.cc b/src/core/ext/transport/chttp2/transport/chttp2_transport.cc index ca6218b0b63..e38ec31263c 100644 --- a/src/core/ext/transport/chttp2/transport/chttp2_transport.cc +++ b/src/core/ext/transport/chttp2/transport/chttp2_transport.cc @@ -1970,6 +1970,13 @@ void grpc_chttp2_maybe_complete_recv_initial_metadata(grpc_chttp2_transport* t, void grpc_chttp2_maybe_complete_recv_message(grpc_chttp2_transport* t, grpc_chttp2_stream* s) { grpc_error_handle error = GRPC_ERROR_NONE; + gpr_log(GPR_DEBUG, + "*** %s recv_message_ready=%p final_metadata_requested=%d " + "seen_error=%d frame_storage=%" PRIdPTR + " read_closed=%d write_closed=%d", + t->is_client ? "client" : "server", s->recv_message_ready, + s->final_metadata_requested, s->seen_error, s->frame_storage.length, + s->read_closed, s->write_closed); if (s->recv_message_ready != nullptr) { if (s->final_metadata_requested && s->seen_error) { grpc_slice_buffer_reset_and_unref_internal(&s->frame_storage); @@ -2014,6 +2021,11 @@ void grpc_chttp2_maybe_complete_recv_message(grpc_chttp2_transport* t, void grpc_chttp2_maybe_complete_recv_trailing_metadata(grpc_chttp2_transport* t, grpc_chttp2_stream* s) { grpc_chttp2_maybe_complete_recv_message(t, s); + gpr_log(GPR_DEBUG, + "*** %p %s recv_trailing_metadata_finished=%p read_closed=%d " + "write_closed=%d", + s, t->is_client ? "client" : "server", + s->recv_trailing_metadata_finished, s->read_closed, s->write_closed); if (s->recv_trailing_metadata_finished != nullptr && s->read_closed && s->write_closed) { if (s->seen_error || !t->is_client) { @@ -2500,6 +2512,9 @@ static void read_action_locked(void* tp, grpc_error_handle error) { grpc_chttp2_transport* t = static_cast(tp); + gpr_log(GPR_DEBUG, "finish_read:%s len=%" PRIdPTR, + grpc_error_std_string(error).c_str(), t->read_buffer.length); + (void)GRPC_ERROR_REF(error); grpc_error_handle err = error;