Home
last modified time | relevance | path

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

/external/grpc-grpc/src/core/ext/transport/chttp2/transport/
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 …]
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()
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 …]
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()
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()
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/kernel-headers/original/uapi/rdma/
Dib_user_cm.h146 __u8 flow_control; member
166 __u8 flow_control; member
244 __u8 flow_control; member
262 __u8 flow_control; member
Drdma_user_cm.h194 __u8 flow_control; member
/external/u-boot/drivers/net/
Dcalxedaxgmac.c176 u32 flow_control; member
399 writel(value, &regs->flow_control); in xgmac_init()
/external/tensorflow/tensorflow/core/kernels/
Dtensor_array_ops.cc91 const Tensor* flow_control; in SetupFlowControlInputs() local
92 TF_RETURN_IF_ERROR(ctx->input("flow_in", &flow_control)); in SetupFlowControlInputs()
94 TF_RETURN_IF_ERROR(ctx->set_output("flow_out", *flow_control)); in SetupFlowControlInputs()
/external/syzkaller/sys/linux/
Drdma_cm.txt237 flow_control int8
/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',
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 \
Dconfig.w32219 "src\\core\\ext\\transport\\chttp2\\transport\\flow_control.cc " +
Dgrpc.gemspec189 s.files += %w( src/core/ext/transport/chttp2/transport/flow_control.h )
613 s.files += %w( src/core/ext/transport/chttp2/transport/flow_control.cc )
DCMakeLists.txt1100 src/core/ext/transport/chttp2/transport/flow_control.cc
1512 src/core/ext/transport/chttp2/transport/flow_control.cc
1926 src/core/ext/transport/chttp2/transport/flow_control.cc
2237 src/core/ext/transport/chttp2/transport/flow_control.cc
2506 src/core/ext/transport/chttp2/transport/flow_control.cc
3176 src/core/ext/transport/chttp2/transport/flow_control.cc
/external/grpc-grpc/tools/doxygen/
DDoxyfile.core.internal999 src/core/ext/transport/chttp2/transport/flow_control.cc \
1000 src/core/ext/transport/chttp2/transport/flow_control.h \