1
0
Fork 0

Add more startup logging

master
Philip O'Toole 3 years ago
parent a6646d18a7
commit 585a204f8b

@ -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))

@ -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{

Loading…
Cancel
Save