/dports/www/domoticz/domoticz-2020.2/extern/mosquitto/lib/ |
H A D | loop.c | 198 unsigned long reconnect_delay; in mosquitto_loop_forever() local 239 if(mosq->reconnect_delay_max > mosq->reconnect_delay){ in mosquitto_loop_forever() 241 reconnect_delay = mosq->reconnect_delay*(mosq->reconnects+1)*(mosq->reconnects+1); in mosquitto_loop_forever() 243 reconnect_delay = mosq->reconnect_delay*(mosq->reconnects+1); in mosquitto_loop_forever() 246 reconnect_delay = mosq->reconnect_delay; in mosquitto_loop_forever() 249 if(reconnect_delay > mosq->reconnect_delay_max){ in mosquitto_loop_forever() 250 reconnect_delay = mosq->reconnect_delay_max; in mosquitto_loop_forever() 256 Sleep(reconnect_delay*1000); in mosquitto_loop_forever() 258 req.tv_sec = reconnect_delay; in mosquitto_loop_forever()
|
H A D | options.c | 105 int mosquitto_reconnect_delay_set(struct mosquitto *mosq, unsigned int reconnect_delay, unsigned in… in mosquitto_reconnect_delay_set() argument 109 if(reconnect_delay == 0) reconnect_delay = 1; in mosquitto_reconnect_delay_set() 111 mosq->reconnect_delay = reconnect_delay; in mosquitto_reconnect_delay_set()
|
/dports/net/mosquitto/mosquitto-2.0.13/lib/ |
H A D | loop.c | 194 static int interruptible_sleep(struct mosquitto *mosq, time_t reconnect_delay) in interruptible_sleep() argument 212 local_timeout.tv_sec = reconnect_delay; in interruptible_sleep() 256 unsigned long reconnect_delay; in mosquitto_loop_forever() local 300 if(mosq->reconnect_delay_max > mosq->reconnect_delay){ in mosquitto_loop_forever() 302 reconnect_delay = mosq->reconnect_delay*(mosq->reconnects+1)*(mosq->reconnects+1); in mosquitto_loop_forever() 304 reconnect_delay = mosq->reconnect_delay*(mosq->reconnects+1); in mosquitto_loop_forever() 307 reconnect_delay = mosq->reconnect_delay; in mosquitto_loop_forever() 310 if(reconnect_delay > mosq->reconnect_delay_max){ in mosquitto_loop_forever() 311 reconnect_delay = mosq->reconnect_delay_max; in mosquitto_loop_forever() 316 rc = interruptible_sleep(mosq, (time_t)reconnect_delay); in mosquitto_loop_forever()
|
H A D | options.c | 113 int mosquitto_reconnect_delay_set(struct mosquitto *mosq, unsigned int reconnect_delay, unsigned in… in mosquitto_reconnect_delay_set() argument 117 if(reconnect_delay == 0) reconnect_delay = 1; in mosquitto_reconnect_delay_set() 119 mosq->reconnect_delay = reconnect_delay; in mosquitto_reconnect_delay_set()
|
/dports/comms/py-fritzconnection/fritzconnection-1.7.2/fritzconnection/core/ |
H A D | fritzmonitor.py | 129 reconnect_delay=MAX_RECONNECT_DELAY, argument 156 "reconnect_delay": reconnect_delay, 207 reconnect_delay = delayer(max_delay=max_reconnect_delay) 209 next(reconnect_delay) 223 reconnect_delay, argument 247 max_reconnect_delay=reconnect_delay,
|
/dports/net/rabbitmq/rabbitmq-server-3.9.11/deps/rabbitmq_shovel/src/ |
H A D | rabbit_shovel_config.erl | 42 RD = proplists:get_value(reconnect_delay, Config, ?DEFAULT_RECONNECT_DELAY), 67 {reconnect_delay, RD}]. 139 reconnect_delay => proplists:get_value(reconnect_delay, Config, 149 lists:keystore(reconnect_delay, 1, 151 {reconnect_delay, 152 ParsedShovel#shovel.reconnect_delay}).
|
/dports/www/janus/janus-gateway-0.11.6/events/ |
H A D | janus_wsevh.c | 166 static int reconnect_delay = 0; variable 607 if(reconnect_delay > 0) { in janus_wsevh_thread() 713 reconnect_delay = 0; 724 reconnect_delay); 814 reconnect_delay = 1; 875 if(reconnect_delay == 0) 876 reconnect_delay = 1; 877 else if(reconnect_delay < JANUS_WSEVH_MAX_RETRY_SECS) { 878 reconnect_delay += reconnect_delay; 879 if(reconnect_delay > JANUS_WSEVH_MAX_RETRY_SECS) [all …]
|
/dports/sysutils/py-salt/salt-3004.1/salt/states/ |
H A D | rabbitmq_upstream.py | 50 reconnect_delay=None, argument 131 "reconnect-delay": reconnect_delay, 165 reconnect_delay=reconnect_delay,
|
/dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/scsi/ |
H A D | scsi_transport_srp.c | 86 if (reconnect_delay < 0 && fast_io_fail_tmo < 0 && dev_loss_tmo < 0) in srp_tmo_valid() 88 if (reconnect_delay == 0) in srp_tmo_valid() 217 return srp_show_tmo(buf, rport->reconnect_delay); in show_reconnect_delay() 235 if (rport->reconnect_delay <= 0 && delay > 0 && in store_reconnect_delay() 242 rport->reconnect_delay = delay; in store_reconnect_delay() 282 res = srp_tmo_valid(rport->reconnect_delay, fast_io_fail_tmo, in store_srp_rport_fast_io_fail_tmo() 317 res = srp_tmo_valid(rport->reconnect_delay, rport->fast_io_fail_tmo, in store_srp_rport_dev_loss_tmo() 390 delay = rport->reconnect_delay * in srp_reconnect_work() 468 delay = rport->reconnect_delay; in __srp_start_tl_fail_timers() 718 rport->reconnect_delay = i->f->reconnect_delay ? in srp_rport_add() [all …]
|
/dports/multimedia/libv4l/linux-5.13-rc2/drivers/scsi/ |
H A D | scsi_transport_srp.c | 86 if (reconnect_delay < 0 && fast_io_fail_tmo < 0 && dev_loss_tmo < 0) in srp_tmo_valid() 88 if (reconnect_delay == 0) in srp_tmo_valid() 217 return srp_show_tmo(buf, rport->reconnect_delay); in show_reconnect_delay() 235 if (rport->reconnect_delay <= 0 && delay > 0 && in store_reconnect_delay() 242 rport->reconnect_delay = delay; in store_reconnect_delay() 282 res = srp_tmo_valid(rport->reconnect_delay, fast_io_fail_tmo, in store_srp_rport_fast_io_fail_tmo() 317 res = srp_tmo_valid(rport->reconnect_delay, rport->fast_io_fail_tmo, in store_srp_rport_dev_loss_tmo() 390 delay = rport->reconnect_delay * in srp_reconnect_work() 468 delay = rport->reconnect_delay; in __srp_start_tl_fail_timers() 718 rport->reconnect_delay = i->f->reconnect_delay ? in srp_rport_add() [all …]
|
/dports/multimedia/v4l-utils/linux-5.13-rc2/drivers/scsi/ |
H A D | scsi_transport_srp.c | 86 if (reconnect_delay < 0 && fast_io_fail_tmo < 0 && dev_loss_tmo < 0) in srp_tmo_valid() 88 if (reconnect_delay == 0) in srp_tmo_valid() 217 return srp_show_tmo(buf, rport->reconnect_delay); in show_reconnect_delay() 235 if (rport->reconnect_delay <= 0 && delay > 0 && in store_reconnect_delay() 242 rport->reconnect_delay = delay; in store_reconnect_delay() 282 res = srp_tmo_valid(rport->reconnect_delay, fast_io_fail_tmo, in store_srp_rport_fast_io_fail_tmo() 317 res = srp_tmo_valid(rport->reconnect_delay, rport->fast_io_fail_tmo, in store_srp_rport_dev_loss_tmo() 390 delay = rport->reconnect_delay * in srp_reconnect_work() 468 delay = rport->reconnect_delay; in __srp_start_tl_fail_timers() 718 rport->reconnect_delay = i->f->reconnect_delay ? in srp_rport_add() [all …]
|
/dports/multimedia/libv4l/linux-5.13-rc2/include/scsi/ |
H A D | scsi_transport_srp.h | 67 int reconnect_delay; member 97 int *reconnect_delay; member 114 extern int srp_tmo_valid(int reconnect_delay, int fast_io_fail_tmo,
|
/dports/multimedia/v4l_compat/linux-5.13-rc2/include/scsi/ |
H A D | scsi_transport_srp.h | 67 int reconnect_delay; member 97 int *reconnect_delay; member 114 extern int srp_tmo_valid(int reconnect_delay, int fast_io_fail_tmo,
|
/dports/multimedia/v4l-utils/linux-5.13-rc2/include/scsi/ |
H A D | scsi_transport_srp.h | 67 int reconnect_delay; member 97 int *reconnect_delay; member 114 extern int srp_tmo_valid(int reconnect_delay, int fast_io_fail_tmo,
|
/dports/devel/py-circuits/circuits-3.2/circuits/node/ |
H A D | node.py | 122 reconnect_delay = kwargs.pop('reconnect_delay', 10) 142 if reconnect_delay > 0: 144 reconnect_delay,
|
/dports/databases/py-tarantool/tarantool-0.7.1/tarantool/ |
H A D | __init__.py | 49 reconnect_delay=RECONNECT_DELAY, 71 reconnect_delay=RECONNECT_DELAY,
|
H A D | mesh_connection.py | 187 reconnect_delay=RECONNECT_DELAY, argument 234 reconnect_delay=reconnect_delay,
|
/dports/www/websocat/websocat-1.9.0/src/ |
H A D | reconnect_peer.rs | 62 reconnect_delay: std::time::Duration, field 118 …self.ratelimiter = Some(tokio_timer::Delay::new(std::time::Instant::now() + self.reconnect_delay)); in poll() 223 …let reconnect_delay = std::time::Duration::from_millis(cp.program_options.autoreconnect_delay_mill… in autoreconnector() localVariable 230 reconnect_delay, in autoreconnector()
|
/dports/comms/py-fritzconnection/fritzconnection-1.7.2/fritzconnection/tests/ |
H A D | test_fritzmonitor.py | 233 event_queue = fm.start(sock=mock_socket, reconnect_delay=0.001) 334 fm.start(sock=mock_socket, reconnect_delay=0.001, reconnect_tries=tries) 357 sock=socket, reconnect_delay=0.001, reconnect_tries=5 368 sock=socket, reconnect_delay=0.001, reconnect_tries=5
|
/dports/devel/py-pika/pika-1.1.0/examples/ |
H A D | asyncio_consumer_example.py | 420 reconnect_delay = self._get_reconnect_delay() 421 LOGGER.info('Reconnecting after %d seconds', reconnect_delay) 422 time.sleep(reconnect_delay)
|
H A D | asynchronous_consumer_example.py | 416 reconnect_delay = self._get_reconnect_delay() 417 LOGGER.info('Reconnecting after %d seconds', reconnect_delay) 418 time.sleep(reconnect_delay)
|
/dports/irc/keitairc2/keitairc-2.0/t/ |
H A D | 02_Config.t | 44 is($c->reconnect_delay(), 10, 'reconnect_delay');
|
/dports/net/rabbitmq/rabbitmq-server-3.9.11/deps/rabbitmq_federation/src/ |
H A D | rabbit_federation_link_sup.erl | 98 spec(U = #upstream{reconnect_delay = Delay}, #exchange{name = XName}) -> 103 spec(Upstream = #upstream{reconnect_delay = Delay}, Q) when ?is_amqqueue(Q) ->
|
/dports/net/rabbitmq/rabbitmq-server-3.9.11/deps/rabbit/docs/ |
H A D | advanced.config.example | 68 %% {reconnect_delay, 2.5} 79 %% {reconnect_delay, 2.5}]}
|
/dports/net/rabbitmq/rabbitmq-server-3.9.11/deps/rabbitmq_shovel/include/ |
H A D | rabbit_shovel.hrl | 21 reconnect_delay,
|