From 2dceb5345b62fc751d5bfeaa066c45f705ac3e39 Mon Sep 17 00:00:00 2001 From: Armon Dadgar Date: Sun, 7 Jun 2015 11:32:01 -0700 Subject: [PATCH] nomad: track local peers --- nomad/server.go | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/nomad/server.go b/nomad/server.go index 697b9b9dc..399fb8993 100644 --- a/nomad/server.go +++ b/nomad/server.go @@ -65,8 +65,9 @@ type Server struct { // peers is used to track the known Nomad servers. This is // used for region forwarding and clustering. - peers map[string][]*serverParts - peerLock sync.RWMutex + peers map[string][]*serverParts + localPeers map[string]*serverParts + peerLock sync.RWMutex // serf is the Serf cluster containing only Nomad // servers. This is used for multi-region federation @@ -114,6 +115,7 @@ func NewServer(config *Config) (*Server, error) { logger: logger, rpcServer: rpc.NewServer(), peers: make(map[string][]*serverParts), + localPeers: make(map[string]*serverParts), reconcileCh: make(chan serf.Member, 32), eventCh: make(chan serf.Event, 256), shutdownCh: make(chan struct{}),