This commit is contained in:
@@ -53,49 +53,50 @@ func NewSyncedPool(local *GrainLocalPool, hostname string, d Discovery) (*Synced
|
||||
remoteIndex: make(map[CartId]*RemoteGrainPool),
|
||||
}
|
||||
|
||||
go func(pingTimer *time.Ticker) {
|
||||
go func() {
|
||||
for {
|
||||
<-pingTimer.C
|
||||
for _, r := range pool.remotes {
|
||||
err := DoPing(r)
|
||||
if err != nil {
|
||||
r.MissedPings++
|
||||
log.Printf("Error pinging remote %s: %v\n, missed pings: %d", r.Host, err, r.MissedPings)
|
||||
if r.MissedPings > 3 {
|
||||
log.Printf("Removing remote %s\n", r.Host)
|
||||
go pool.RemoveHost(r)
|
||||
//pool.remotes = append(pool.remotes[:i], pool.remotes[i+1:]...)
|
||||
for range time.Tick(time.Second * 2) {
|
||||
for _, r := range pool.remotes {
|
||||
err := DoPing(r)
|
||||
if err != nil {
|
||||
r.MissedPings++
|
||||
log.Printf("Error pinging remote %s: %v\n, missed pings: %d", r.Host, err, r.MissedPings)
|
||||
if r.MissedPings > 3 {
|
||||
log.Printf("Removing remote %s\n", r.Host)
|
||||
go pool.RemoveHost(r)
|
||||
//pool.remotes = append(pool.remotes[:i], pool.remotes[i+1:]...)
|
||||
|
||||
}
|
||||
} else {
|
||||
r.MissedPings = 0
|
||||
}
|
||||
} else {
|
||||
r.MissedPings = 0
|
||||
}
|
||||
connectedRemotes.Set(float64(len(pool.remotes)))
|
||||
}
|
||||
connectedRemotes.Set(float64(len(pool.remotes)))
|
||||
}
|
||||
}(time.NewTicker(time.Second))
|
||||
}()
|
||||
|
||||
if d != nil {
|
||||
go func(discoveryTimer *time.Ticker) {
|
||||
<-discoveryTimer.C
|
||||
log.Printf("Looking for new nodes")
|
||||
hosts, err := d.Discover()
|
||||
if err != nil {
|
||||
log.Printf("Error discovering hosts: %v", err)
|
||||
}
|
||||
for _, h := range hosts {
|
||||
if h == hostname {
|
||||
continue
|
||||
}
|
||||
log.Printf("Discovered host %s", h)
|
||||
|
||||
err := pool.AddRemote(h)
|
||||
go func() {
|
||||
for range time.Tick(time.Second * 5) {
|
||||
log.Printf("Looking for new nodes")
|
||||
hosts, err := d.Discover()
|
||||
if err != nil {
|
||||
log.Printf("Error adding remote %s: %v", h, err)
|
||||
log.Printf("Error discovering hosts: %v", err)
|
||||
}
|
||||
for _, h := range hosts {
|
||||
if h == hostname {
|
||||
continue
|
||||
}
|
||||
log.Printf("Discovered host %s", h)
|
||||
|
||||
err := pool.AddRemote(h)
|
||||
if err != nil {
|
||||
log.Printf("Error adding remote %s: %v", h, err)
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
}(time.NewTicker(time.Second * 5))
|
||||
}()
|
||||
} else {
|
||||
log.Printf("No discovery, waiting for remotes to connect")
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user