bmp: try to reconnect after write failure

Signed-off-by: FUJITA Tomonori <fujita.tomonori@lab.ntt.co.jp>

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
 						}
 					}