consul: Leave does a RemovePeer RPC call

2013-12-09 15:01:42 -08:00 · 2013-12-09 15:01:42 -08:00 · 500927cbb1
parent e699a14fe3
commit 500927cbb1
1 changed files with 4 additions and 5 deletions
--- a/consul/server.go
+++ b/consul/server.go
@ -293,13 +293,12 @@ func (s *Server) Leave() error {
 		}

 		// Request that we are removed
-		// TODO: Properly forward to leader
-		future := s.raft.RemovePeer(s.rpcListener.Addr())
-
-		// Wait for the future
 		ch := make(chan error, 1)
 		go func() {
-			ch <- future.Error()
+			var out struct{}
+			peer := s.rpcListener.Addr().String()
+			err := s.connPool.RPC(leader, "Raft.RemovePeer", peer, &out)
+			ch <- err
 		}()

 		// Wait for the commit