Commit ced3ff40 authored by kingwang's avatar kingwang Committed by vipwzw

add ignore

parent c439d62e
......@@ -3,8 +3,8 @@ package para
import (
"bytes"
"context"
"fmt"
"sync/atomic"
"time"
"sync"
......@@ -60,10 +60,10 @@ func (mem *Mempool) SetQueueClient(client queue.Client) {
msg.Reply(client.NewMessage(mem.key, types.EventReply, &types.Reply{IsOk: true, Msg: reply.GetMsg()}))
break
} else if err != nil && i != retry_times-1 {
time.Sleep(time.Millisecond * 10)
continue
} else {
msg.Reply(client.NewMessage(mem.key, types.EventReply, &types.Reply{IsOk: false,
Msg: []byte(fmt.Sprintf("Send transaction to main chain failed, %v", err))}))
msg.Reply(client.NewMessage(mem.key, types.EventReply, err))
}
}
}
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment