Lines Matching refs:call
96 * client's handles call record is on the dispatch list (so that
201 #define WIRE_HDR_SIZE 20 /* serialized call header, sans proc number */
202 #define MSG_OFFSET 128 /* offset of call into the mblk */
424 clnt_cots_kcallit, /* do rpc call */
425 clnt_cots_kabort, /* abort call */
600 /* Preserialize the call message header */
748 calllist_t *call = &p->cku_call;
754 RPCLOG(64, "clnt_cots_kdestroy h: removing call for xid 0x%x "
756 call_table_remove(call);
759 if (call->call_reply)
760 freemsg(call->call_reply);
761 cv_destroy(&call->call_cv);
762 mutex_destroy(&call->call_lock);
781 calllist_t *call = &p->cku_call;
830 * If the call is not a retry, allocate a new xid and cache it
833 * Treat call as a retry for purposes of binding the source
835 * the previous call.
839 call->call_zoneid = rpc_zoneid();
843 * determines whether or not our call record gets placed on
854 RPCLOG(8, "clnt_cots_kcallit: new call, dequeuing old"
855 " one (%p)\n", (void *)call);
856 call_table_remove(call);
858 RPCLOG(64, "clnt_cots_kcallit: removing call from "
863 if (call->call_reply != NULL) {
864 freemsg(call->call_reply);
865 call->call_reply = NULL;
1008 (call->call_reply != NULL ||
1012 * If we've sent a request and our call is on the dispatch
1022 * this after the call to connmgr_get so that we have the correct
1108 RPCLOG(2, "clnt_cots_kcallit: connected, sending call, tidu_size %d\n",
1115 status = clnt_dispatch_send(wq, mp, call, p->cku_xid,
1118 if ((status == RPC_CANTSEND) && (call->call_reason == ENOBUFS)) {
1122 * specified for the call, or zone is going away.
1142 p->cku_err.re_errno = call->call_reason;
1159 RPCLOG(64, "clnt_cots_kcallit: sent call for xid 0x%x\n",
1170 * (both indicated by call_status), call->call_reply will contain
1174 mutex_enter(&call->call_lock);
1176 if (call->call_status == RPC_TIMEDOUT) {
1203 while ((cv_wait_ret = cv_timedwait(&call->call_cv,
1204 &call->call_lock, timout)) > 0 &&
1205 call->call_status == RPC_TIMEDOUT)
1209 &call->call_cv,
1210 &call->call_lock, timout)) > 0 &&
1211 call->call_status == RPC_TIMEDOUT)
1233 * try to call us again and thus force the
1238 if (call->call_status != RPC_SUCCESS) {
1262 mp = call->call_reply;
1263 call->call_reply = NULL;
1266 * call_err is the error info when the call is on dispatch queue.
1271 status = call->call_status;
1272 p->cku_err = call->call_err;
1273 mutex_exit(&call->call_lock);
1320 call_table_remove(call);
1326 if (call->call_reply) {
1327 freemsg(call->call_reply);
1328 call->call_reply = NULL;
1377 mutex_enter(&call->call_lock);
1378 if (call->call_reply == NULL)
1379 call->call_status = RPC_TIMEDOUT;
1380 mutex_exit(&call->call_lock);
1417 call_table_remove(call);
1424 if (call->call_reply) {
1425 freemsg(call->call_reply);
1426 call->call_reply = NULL;
1503 call_table_remove(call);
1516 if ((p->cku_flags & CKU_ONQUEUE) == 0 && call->call_reply) {
1517 freemsg(call->call_reply);
1518 call->call_reply = NULL;
1541 * handle, and clears the xid field so there is no way a new call
1544 * call time, as cots creates the transport at call time - device,
1553 calllist_t *call = &p->cku_call;
1557 call_table_remove(call);
1559 RPCLOG(64, "clnt_cots_kinit: removing call for xid 0x%x from"
1563 if (call->call_reply != NULL) {
1564 freemsg(call->call_reply);
1565 call->call_reply = NULL;
1568 call->call_bucket = NULL;
1569 call->call_hash = 0;
1775 * Re-map the call status to RPC_INTR if the err code is
1827 * If the call is not a retry, look for a transport entry that
1944 RPCLOG(2, "connmgr_get: call going out on %p\n",
1965 * be sent on the same source port as the original call.
2034 * it is probably better to send the call out using
2077 * reconnected by another thread, or the original call
2234 * Keep the kernel stack lean. Don't move this call
2236 * call is declared in connmgr_wrapconnect()
2238 calllist_t call;
2240 bzero(&call, sizeof (call));
2241 cv_init(&call.call_cv, NULL, CV_DEFAULT, NULL);
2247 &call, &tidu_size, FALSE, waitp, nosignal, cr);
2248 *rpcerr = call.call_err;
2249 cv_destroy(&call.call_cv);
2357 calllist_t call;
2377 bzero(&call, sizeof (call));
2378 cv_init(&call.call_cv, NULL, CV_DEFAULT, NULL);
2381 destaddr, addrfmly, &call, &cm_entry->x_tidu_size,
2384 *rpcerr = call.call_err;
2385 cv_destroy(&call.call_cv);
2575 * Called by KRPC after sending the call message to release the connection
2692 RPCLOG(8, " call %p\n", (void *)wq);
3102 * (through put) to send the call.
3158 * Called by rpcmod to notify a client with a clnt_pending call that its reply
3242 * an RPC call with a different xid to reside here.
3245 * out and left its call record on the dispatch
3248 * RPC call.
3576 RPCLOG(1, "aborting clnt_pending call %p\n",
3594 * This can happen if thread A is making a call over a
3603 * connection attempt failed versus those where the call
3609 RPCLOG(1, " aborting clnt_pending call %p\n",