Lines Matching refs:msg_slot

1089 	struct xpc_send_msg_slot_uv *msg_slot;  in xpc_allocate_send_msg_slot_uv()  local
1102 msg_slot = &ch_uv->send_msg_slots[entry]; in xpc_allocate_send_msg_slot_uv()
1104 msg_slot->msg_slot_number = entry; in xpc_allocate_send_msg_slot_uv()
1106 &msg_slot->next); in xpc_allocate_send_msg_slot_uv()
1123 struct xpc_notify_mq_msg_uv *msg_slot; in xpc_allocate_recv_msg_slot_uv() local
1136 msg_slot = ch_uv->recv_msg_slots + in xpc_allocate_recv_msg_slot_uv()
1139 msg_slot->hdr.msg_slot_number = entry; in xpc_allocate_recv_msg_slot_uv()
1336 struct xpc_send_msg_slot_uv *msg_slot; in xpc_allocate_msg_slot_uv() local
1352 msg_slot = container_of(entry, struct xpc_send_msg_slot_uv, next); in xpc_allocate_msg_slot_uv()
1353 *address_of_msg_slot = msg_slot; in xpc_allocate_msg_slot_uv()
1359 struct xpc_send_msg_slot_uv *msg_slot) in xpc_free_msg_slot_uv() argument
1361 xpc_put_fifo_entry_uv(&ch->sn.uv.msg_slot_free_list, &msg_slot->next); in xpc_free_msg_slot_uv()
1370 struct xpc_send_msg_slot_uv *msg_slot, in xpc_notify_sender_uv() argument
1373 xpc_notify_func func = msg_slot->func; in xpc_notify_sender_uv()
1375 if (func != NULL && cmpxchg(&msg_slot->func, func, NULL) == func) { in xpc_notify_sender_uv()
1380 "msg_slot_number=%d partid=%d channel=%d\n", msg_slot, in xpc_notify_sender_uv()
1381 msg_slot->msg_slot_number, ch->partid, ch->number); in xpc_notify_sender_uv()
1383 func(reason, ch->partid, ch->number, msg_slot->key); in xpc_notify_sender_uv()
1386 "msg_slot_number=%d partid=%d channel=%d\n", msg_slot, in xpc_notify_sender_uv()
1387 msg_slot->msg_slot_number, ch->partid, ch->number); in xpc_notify_sender_uv()
1395 struct xpc_send_msg_slot_uv *msg_slot; in xpc_handle_notify_mq_ack_uv() local
1398 msg_slot = &ch->sn.uv.send_msg_slots[entry]; in xpc_handle_notify_mq_ack_uv()
1400 BUG_ON(msg_slot->msg_slot_number != msg->hdr.msg_slot_number); in xpc_handle_notify_mq_ack_uv()
1401 msg_slot->msg_slot_number += ch->local_nentries; in xpc_handle_notify_mq_ack_uv()
1403 if (msg_slot->func != NULL) in xpc_handle_notify_mq_ack_uv()
1404 xpc_notify_sender_uv(ch, msg_slot, xpMsgDelivered); in xpc_handle_notify_mq_ack_uv()
1406 xpc_free_msg_slot_uv(ch, msg_slot); in xpc_handle_notify_mq_ack_uv()
1416 struct xpc_notify_mq_msg_uv *msg_slot; in xpc_handle_notify_mq_msg_uv() local
1455 msg_slot = ch_uv->recv_msg_slots + in xpc_handle_notify_mq_msg_uv()
1458 BUG_ON(msg_slot->hdr.size != 0); in xpc_handle_notify_mq_msg_uv()
1460 memcpy(msg_slot, msg, msg->hdr.size); in xpc_handle_notify_mq_msg_uv()
1462 xpc_put_fifo_entry_uv(&ch_uv->recv_msg_list, &msg_slot->hdr.u.next); in xpc_handle_notify_mq_msg_uv()
1539 struct xpc_send_msg_slot_uv *msg_slot = NULL; in xpc_send_payload_uv() local
1561 ret = xpc_allocate_msg_slot_uv(ch, flags, &msg_slot); in xpc_send_payload_uv()
1568 msg_slot->key = key; in xpc_send_payload_uv()
1570 msg_slot->func = func; in xpc_send_payload_uv()
1582 msg->hdr.msg_slot_number = msg_slot->msg_slot_number; in xpc_send_payload_uv()
1603 if (cmpxchg(&msg_slot->func, func, NULL) != func) { in xpc_send_payload_uv()
1608 msg_slot->key = NULL; in xpc_send_payload_uv()
1611 xpc_free_msg_slot_uv(ch, msg_slot); in xpc_send_payload_uv()
1627 struct xpc_send_msg_slot_uv *msg_slot; in xpc_notify_senders_of_disconnect_uv() local
1637 msg_slot = &ch->sn.uv.send_msg_slots[entry]; in xpc_notify_senders_of_disconnect_uv()
1638 if (msg_slot->func != NULL) in xpc_notify_senders_of_disconnect_uv()
1639 xpc_notify_sender_uv(ch, msg_slot, ch->reason); in xpc_notify_senders_of_disconnect_uv()