kemko/nomad
1
0
Fork 0
mirror of https://github.com/kemko/nomad.git synced 2026-01-08 11:25:41 +03:00
Code Issues Packages Projects Releases Wiki Activity

Rename mergedNomadMap to mergedPrimaryMap. Gratuitous, but more correct.

Browse Source
This commit is contained in:
Sean Chittenden
2016-05-26 13:28:45 -07:00
parent 71dde1b584
commit bc94ce8aa6
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
client/rpc_proxy/rpc_proxy.go
View File

@@ -651,10 +651,10 @@ func (p *RpcProxy) UpdateFromNodeUpdateResponse(resp *structs.NodeUpdateResponse
// 'n' == new
state byte
}
mergedNomadMap := make(map[EndpointKey]*targetServer, len(p.primaryServers.L)+len(resp.Servers))
mergedPrimaryMap := make(map[EndpointKey]*targetServer, len(p.primaryServers.L)+len(resp.Servers))
numOldServers := 0
for _, s := range p.primaryServers.L {
mergedNomadMap[*s.Key()] = &targetServer{server: s, state: 'o'}
mergedPrimaryMap[*s.Key()] = &targetServer{server: s, state: 'o'}
numOldServers++
}
numBothServers := 0
@@ -685,12 +685,12 @@ func (p *RpcProxy) UpdateFromNodeUpdateResponse(resp *structs.NodeUpdateResponse
}
k := server.Key()
_, found := mergedNomadMap[*k]
_, found := mergedPrimaryMap[*k]
if found {
mergedNomadMap[*k].state = 'b'
mergedPrimaryMap[*k].state = 'b'
numBothServers++
} else {
mergedNomadMap[*k] = &targetServer{server: server, state: 'n'}
mergedPrimaryMap[*k] = &targetServer{server: server, state: 'n'}
newServers = true
}
}
@@ -703,7 +703,7 @@ func (p *RpcProxy) UpdateFromNodeUpdateResponse(resp *structs.NodeUpdateResponse
p.listLock.Lock()
defer p.listLock.Unlock()
newServerCfg := p.getServerList()
for k, v := range mergedNomadMap {
for k, v := range mergedPrimaryMap {
switch v.state {
case 'b':
// Do nothing, server exists in both