|
8 | 8 | "encoding/json" |
9 | 9 | "fmt" |
10 | 10 | "log" |
| 11 | + "math/big" |
11 | 12 | "os" |
12 | 13 | "sync" |
13 | 14 | "time" |
@@ -347,10 +348,18 @@ func (o *Operator) ProcessNewBatchLogV2(newBatchLog *servicemanager.ContractAlig |
347 | 348 | results := make(chan bool, verificationDataBatchLen) |
348 | 349 | var wg sync.WaitGroup |
349 | 350 | wg.Add(verificationDataBatchLen) |
| 351 | + |
| 352 | + disabledVerifiersBitmap, err := o.avsReader.DisabledVerifiers() |
| 353 | + if err != nil { |
| 354 | + o.Logger.Errorf("Could not check verifiers status: %s", err) |
| 355 | + results <- false |
| 356 | + return err |
| 357 | + } |
| 358 | + |
350 | 359 | for _, verificationData := range verificationDataBatch { |
351 | 360 | go func(data VerificationData) { |
352 | 361 | defer wg.Done() |
353 | | - o.verify(data, results) |
| 362 | + o.verify(data, disabledVerifiersBitmap, results) |
354 | 363 | o.metrics.IncOperatorTaskResponses() |
355 | 364 | }(verificationData) |
356 | 365 | } |
@@ -420,10 +429,16 @@ func (o *Operator) ProcessNewBatchLogV3(newBatchLog *servicemanager.ContractAlig |
420 | 429 | results := make(chan bool, verificationDataBatchLen) |
421 | 430 | var wg sync.WaitGroup |
422 | 431 | wg.Add(verificationDataBatchLen) |
| 432 | + disabledVerifiersBitmap, err := o.avsReader.DisabledVerifiers() |
| 433 | + if err != nil { |
| 434 | + o.Logger.Errorf("Could not check verifiers status: %s", err) |
| 435 | + results <- false |
| 436 | + return err |
| 437 | + } |
423 | 438 | for _, verificationData := range verificationDataBatch { |
424 | 439 | go func(data VerificationData) { |
425 | 440 | defer wg.Done() |
426 | | - o.verify(data, results) |
| 441 | + o.verify(data, disabledVerifiersBitmap, results) |
427 | 442 | o.metrics.IncOperatorTaskResponses() |
428 | 443 | }(verificationData) |
429 | 444 | } |
@@ -454,13 +469,7 @@ func (o *Operator) afterHandlingBatchV3(log *servicemanager.ContractAlignedLayer |
454 | 469 | } |
455 | 470 | } |
456 | 471 |
|
457 | | -func (o *Operator) verify(verificationData VerificationData, results chan bool) { |
458 | | - disabledVerifiersBitmap, err := o.avsReader.DisabledVerifiers() |
459 | | - if err != nil { |
460 | | - o.Logger.Errorf("Could not check verifier status: %s", err) |
461 | | - results <- false |
462 | | - return |
463 | | - } |
| 472 | +func (o *Operator) verify(verificationData VerificationData, disabledVerifiersBitmap *big.Int, results chan bool) { |
464 | 473 | IsVerifierDisabled := IsVerifierDisabled(disabledVerifiersBitmap, verificationData.ProvingSystemId) |
465 | 474 | if IsVerifierDisabled { |
466 | 475 | o.Logger.Infof("Verifier %s is disbled. Skipping verifie", verificationData.ProvingSystemId.String()) |
|
0 commit comments