remove locks

deployment/deployment.yaml

@@ -6,7 +6,7 @@ metadata:
     arch: amd64
   name: cart-actor-x86
 spec:
-  replicas: 0
+  replicas: 3
   selector:
     matchLabels:
       app: cart-actor
@@ -92,7 +92,7 @@ metadata:
     arch: arm64
   name: cart-actor-arm64
 spec:
-  replicas: 3
+  replicas: 0
   selector:
     matchLabels:
       app: cart-actor

grain-pool.go

@@ -115,8 +115,8 @@ func (p *GrainLocalPool) GetGrains() map[CartId]*CartGrain {
 
 func (p *GrainLocalPool) GetGrain(id CartId) (*CartGrain, error) {
 	var err error
-	p.mu.RLock()
-	defer p.mu.RUnlock()
+	// p.mu.RLock()
+	// defer p.mu.RUnlock()
 	grain, ok := p.grains[id]
 	grainLookups.Inc()
 	if grain == nil || !ok {

synced-pool.go

@@ -320,8 +320,8 @@ func (p *SyncedPool) Negotiate() {
 }
 
 func (p *SyncedPool) GetHealthyRemotes() []*RemoteHost {
-	p.mu.RLock()
-	defer p.mu.RUnlock()
+	// p.mu.RLock()
+	// defer p.mu.RUnlock()
 	remotes := make([]*RemoteHost, 0, len(p.remotes))
 	for _, r := range p.remotes {
 		if r.IsHealthy() {
@@ -422,12 +422,14 @@ func (p *SyncedPool) AddRemote(host string) error {
 
 func (p *SyncedPool) getGrain(id CartId) (Grain, error) {
 	var err error
+	p.mu.RLock()
+	defer p.mu.RUnlock()
 	localGrain, ok := p.local.grains[id]
 	if !ok {
 		// check if remote grain exists
-		p.mu.RLock()
+
 		remoteGrain, ok := p.remoteIndex[id]
-		p.mu.RUnlock()
+
 		if ok {
 			remoteLookupCount.Inc()
 			return remoteGrain, nil