| /external/rust/crates/grpcio-sys/grpc/src/core/ext/transport/chttp2/transport/ |
| D | writing.cc | 176 t->flow_control->remote_window(), in report_stall()
179 s->flow_control->remote_window_delta() + in report_stall()
182 s->flow_control->remote_window_delta()); in report_stall()
239 t_->flow_control->MaybeSendUpdate(t_->outbuf.count > 0); in FlushWindowUpdates()
327 0, s_->flow_control->remote_window_delta() + in stream_remote_window()
335 GPR_MIN(stream_remote_window(), t_->flow_control->remote_window())); in max_outgoing()
349 s_->flow_control->SentData(send_bytes); in FlushUncompressedBytes()
384 s_->flow_control->SentData(send_bytes); in FlushCompressedBytes()
435 (int)(s->flow_control->local_window_delta() - in StreamWriteContext()
436 s->flow_control->announced_window_delta()))); in StreamWriteContext()
[all …]
|
| D | frame_window_update.cc | 101 s->flow_control->RecvUpdate(received_update); in grpc_chttp2_window_update_parser_parse()
109 bool was_zero = t->flow_control->remote_window() <= 0; in grpc_chttp2_window_update_parser_parse()
110 t->flow_control->RecvUpdate(received_update); in grpc_chttp2_window_update_parser_parse()
111 bool is_zero = t->flow_control->remote_window() <= 0; in grpc_chttp2_window_update_parser_parse()
|
| D | parsing.cc | 193 } else if (t->flow_control->flow_control_enabled() && in grpc_chttp2_perform_read()
339 grpc_core::BdpEstimator* bdp_est = t->flow_control->bdp_estimator(); in init_data_frame_parser()
353 err = t->flow_control->RecvData(t->incoming_frame_size); in init_data_frame_parser()
354 action = t->flow_control->MakeAction(); in init_data_frame_parser()
356 err = s->flow_control->RecvData(t->incoming_frame_size); in init_data_frame_parser()
357 action = s->flow_control->MakeAction(); in init_data_frame_parser()
|
| D | stream_lists.cc | 188 GPR_ASSERT(t->flow_control->flow_control_enabled()); in grpc_chttp2_list_add_stalled_by_transport()
204 GPR_ASSERT(t->flow_control->flow_control_enabled()); in grpc_chttp2_list_add_stalled_by_stream()
|
| D | chttp2_transport.cc | 220 flow_control.Destroy(); in ~grpc_chttp2_transport()
482 flow_control.Init<grpc_core::chttp2::TransportFlowControl>(this, in grpc_chttp2_transport()
485 flow_control.Init<grpc_core::chttp2::TransportFlowControlDisabled>(this); in grpc_chttp2_transport()
501 grpc_chttp2_act_on_flowctl_action(flow_control->PeriodicUpdate(), this, in grpc_chttp2_transport()
624 if (t->flow_control->flow_control_enabled()) {
625 flow_control.Init<grpc_core::chttp2::StreamFlowControl>(
627 t->flow_control.get()),
630 flow_control.Init<grpc_core::chttp2::StreamFlowControlDisabled>();
682 flow_control.Destroy(); in ~grpc_chttp2_stream()
1557 s->flow_control->IncomingByteStreamUpdate(GRPC_HEADER_SIZE_IN_BYTES, in perform_stream_op_locked()
[all …]
|
| D | frame_settings.cc | 195 if (!t->flow_control->flow_control_enabled() && in grpc_chttp2_settings_parser_parse()
|
| D | internal.h | 411 flow_control; member
630 flow_control; member
|
| /external/grpc-grpc/src/core/ext/transport/chttp2/transport/ |
| D | frame_window_update.cc | 103 s->flow_control->RecvUpdate(received_update); in grpc_chttp2_window_update_parser_parse()
111 bool was_zero = t->flow_control->remote_window() <= 0; in grpc_chttp2_window_update_parser_parse()
112 t->flow_control->RecvUpdate(received_update); in grpc_chttp2_window_update_parser_parse()
113 bool is_zero = t->flow_control->remote_window() <= 0; in grpc_chttp2_window_update_parser_parse()
|
| D | writing.cc | 155 t->flow_control->remote_window(), in report_stall()
158 s->flow_control->remote_window_delta() + in report_stall()
161 s->flow_control->remote_window_delta()); in report_stall()
226 t_->flow_control->MaybeSendUpdate(t_->outbuf.count > 0); in FlushWindowUpdates()
323 0, s_->flow_control->remote_window_delta() + in stream_remote_window()
331 GPR_MIN(stream_remote_window(), t_->flow_control->remote_window())); in max_outgoing()
364 s_->flow_control->SentData(send_bytes); in FlushCompressedBytes()
412 (int)(s->flow_control->local_window_delta() - in StreamWriteContext()
413 s->flow_control->announced_window_delta()))); in StreamWriteContext()
459 const uint32_t stream_announce = s_->flow_control->MaybeSendUpdate(); in FlushWindowUpdates()
[all …]
|
| D | stream_lists.cc | 188 GPR_ASSERT(t->flow_control->flow_control_enabled()); in grpc_chttp2_list_add_stalled_by_transport()
204 GPR_ASSERT(t->flow_control->flow_control_enabled()); in grpc_chttp2_list_add_stalled_by_stream()
|
| D | parsing.cc | 192 } else if (t->flow_control->flow_control_enabled() && in grpc_chttp2_perform_read()
348 err = t->flow_control->RecvData(t->incoming_frame_size); in init_data_frame_parser()
349 action = t->flow_control->MakeAction(); in init_data_frame_parser()
351 err = s->flow_control->RecvData(t->incoming_frame_size); in init_data_frame_parser()
352 action = s->flow_control->MakeAction(); in init_data_frame_parser()
|
| D | chttp2_transport.cc | 193 t->flow_control.Destroy(); in destruct_transport()
547 t->flow_control.Init<grpc_core::chttp2::TransportFlowControl>(t, in init_transport()
550 t->flow_control.Init<grpc_core::chttp2::TransportFlowControlDisabled>(t); in init_transport()
567 grpc_chttp2_act_on_flowctl_action(t->flow_control->PeriodicUpdate(), t, in init_transport()
706 if (t->flow_control->flow_control_enabled()) { in init_stream()
707 s->flow_control.Init<grpc_core::chttp2::StreamFlowControl>( in init_stream()
709 t->flow_control.get()), in init_stream()
712 s->flow_control.Init<grpc_core::chttp2::StreamFlowControlDisabled>(); in init_stream()
758 s->flow_control.Destroy(); in destroy_stream_locked()
1628 s->flow_control->IncomingByteStreamUpdate(GRPC_HEADER_SIZE_IN_BYTES, in perform_stream_op_locked()
[all …]
|
| D | internal.h | 403 flow_control; member
585 flow_control; member
|
| D | frame_settings.cc | 192 if (!t->flow_control->flow_control_enabled() && in grpc_chttp2_settings_parser_parse()
|
| /external/grpc-grpc/test/cpp/microbenchmarks/ |
| D | bm_fullstack_trickle.cc | 155 client->flow_control->remote_window_, in Log()
156 server->flow_control->remote_window_, in Log()
157 client->flow_control->announced_window_, in Log()
158 server->flow_control->announced_window_, in Log()
159 client_stream ? client_stream->flow_control->remote_window_delta_ : -1, in Log()
160 server_stream ? server_stream->flow_control->remote_window_delta_ : -1, in Log()
161 client_stream ? client_stream->flow_control->local_window_delta_ : -1, in Log()
162 server_stream ? server_stream->flow_control->local_window_delta_ : -1, in Log()
163 client_stream ? client_stream->flow_control->announced_window_delta_ in Log()
165 server_stream ? server_stream->flow_control->announced_window_delta_ in Log()
|
| D | bm_chttp2_transport.cc | 434 s->chttp2_stream()->flow_control->TestOnlyForceHugeWindow(); in BM_TransportStreamSend()
435 f.chttp2_transport()->flow_control->TestOnlyForceHugeWindow(); in BM_TransportStreamSend()
565 s.chttp2_stream()->flow_control->TestOnlyForceHugeWindow(); in BM_TransportStreamRecv()
566 f.chttp2_transport()->flow_control->TestOnlyForceHugeWindow(); in BM_TransportStreamRecv()
|
| /external/libwebsockets/plugins/raw-proxy/ |
| D | protocol_lws_raw_proxy.c | 151 flow_control(struct conn *conn, int side, int enable) in flow_control() function
267 flow_control(conn, ACC, 1); in callback_raw_proxy()
316 flow_control(conn, ONW, 0); in callback_raw_proxy()
358 flow_control(conn, ACC, 1); in callback_raw_proxy()
418 flow_control(conn, ACC, 0); in callback_raw_proxy()
473 flow_control(conn, ACC, 0); in callback_raw_proxy()
517 flow_control(conn, ONW, 1); in callback_raw_proxy()
|
| /external/mesa3d/src/panfrost/bifrost/ |
| D | bi_schedule.c | 210 u->flow_control = BIFROST_FLOW_NBTB; in bi_make_singleton()
263 last_clause->flow_control = BIFROST_FLOW_NBTB_UNCONDITIONAL; in bi_schedule()
|
| D | bifrost.h | 131 enum bifrost_flow flow_control : 3; member
|
| D | disassemble.c | 83 fprintf(fp, "%s ", bi_flow_control_name(header.flow_control)); in dump_header()
650 if (header.flow_control == BIFROST_FLOW_END) in dump_clause()
|
| D | compiler.h | 416 enum bifrost_flow flow_control; member
|
| D | bi_print.c | 418 fprintf(fp, " %s", bi_flow_control_name(clause->flow_control)); in bi_print_clause()
|
| D | bi_pack.c | 48 .flow_control = in bi_pack_header()
50 clause->flow_control, in bi_pack_header()
|
| /external/kernel-headers/original/uapi/rdma/ |
| D | rdma_user_cm.h | 198 __u8 flow_control; member
|
| /external/tensorflow/tensorflow/core/kernels/ |
| D | tensor_array_ops.cc | 92 const Tensor* flow_control; in SetupFlowControlInputs() local
93 TF_RETURN_IF_ERROR(ctx->input("flow_in", &flow_control)); in SetupFlowControlInputs()
95 TF_RETURN_IF_ERROR(ctx->set_output("flow_out", *flow_control)); in SetupFlowControlInputs()
|