Lines Matching refs:conn
405 clnt_compose_rdma_header(CONN *conn, CLIENT *h, rdma_buf_t *clmsg,
415 if (rdma_buf_alloc(conn, clmsg)) {
438 clnt_setup_rlist(CONN *conn, XDR *xdrs, XDR *call_xdrp)
447 status = clist_register(conn, rclp, CLIST_REG_SOURCE);
465 clnt_setup_wlist(CONN *conn, XDR *xdrs, XDR *call_xdrp, rdma_buf_t *rndbuf)
492 if (rdma_buf_alloc(conn, &rndcl->rb_longbuf)) {
506 status = clist_register(conn, wlist, CLIST_REG_DST);
508 rdma_buf_free(conn, rndbuf);
517 rdma_buf_free(conn, rndbuf);
527 clnt_setup_long_reply(CONN *conn, struct clist **clpp, uint_t length)
539 if (rdma_buf_alloc(conn, &((*clpp)->rb_longbuf))) {
550 if (clist_register(conn, *clpp, CLIST_REG_DST)) {
552 rdma_buf_free(conn, &((*clpp)->rb_longbuf));
598 CONN *conn = NULL;
658 &p->cku_addr, p->cku_addrfmly, p->cku_rd_handle, &conn);
666 if (conn == NULL) {
714 if (p->cku_srcaddr.maxlen < conn->c_laddr.len) {
718 p->cku_srcaddr.buf = kmem_zalloc(conn->c_laddr.maxlen,
720 p->cku_srcaddr.maxlen = conn->c_laddr.maxlen;
723 p->cku_srcaddr.len = conn->c_laddr.len;
724 bcopy(conn->c_laddr.buf, p->cku_srcaddr.buf, conn->c_laddr.len);
726 clnt_check_credit(conn);
753 if (rdma_buf_alloc(conn, &rpcmsg)) {
764 rdma_minchunk, NULL, XDR_ENCODE, conn);
771 rdma_buf_free(conn, &rpcmsg);
798 if (rdma_buf_alloc(conn, &cl_rpcmsg->rb_longbuf)) {
809 cl_rpcmsg, XDR_ENCODE, conn);
850 status = clnt_compose_rdma_header(conn, h, &clmsg,
864 status = clnt_setup_rlist(conn, rdmahdr_o_xdrs, call_xdrp);
867 rdma_buf_free(conn, &clmsg);
878 status = clnt_setup_wlist(conn, rdmahdr_o_xdrs, call_xdrp, &rndup);
880 rdma_buf_free(conn, &clmsg);
895 status = clnt_setup_long_reply(conn, &cl_long_reply, long_reply_len);
901 rdma_buf_free(conn, &clmsg);
937 status = rdma_clnt_postrecv(conn, p->cku_xid);
939 rdma_buf_free(conn, &clmsg);
949 status = clist_syncmem(conn, cl, CLIST_REG_SOURCE);
951 (void) rdma_clnt_postrecv_remove(conn, p->cku_xid);
952 rdma_buf_free(conn, &clmsg);
962 status = RDMA_SEND(conn, cl_sendlist, p->cku_xid);
964 (void) rdma_clnt_postrecv_remove(conn, p->cku_xid);
981 status = RDMA_RECV(conn, &cl_recvlist, p->cku_xid);
1023 clnt_update_credit(conn, rdma_credit);
1044 clnt_decode_long_reply(conn, cl_long_reply,
1151 clnt_return_credit(conn);
1160 (void) clist_deregister(conn, cl_long_reply);
1161 rdma_buf_free(conn, &cl_long_reply->rb_longbuf);
1169 rdma_buf_free(conn, &rndup);
1185 RDMA_BUF_FREE(conn, &recvmsg);
1189 RDMA_REL_CONN(conn);
1202 clnt_decode_long_reply(CONN *conn,
1214 cl_recvlist->c_len - off, 0, cl, XDR_DECODE, conn);
1230 cl_rdma_reply->c_len, 0, NULL, XDR_DECODE, conn);
1237 clnt_return_credit(CONN *conn)
1239 rdma_clnt_cred_ctrl_t *cc_info = &conn->rdma_conn_cred_ctrl_u.c_clnt_cc;
1241 mutex_enter(&conn->c_lock);
1244 mutex_exit(&conn->c_lock);
1248 clnt_update_credit(CONN *conn, uint32_t rdma_credit)
1250 rdma_clnt_cred_ctrl_t *cc_info = &conn->rdma_conn_cred_ctrl_u.c_clnt_cc;
1261 mutex_enter(&conn->c_lock);
1263 mutex_exit(&conn->c_lock);
1267 clnt_check_credit(CONN *conn)
1269 rdma_clnt_cred_ctrl_t *cc_info = &conn->rdma_conn_cred_ctrl_u.c_clnt_cc;
1275 mutex_enter(&conn->c_lock);
1282 cv_wait(&cc_info->clnt_cc_cv, &conn->c_lock);
1285 mutex_exit(&conn->c_lock);