diff --git a/synced-pool.go b/synced-pool.go index 193276b..b55719e 100644 --- a/synced-pool.go +++ b/synced-pool.go @@ -443,9 +443,9 @@ func (p *SyncedPool) getGrain(id CartId, requestOwnership bool) (Grain, error) { remoteLookupCount.Inc() return remoteGrain, nil } - if requestOwnership { - go p.RequestOwnership(id) - } + + go p.RequestOwnership(id) + localGrain, err = p.local.GetGrain(id) if err != nil { return nil, err @@ -478,10 +478,5 @@ func (p *SyncedPool) Get(id CartId) (*CallResult, error) { if remoteGrain, ok := grain.(*RemoteGrain); ok { return remoteGrain.GetCurrentState() } - if localGrain, ok := grain.(*CartGrain); ok { - if len(localGrain.storageMessages) > 0 { - go p.RequestOwnership(id) - } - } return grain.GetCurrentState() }