Lines Matching refs:call
751 calllist_t *call = &p->cku_call; in clnt_cots_kdestroy() local
759 call_table_remove(call); in clnt_cots_kdestroy()
762 if (call->call_reply) in clnt_cots_kdestroy()
763 freemsg(call->call_reply); in clnt_cots_kdestroy()
764 cv_destroy(&call->call_cv); in clnt_cots_kdestroy()
765 mutex_destroy(&call->call_lock); in clnt_cots_kdestroy()
784 calllist_t *call = &p->cku_call; in clnt_cots_kcallit() local
842 call->call_zoneid = rpc_zoneid(); in clnt_cots_kcallit()
858 " one (%p)\n", (void *)call); in clnt_cots_kcallit()
859 call_table_remove(call); in clnt_cots_kcallit()
866 if (call->call_reply != NULL) { in clnt_cots_kcallit()
867 freemsg(call->call_reply); in clnt_cots_kcallit()
868 call->call_reply = NULL; in clnt_cots_kcallit()
1011 (call->call_reply != NULL || in clnt_cots_kcallit()
1118 status = clnt_dispatch_send(wq, mp, call, p->cku_xid, in clnt_cots_kcallit()
1121 if ((status == RPC_CANTSEND) && (call->call_reason == ENOBUFS)) { in clnt_cots_kcallit()
1145 p->cku_err.re_errno = call->call_reason; in clnt_cots_kcallit()
1177 mutex_enter(&call->call_lock); in clnt_cots_kcallit()
1179 if (call->call_status == RPC_TIMEDOUT) { in clnt_cots_kcallit()
1206 while ((cv_wait_ret = cv_timedwait(&call->call_cv, in clnt_cots_kcallit()
1207 &call->call_lock, timout)) > 0 && in clnt_cots_kcallit()
1208 call->call_status == RPC_TIMEDOUT) in clnt_cots_kcallit()
1212 &call->call_cv, in clnt_cots_kcallit()
1213 &call->call_lock, timout)) > 0 && in clnt_cots_kcallit()
1214 call->call_status == RPC_TIMEDOUT) in clnt_cots_kcallit()
1241 if (call->call_status != RPC_SUCCESS) { in clnt_cots_kcallit()
1265 mp = call->call_reply; in clnt_cots_kcallit()
1266 call->call_reply = NULL; in clnt_cots_kcallit()
1274 status = call->call_status; in clnt_cots_kcallit()
1275 p->cku_err = call->call_err; in clnt_cots_kcallit()
1276 mutex_exit(&call->call_lock); in clnt_cots_kcallit()
1323 call_table_remove(call); in clnt_cots_kcallit()
1329 if (call->call_reply) { in clnt_cots_kcallit()
1330 freemsg(call->call_reply); in clnt_cots_kcallit()
1331 call->call_reply = NULL; in clnt_cots_kcallit()
1380 mutex_enter(&call->call_lock); in clnt_cots_kcallit()
1381 if (call->call_reply == NULL) in clnt_cots_kcallit()
1382 call->call_status = RPC_TIMEDOUT; in clnt_cots_kcallit()
1383 mutex_exit(&call->call_lock); in clnt_cots_kcallit()
1420 call_table_remove(call); in clnt_cots_kcallit()
1427 if (call->call_reply) { in clnt_cots_kcallit()
1428 freemsg(call->call_reply); in clnt_cots_kcallit()
1429 call->call_reply = NULL; in clnt_cots_kcallit()
1506 call_table_remove(call); in clnt_cots_kcallit()
1519 if ((p->cku_flags & CKU_ONQUEUE) == 0 && call->call_reply) { in clnt_cots_kcallit()
1520 freemsg(call->call_reply); in clnt_cots_kcallit()
1521 call->call_reply = NULL; in clnt_cots_kcallit()
1556 calllist_t *call = &p->cku_call; in clnt_cots_kinit() local
1560 call_table_remove(call); in clnt_cots_kinit()
1566 if (call->call_reply != NULL) { in clnt_cots_kinit()
1567 freemsg(call->call_reply); in clnt_cots_kinit()
1568 call->call_reply = NULL; in clnt_cots_kinit()
1571 call->call_bucket = NULL; in clnt_cots_kinit()
1572 call->call_hash = 0; in clnt_cots_kinit()
2239 calllist_t call; in connmgr_get() local
2241 bzero(&call, sizeof (call)); in connmgr_get()
2242 cv_init(&call.call_cv, NULL, CV_DEFAULT, NULL); in connmgr_get()
2248 &call, &tidu_size, FALSE, waitp, nosignal, cr); in connmgr_get()
2249 *rpcerr = call.call_err; in connmgr_get()
2250 cv_destroy(&call.call_cv); in connmgr_get()
2360 calllist_t call; in connmgr_wrapconnect() local
2380 bzero(&call, sizeof (call)); in connmgr_wrapconnect()
2381 cv_init(&call.call_cv, NULL, CV_DEFAULT, NULL); in connmgr_wrapconnect()
2384 destaddr, addrfmly, &call, &cm_entry->x_tidu_size, in connmgr_wrapconnect()
2387 *rpcerr = call.call_err; in connmgr_wrapconnect()
2388 cv_destroy(&call.call_cv); in connmgr_wrapconnect()