Home
last modified time | relevance | path

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

12

/third_party/boost/libs/asio/test/
Dserial_port_base.cpp53 serial_port_base::flow_control flow_control1( in test()
54 serial_port_base::flow_control::none); in test()
56 serial_port_base::flow_control flow_control2; in test()
58 (void)static_cast<serial_port_base::flow_control::type>( in test()
/third_party/grpc/src/core/ext/transport/chttp2/transport/
Dwriting.cc176 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 …]
Dframe_window_update.cc101 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()
Dparsing.cc193 } 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()
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()
Dchttp2_transport.cc220 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 …]
Dinternal.h411 flow_control; member
630 flow_control; member
Dframe_settings.cc195 if (!t->flow_control->flow_control_enabled() && in grpc_chttp2_settings_parser_parse()
/third_party/grpc/test/cpp/microbenchmarks/
Dbm_fullstack_trickle.cc156 client->flow_control->remote_window_, in Log()
157 server->flow_control->remote_window_, in Log()
158 client->flow_control->announced_window_, in Log()
159 server->flow_control->announced_window_, in Log()
160 client_stream ? client_stream->flow_control->remote_window_delta_ : -1, in Log()
161 server_stream ? server_stream->flow_control->remote_window_delta_ : -1, in Log()
162 client_stream ? client_stream->flow_control->local_window_delta_ : -1, in Log()
163 server_stream ? server_stream->flow_control->local_window_delta_ : -1, in Log()
164 client_stream ? client_stream->flow_control->announced_window_delta_ in Log()
166 server_stream ? server_stream->flow_control->announced_window_delta_ in Log()
Dbm_chttp2_transport.cc452 s->chttp2_stream()->flow_control->TestOnlyForceHugeWindow(); in BM_TransportStreamSend()
453 f.chttp2_transport()->flow_control->TestOnlyForceHugeWindow(); in BM_TransportStreamSend()
593 s->chttp2_stream()->flow_control->TestOnlyForceHugeWindow(); in BM_TransportStreamRecv()
594 f.chttp2_transport()->flow_control->TestOnlyForceHugeWindow(); in BM_TransportStreamRecv()
/third_party/boost/libs/asio/include/boost/asio/impl/
Dserial_port_base.hpp34 inline serial_port_base::flow_control::type
35 serial_port_base::flow_control::value() const in value()
Dserial_port_base.ipp210 serial_port_base::flow_control::flow_control(
211 serial_port_base::flow_control::type t)
216 std::out_of_range ex("invalid flow_control value");
221 BOOST_ASIO_SYNC_OP_VOID serial_port_base::flow_control::store(
288 BOOST_ASIO_SYNC_OP_VOID serial_port_base::flow_control::load(
/third_party/boost/boost/asio/impl/
Dserial_port_base.hpp34 inline serial_port_base::flow_control::type
35 serial_port_base::flow_control::value() const in value()
Dserial_port_base.ipp210 serial_port_base::flow_control::flow_control(
211 serial_port_base::flow_control::type t)
216 std::out_of_range ex("invalid flow_control value");
221 BOOST_ASIO_SYNC_OP_VOID serial_port_base::flow_control::store(
288 BOOST_ASIO_SYNC_OP_VOID serial_port_base::flow_control::load(
/third_party/libwebsockets/plugins/raw-proxy/
Dprotocol_lws_raw_proxy.c155 flow_control(struct conn *conn, int side, int enable) in flow_control() function
273 flow_control(conn, ACC, 1); in callback_raw_proxy()
322 flow_control(conn, ONW, 0); in callback_raw_proxy()
364 flow_control(conn, ACC, 1); in callback_raw_proxy()
424 flow_control(conn, ACC, 0); in callback_raw_proxy()
479 flow_control(conn, ACC, 0); in callback_raw_proxy()
523 flow_control(conn, ONW, 1); in callback_raw_proxy()
/third_party/boost/boost/asio/
Dserial_port_base.hpp72 class flow_control class in boost::asio::serial_port_base
76 BOOST_ASIO_DECL explicit flow_control(type t = none);
/third_party/boost/libs/asio/include/boost/asio/
Dserial_port_base.hpp72 class flow_control class in boost::asio::serial_port_base
76 BOOST_ASIO_DECL explicit flow_control(type t = none);
/third_party/mesa3d/src/panfrost/bifrost/
Dbi_print.c98 fprintf(fp, " %s", bi_flow_control_name(clause->flow_control)); in bi_print_clause()
Dbi_pack.c43 .flow_control = in bi_pack_header()
45 BIFROST_FLOW_END : clause->flow_control, in bi_pack_header()
Dbifrost.h145 enum bifrost_flow flow_control : 3; member
Dbi_schedule.c1570 clause->flow_control = BIFROST_FLOW_NBTB; in bi_schedule_clause()
1819 last_clause->flow_control = BIFROST_FLOW_NBTB_UNCONDITIONAL; in bi_schedule_block()
1954 .flow_control = BIFROST_FLOW_NBTB, in bi_add_nop_for_atest()
Ddisassemble.c83 fprintf(fp, "%s ", bi_flow_control_name(header.flow_control)); in dump_header()
Dcompiler.h543 enum bifrost_flow flow_control; member
/third_party/boost/libs/asio/doc/overview/
Dserial_ports.qbk33 [link boost_asio.reference.serial_port_base__flow_control serial_port_base::flow_control],
/third_party/grpc/
DgRPC-Core.podspec346 'src/core/ext/transport/chttp2/transport/flow_control.cc',
347 'src/core/ext/transport/chttp2/transport/flow_control.h',
1170 'src/core/ext/transport/chttp2/transport/flow_control.h',

12