From 990cbb33b7eb0d7343aa7b16bb118f4f7864cc33 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Toni=20Ram=C3=ADrez?= Date: Tue, 4 Feb 2025 09:20:36 +0100 Subject: [PATCH 1/2] fix: witness loop --- aggregator/aggregator.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/aggregator/aggregator.go b/aggregator/aggregator.go index a817320ce..ed5acc0e0 100644 --- a/aggregator/aggregator.go +++ b/aggregator/aggregator.go @@ -1215,7 +1215,8 @@ func (a *Aggregator) getAndLockBatchToProve( // Request the witness from the server, if it is busy just keep looping until it is available start := time.Now() - witness, err := a.rpcClient.GetWitness(batchNumberToVerify, a.cfg.UseFullWitness) + var witness []byte + witness, err = a.rpcClient.GetWitness(batchNumberToVerify, a.cfg.UseFullWitness) for err != nil { if errors.Is(err, rpc.ErrBusy) { a.logger.Debugf( @@ -1226,6 +1227,7 @@ func (a *Aggregator) getAndLockBatchToProve( a.logger.Errorf("Failed to get witness for batch %d, err: %v", batchNumberToVerify, err) } time.Sleep(a.cfg.RetryTime.Duration) + witness, err = a.rpcClient.GetWitness(batchNumberToVerify, a.cfg.UseFullWitness) } end := time.Now() a.logger.Debugf("Time to get witness for batch %d: %v", batchNumberToVerify, end.Sub(start)) From 1fae0a955f6b99c94206ee8c5c16ff18eabaa163 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Toni=20Ram=C3=ADrez?= Date: Tue, 4 Feb 2025 09:23:44 +0100 Subject: [PATCH 2/2] fix: witness loop --- aggregator/aggregator.go | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/aggregator/aggregator.go b/aggregator/aggregator.go index ed5acc0e0..9ff6dc28e 100644 --- a/aggregator/aggregator.go +++ b/aggregator/aggregator.go @@ -1215,8 +1215,7 @@ func (a *Aggregator) getAndLockBatchToProve( // Request the witness from the server, if it is busy just keep looping until it is available start := time.Now() - var witness []byte - witness, err = a.rpcClient.GetWitness(batchNumberToVerify, a.cfg.UseFullWitness) + witness, err := a.rpcClient.GetWitness(batchNumberToVerify, a.cfg.UseFullWitness) for err != nil { if errors.Is(err, rpc.ErrBusy) { a.logger.Debugf(