exponential delay for reconnect
This commit is contained in:
parent
ea9fc18c15
commit
49f206eab3
1 changed files with 2 additions and 2 deletions
|
|
@ -35,7 +35,7 @@ class Relay:
|
||||||
self.reconnect: bool = True
|
self.reconnect: bool = True
|
||||||
self.shutdown: bool = False
|
self.shutdown: bool = False
|
||||||
self.error_counter: int = 0
|
self.error_counter: int = 0
|
||||||
self.error_threshold: int = 0
|
self.error_threshold: int = 100
|
||||||
self.num_received_events: int = 0
|
self.num_received_events: int = 0
|
||||||
self.num_sent_events: int = 0
|
self.num_sent_events: int = 0
|
||||||
self.num_subscriptions: int = 0
|
self.num_subscriptions: int = 0
|
||||||
|
|
@ -76,7 +76,7 @@ class Relay:
|
||||||
pass
|
pass
|
||||||
self.connected = False
|
self.connected = False
|
||||||
if self.reconnect:
|
if self.reconnect:
|
||||||
time.sleep(1)
|
time.sleep(self.error_counter**2)
|
||||||
self.connect(self.ssl_options, self.proxy)
|
self.connect(self.ssl_options, self.proxy)
|
||||||
|
|
||||||
@property
|
@property
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue