Lines Matching refs:cep

751 	struct scif_endpt *cep;  in scif_accept()  local
807 cep = kzalloc(sizeof(*cep), GFP_KERNEL); in scif_accept()
808 if (!cep) { in scif_accept()
812 spin_lock_init(&cep->lock); in scif_accept()
813 mutex_init(&cep->sendlock); in scif_accept()
814 mutex_init(&cep->recvlock); in scif_accept()
815 cep->state = SCIFEP_CONNECTING; in scif_accept()
816 cep->remote_dev = &scif_dev[peer->node]; in scif_accept()
817 cep->remote_ep = conreq->msg.payload[0]; in scif_accept()
819 scif_rma_ep_init(cep); in scif_accept()
821 err = scif_reserve_dma_chan(cep); in scif_accept()
828 cep->qp_info.qp = kzalloc(sizeof(*cep->qp_info.qp), GFP_KERNEL); in scif_accept()
829 if (!cep->qp_info.qp) { in scif_accept()
834 err = scif_anon_inode_getfile(cep); in scif_accept()
838 cep->qp_info.qp->magic = SCIFEP_MAGIC; in scif_accept()
839 spdev = scif_get_peer_dev(cep->remote_dev); in scif_accept()
844 err = scif_setup_qp_accept(cep->qp_info.qp, &cep->qp_info.qp_offset, in scif_accept()
846 cep->remote_dev); in scif_accept()
848 dev_dbg(&cep->remote_dev->sdev->dev, in scif_accept()
850 lep, cep, err, cep->qp_info.qp_offset); in scif_accept()
855 cep->port.node = lep->port.node; in scif_accept()
856 cep->port.port = lep->port.port; in scif_accept()
857 cep->peer.node = peer->node; in scif_accept()
858 cep->peer.port = peer->port; in scif_accept()
859 init_waitqueue_head(&cep->sendwq); in scif_accept()
860 init_waitqueue_head(&cep->recvwq); in scif_accept()
861 init_waitqueue_head(&cep->conwq); 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()
875 err = wait_event_timeout(cep->conwq, cep->state != SCIFEP_CONNECTING, in scif_accept()
877 if (!err && scifdev_alive(cep)) in scif_accept()
884 spin_lock(&cep->lock); in scif_accept()
886 if (cep->state == SCIFEP_CLOSING) { in scif_accept()
891 spin_unlock(&cep->lock); in scif_accept()
892 scif_teardown_ep(cep); in scif_accept()
893 kfree(cep); in scif_accept()
903 scif_get_port(cep->port.port); in scif_accept()
904 *newepd = (scif_epd_t)cep; in scif_accept()
905 spin_unlock(&cep->lock); in scif_accept()
908 scif_anon_inode_fput(cep); in scif_accept()
910 scif_teardown_ep(cep); in scif_accept()
912 kfree(cep); in scif_accept()