diff --git a/client/internal/peer/handshaker.go b/client/internal/peer/handshaker.go index 03d1803e7..91b573515 100644 --- a/client/internal/peer/handshaker.go +++ b/client/internal/peer/handshaker.go @@ -94,7 +94,9 @@ func (h *Handshaker) Listen(ctx context.Context) { for _, listener := range h.onNewOfferListeners { listener(&remoteOfferAnswer) } + h.log.Infof("received offer, running version %s, remote WireGuard listen port %d, session id: %s", remoteOfferAnswer.Version, remoteOfferAnswer.WgListenPort, remoteOfferAnswer.SessionIDString()) case remoteOfferAnswer := <-h.remoteAnswerCh: + h.log.Infof("received answer, running version %s, remote WireGuard listen port %d, session id: %s", remoteOfferAnswer.Version, remoteOfferAnswer.WgListenPort, remoteOfferAnswer.SessionIDString()) for _, listener := range h.onNewOfferListeners { listener(&remoteOfferAnswer) } diff --git a/client/internal/peer/worker_ice.go b/client/internal/peer/worker_ice.go index ef4354795..606f20aa1 100644 --- a/client/internal/peer/worker_ice.go +++ b/client/internal/peer/worker_ice.go @@ -107,6 +107,7 @@ func (w *WorkerICE) OnNewOffer(remoteOfferAnswer *OfferAnswer) { return } if w.remoteSessionID == *remoteOfferAnswer.SessionID { + w.log.Debugf("agent already exists and session ID matches, skipping the offer: %s", remoteOfferAnswer.SessionIDString()) w.muxAgent.Unlock() return }