(req *types.AddTxReq)
| 487 | } |
| 488 | |
| 489 | func (c *Chain) addTx(req *types.AddTxReq) { |
| 490 | select { |
| 491 | case c.pendingAddTxReqs <- req: |
| 492 | case <-c.ctx.Done(): |
| 493 | log.WithError(c.ctx.Err()).Warn("add transaction aborted") |
| 494 | } |
| 495 | } |
| 496 | |
| 497 | func (c *Chain) processAddTxReq(addTxReq *types.AddTxReq) { |
| 498 | // Nil check |