Home
last modified time | relevance | path

Searched refs:flow_control (Results 1 – 25 of 30) sorted by relevance

12

/external/grpc-grpc/src/core/ext/transport/chttp2/transport/
Dframe_window_update.cc103 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()
Dwriting.cc155 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 …]
Dstream_lists.cc188 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()
Dparsing.cc192 } 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()
Dchttp2_transport.cc193 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 …]
Dinternal.h403 flow_control; member
585 flow_control; member
Dframe_settings.cc192 if (!t->flow_control->flow_control_enabled() && in grpc_chttp2_settings_parser_parse()
/external/grpc-grpc/test/cpp/microbenchmarks/
Dbm_fullstack_trickle.cc155 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()
Dbm_chttp2_transport.cc434 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/mesa3d/src/panfrost/bifrost/
Dbi_schedule.c210 u->flow_control = BIFROST_FLOW_NBTB; in bi_make_singleton()
263 last_clause->flow_control = BIFROST_FLOW_NBTB_UNCONDITIONAL; in bi_schedule()
Dbifrost.h131 enum bifrost_flow flow_control : 3; member
Ddisassemble.c83 fprintf(fp, "%s ", bi_flow_control_name(header.flow_control)); in dump_header()
650 if (header.flow_control == BIFROST_FLOW_END) in dump_clause()
Dcompiler.h416 enum bifrost_flow flow_control; member
Dbi_print.c418 fprintf(fp, " %s", bi_flow_control_name(clause->flow_control)); in bi_print_clause()
Dbi_pack.c48 .flow_control = in bi_pack_header()
50 clause->flow_control, in bi_pack_header()
/external/u-boot/drivers/net/
Dcalxedaxgmac.c176 u32 flow_control; member
399 writel(value, &regs->flow_control); in xgmac_init()
/external/kernel-headers/original/uapi/rdma/
Drdma_user_cm.h194 __u8 flow_control; member
/external/u-boot/arch/x86/include/asm/
Dacpi_table.h375 u8 flow_control; member
/external/tensorflow/tensorflow/core/kernels/
Dtensor_array_ops.cc92 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()
/external/grpc-grpc/
DgRPC-Core.podspec257 'src/core/ext/transport/chttp2/transport/flow_control.h',
677 'src/core/ext/transport/chttp2/transport/flow_control.cc',
862 'src/core/ext/transport/chttp2/transport/flow_control.h',
Dgrpc.gyp436 'src/core/ext/transport/chttp2/transport/flow_control.cc',
821 'src/core/ext/transport/chttp2/transport/flow_control.cc',
1057 'src/core/ext/transport/chttp2/transport/flow_control.cc',
1250 'src/core/ext/transport/chttp2/transport/flow_control.cc',
DAndroid.bp565 "src/core/ext/transport/chttp2/transport/flow_control.cc",
DBUILD1568 "src/core/ext/transport/chttp2/transport/flow_control.cc",
1592 "src/core/ext/transport/chttp2/transport/flow_control.h",
DgRPC-C++.podspec248 'src/core/ext/transport/chttp2/transport/flow_control.h',
Dconfig.m4244 src/core/ext/transport/chttp2/transport/flow_control.cc \

12