From 585a204f8b4d98de5b7ea16142d48bd2b77e698c Mon Sep 17 00:00:00 2001 From: Philip O'Toole Date: Fri, 21 May 2021 10:12:16 -0400 Subject: [PATCH] Add more startup logging --- cmd/rqlited/main.go | 1 + tcp/mux.go | 1 + 2 files changed, 2 insertions(+) diff --git a/cmd/rqlited/main.go b/cmd/rqlited/main.go index c66fc9d2..e55202dc 100644 --- a/cmd/rqlited/main.go +++ b/cmd/rqlited/main.go @@ -297,6 +297,7 @@ func main() { if err := waitForConsensus(str); err != nil { log.Fatalf(err.Error()) } + log.Println("store has reached consensus") // Create cluster service, so nodes can learn information about each other. clstr, err := clusterService(mux.Listen(cluster.MuxClusterHeader)) diff --git a/tcp/mux.go b/tcp/mux.go index 90c61244..1480a847 100644 --- a/tcp/mux.go +++ b/tcp/mux.go @@ -254,6 +254,7 @@ func (mux *Mux) Listen(header byte) *Layer { if _, ok := mux.m[header]; ok { panic(fmt.Sprintf("listener already registered under header byte: %d", header)) } + mux.Logger.Printf("received handler registration request for header %d", header) // Create a new listener and assign it. ln := &listener{