/dports/devel/grpc/grpc-1.42.0/src/core/ext/transport/chttp2/transport/ |
H A D | parsing.cc | 113 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 D | flow_control.cc | 210 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 D | flow_control.h | 255 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 D | internal.h | 425 uint32_t incoming_frame_size = 0; member
|
/dports/devel/pecl-grpc/grpc-1.42.0/src/core/ext/transport/chttp2/transport/ |
H A D | parsing.cc | 113 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 D | flow_control.cc | 210 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 D | flow_control.h | 255 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 D | internal.h | 425 uint32_t incoming_frame_size = 0; member
|
/dports/devel/py-grpcio/grpcio-1.43.0/src/core/ext/transport/chttp2/transport/ |
H A D | parsing.cc | 113 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 D | flow_control.cc | 210 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 D | flow_control.h | 255 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 D | internal.h | 427 uint32_t incoming_frame_size = 0; member
|
/dports/devel/grpc130/grpc-1.30.2/src/core/ext/transport/chttp2/transport/ |
H A D | flow_control.cc | 205 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 D | parsing.cc | 112 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 D | flow_control.h | 250 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 D | internal.h | 420 uint32_t incoming_frame_size = 0; member
|
/dports/devel/grpc134/grpc-1.34.1/src/core/ext/transport/chttp2/transport/ |
H A D | flow_control.cc | 207 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 D | parsing.cc | 112 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 D | flow_control.h | 249 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 D | internal.h | 424 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 D | flow_control.cc | 205 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 D | flow_control.h | 173 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 D | parsing.cc | 112 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 D | internal.h | 434 uint32_t incoming_frame_size = 0; member
|