(c *client, inBound bool)
| 249 | } |
| 250 | |
| 251 | func (n *server) runClient(c *client, inBound bool) { |
| 252 | if err := c.run(); err != nil { |
| 253 | err = &P2PError{err: errors.Errorf("runClient (%t) err: %w", inBound, err), t: time.Now()} |
| 254 | n.logger.Error(err) |
| 255 | } |
| 256 | |
| 257 | var delpeer chan []byte |
| 258 | if inBound { |
| 259 | delpeer = n.removeIncomingC |
| 260 | } else { |
| 261 | delpeer = n.removeCallingC |
| 262 | } |
| 263 | select { |
| 264 | case <-n.ctx.Done(): |
| 265 | return |
| 266 | case delpeer <- c.remoteID: |
| 267 | } |
| 268 | } |
| 269 | |
| 270 | func (n *server) handleCallReq(req p2pRequest) (c *client) { |
| 271 | var fd net.Conn |
no test coverage detected