Browse Source

Merge pull request #1474 from jonboulle/1474_print_peers

print out remote peers' information and config change in the cluster
Jonathan Boulle 11 years ago
parent
commit
a6ba4d357c
2 changed files with 5 additions and 3 deletions
  1. 0 1
      etcdserver/etcdhttp/client.go
  2. 5 2
      etcdserver/server.go

+ 0 - 1
etcdserver/etcdhttp/client.go

@@ -223,7 +223,6 @@ func (h *membersHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
 			log.Printf("etcdhttp: error removing node %s: %v", id, err)
 			log.Printf("etcdhttp: error removing node %s: %v", id, err)
 			writeError(w, err)
 			writeError(w, err)
 		default:
 		default:
-			log.Printf("etcdhttp: removed node %x", id)
 			w.WriteHeader(http.StatusNoContent)
 			w.WriteHeader(http.StatusNoContent)
 		}
 		}
 	}
 	}

+ 5 - 2
etcdserver/server.go

@@ -235,6 +235,9 @@ func NewServer(cfg *ServerConfig) (*EtcdServer, error) {
 			index = snapshot.Index
 			index = snapshot.Index
 		}
 		}
 		cfg.Cluster = NewClusterFromStore(cfg.Cluster.token, st)
 		cfg.Cluster = NewClusterFromStore(cfg.Cluster.token, st)
+		if snapshot != nil {
+			log.Printf("etcdserver: loaded peers from snapshot: %s", cfg.Cluster)
+		}
 		if !cfg.ForceNewCluster {
 		if !cfg.ForceNewCluster {
 			id, n, w = restartNode(cfg, index, snapshot)
 			id, n, w = restartNode(cfg, index, snapshot)
 		} else {
 		} else {
@@ -663,12 +666,12 @@ func (s *EtcdServer) applyConfChange(cc raftpb.ConfChange) error {
 		}
 		}
 		s.Cluster.AddMember(m)
 		s.Cluster.AddMember(m)
 		s.sender.Add(m)
 		s.sender.Add(m)
-		log.Printf("etcdserver: added node %s to cluster", types.ID(cc.NodeID))
+		log.Printf("etcdserver: added node %s %v to cluster %s", types.ID(cc.NodeID), m.PeerURLs, s.Cluster.ID())
 	case raftpb.ConfChangeRemoveNode:
 	case raftpb.ConfChangeRemoveNode:
 		id := types.ID(cc.NodeID)
 		id := types.ID(cc.NodeID)
 		s.Cluster.RemoveMember(id)
 		s.Cluster.RemoveMember(id)
 		s.sender.Remove(id)
 		s.sender.Remove(id)
-		log.Printf("etcdserver: removed node %s from cluster", id)
+		log.Printf("etcdserver: removed node %s from cluster %s", id, s.Cluster.ID())
 	}
 	}
 	return nil
 	return nil
 }
 }