Skip to content

Commit 2b6b894

Browse files
authored
Add missing unlock (#1450)
1 parent 50361b6 commit 2b6b894

File tree

1 file changed

+1
-6
lines changed

1 file changed

+1
-6
lines changed

aggregator/pkg/server.go

Lines changed: 1 addition & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -99,9 +99,6 @@ func (agg *Aggregator) ProcessOperatorSignedTaskResponseV2(signedTaskResponse *t
9999
*reply = 0
100100
}
101101

102-
agg.AggregatorConfig.BaseConfig.Logger.Info("- Unlocked Resources: Task response processing finished")
103-
agg.taskMutex.Unlock()
104-
105102
return nil
106103
}
107104

@@ -143,11 +140,9 @@ func (agg *Aggregator) ProcessNewSignature(ctx context.Context, taskIndex uint32
143140
func (agg *Aggregator) GetTaskIndex(batchIdentifierHash [32]byte) (uint32, error) {
144141
getTaskIndex_func := func() (uint32, error) {
145142
agg.taskMutex.Lock()
146-
agg.AggregatorConfig.BaseConfig.Logger.Info("- Locked Resources: Starting processing of Response")
147143
taskIndex, ok := agg.batchesIdxByIdentifierHash[batchIdentifierHash]
144+
agg.taskMutex.Unlock()
148145
if !ok {
149-
agg.taskMutex.Unlock()
150-
agg.logger.Info("- Unlocked Resources: Task not found in the internal map")
151146
return taskIndex, fmt.Errorf("Task not found in the internal map")
152147
} else {
153148
return taskIndex, nil

0 commit comments

Comments
 (0)