Searched refs:ping_state (Results 1 – 8 of 8) sorted by relevance
/external/grpc-grpc/src/core/ext/transport/chttp2/transport/ |
D | writing.cc | 60 if (t->ping_state.pings_before_data_required == 0 && in maybe_initiate_ping() 66 t->ping_state.pings_before_data_required, in maybe_initiate_ping() 79 t->ping_state.last_ping_sent_time + next_allowed_ping_interval; in maybe_initiate_ping() 88 static_cast<double>(t->ping_state.last_ping_sent_time), in maybe_initiate_ping() 91 if (!t->ping_state.is_delayed_ping_timer_set) { in maybe_initiate_ping() 92 t->ping_state.is_delayed_ping_timer_set = true; in maybe_initiate_ping() 94 grpc_timer_init(&t->ping_state.delayed_ping_timer, next_allowed_ping, in maybe_initiate_ping() 108 t->ping_state.last_ping_sent_time = now; in maybe_initiate_ping() 112 t->ping_state.pings_before_data_required, in maybe_initiate_ping() 115 t->ping_state.pings_before_data_required -= in maybe_initiate_ping() [all …]
|
D | parsing.cc | 376 t->ping_state.last_ping_sent_time = GRPC_MILLIS_INF_PAST; in init_data_frame_parser() 549 t->ping_state.last_ping_sent_time = GRPC_MILLIS_INF_PAST; in init_header_frame_parser()
|
D | chttp2_transport.cc | 555 t->ping_state.pings_before_data_required = 0; in init_transport() 556 t->ping_state.is_delayed_ping_timer_set = false; in init_transport() 557 t->ping_state.last_ping_sent_time = GRPC_MILLIS_INF_PAST; in init_transport() 615 if (t->ping_state.is_delayed_ping_timer_set) { in close_transport_locked() 616 grpc_timer_cancel(&t->ping_state.delayed_ping_timer); in close_transport_locked() 1742 t->ping_state.is_delayed_ping_timer_set = false; in retry_initiate_ping_locked()
|
D | internal.h | 377 grpc_chttp2_repeated_ping_state ping_state; member
|
/external/rust/crates/grpcio-sys/grpc/src/core/ext/transport/chttp2/transport/ |
D | writing.cc | 65 if (t->ping_state.pings_before_data_required == 0 && in maybe_initiate_ping() 73 t->ping_state.pings_before_data_required, in maybe_initiate_ping() 87 t->ping_state.last_ping_sent_time + next_allowed_ping_interval; in maybe_initiate_ping() 98 static_cast<double>(t->ping_state.last_ping_sent_time), in maybe_initiate_ping() 101 if (!t->ping_state.is_delayed_ping_timer_set) { in maybe_initiate_ping() 102 t->ping_state.is_delayed_ping_timer_set = true; in maybe_initiate_ping() 107 grpc_timer_init(&t->ping_state.delayed_ping_timer, next_allowed_ping, in maybe_initiate_ping() 122 t->ping_state.last_ping_sent_time = now; in maybe_initiate_ping() 128 t->ping_state.pings_before_data_required, in maybe_initiate_ping() 131 t->ping_state.pings_before_data_required -= in maybe_initiate_ping() [all …]
|
D | parsing.cc | 382 t->ping_state.last_ping_sent_time = GRPC_MILLIS_INF_PAST; in init_data_frame_parser() 579 t->ping_state.last_ping_sent_time = GRPC_MILLIS_INF_PAST; in init_header_frame_parser()
|
D | chttp2_transport.cc | 490 ping_state.pings_before_data_required = 0; in grpc_chttp2_transport() 491 ping_state.is_delayed_ping_timer_set = false; in grpc_chttp2_transport() 492 ping_state.last_ping_sent_time = GRPC_MILLIS_INF_PAST; in grpc_chttp2_transport() 549 if (t->ping_state.is_delayed_ping_timer_set) { in close_transport_locked() 550 grpc_timer_cancel(&t->ping_state.delayed_ping_timer); in close_transport_locked() 1692 t->ping_state.is_delayed_ping_timer_set = false; in retry_initiate_ping_locked() 1749 t->ping_state.pings_before_data_required = in grpc_chttp2_reset_ping_clock()
|
D | internal.h | 385 grpc_chttp2_repeated_ping_state ping_state; member
|