Searched refs:read_closed (Results 1 – 10 of 10) sorted by relevance
723 GPR_ASSERT((s->write_closed && s->read_closed) || s->id == 0); in destroy_stream_locked()1618 if (!s->read_closed) { in perform_stream_op_locked()1625 if (!s->read_closed && s->frame_storage.length == 0) { in perform_stream_op_locked()1959 if (s->recv_trailing_metadata_finished != nullptr && s->read_closed && in grpc_chttp2_maybe_complete_recv_trailing_metadata()1970 if (s->read_closed && s->frame_storage.length > 0 && !pending_data && in grpc_chttp2_maybe_complete_recv_trailing_metadata()1998 if (s->read_closed && s->frame_storage.length == 0 && !pending_data && in grpc_chttp2_maybe_complete_recv_trailing_metadata()2059 if (!s->read_closed || !s->write_closed) { in grpc_chttp2_cancel_stream()2181 if (s->read_closed && s->write_closed) { in grpc_chttp2_mark_stream_closed()2189 if (close_reads && !s->read_closed) { in grpc_chttp2_mark_stream_closed()2191 s->read_closed = true; in grpc_chttp2_mark_stream_closed()[all …]
363 if (err == GRPC_ERROR_NONE && s->read_closed) { in init_data_frame_parser()606 if (GPR_UNLIKELY(s->read_closed)) { in init_header_frame_parser()
391 if (!s_->read_closed) { in UpdateAction()
525 bool read_closed; member
573 if (!t_->is_client && !s_->read_closed) { in SentLastFrame()
648 GPR_ASSERT((write_closed && read_closed) || id == 0); in ~grpc_chttp2_stream()1547 if (!s->read_closed) { in perform_stream_op_locked()1554 if (!s->read_closed && s->frame_storage.length == 0) { in perform_stream_op_locked()1920 if (s->recv_trailing_metadata_finished != nullptr && s->read_closed && in grpc_chttp2_maybe_complete_recv_trailing_metadata()1931 if (s->read_closed && s->frame_storage.length > 0 && !pending_data && in grpc_chttp2_maybe_complete_recv_trailing_metadata()1972 if (s->read_closed && s->frame_storage.length == 0 && !pending_data && in grpc_chttp2_maybe_complete_recv_trailing_metadata()2034 if (!s->read_closed || !s->write_closed) { in grpc_chttp2_cancel_stream()2154 if (s->read_closed && s->write_closed) { in grpc_chttp2_mark_stream_closed()2165 if (close_reads && !s->read_closed) { in grpc_chttp2_mark_stream_closed()2167 s->read_closed = true; in grpc_chttp2_mark_stream_closed()[all …]
368 if (err == GRPC_ERROR_NONE && s->read_closed) { in init_data_frame_parser()639 if (GPR_UNLIKELY(s->read_closed)) { in init_header_frame_parser()
394 if (!s_->read_closed) { in UpdateAction()
568 bool read_closed = false; member
616 if (!t_->is_client && !s_->read_closed) { in SentLastFrame()