|
GRPC Core
9.0.0
|
#include <internal.h>
Data Structures | |
| struct | Reffer |
Public Member Functions | |
| grpc_chttp2_stream (grpc_chttp2_transport *t, grpc_stream_refcount *refcount, const void *server_data, grpc_core::Arena *arena) | |
| ~grpc_chttp2_stream () | |
| grpc_chttp2_stream::grpc_chttp2_stream | ( | grpc_chttp2_transport * | t, |
| grpc_stream_refcount * | refcount, | ||
| const void * | server_data, | ||
| grpc_core::Arena * | arena | ||
| ) |
| grpc_chttp2_stream::~grpc_chttp2_stream | ( | ) |
| bool grpc_chttp2_stream::all_incoming_byte_streams_finished = false |
Are all published incoming byte streams closed.
| size_t grpc_chttp2_stream::byte_counter = 0 |
Byte counter for number of bytes written.
| grpc_error* grpc_chttp2_stream::byte_stream_error = GRPC_ERROR_NONE |
| grpc_transport_stream_stats* grpc_chttp2_stream::collecting_stats = nullptr |
| grpc_closure grpc_chttp2_stream::complete_fetch_locked |
| grpc_slice_buffer grpc_chttp2_stream::compressed_data_buffer |
Buffer storing data that is compressed but not sent.
| void* grpc_chttp2_stream::context |
| grpc_chttp2_data_parser grpc_chttp2_stream::data_parser |
parsing state for data frames
| grpc_millis grpc_chttp2_stream::deadline = GRPC_MILLIS_INF_FUTURE |
| grpc_slice_buffer grpc_chttp2_stream::decompressed_data_buffer |
Temporary buffer storing decompressed data.
Initialized, used, and destroyed only when stream uses (non-identity) compression.
| size_t grpc_chttp2_stream::decompressed_header_bytes = 0 |
gRPC header bytes that are already decompressed
| grpc_closure grpc_chttp2_stream::destroy_stream |
| grpc_closure* grpc_chttp2_stream::destroy_stream_arg |
| bool grpc_chttp2_stream::eos_received = false |
| bool grpc_chttp2_stream::eos_sent = false |
| uint32_t grpc_chttp2_stream::fetched_send_message_length = 0 |
| grpc_core::OrphanablePtr<grpc_core::ByteStream> grpc_chttp2_stream::fetching_send_message |
| grpc_closure* grpc_chttp2_stream::fetching_send_message_finished = nullptr |
| grpc_slice grpc_chttp2_stream::fetching_slice = grpc_empty_slice() |
| bool grpc_chttp2_stream::final_metadata_requested = false |
| grpc_chttp2_write_cb* grpc_chttp2_stream::finish_after_write = nullptr |
| grpc_core::PolymorphicManualConstructor< grpc_core::chttp2::StreamFlowControlBase, grpc_core::chttp2::StreamFlowControl, grpc_core::chttp2::StreamFlowControlDisabled> grpc_chttp2_stream::flow_control |
| grpc_slice_buffer grpc_chttp2_stream::flow_controlled_buffer |
| int64_t grpc_chttp2_stream::flow_controlled_bytes_flowed = 0 |
| int64_t grpc_chttp2_stream::flow_controlled_bytes_written = 0 |
| grpc_error* grpc_chttp2_stream::forced_close_error = GRPC_ERROR_NONE |
saw some stream level error
| grpc_slice_buffer grpc_chttp2_stream::frame_storage |
| uint8_t grpc_chttp2_stream::header_frames_received = 0 |
how many header frames have we received?
| uint32_t grpc_chttp2_stream::id = 0 |
HTTP2 stream id for this stream, or zero if one has not been assigned.
| uint8_t grpc_chttp2_stream::included[STREAM_LIST_COUNT] = {} |
| grpc_chttp2_stream_link grpc_chttp2_stream::links[STREAM_LIST_COUNT] |
| grpc_chttp2_incoming_metadata_buffer grpc_chttp2_stream::metadata_buffer[2] |
| int64_t grpc_chttp2_stream::next_message_end_offset |
| grpc_chttp2_write_cb* grpc_chttp2_stream::on_flow_controlled_cbs = nullptr |
| grpc_closure* grpc_chttp2_stream::on_next = nullptr |
| grpc_chttp2_write_cb* grpc_chttp2_stream::on_write_finished_cbs = nullptr |
| bool grpc_chttp2_stream::pending_byte_stream = false |
| grpc_published_metadata_method grpc_chttp2_stream::published_metadata[2] = {} |
| bool grpc_chttp2_stream::read_closed = false |
Is this stream reading half-closed.
| grpc_error* grpc_chttp2_stream::read_closed_error = GRPC_ERROR_NONE |
the error that resulted in this stream being read-closed
| int64_t grpc_chttp2_stream::received_bytes = 0 |
number of bytes received - reset at end of parse thread execution
| bool grpc_chttp2_stream::received_last_frame = false |
| grpc_metadata_batch* grpc_chttp2_stream::recv_initial_metadata |
| grpc_closure* grpc_chttp2_stream::recv_initial_metadata_ready = nullptr |
| grpc_core::OrphanablePtr<grpc_core::ByteStream>* grpc_chttp2_stream::recv_message |
| grpc_closure* grpc_chttp2_stream::recv_message_ready = nullptr |
| grpc_metadata_batch* grpc_chttp2_stream::recv_trailing_metadata |
| grpc_closure* grpc_chttp2_stream::recv_trailing_metadata_finished = nullptr |
| grpc_stream_refcount* grpc_chttp2_stream::refcount |
| struct grpc_chttp2_stream::Reffer grpc_chttp2_stream::reffer |
| grpc_closure grpc_chttp2_stream::reset_byte_stream |
| bool grpc_chttp2_stream::seen_error = false |
Has this stream seen an error.
If true, then pending incoming frames can be thrown away.
| grpc_metadata_batch* grpc_chttp2_stream::send_initial_metadata = nullptr |
things the upper layers would like to send
| grpc_closure* grpc_chttp2_stream::send_initial_metadata_finished = nullptr |
| grpc_metadata_batch* grpc_chttp2_stream::send_trailing_metadata = nullptr |
| grpc_closure* grpc_chttp2_stream::send_trailing_metadata_finished = nullptr |
| size_t grpc_chttp2_stream::sending_bytes = 0 |
| bool grpc_chttp2_stream::sent_initial_metadata = false |
| bool grpc_chttp2_stream::sent_trailing_metadata = false |
| grpc_transport_stream_stats grpc_chttp2_stream::stats = grpc_transport_stream_stats() |
| grpc_stream_compression_context* grpc_chttp2_stream::stream_compression_ctx |
Stream compression compress context.
| grpc_stream_compression_method grpc_chttp2_stream::stream_compression_method |
| grpc_stream_compression_context* grpc_chttp2_stream::stream_decompression_ctx |
Stream compression decompress context.
| grpc_stream_compression_method grpc_chttp2_stream::stream_decompression_method |
| grpc_chttp2_transport* grpc_chttp2_stream::t |
| bool grpc_chttp2_stream::traced = false |
Whether the bytes needs to be traced using Fathom.
| bool* grpc_chttp2_stream::trailing_metadata_available = nullptr |
| size_t grpc_chttp2_stream::uncompressed_data_size |
Amount of uncompressed bytes sent out when compressed_data_buffer is emptied.
| grpc_slice_buffer grpc_chttp2_stream::unprocessed_incoming_frames_buffer |
| size_t grpc_chttp2_stream::unprocessed_incoming_frames_buffer_cached_length = 0 |
| bool grpc_chttp2_stream::unprocessed_incoming_frames_decompressed = false |
Whether bytes stored in unprocessed_incoming_byte_stream is decompressed.
| bool grpc_chttp2_stream::write_buffering = false |
Are we buffering writes on this stream? If yes, we won't become writable until there's enough queued up in the flow_controlled_buffer.
| bool grpc_chttp2_stream::write_closed = false |
Is this stream closed for writing.
| grpc_error* grpc_chttp2_stream::write_closed_error = GRPC_ERROR_NONE |
the error that resulted in this stream being write-closed
1.9.1