From edd992857b6cebf32dfff77c20b6864645a346d5 Mon Sep 17 00:00:00 2001 From: Pascal Fischer Date: Wed, 14 Aug 2024 10:46:44 +0200 Subject: [PATCH] add error handling --- signal/server/signal.go | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/signal/server/signal.go b/signal/server/signal.go index 37d7c6e33..69387cc69 100644 --- a/signal/server/signal.go +++ b/signal/server/signal.go @@ -114,7 +114,10 @@ func (s *Server) ConnectStream(stream proto.SignalExchange_ConnectStreamServer) log.Debugf("Received a response from peer [%s] to peer [%s]", msg.Key, msg.RemoteKey) - s.dispatcher.SendMessage(stream.Context(), msg) + _, err = s.dispatcher.SendMessage(stream.Context(), msg) + if err != nil { + log.Debugf("error while sending message from peer [%s] to peer [%s] %v", msg.Key, msg.RemoteKey, err) + } } <-stream.Context().Done()