0ct0pu5/moby
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

Merge pull request #580 from mavenugo/discovery

Browse source 
serfJoin doesnt happen if self notification comes later
This commit is contained in:
aboch 2015-10-01 23:27:18 -07:00
commit add63f4247
2 changed files with 15 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
libnetwork/drivers/overlay/ov_serf.go
View file

@ -68,13 +68,13 @@ func (d *driver) serfInit() error {
return nil
}
func (d *driver) serfJoin() error {
if d.neighIP == "" {
func (d *driver) serfJoin(neighIP string) error {
if neighIP == "" {
return fmt.Errorf("no neighbor to join")
}
if _, err := d.serfInstance.Join([]string{d.neighIP}, false); err != nil {
if _, err := d.serfInstance.Join([]string{neighIP}, false); err != nil {
return fmt.Errorf("Failed to join the cluster at neigh IP %s: %v",
d.neighIP, err)
neighIP, err)
}
return nil
}

18
libnetwork/drivers/overlay/overlay.go
View file

@ -152,7 +152,7 @@ func (d *driver) Type() string {
}
func (d *driver) nodeJoin(node string, self bool) {
if self && node != "" && !d.isSerfAlive() {
if self && !d.isSerfAlive() {
d.Lock()
d.bindAddress = node
d.Unlock()
@ -163,13 +163,17 @@ func (d *driver) nodeJoin(node string, self bool) {
}
}
if d.serfInstance != nil && !self && node != "" {
d.Lock()
if !self {
d.neighIP = node
}
neighIP := d.neighIP
d.Unlock()
if d.serfInstance != nil && neighIP != "" {
var err error
d.joinOnce.Do(func() {
d.Lock()
d.neighIP = node
d.Unlock()
err = d.serfJoin()
err = d.serfJoin(neighIP)
})
if err != nil {
logrus.Errorf("joining serf neighbor %s failed: %v", node, err)
@ -185,7 +189,7 @@ func (d *driver) nodeJoin(node string, self bool) {
func (d *driver) DiscoverNew(dType driverapi.DiscoveryType, data interface{}) error {
if dType == driverapi.NodeDiscovery {
nodeData, ok := data.(driverapi.NodeDiscoveryData)
if !ok {
if !ok || nodeData.Address == "" {
return fmt.Errorf("invalid discovery data")
}
d.nodeJoin(nodeData.Address, nodeData.Self)