Skip to content

Commit 69c20b8

Browse files
committed
Remove locking from router where to forward since hasher is now thread-safe
1 parent 1f1e2f9 commit 69c20b8

File tree

1 file changed

+0
-8
lines changed

1 file changed

+0
-8
lines changed

pkg/router/epoch.go

-8
Original file line numberDiff line numberDiff line change
@@ -68,14 +68,6 @@ func (e *epochManager) addRequestToCurrentEpoch(r *request) chan any {
6868
}
6969

7070
func (e *epochManager) whereToForward(block string) (shardNodeID int) {
71-
log.Debug().Msgf("Aquiring lock for epoch manager in whereToForward")
72-
e.mu.Lock()
73-
log.Debug().Msgf("Aquired lock for epoch manager in whereToForward")
74-
defer func() {
75-
log.Debug().Msgf("Releasing lock for epoch manager in whereToForward")
76-
e.mu.Unlock()
77-
log.Debug().Msgf("Released lock for epoch manager in whereToForward")
78-
}()
7971
h := e.hasher.Hash(block)
8072
return int(math.Mod(float64(h), float64(len(e.shardNodeRPCClients))))
8173
}

0 commit comments

Comments
 (0)