Home
last modified time | relevance | path

Searched refs:reconnect_delay (Results 1 – 25 of 121) sorted by relevance

12345

/dports/www/domoticz/domoticz-2020.2/extern/mosquitto/lib/
H A Dloop.c198 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 Doptions.c105 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 Dloop.c194 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 Doptions.c113 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 Dfritzmonitor.py129 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 Drabbit_shovel_config.erl42 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 Djanus_wsevh.c166 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 Drabbitmq_upstream.py50 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 Dscsi_transport_srp.c86 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 Dscsi_transport_srp.c86 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 Dscsi_transport_srp.c86 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 Dscsi_transport_srp.h67 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 Dscsi_transport_srp.h67 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 Dscsi_transport_srp.h67 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 Dnode.py122 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__.py49 reconnect_delay=RECONNECT_DELAY,
71 reconnect_delay=RECONNECT_DELAY,
H A Dmesh_connection.py187 reconnect_delay=RECONNECT_DELAY, argument
234 reconnect_delay=reconnect_delay,
/dports/www/websocat/websocat-1.9.0/src/
H A Dreconnect_peer.rs62 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 Dtest_fritzmonitor.py233 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 Dasyncio_consumer_example.py420 reconnect_delay = self._get_reconnect_delay()
421 LOGGER.info('Reconnecting after %d seconds', reconnect_delay)
422 time.sleep(reconnect_delay)
H A Dasynchronous_consumer_example.py416 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 D02_Config.t44 is($c->reconnect_delay(), 10, 'reconnect_delay');
/dports/net/rabbitmq/rabbitmq-server-3.9.11/deps/rabbitmq_federation/src/
H A Drabbit_federation_link_sup.erl98 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 Dadvanced.config.example68 %% {reconnect_delay, 2.5}
79 %% {reconnect_delay, 2.5}]}
/dports/net/rabbitmq/rabbitmq-server-3.9.11/deps/rabbitmq_shovel/include/
H A Drabbit_shovel.hrl21 reconnect_delay,

12345