Lines Matching refs:msg
94 struct scifmsg msg; in scif_disconnect_ep() local
146 msg.uop = SCIF_DISCNCT; in scif_disconnect_ep()
147 msg.src = ep->port; in scif_disconnect_ep()
148 msg.dst = ep->peer; in scif_disconnect_ep()
149 msg.payload[0] = (u64)ep; in scif_disconnect_ep()
150 msg.payload[1] = ep->remote_ep; in scif_disconnect_ep()
152 err = scif_nodeqp_send(ep->remote_dev, &msg); in scif_disconnect_ep()
222 struct scifmsg msg; in scif_close() local
282 msg.uop = SCIF_CNCT_REJ; in scif_close()
283 msg.dst.node = conreq->msg.src.node; in scif_close()
284 msg.dst.port = conreq->msg.src.port; in scif_close()
285 msg.payload[0] = conreq->msg.payload[0]; in scif_close()
286 msg.payload[1] = conreq->msg.payload[1]; in scif_close()
292 scif_nodeqp_send(&scif_dev[conreq->msg.src.node], in scif_close()
293 &msg); in scif_close()
474 struct scifmsg msg; in scif_conn_func() local
501 msg.src = ep->port; in scif_conn_func()
502 msg.dst = ep->conn_port; in scif_conn_func()
503 msg.uop = SCIF_CNCT_REQ; in scif_conn_func()
504 msg.payload[0] = (u64)ep; in scif_conn_func()
505 msg.payload[1] = ep->qp_info.qp_offset; in scif_conn_func()
506 err = _scif_nodeqp_send(ep->remote_dev, &msg); in scif_conn_func()
537 msg.uop = SCIF_CNCT_GNTNACK; in scif_conn_func()
538 msg.payload[0] = ep->remote_ep; in scif_conn_func()
539 _scif_nodeqp_send(ep->remote_dev, &msg); in scif_conn_func()
544 msg.uop = SCIF_CNCT_GNTACK; in scif_conn_func()
545 msg.payload[0] = ep->remote_ep; in scif_conn_func()
546 err = _scif_nodeqp_send(ep->remote_dev, &msg); in scif_conn_func()
753 struct scifmsg msg; in scif_accept() local
804 peer->node = conreq->msg.src.node; in scif_accept()
805 peer->port = conreq->msg.src.port; in scif_accept()
817 cep->remote_ep = conreq->msg.payload[0]; in scif_accept()
845 conreq->msg.payload[1], SCIF_ENDPT_QP_SIZE, in scif_accept()
863 msg.uop = SCIF_CNCT_GNT; in scif_accept()
864 msg.src = cep->port; in scif_accept()
865 msg.payload[0] = cep->remote_ep; in scif_accept()
866 msg.payload[1] = cep->qp_info.qp_offset; in scif_accept()
867 msg.payload[2] = (u64)cep; in scif_accept()
869 err = _scif_nodeqp_send(cep->remote_dev, &msg); in scif_accept()
914 msg.uop = SCIF_CNCT_REJ; in scif_accept()
915 msg.dst.node = conreq->msg.src.node; in scif_accept()
916 msg.dst.port = conreq->msg.src.port; in scif_accept()
917 msg.payload[0] = conreq->msg.payload[0]; in scif_accept()
918 msg.payload[1] = conreq->msg.payload[1]; in scif_accept()
919 scif_nodeqp_send(&scif_dev[conreq->msg.src.node], &msg); in scif_accept()
946 static int _scif_send(scif_epd_t epd, void *msg, int len, int flags) in _scif_send() argument
963 ret = scif_rb_write(&qp->outbound_q, msg, in _scif_send()
980 msg = msg + curr_xfer_len; in _scif_send()
1008 static int _scif_recv(scif_epd_t epd, void *msg, int len, int flags) in _scif_recv() argument
1031 msg, curr_recv_len); in _scif_recv()
1054 msg = msg + curr_recv_len; in _scif_recv()
1104 int scif_user_send(scif_epd_t epd, void __user *msg, int len, int flags) in scif_user_send() argument
1136 if (copy_from_user(tmp, msg, loop_len)) { in scif_user_send()
1144 msg += err; in scif_user_send()
1165 int scif_user_recv(scif_epd_t epd, void __user *msg, int len, int flags) in scif_user_recv() argument
1200 if (copy_to_user(msg, tmp, err)) { in scif_user_recv()
1205 msg += err; in scif_user_recv()
1226 int scif_send(scif_epd_t epd, void *msg, int len, int flags) in scif_send() argument
1250 ret = _scif_send(epd, msg, len, flags); in scif_send()
1268 int scif_recv(scif_epd_t epd, void *msg, int len, int flags) in scif_recv() argument
1290 ret = _scif_recv(epd, msg, len, flags); in scif_recv()