|
52 | 52 | rtyAttNum = uint(5)
|
53 | 53 | rtyAtt = retry.Attempts(rtyAttNum)
|
54 | 54 | rtyDel = retry.Delay(time.Millisecond * 400)
|
55 |
| - memPoolDel = retry.Delay(time.Second * 30) |
| 55 | + specialDel = retry.Delay(time.Second * 30) |
56 | 56 | rtyErr = retry.LastErrorOnly(true)
|
57 | 57 | numRegex = regexp.MustCompile("[0-9]+")
|
58 | 58 | defaultBroadcastWaitTimeout = 10 * time.Minute
|
@@ -835,20 +835,15 @@ func (ap *WasmProvider) SendMessagesToMempool(
|
835 | 835 | }
|
836 | 836 |
|
837 | 837 | if msg.Type() == MethodUpdateClient {
|
838 |
| - delay := retry.Delay(time.Millisecond * time.Duration(ap.PCfg.BlockInterval)) |
839 |
| - retryAttempt := rtyAtt |
840 | 838 | if err := retry.Do(func() error {
|
841 | 839 | if err := ap.BroadcastTx(cliCtx, txBytes, []provider.RelayerMessage{msg}, asyncCtx, defaultBroadcastWaitTimeout, asyncCallback, true); err != nil {
|
| 840 | + ap.log.Error("Failed to update client", zap.Any("Message", msg), zap.Error(err)) |
842 | 841 | if strings.Contains(err.Error(), sdkerrors.ErrWrongSequence.Error()) {
|
843 | 842 | ap.handleAccountSequenceMismatchError(err)
|
844 |
| - } else if strings.Contains(err.Error(), sdkerrors.ErrMempoolIsFull.Error()) { |
845 |
| - ap.log.Info("Mempool is full, retrying later with increased delay") |
846 |
| - delay = memPoolDel |
847 |
| - retryAttempt = retry.Attempts(0) |
848 | 843 | }
|
849 | 844 | }
|
850 | 845 | return err
|
851 |
| - }, retry.Context(ctx), retryAttempt, delay, rtyErr); err != nil { |
| 846 | + }, retry.Context(ctx), retry.Attempts(0), specialDel, rtyErr); err != nil { |
852 | 847 | ap.log.Error("Failed to update client", zap.Any("Message", msg))
|
853 | 848 | return err
|
854 | 849 | }
|
|
0 commit comments