add reconnect into cycle

subsan · Mar 14, 2023 · 2707aef · 2707aef
1 parent d3485bd
commit 2707aef
Showing 1 changed file with 7 additions and 5 deletions.
diff --git a/pkg/connector/listener.go b/pkg/connector/listener.go
@@ -42,17 +42,19 @@ func disconnect() {
 }
 
 func reconnect() {
-	time.Sleep(config.Config.Timeout.Reconnect)
-	log.Printf(" [  ] [connector] try reconnect")
-	disconnect()
-	connect()
+	for !isConnected {
+		time.Sleep(config.Config.Timeout.Reconnect)
+		log.Printf(" [  ] [connector] try reconnect")
+		disconnect()
+		connect()
+	}
 }
 
 func Listener(address string) {
 	connectionAddress = address
 	connect()
 
-	for !isConnected {
+	if !isConnected {
 		reconnect()
 	}