Function NewP2pRequest

p2p/request.go:30–34

(ctx context.Context, rType int, id []byte, addr string, msg proto.Message, nonce uint64)

}

func NewP2pRequest(ctx context.Context, rType int, id []byte, addr string, msg proto.Message, nonce uint64) (req *p2pRequest) {
	rctx, cancel := context.WithCancel(ctx)
	req = &p2pRequest{ctx: rctx, cancel: cancel, id: id, msg: msg, rType: rType, nonce: nonce, reply: make(chan p2pResult)}
	return
}
func (r *p2pRequest) sendReq(ch chan p2pRequest) (err error) {
	select {
	case ch <- *r: