Commit 54d53dfc authored by vipwzw's avatar vipwzw Committed by 33cn

Update executor.go

parent 8e1ed91a
...@@ -238,6 +238,10 @@ func (exec *Executor) procExecTxList(msg queue.Message) { ...@@ -238,6 +238,10 @@ func (exec *Executor) procExecTxList(msg queue.Message) {
panic("len(receiptlist) must be equal tx.GroupCount") panic("len(receiptlist) must be equal tx.GroupCount")
} }
if err != nil { if err != nil {
if api.IsGrpcError(err) || api.IsQueueError(err) {
msg.Reply(exec.client.NewMessage("", types.EventReceipts, err))
return
}
for n := 0; n < int(tx.GroupCount); n++ { for n := 0; n < int(tx.GroupCount); n++ {
receipts = append(receipts, types.NewErrReceipt(err)) receipts = append(receipts, types.NewErrReceipt(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