diff --git a/synced-pool.go b/synced-pool.go index 38bf8e4..3036c92 100644 --- a/synced-pool.go +++ b/synced-pool.go @@ -407,6 +407,7 @@ func (p *SyncedPool) AddRemote(host string) error { } func (p *SyncedPool) getGrain(id CartId) (Grain, error) { + var err error localGrain, ok := p.local.grains[id] if !ok { // check if remote grain exists @@ -418,11 +419,11 @@ func (p *SyncedPool) getGrain(id CartId) (Grain, error) { return remoteGrain, nil } - err := p.RequestOwnership(id) - if err != nil { - log.Printf("Error requesting ownership: %v\n", err) - return nil, err - } + go p.RequestOwnership(id) + // if err != nil { + // log.Printf("Error requesting ownership: %v\n", err) + // return nil, err + // } localGrain, err = p.local.GetGrain(id) if err != nil {