From 36b2523669253eb7035ee3998547148337c741a2 Mon Sep 17 00:00:00 2001 From: Benjamin Wang Date: Wed, 13 Dec 2023 18:41:22 +0000 Subject: [PATCH] added some log messages for better diagnosis Signed-off-by: Benjamin Wang --- server/etcdserver/bootstrap.go | 4 ++++ server/etcdserver/server.go | 5 ++++- 2 files changed, 8 insertions(+), 1 deletion(-) diff --git a/server/etcdserver/bootstrap.go b/server/etcdserver/bootstrap.go index 466aa549ecd..b9948f30ef5 100644 --- a/server/etcdserver/bootstrap.go +++ b/server/etcdserver/bootstrap.go @@ -90,18 +90,22 @@ func bootstrap(cfg config.ServerConfig) (b *bootstrappedServer, err error) { bwal = bootstrapWALFromSnapshot(cfg, backend.snapshot) } + cfg.Logger.Info("bootstrapping cluster") cluster, err := bootstrapCluster(cfg, bwal, prt) if err != nil { backend.Close() return nil, err } + cfg.Logger.Info("bootstrapping storage") s := bootstrapStorage(cfg, st, backend, bwal, cluster) if err = cluster.Finalize(cfg, s); err != nil { backend.Close() return nil, err } + + cfg.Logger.Info("bootstrapping raft") raft := bootstrapRaft(cfg, cluster, s.wal) return &bootstrappedServer{ prt: prt, diff --git a/server/etcdserver/server.go b/server/etcdserver/server.go index 55b19764958..ac5f0c7ab29 100644 --- a/server/etcdserver/server.go +++ b/server/etcdserver/server.go @@ -298,8 +298,10 @@ type EtcdServer struct { func NewServer(cfg config.ServerConfig) (srv *EtcdServer, err error) { b, err := bootstrap(cfg) if err != nil { + cfg.Logger.Error("bootstrap failed", zap.Error(err)) return nil, err } + cfg.Logger.Info("bootstrap successfully") defer func() { if err != nil { @@ -1975,7 +1977,9 @@ func removeNeedlessRangeReqs(txn *pb.TxnRequest) { // applyConfChange applies a ConfChange to the server. It is only // invoked with a ConfChange that has already passed through Raft func (s *EtcdServer) applyConfChange(cc raftpb.ConfChange, confState *raftpb.ConfState, shouldApplyV3 membership.ShouldApplyV3) (bool, error) { + lg := s.Logger() if err := s.cluster.ValidateConfigurationChange(cc); err != nil { + lg.Error("Validation on configuration change failed", zap.Bool("shouldApplyV3", bool(shouldApplyV3)), zap.Error(err)) cc.NodeID = raft.None s.r.ApplyConfChange(cc) @@ -1988,7 +1992,6 @@ func (s *EtcdServer) applyConfChange(cc raftpb.ConfChange, confState *raftpb.Con return false, err } - lg := s.Logger() *confState = *s.r.ApplyConfChange(cc) s.beHooks.SetConfState(confState) switch cc.Type {