func (m *MiningPool) SubmitWork(bh *types.BlockHeader) error {
reply := make(chan error, 1)
m.submitCh <- &submitBlockMsg{blockHeader: bh, reply: reply}
- return <-reply
+ err := <-reply
+ if err != nil {
+ log.WithFields(log.Fields{"err": err, "height": bh.Height}).Warning("submitWork failed")
+ }
+ return err
}
func (m *MiningPool) submitWork(bh *types.BlockHeader) error {
m.block.Timestamp = bh.Timestamp
isOrphan, err := m.chain.ProcessBlock(m.block)
if err != nil {
- log.WithFields(log.Fields{"err": err, "height": m.block.Height}).Warning("submitWork failed")
return err
}
if isOrphan {