(req *request)
| 75 | } |
| 76 | |
| 77 | func (e *ethAdaptor) waitForReply(req *request) (err error) { |
| 78 | for { |
| 79 | select { |
| 80 | case e.reqQueue <- req: |
| 81 | case <-e.ctx.Done(): |
| 82 | err = e.ctx.Err() |
| 83 | return |
| 84 | case <-req.opCtx.Done(): |
| 85 | err = req.opCtx.Err() |
| 86 | return |
| 87 | } |
| 88 | |
| 89 | select { |
| 90 | case r := <-req.reply: |
| 91 | err = r.err |
| 92 | if err != nil { |
| 93 | fmt.Println(" error ", r.err) |
| 94 | return |
| 95 | } |
| 96 | case <-e.ctx.Done(): |
| 97 | err = e.ctx.Err() |
| 98 | return |
| 99 | case <-req.opCtx.Done(): |
| 100 | err = req.opCtx.Err() |
| 101 | return |
| 102 | } |
| 103 | return |
| 104 | } |
| 105 | } |
| 106 | |
| 107 | func (e *ethAdaptor) SetGroupSize(g uint64) (err error) { |
| 108 | if !e.isConnecting() { |
no outgoing calls
no test coverage detected