| /external/grpc-grpc/src/core/ext/transport/chttp2/transport/ |
| frame_window_update.cc | 103 s->flow_control->RecvUpdate(received_update);
111 bool was_zero = t->flow_control->remote_window() <= 0;
112 t->flow_control->RecvUpdate(received_update);
113 bool is_zero = t->flow_control->remote_window() <= 0;
|
| writing.cc | 155 t->flow_control->remote_window(),
158 s->flow_control->remote_window_delta() +
161 s->flow_control->remote_window_delta());
226 t_->flow_control->MaybeSendUpdate(t_->outbuf.count > 0);
323 0, s_->flow_control->remote_window_delta() +
331 GPR_MIN(stream_remote_window(), t_->flow_control->remote_window()));
364 s_->flow_control->SentData(send_bytes);
412 (int)(s->flow_control->local_window_delta() -
413 s->flow_control->announced_window_delta())));
459 const uint32_t stream_announce = s_->flow_control->MaybeSendUpdate()
[all...] |
| stream_lists.cc | 188 GPR_ASSERT(t->flow_control->flow_control_enabled());
204 GPR_ASSERT(t->flow_control->flow_control_enabled());
|
| parsing.cc | 192 } else if (t->flow_control->flow_control_enabled() &&
348 err = t->flow_control->RecvData(t->incoming_frame_size);
349 action = t->flow_control->MakeAction();
351 err = s->flow_control->RecvData(t->incoming_frame_size);
352 action = s->flow_control->MakeAction();
|
| chttp2_transport.cc | 193 t->flow_control.Destroy();
547 t->flow_control.Init<grpc_core::chttp2::TransportFlowControl>(t,
550 t->flow_control.Init<grpc_core::chttp2::TransportFlowControlDisabled>(t);
567 grpc_chttp2_act_on_flowctl_action(t->flow_control->PeriodicUpdate(), t,
706 if (t->flow_control->flow_control_enabled()) {
707 s->flow_control.Init<grpc_core::chttp2::StreamFlowControl>(
709 t->flow_control.get()),
712 s->flow_control.Init<grpc_core::chttp2::StreamFlowControlDisabled>();
758 s->flow_control.Destroy();
[all...] |
| internal.h | 27 #include "src/core/ext/transport/chttp2/transport/flow_control.h"
403 flow_control; member in struct:grpc_chttp2_transport
585 flow_control; member in struct:grpc_chttp2_stream
|
| frame_settings.cc | 192 if (!t->flow_control->flow_control_enabled() &&
|
| /device/google/contexthub/firmware/os/inc/ |
| usart.h | 64 UsartFlowControlCfg flow_control);
|
| /device/google/contexthub/firmware/os/platform/stm32/ |
| usart.c | 89 UsartFlowControlCfg flow_control)
110 flow_control = USART_FLOW_CONTROL_NONE;
115 block->CR3 = (block->CR3 &~ 0x0300) | flowCtrlVals[flow_control];
|
| /bionic/libc/kernel/uapi/rdma/ |
| ib_user_cm.h | 110 __u8 flow_control; member in struct:ib_ucm_req
129 __u8 flow_control; member in struct:ib_ucm_rep
198 __u8 flow_control; member in struct:ib_ucm_req_event_resp
215 __u8 flow_control; member in struct:ib_ucm_rep_event_resp
|
| rdma_user_cm.h | 154 __u8 flow_control; member in struct:rdma_ucm_conn_param
|
| /device/google/bonito/sdm710/kernel-headers/linux/ |
| rmnet_data.h | 73 } flow_control; member in union:rmnet_nl_msg_s::__anon1991
|
| /device/google/bonito/sdm710/original-kernel-headers/linux/ |
| rmnet_data.h | 77 } flow_control; member in union:rmnet_nl_msg_s::__anon2128
|
| /device/google/crosshatch/sdm845/kernel-headers/linux/ |
| rmnet_data.h | 73 } flow_control; member in union:rmnet_nl_msg_s::__anon2556
|
| /device/google/crosshatch/sdm845/original-kernel-headers/linux/ |
| rmnet_data.h | 77 } flow_control; member in union:rmnet_nl_msg_s::__anon2692
|
| /external/kernel-headers/original/uapi/rdma/ |
| ib_user_cm.h | 146 __u8 flow_control; member in struct:ib_ucm_req
166 __u8 flow_control; member in struct:ib_ucm_rep
244 __u8 flow_control; member in struct:ib_ucm_req_event_resp
262 __u8 flow_control; member in struct:ib_ucm_rep_event_resp
|
| rdma_user_cm.h | 194 __u8 flow_control; member in struct:rdma_ucm_conn_param
|
| /external/grpc-grpc/test/cpp/microbenchmarks/ |
| bm_fullstack_trickle.cc | 155 client->flow_control->remote_window_,
156 server->flow_control->remote_window_,
157 client->flow_control->announced_window_,
158 server->flow_control->announced_window_,
159 client_stream ? client_stream->flow_control->remote_window_delta_ : -1,
160 server_stream ? server_stream->flow_control->remote_window_delta_ : -1,
161 client_stream ? client_stream->flow_control->local_window_delta_ : -1,
162 server_stream ? server_stream->flow_control->local_window_delta_ : -1,
163 client_stream ? client_stream->flow_control->announced_window_delta_
165 server_stream ? server_stream->flow_control->announced_window_delta
[all...] |
| bm_chttp2_transport.cc | 434 s->chttp2_stream()->flow_control->TestOnlyForceHugeWindow();
435 f.chttp2_transport()->flow_control->TestOnlyForceHugeWindow();
565 s.chttp2_stream()->flow_control->TestOnlyForceHugeWindow();
566 f.chttp2_transport()->flow_control->TestOnlyForceHugeWindow();
|
| /device/google/marlin/dataservices/rmnetctl/src/ |
| librmnetctl.c | 892 request.flow_control.id = id;
893 request.flow_control.map_flow_id = map_flow_id;
894 request.flow_control.tc_flow_id = tc_flow_id;
|
| /external/u-boot/drivers/net/ |
| calxedaxgmac.c | 176 u32 flow_control; member in struct:xgmac_regs
399 writel(value, ®s->flow_control);
|
| /external/tensorflow/tensorflow/core/kernels/ |
| tensor_array_ops.cc | 91 const Tensor* flow_control; local
92 TF_RETURN_IF_ERROR(ctx->input("flow_in", &flow_control));
94 TF_RETURN_IF_ERROR(ctx->set_output("flow_out", *flow_control));
[all...] |
