Home
last modified time | relevance | path

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

/dports/devel/grpc/grpc-1.42.0/src/core/ext/transport/chttp2/transport/
H A Dparsing.cc113 t->incoming_frame_size = (static_cast<uint32_t>(*cur)) << 16; in grpc_chttp2_perform_read()
129 t->incoming_frame_size |= *cur; in grpc_chttp2_perform_read()
183 if (t->incoming_frame_size == 0) { in grpc_chttp2_perform_read()
195 t->incoming_frame_size > in grpc_chttp2_perform_read()
200 t->incoming_frame_size, in grpc_chttp2_perform_read()
232 cur += t->incoming_frame_size; in grpc_chttp2_perform_read()
373 bdp_est->AddIncomingBytes(t->incoming_frame_size); in init_data_frame_parser()
380 err = t->flow_control->RecvData(t->incoming_frame_size); in init_data_frame_parser()
383 err = s->flow_control->RecvData(t->incoming_frame_size); in init_data_frame_parser()
393 s->received_bytes += t->incoming_frame_size; in init_data_frame_parser()
[all …]
H A Dflow_control.cc210 int64_t incoming_frame_size) { in ValidateRecvData() argument
211 if (incoming_frame_size > announced_window_) { in ValidateRecvData()
214 incoming_frame_size, announced_window_)); in ValidateRecvData()
223 grpc_error_handle StreamFlowControl::RecvData(int64_t incoming_frame_size) { in RecvData() argument
227 error = tfc_->ValidateRecvData(incoming_frame_size); in RecvData()
239 if (incoming_frame_size > acked_stream_window) { in RecvData()
240 if (incoming_frame_size <= sent_stream_window) { in RecvData()
254 incoming_frame_size, acked_stream_window)); in RecvData()
258 UpdateAnnouncedWindowDelta(tfc_, -incoming_frame_size); in RecvData()
259 local_window_delta_ -= incoming_frame_size; in RecvData()
[all …]
H A Dflow_control.h255 grpc_error_handle ValidateRecvData(int64_t incoming_frame_size);
256 void CommitRecvData(int64_t incoming_frame_size) { in CommitRecvData() argument
257 announced_window_ -= incoming_frame_size; in CommitRecvData()
260 grpc_error_handle RecvData(int64_t incoming_frame_size) override { in RecvData() argument
262 grpc_error_handle error = ValidateRecvData(incoming_frame_size); in RecvData()
264 CommitRecvData(incoming_frame_size); in RecvData()
436 grpc_error_handle RecvData(int64_t incoming_frame_size) override;
H A Dinternal.h425 uint32_t incoming_frame_size = 0; member
/dports/devel/pecl-grpc/grpc-1.42.0/src/core/ext/transport/chttp2/transport/
H A Dparsing.cc113 t->incoming_frame_size = (static_cast<uint32_t>(*cur)) << 16; in grpc_chttp2_perform_read()
129 t->incoming_frame_size |= *cur; in grpc_chttp2_perform_read()
183 if (t->incoming_frame_size == 0) { in grpc_chttp2_perform_read()
195 t->incoming_frame_size > in grpc_chttp2_perform_read()
200 t->incoming_frame_size, in grpc_chttp2_perform_read()
232 cur += t->incoming_frame_size; in grpc_chttp2_perform_read()
373 bdp_est->AddIncomingBytes(t->incoming_frame_size); in init_data_frame_parser()
380 err = t->flow_control->RecvData(t->incoming_frame_size); in init_data_frame_parser()
383 err = s->flow_control->RecvData(t->incoming_frame_size); in init_data_frame_parser()
393 s->received_bytes += t->incoming_frame_size; in init_data_frame_parser()
[all …]
H A Dflow_control.cc210 int64_t incoming_frame_size) { in ValidateRecvData() argument
211 if (incoming_frame_size > announced_window_) { in ValidateRecvData()
214 incoming_frame_size, announced_window_)); in ValidateRecvData()
223 grpc_error_handle StreamFlowControl::RecvData(int64_t incoming_frame_size) { in RecvData() argument
227 error = tfc_->ValidateRecvData(incoming_frame_size); in RecvData()
239 if (incoming_frame_size > acked_stream_window) { in RecvData()
240 if (incoming_frame_size <= sent_stream_window) { in RecvData()
254 incoming_frame_size, acked_stream_window)); in RecvData()
258 UpdateAnnouncedWindowDelta(tfc_, -incoming_frame_size); in RecvData()
259 local_window_delta_ -= incoming_frame_size; in RecvData()
[all …]
H A Dflow_control.h255 grpc_error_handle ValidateRecvData(int64_t incoming_frame_size);
256 void CommitRecvData(int64_t incoming_frame_size) { in CommitRecvData() argument
257 announced_window_ -= incoming_frame_size; in CommitRecvData()
260 grpc_error_handle RecvData(int64_t incoming_frame_size) override { in RecvData() argument
262 grpc_error_handle error = ValidateRecvData(incoming_frame_size); in RecvData()
264 CommitRecvData(incoming_frame_size); in RecvData()
436 grpc_error_handle RecvData(int64_t incoming_frame_size) override;
H A Dinternal.h425 uint32_t incoming_frame_size = 0; member
/dports/devel/py-grpcio/grpcio-1.43.0/src/core/ext/transport/chttp2/transport/
H A Dparsing.cc113 t->incoming_frame_size = (static_cast<uint32_t>(*cur)) << 16; in grpc_chttp2_perform_read()
129 t->incoming_frame_size |= *cur; in grpc_chttp2_perform_read()
183 if (t->incoming_frame_size == 0) { in grpc_chttp2_perform_read()
195 t->incoming_frame_size > in grpc_chttp2_perform_read()
200 t->incoming_frame_size, in grpc_chttp2_perform_read()
232 cur += t->incoming_frame_size; in grpc_chttp2_perform_read()
373 bdp_est->AddIncomingBytes(t->incoming_frame_size); in init_data_frame_parser()
380 err = t->flow_control->RecvData(t->incoming_frame_size); in init_data_frame_parser()
383 err = s->flow_control->RecvData(t->incoming_frame_size); in init_data_frame_parser()
393 s->received_bytes += t->incoming_frame_size; in init_data_frame_parser()
[all …]
H A Dflow_control.cc210 int64_t incoming_frame_size) { in ValidateRecvData() argument
211 if (incoming_frame_size > announced_window_) { in ValidateRecvData()
214 incoming_frame_size, announced_window_)); in ValidateRecvData()
223 grpc_error_handle StreamFlowControl::RecvData(int64_t incoming_frame_size) { in RecvData() argument
227 error = tfc_->ValidateRecvData(incoming_frame_size); in RecvData()
239 if (incoming_frame_size > acked_stream_window) { in RecvData()
240 if (incoming_frame_size <= sent_stream_window) { in RecvData()
254 incoming_frame_size, acked_stream_window)); in RecvData()
258 UpdateAnnouncedWindowDelta(tfc_, -incoming_frame_size); in RecvData()
259 local_window_delta_ -= incoming_frame_size; in RecvData()
[all …]
H A Dflow_control.h255 grpc_error_handle ValidateRecvData(int64_t incoming_frame_size);
256 void CommitRecvData(int64_t incoming_frame_size) { in CommitRecvData() argument
257 announced_window_ -= incoming_frame_size; in CommitRecvData()
260 grpc_error_handle RecvData(int64_t incoming_frame_size) override { in RecvData() argument
262 grpc_error_handle error = ValidateRecvData(incoming_frame_size); in RecvData()
264 CommitRecvData(incoming_frame_size); in RecvData()
436 grpc_error_handle RecvData(int64_t incoming_frame_size) override;
H A Dinternal.h427 uint32_t incoming_frame_size = 0; member
/dports/devel/grpc130/grpc-1.30.2/src/core/ext/transport/chttp2/transport/
H A 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()
254 incoming_frame_size, acked_stream_window); in RecvData()
261 UpdateAnnouncedWindowDelta(tfc_, -incoming_frame_size); in RecvData()
262 local_window_delta_ -= incoming_frame_size; in RecvData()
[all …]
H A 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()
234 cur += t->incoming_frame_size; in grpc_chttp2_perform_read()
352 err = t->flow_control->RecvData(t->incoming_frame_size); in init_data_frame_parser()
355 err = s->flow_control->RecvData(t->incoming_frame_size); in init_data_frame_parser()
365 s->received_bytes += t->incoming_frame_size; in init_data_frame_parser()
[all …]
H A Dflow_control.h250 grpc_error* ValidateRecvData(int64_t incoming_frame_size);
251 void CommitRecvData(int64_t incoming_frame_size) { in CommitRecvData() argument
252 announced_window_ -= incoming_frame_size; in CommitRecvData()
255 grpc_error* RecvData(int64_t incoming_frame_size) override { in RecvData() argument
257 grpc_error* error = ValidateRecvData(incoming_frame_size); in RecvData()
259 CommitRecvData(incoming_frame_size); in RecvData()
432 grpc_error* RecvData(int64_t incoming_frame_size) override;
H A Dinternal.h420 uint32_t incoming_frame_size = 0; member
/dports/devel/grpc134/grpc-1.34.1/src/core/ext/transport/chttp2/transport/
H A 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()
254 incoming_frame_size, acked_stream_window) in RecvData()
259 UpdateAnnouncedWindowDelta(tfc_, -incoming_frame_size); in RecvData()
260 local_window_delta_ -= incoming_frame_size; in RecvData()
[all …]
H A Dparsing.cc112 t->incoming_frame_size = (static_cast<uint32_t>(*cur)) << 16; 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()
232 cur += t->incoming_frame_size; in grpc_chttp2_perform_read()
346 bdp_est->AddIncomingBytes(t->incoming_frame_size); in init_data_frame_parser()
353 err = t->flow_control->RecvData(t->incoming_frame_size); in init_data_frame_parser()
356 err = s->flow_control->RecvData(t->incoming_frame_size); in init_data_frame_parser()
366 s->received_bytes += t->incoming_frame_size; in init_data_frame_parser()
[all …]
H A 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;
H A Dinternal.h424 uint32_t incoming_frame_size = 0; member
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/grpc/src/src/core/ext/transport/chttp2/transport/
H A 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()
254 incoming_frame_size, acked_stream_window); in RecvData()
261 UpdateAnnouncedWindowDelta(tfc_, -incoming_frame_size); in RecvData()
262 local_window_delta_ -= incoming_frame_size; in RecvData()
[all …]
H A 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 …]
H A 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()
234 cur += t->incoming_frame_size; in grpc_chttp2_perform_read()
349 err = t->flow_control->RecvData(t->incoming_frame_size); in init_data_frame_parser()
352 err = s->flow_control->RecvData(t->incoming_frame_size); in init_data_frame_parser()
362 s->received_bytes += t->incoming_frame_size; in init_data_frame_parser()
[all …]
H A Dinternal.h434 uint32_t incoming_frame_size = 0; member