GRPC C++
1.39.1
|
#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_handle grpc_chttp2_stream::byte_stream_error |
bool* grpc_chttp2_stream::call_failed_before_recv_message = nullptr |
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_handle 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_handle 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 |
bool* grpc_chttp2_stream::sent_trailing_metadata_op = nullptr |
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_handle grpc_chttp2_stream::write_closed_error = GRPC_ERROR_NONE |
the error that resulted in this stream being write-closed