This commit is contained in:
@@ -104,7 +104,7 @@ func (p *SyncedPool) GrainOwnerChangeHandler(data []byte) (uint32, []byte, error
|
||||
|
||||
for _, r := range p.remotes {
|
||||
if r.Host == host {
|
||||
log.Printf("Remote grain %s changed to %s\n", id, host)
|
||||
// log.Printf("Remote grain %s changed to %s\n", id, host)
|
||||
p.mu.Lock()
|
||||
if p.local.grains[id] != nil {
|
||||
log.Printf("Grain %s already exists locally, deleting\n", id)
|
||||
@@ -112,7 +112,7 @@ func (p *SyncedPool) GrainOwnerChangeHandler(data []byte) (uint32, []byte, error
|
||||
}
|
||||
grain, err := NewRemoteGrain(id, r.Host)
|
||||
if err != nil {
|
||||
log.Printf("Error creating remote grain %s: %v\n", id, err)
|
||||
log.Printf("Owner change failed %s: %v\n", id, err)
|
||||
return AckChange, []byte("error"), nil
|
||||
}
|
||||
p.remoteIndex[id] = grain
|
||||
|
||||
Reference in New Issue
Block a user