diff --git a/internal/db/messages.go b/internal/db/messages.go index 8c22e6b4b4..6a581d9796 100644 --- a/internal/db/messages.go +++ b/internal/db/messages.go @@ -75,6 +75,7 @@ func (db *db) handleMessages(ctx context.Context, sub *event.Subscription) { } }) go onceReps.Do(func() { + log.Info("Loading replicators") err := db.loadAndPublishReplicators(ctx) if err != nil { log.ErrorContextE(ctx, "Failed to load replicators", err) diff --git a/net/server.go b/net/server.go index 3b4922fe5e..72a92eb27e 100644 --- a/net/server.go +++ b/net/server.go @@ -358,6 +358,7 @@ func (s *server) updateReplicators(evt event.Replicator) { if evt.Docs != nil { for update := range evt.Docs { + log.Info("Replicator update", corelog.Any("to peer", evt.Info.ID)) if err := s.pushLog(s.peer.ctx, update, evt.Info.ID); err != nil { log.ErrorContextE( s.peer.ctx,