Lines Matching refs:dest_port
672 register ipc_port_t dest_port;
853 dest_port = (ipc_port_t) entry->ie_object;
854 assert(dest_port != IP_NULL);
862 * dest_port == reply_port, and simple locking is
867 ip_lock(dest_port);
868 if (!ip_active(dest_port) ||
870 ip_unlock(dest_port);
876 assert(dest_port->ip_srights > 0);
877 dest_port->ip_srights++;
878 ip_reference(dest_port);
891 hdr->msgh_remote_port = dest_port;
896 if (dest_port->ip_receiver == ipc_space_kernel) {
906 assert(ip_active(dest_port));
907 dest_port->ip_messages.imq_seqno++;
908 ip_unlock(dest_port);
912 if (imq_full(&dest_port->ip_messages)) {
931 ip_unlock(dest_port);
1001 dest_port = (ipc_port_t) entry->ie_object;
1002 assert(dest_port != IP_NULL);
1004 ip_lock(dest_port);
1005 if (!ip_active(dest_port)) {
1006 ip_unlock(dest_port);
1011 assert(dest_port->ip_sorights > 0);
1025 hdr->msgh_remote_port = dest_port;
1029 assert(dest_port->ip_receiver != ipc_space_kernel);
1127 ip_unlock(dest_port);
1144 * space is unlocked, dest_port is locked,
1145 * we can queue kmsg to dest_port,
1153 assert(ip_active(dest_port));
1154 assert(dest_port->ip_receiver != ipc_space_kernel);
1155 // assert(!imq_full(&dest_port->ip_messages) ||
1167 dest_mqueue = &dest_port->ip_messages;
1182 ip_unlock(dest_port);
1227 ip_unlock(dest_port);
1309 * dest_port == reply_port, and simple locking is
1314 ip_lock(dest_port);
1315 if (!ip_active(dest_port) ||
1369 assert(dest_port->ip_srights > 0);
1370 ip_release(dest_port);
1372 if (dest_port->ip_receiver == space)
1373 dest_name = dest_port->ip_receiver_name;
1377 if ((--dest_port->ip_srights == 0) &&
1378 (dest_port->ip_nsrequest != IP_NULL)) {
1384 nsrequest = dest_port->ip_nsrequest;
1385 mscount = dest_port->ip_mscount;
1386 dest_port->ip_nsrequest = IP_NULL;
1387 ip_unlock(dest_port);
1390 ip_unlock(dest_port);
1401 ip_unlock(dest_port);
1412 ip_lock(dest_port);
1413 if (!ip_active(dest_port)) {
1414 ip_unlock(dest_port);
1421 assert(dest_port->ip_sorights > 0);
1423 if (dest_port->ip_receiver == space) {
1424 ip_release(dest_port);
1425 dest_port->ip_sorights--;
1426 dest_name = dest_port->ip_receiver_name;
1427 ip_unlock(dest_port);
1429 ip_unlock(dest_port);
1431 ipc_notify_send_once(dest_port);
1449 ip_lock(dest_port);
1450 if (!ip_active(dest_port)) {
1451 ip_unlock(dest_port);
1458 assert(dest_port->ip_sorights > 0);
1460 if (dest_port->ip_receiver == space) {
1461 ip_release(dest_port);
1462 dest_port->ip_sorights--;
1463 dest_name = dest_port->ip_receiver_name;
1464 ip_unlock(dest_port);
1466 ip_unlock(dest_port);
1468 ipc_notify_send_once(dest_port);
1554 dest_port = (ipc_port_t) hdr->msgh_remote_port;
1555 assert(IP_VALID(dest_port));
1557 ip_lock(dest_port);
1558 if (!ip_active(dest_port)) {
1559 ip_unlock(dest_port);
1563 if (dest_port->ip_receiver == ipc_space_kernel) {
1564 dest_port->ip_messages.imq_seqno++;
1565 ip_unlock(dest_port);
1569 if (!imq_full(&dest_port->ip_messages) ||
1601 ip_unlock(dest_port);
1698 dest_port = reply_port;
1781 dest_port = (ipc_port_t) hdr->msgh_remote_port;