This commit is contained in:
@@ -107,7 +107,7 @@ func (p *RemoteGrainPool) findRemoteGrain(id CartId) *RemoteGrain {
|
|||||||
p.mu.RLock()
|
p.mu.RLock()
|
||||||
grain, ok := p.grains[id]
|
grain, ok := p.grains[id]
|
||||||
p.mu.RUnlock()
|
p.mu.RUnlock()
|
||||||
if !ok {
|
if !ok || grain == nil {
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
grain.Connect()
|
grain.Connect()
|
||||||
|
|||||||
Reference in New Issue
Block a user