diff --git a/synced-pool.go b/synced-pool.go index 0bd2ba2..2ab019d 100644 --- a/synced-pool.go +++ b/synced-pool.go @@ -384,10 +384,13 @@ func (p *SyncedPool) getGrainPool(id CartId) (GrainPool, error) { remoteLookupCount.Inc() return remotePool, nil } - err := p.RequestOwnership(id) - if err != nil { - return nil, err + if !ok { + err := p.RequestOwnership(id) + if err != nil { + return nil, err + } } + } return p.local, nil }