Lines Matching refs:msg_slot
1085 struct xpc_send_msg_slot_uv *msg_slot; in xpc_allocate_send_msg_slot_uv() local
1098 msg_slot = &ch_uv->send_msg_slots[entry]; in xpc_allocate_send_msg_slot_uv()
1100 msg_slot->msg_slot_number = entry; in xpc_allocate_send_msg_slot_uv()
1102 &msg_slot->next); in xpc_allocate_send_msg_slot_uv()
1119 struct xpc_notify_mq_msg_uv *msg_slot; in xpc_allocate_recv_msg_slot_uv() local
1132 msg_slot = ch_uv->recv_msg_slots + in xpc_allocate_recv_msg_slot_uv()
1135 msg_slot->hdr.msg_slot_number = entry; in xpc_allocate_recv_msg_slot_uv()
1332 struct xpc_send_msg_slot_uv *msg_slot; in xpc_allocate_msg_slot_uv() local
1348 msg_slot = container_of(entry, struct xpc_send_msg_slot_uv, next); in xpc_allocate_msg_slot_uv()
1349 *address_of_msg_slot = msg_slot; in xpc_allocate_msg_slot_uv()
1355 struct xpc_send_msg_slot_uv *msg_slot) in xpc_free_msg_slot_uv() argument
1357 xpc_put_fifo_entry_uv(&ch->sn.uv.msg_slot_free_list, &msg_slot->next); in xpc_free_msg_slot_uv()
1366 struct xpc_send_msg_slot_uv *msg_slot, in xpc_notify_sender_uv() argument
1369 xpc_notify_func func = msg_slot->func; in xpc_notify_sender_uv()
1371 if (func != NULL && cmpxchg(&msg_slot->func, func, NULL) == func) { in xpc_notify_sender_uv()
1376 "msg_slot_number=%d partid=%d channel=%d\n", msg_slot, in xpc_notify_sender_uv()
1377 msg_slot->msg_slot_number, ch->partid, ch->number); in xpc_notify_sender_uv()
1379 func(reason, ch->partid, ch->number, msg_slot->key); in xpc_notify_sender_uv()
1382 "msg_slot_number=%d partid=%d channel=%d\n", msg_slot, in xpc_notify_sender_uv()
1383 msg_slot->msg_slot_number, ch->partid, ch->number); in xpc_notify_sender_uv()
1391 struct xpc_send_msg_slot_uv *msg_slot; in xpc_handle_notify_mq_ack_uv() local
1394 msg_slot = &ch->sn.uv.send_msg_slots[entry]; in xpc_handle_notify_mq_ack_uv()
1396 BUG_ON(msg_slot->msg_slot_number != msg->hdr.msg_slot_number); in xpc_handle_notify_mq_ack_uv()
1397 msg_slot->msg_slot_number += ch->local_nentries; in xpc_handle_notify_mq_ack_uv()
1399 if (msg_slot->func != NULL) in xpc_handle_notify_mq_ack_uv()
1400 xpc_notify_sender_uv(ch, msg_slot, xpMsgDelivered); in xpc_handle_notify_mq_ack_uv()
1402 xpc_free_msg_slot_uv(ch, msg_slot); in xpc_handle_notify_mq_ack_uv()
1412 struct xpc_notify_mq_msg_uv *msg_slot; in xpc_handle_notify_mq_msg_uv() local
1451 msg_slot = ch_uv->recv_msg_slots + in xpc_handle_notify_mq_msg_uv()
1454 BUG_ON(msg_slot->hdr.size != 0); in xpc_handle_notify_mq_msg_uv()
1456 memcpy(msg_slot, msg, msg->hdr.size); in xpc_handle_notify_mq_msg_uv()
1458 xpc_put_fifo_entry_uv(&ch_uv->recv_msg_list, &msg_slot->hdr.u.next); in xpc_handle_notify_mq_msg_uv()
1535 struct xpc_send_msg_slot_uv *msg_slot = NULL; in xpc_send_payload_uv() local
1557 ret = xpc_allocate_msg_slot_uv(ch, flags, &msg_slot); in xpc_send_payload_uv()
1564 msg_slot->key = key; in xpc_send_payload_uv()
1566 msg_slot->func = func; in xpc_send_payload_uv()
1578 msg->hdr.msg_slot_number = msg_slot->msg_slot_number; in xpc_send_payload_uv()
1599 if (cmpxchg(&msg_slot->func, func, NULL) != func) { in xpc_send_payload_uv()
1604 msg_slot->key = NULL; in xpc_send_payload_uv()
1607 xpc_free_msg_slot_uv(ch, msg_slot); in xpc_send_payload_uv()
1623 struct xpc_send_msg_slot_uv *msg_slot; in xpc_notify_senders_of_disconnect_uv() local
1633 msg_slot = &ch->sn.uv.send_msg_slots[entry]; in xpc_notify_senders_of_disconnect_uv()
1634 if (msg_slot->func != NULL) in xpc_notify_senders_of_disconnect_uv()
1635 xpc_notify_sender_uv(ch, msg_slot, ch->reason); in xpc_notify_senders_of_disconnect_uv()