Searched defs:read_state (Results 1 – 10 of 10) sorted by relevance
119 struct read_state { struct120 explicit read_state(grpc_core::Arena* arena) in read_state() argument126 char* read_buffer = nullptr;127 bool length_field_received = false;128 int received_bytes = 0;129 int remaining_bytes = 0;130 int length_field = 0;131 bool compressed = false;132 char grpc_header_bytes[GRPC_HEADER_SIZE_IN_BYTES] = {};133 char* payload_field = nullptr;[all …]
113 struct read_state { struct115 char* read_buffer;116 bool length_field_received;117 int received_bytes;118 int remaining_bytes;119 int length_field;120 bool compressed;121 char grpc_header_bytes[GRPC_HEADER_SIZE_IN_BYTES];122 char* payload_field;123 bool read_stream_closed;[all …]
63 struct read_state struct65 Dwfl *dwfl;66 Dwfl_Memory_Callback *memory_callback;67 void *memory_callback_arg;68 void **buffer;69 size_t *buffer_available;250 finish_portion (struct read_state *read_state, in finish_portion()259 read_portion (struct read_state *read_state, in read_portion()301 struct read_state read_state; in dwfl_segment_report_module() local
56 ReadState read_state = ReadData(input_buf_, Channel::kReadBufferSize, in ProcessIncomingMessages() local
57 ReadState read_state = ReadData(input_buf_, Channel::kReadBufferSize, in ProcessIncomingMessages() local
224 def read_state(state_file: pathlib.Path) -> State: function
147 fn read_state(&self) -> Poll<TimerResult> { in read_state() method
626 pub read_state: PitRWState, field
273 __u8 read_state; member
1192 pub read_state: u8, field