| /dports/textproc/p5-Search-Elasticsearch/Search-Elasticsearch-6.00/t/60_Cxn/ |
| H A D | 10_basic.t | 14 is $c->next_ping, 0, "No ping scheduled";
22 ok $c->next_ping > time(), "Ping scheduled";
23 ok $c->next_ping <= time() + $c->dead_timeout, "Dead timeout x 1";
28 ok $c->next_ping > time(), "Ping scheduled";
29 ok $c->next_ping <= time() + 2 * $c->dead_timeout, "Dead timeout x 2";
34 ok $c->next_ping > time(), "Ping scheduled";
35 ok $c->next_ping <= time() + $c->max_dead_timeout, "Max dead timeout";
42 is $c->next_ping, -1, "Next ping scheduled for now";
|
| /dports/net/p5-Net-MQTT/Net-MQTT-1.143260/bin/ |
| H A D | net-mqtt-pub | 47 my $next_ping;
86 if (Time::HiRes::time > $next_ping) {
99 $next_ping = Time::HiRes::time + $keep_alive_timer;
106 my $timeout = $next_ping - Time::HiRes::time;
112 $timeout = $next_ping - Time::HiRes::time;
|
| H A D | net-mqtt-sub | 46 my $next_ping;
79 if (Time::HiRes::time > $next_ping) {
92 $next_ping = Time::HiRes::time + $keep_alive_timer;
98 my $timeout = $next_ping - Time::HiRes::time;
103 $timeout = $next_ping - Time::HiRes::time;
|
| /dports/dns/knot-resolver/knot-resolver-5.4.3/tests/pytests/ |
| H A D | conn_flood.py | 39 next_ping = time.time() + 4 # less than tcp idle timeout / 2
42 while time.time() < next_ping:
51 next_ping = time.time() + 4
|
| /dports/textproc/p5-Search-Elasticsearch/Search-Elasticsearch-6.00/lib/Search/Elasticsearch/Role/ |
| H A D | Cxn.pm | 138 sub is_live { !shift->next_ping }
139 sub is_dead { !!shift->next_ping }
147 $self->next_ping(0);
159 my $next = $self->next_ping( time() + $timeout );
171 $self->next_ping(-1);
|
| /dports/textproc/p5-Search-Elasticsearch/Search-Elasticsearch-6.00/lib/Search/Elasticsearch/CxnPool/ |
| H A D | Static.pm | 24 if ( $cxn->next_ping < $now ) {
|
| /dports/textproc/p5-Search-Elasticsearch/Search-Elasticsearch-6.00/lib/Search/Elasticsearch/Role/CxnPool/Static/ |
| H A D | NoPing.pm | 24 || $cxn->next_ping < time();
|
| /dports/textproc/p5-Search-Elasticsearch/Search-Elasticsearch-6.00/t/50_Cxn_Pool/ |
| H A D | 11_static_node_missing.t | 28 $t->cxn_pool->cxns->[1]->next_ping(-1);
|
| H A D | 12_static_node_fails.t | 35 $t->cxn_pool->cxns->[0]->next_ping(-1);
|
| /dports/www/kannel/gateway-1.4.4/gw/smsc/ |
| H A D | smsc_oisd.c | 103 time_t next_ping; member
745 pdata->next_ping = time(NULL) + pdata->keepalive; in oisd_get_packet()
1221 if (pdata->keepalive > 0 && pdata->next_ping < time(NULL)) { in oisd_receive_msg()
1563 pdata->next_ping = time(NULL) + pdata->keepalive; in smsc_oisd_create()
|
| H A D | smsc_cimd2.c | 115 time_t next_ping; member
1560 pdata->next_ping = time(NULL) + pdata->keepalive; in cimd2_get_packet()
2025 if (pdata->keepalive > 0 && pdata->next_ping < time(NULL)) { in cimd2_receive_msg()
2394 pdata->next_ping = time(NULL) + pdata->keepalive; in smsc_cimd2_create()
|
| /dports/devel/grpc130/grpc-1.30.2/src/core/ext/transport/chttp2/transport/ |
| H A D | chttp2_transport.cc | 2666 grpc_millis next_ping = t->flow_control->bdp_estimator()->CompletePing(); in finish_bdp_ping_locked() local
2673 grpc_timer_init(&t->next_bdp_ping_timer, next_ping, in finish_bdp_ping_locked()
|
| /dports/devel/grpc134/grpc-1.34.1/src/core/ext/transport/chttp2/transport/ |
| H A D | chttp2_transport.cc | 2628 grpc_millis next_ping = t->flow_control->bdp_estimator()->CompletePing(); in finish_bdp_ping_locked() local
2635 grpc_timer_init(&t->next_bdp_ping_timer, next_ping, in finish_bdp_ping_locked()
|
| /dports/devel/grpc/grpc-1.42.0/src/core/ext/transport/chttp2/transport/ |
| H A D | chttp2_transport.cc | 2668 grpc_millis next_ping = t->flow_control->bdp_estimator()->CompletePing(); in finish_bdp_ping_locked() local
2675 grpc_timer_init(&t->next_bdp_ping_timer, next_ping, in finish_bdp_ping_locked()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/grpc/src/src/core/ext/transport/chttp2/transport/ |
| H A D | chttp2_transport.cc | 2651 grpc_millis next_ping = t->flow_control->bdp_estimator()->CompletePing(); in finish_bdp_ping_locked() local
2656 grpc_timer_init(&t->next_bdp_ping_timer, next_ping, in finish_bdp_ping_locked()
|
| /dports/devel/pecl-grpc/grpc-1.42.0/src/core/ext/transport/chttp2/transport/ |
| H A D | chttp2_transport.cc | 2668 grpc_millis next_ping = t->flow_control->bdp_estimator()->CompletePing();
2675 grpc_timer_init(&t->next_bdp_ping_timer, next_ping,
|
| /dports/devel/py-grpcio/grpcio-1.43.0/src/core/ext/transport/chttp2/transport/ |
| H A D | chttp2_transport.cc | 2659 grpc_millis next_ping = t->flow_control->bdp_estimator()->CompletePing(); in finish_bdp_ping_locked() local
2666 grpc_timer_init(&t->next_bdp_ping_timer, next_ping, in finish_bdp_ping_locked()
|