Mirroristas/etcd
2
0
Fork 0
mirror of https://github.com/etcd-io/etcd.git synced 2024-09-27 06:25:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #1660 from yichengq/209

Browse Source 
etcdserver: not add sender when it has existed
This commit is contained in:
Yicheng Qin 2014-11-07 16:10:50 -08:00
commit 2fc47034ee
2 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
etcdserver/sender.go
View File

@ -92,6 +92,9 @@ func (h *sendHub) Stop() {
}
func (h *sendHub) Add(m *Member) {
if _, ok := h.senders[m.ID]; ok {
return
}
// TODO: considering how to switch between all available peer urls
u := fmt.Sprintf("%s%s", m.PickPeerURL(), raftPrefix)
c := &http.Client{Transport: h.tr}

6
etcdserver/sender_test.go
View File

@ -61,6 +61,12 @@ func TestSendHubAdd(t *testing.T) {
if s.u != "http://a/raft" {
t.Errorf("url = %s, want %s", s.u, "http://a/raft")
}
h.Add(m)
ns := h.senders[types.ID(1)]
if s != ns {
t.Errorf("sender = %p, want %p", ns, s)
}
}
func TestSendHubRemove(t *testing.T) {