diff options
| -rw-r--r-- | server/bmp.go | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/server/bmp.go b/server/bmp.go index 27a278bc..bd748ed9 100644 --- a/server/bmp.go +++ b/server/bmp.go @@ -125,6 +125,7 @@ func (w *bmpWatcher) loop() error { buf, _ := i.Serialize() if _, err := newConn.Write(buf); err != nil { log.Warnf("failed to write to bmp server %s", server.host) + go w.tryConnect(server) break } req := &GrpcRequest{ @@ -138,6 +139,7 @@ func (w *bmpWatcher) loop() error { buf, _ = msg.Serialize() if _, err := newConn.Write(buf); err != nil { log.Warnf("failed to write to bmp server %s %s", server.host, err) + go w.tryConnect(server) return err } } |