Browse Source

etcdserver: fix sender logging

Xiang Li 11 years ago
parent
commit
0f8b035253
1 changed files with 6 additions and 4 deletions
  1. 6 4
      etcdserver/sender.go

+ 6 - 4
etcdserver/sender.go

@@ -55,10 +55,12 @@ func send(c *http.Client, cl *Cluster, m raftpb.Message, ss *stats.ServerStats,
 	for i := 0; i < 3; i++ {
 	for i := 0; i < 3; i++ {
 		memb := cl.Member(m.To)
 		memb := cl.Member(m.To)
 		if memb == nil {
 		if memb == nil {
-			// TODO: unknown peer id.. what do we do? I
-			// don't think his should ever happen, need to
-			// look into this further.
-			log.Printf("etcdhttp: no member for %s", strutil.IDAsHex(m.To))
+			if !cl.IsIDRemoved(m.To) {
+				// TODO: unknown peer id.. what do we do? I
+				// don't think his should ever happen, need to
+				// look into this further.
+				log.Printf("etcdhttp: error sending message to unknown receiver %s", strutil.IDAsHex(m.To))
+			}
 			return
 			return
 		}
 		}
 		u := fmt.Sprintf("%s%s", memb.PickPeerURL(), raftPrefix)
 		u := fmt.Sprintf("%s%s", memb.PickPeerURL(), raftPrefix)