Home
last modified time | relevance | path

Searched refs:incoming_frame_size (Results 1 – 8 of 8) sorted by relevance

/external/rust/crates/grpcio-sys/grpc/src/core/ext/transport/chttp2/transport/
Dflow_control.cc207 int64_t incoming_frame_size) { in ValidateRecvData() argument
208 if (incoming_frame_size > announced_window_) { in ValidateRecvData()
212 incoming_frame_size, announced_window_) in ValidateRecvData()
222 grpc_error* StreamFlowControl::RecvData(int64_t incoming_frame_size) { in RecvData() argument
226 error = tfc_->ValidateRecvData(incoming_frame_size); in RecvData()
238 if (incoming_frame_size > acked_stream_window) { in RecvData()
239 if (incoming_frame_size <= sent_stream_window) { in RecvData()
249 incoming_frame_size, acked_stream_window, sent_stream_window); in RecvData()
254 incoming_frame_size, acked_stream_window) in RecvData()
259 UpdateAnnouncedWindowDelta(tfc_, -incoming_frame_size); in RecvData()
[all …]
Dparsing.cc112 t->incoming_frame_size = (static_cast<uint32_t>(*cur)) << 16; in grpc_chttp2_perform_read()
120 t->incoming_frame_size |= (static_cast<uint32_t>(*cur)) << 8; in grpc_chttp2_perform_read()
128 t->incoming_frame_size |= *cur; in grpc_chttp2_perform_read()
182 if (t->incoming_frame_size == 0) { in grpc_chttp2_perform_read()
194 t->incoming_frame_size > in grpc_chttp2_perform_read()
199 t->incoming_frame_size, in grpc_chttp2_perform_read()
210 if (static_cast<uint32_t>(end - cur) == t->incoming_frame_size) { in grpc_chttp2_perform_read()
222 } else if (static_cast<uint32_t>(end - cur) > t->incoming_frame_size) { in grpc_chttp2_perform_read()
227 cur_offset + t->incoming_frame_size), in grpc_chttp2_perform_read()
232 cur += t->incoming_frame_size; in grpc_chttp2_perform_read()
[all …]
Dflow_control.h249 grpc_error* ValidateRecvData(int64_t incoming_frame_size);
250 void CommitRecvData(int64_t incoming_frame_size) { in CommitRecvData() argument
251 announced_window_ -= incoming_frame_size; in CommitRecvData()
254 grpc_error* RecvData(int64_t incoming_frame_size) override { in RecvData() argument
256 grpc_error* error = ValidateRecvData(incoming_frame_size); in RecvData()
258 CommitRecvData(incoming_frame_size); in RecvData()
430 grpc_error* RecvData(int64_t incoming_frame_size) override;
Dinternal.h424 uint32_t incoming_frame_size = 0; member
/external/grpc-grpc/src/core/ext/transport/chttp2/transport/
Dflow_control.cc205 int64_t incoming_frame_size) { in ValidateRecvData() argument
206 if (incoming_frame_size > announced_window_) { in ValidateRecvData()
210 incoming_frame_size, announced_window_); in ValidateRecvData()
222 grpc_error* StreamFlowControl::RecvData(int64_t incoming_frame_size) { in RecvData() argument
226 error = tfc_->ValidateRecvData(incoming_frame_size); in RecvData()
238 if (incoming_frame_size > acked_stream_window) { in RecvData()
239 if (incoming_frame_size <= sent_stream_window) { in RecvData()
249 incoming_frame_size, acked_stream_window, sent_stream_window); in RecvData()
254 incoming_frame_size, acked_stream_window); in RecvData()
261 UpdateAnnouncedWindowDelta(tfc_, -incoming_frame_size); in RecvData()
[all …]
Dflow_control.h173 virtual grpc_error* RecvData(int64_t incoming_frame_size) { abort(); } in RecvData() argument
217 grpc_error* RecvData(int64_t incoming_frame_size) override { in RecvData() argument
253 grpc_error* ValidateRecvData(int64_t incoming_frame_size);
254 void CommitRecvData(int64_t incoming_frame_size) { in CommitRecvData() argument
255 announced_window_ -= incoming_frame_size; in CommitRecvData()
258 grpc_error* RecvData(int64_t incoming_frame_size) override { in RecvData() argument
260 grpc_error* error = ValidateRecvData(incoming_frame_size); in RecvData()
262 CommitRecvData(incoming_frame_size); in RecvData()
363 virtual grpc_error* RecvData(int64_t incoming_frame_size) { abort(); } in RecvData() argument
408 grpc_error* RecvData(int64_t incoming_frame_size) override { in RecvData() argument
[all …]
Dparsing.cc111 t->incoming_frame_size = (static_cast<uint32_t>(*cur)) << 16; in grpc_chttp2_perform_read()
119 t->incoming_frame_size |= (static_cast<uint32_t>(*cur)) << 8; in grpc_chttp2_perform_read()
127 t->incoming_frame_size |= *cur; in grpc_chttp2_perform_read()
181 if (t->incoming_frame_size == 0) { in grpc_chttp2_perform_read()
193 t->incoming_frame_size > in grpc_chttp2_perform_read()
198 t->incoming_frame_size, in grpc_chttp2_perform_read()
211 if (static_cast<uint32_t>(end - cur) == t->incoming_frame_size) { in grpc_chttp2_perform_read()
223 } else if (static_cast<uint32_t>(end - cur) > t->incoming_frame_size) { in grpc_chttp2_perform_read()
228 cur_offset + t->incoming_frame_size), in grpc_chttp2_perform_read()
233 cur += t->incoming_frame_size; in grpc_chttp2_perform_read()
[all …]
Dinternal.h416 uint32_t incoming_frame_size; member