Lines Matching refs:cep

741 	struct scif_endpt *cep;  in scif_accept()  local
797 cep = kzalloc(sizeof(*cep), GFP_KERNEL); in scif_accept()
798 if (!cep) { in scif_accept()
802 spin_lock_init(&cep->lock); in scif_accept()
803 mutex_init(&cep->sendlock); in scif_accept()
804 mutex_init(&cep->recvlock); in scif_accept()
805 cep->state = SCIFEP_CONNECTING; in scif_accept()
806 cep->remote_dev = &scif_dev[peer->node]; in scif_accept()
807 cep->remote_ep = conreq->msg.payload[0]; in scif_accept()
809 scif_rma_ep_init(cep); in scif_accept()
811 err = scif_reserve_dma_chan(cep); in scif_accept()
818 cep->qp_info.qp = kzalloc(sizeof(*cep->qp_info.qp), GFP_KERNEL); in scif_accept()
819 if (!cep->qp_info.qp) { in scif_accept()
824 err = scif_anon_inode_getfile(cep); in scif_accept()
828 cep->qp_info.qp->magic = SCIFEP_MAGIC; in scif_accept()
829 spdev = scif_get_peer_dev(cep->remote_dev); in scif_accept()
834 err = scif_setup_qp_accept(cep->qp_info.qp, &cep->qp_info.qp_offset, in scif_accept()
836 cep->remote_dev); in scif_accept()
838 dev_dbg(&cep->remote_dev->sdev->dev, in scif_accept()
840 lep, cep, err, cep->qp_info.qp_offset); in scif_accept()
845 cep->port.node = lep->port.node; in scif_accept()
846 cep->port.port = lep->port.port; in scif_accept()
847 cep->peer.node = peer->node; in scif_accept()
848 cep->peer.port = peer->port; in scif_accept()
849 init_waitqueue_head(&cep->sendwq); in scif_accept()
850 init_waitqueue_head(&cep->recvwq); in scif_accept()
851 init_waitqueue_head(&cep->conwq); in scif_accept()
854 msg.src = cep->port; in scif_accept()
855 msg.payload[0] = cep->remote_ep; in scif_accept()
856 msg.payload[1] = cep->qp_info.qp_offset; in scif_accept()
857 msg.payload[2] = (u64)cep; in scif_accept()
859 err = _scif_nodeqp_send(cep->remote_dev, &msg); in scif_accept()
865 err = wait_event_timeout(cep->conwq, cep->state != SCIFEP_CONNECTING, in scif_accept()
867 if (!err && scifdev_alive(cep)) in scif_accept()
874 spin_lock(&cep->lock); in scif_accept()
876 if (cep->state == SCIFEP_CLOSING) { in scif_accept()
881 spin_unlock(&cep->lock); in scif_accept()
882 scif_teardown_ep(cep); in scif_accept()
883 kfree(cep); in scif_accept()
893 scif_get_port(cep->port.port); in scif_accept()
894 *newepd = (scif_epd_t)cep; in scif_accept()
895 spin_unlock(&cep->lock); in scif_accept()
898 scif_anon_inode_fput(cep); in scif_accept()
900 scif_teardown_ep(cep); in scif_accept()
902 kfree(cep); in scif_accept()