Lines Matching refs:get
1681 ch_sn2->local_GP->get = 0; in xpc_teardown_msg_structures_sn2()
1683 ch_sn2->remote_GP.get = 0; in xpc_teardown_msg_structures_sn2()
1685 ch_sn2->w_local_GP.get = 0; in xpc_teardown_msg_structures_sn2()
1687 ch_sn2->w_remote_GP.get = 0; in xpc_teardown_msg_structures_sn2()
1712 s64 get = ch->sn.sn2.w_remote_GP.get - 1; in xpc_notify_senders_sn2() local
1714 while (++get < put && atomic_read(&ch->n_to_notify) > 0) { in xpc_notify_senders_sn2()
1716 notify = &ch->sn.sn2.notify_queue[get % ch->local_nentries]; in xpc_notify_senders_sn2()
1737 (void *)notify, get, ch->partid, ch->number); in xpc_notify_senders_sn2()
1744 (void *)notify, get, ch->partid, ch->number); in xpc_notify_senders_sn2()
1763 s64 get; in xpc_clear_local_msgqueue_flags_sn2() local
1765 get = ch_sn2->w_remote_GP.get; in xpc_clear_local_msgqueue_flags_sn2()
1768 (get % ch->local_nentries) * in xpc_clear_local_msgqueue_flags_sn2()
1772 } while (++get < ch_sn2->remote_GP.get); in xpc_clear_local_msgqueue_flags_sn2()
1804 return ch->sn.sn2.w_remote_GP.put - ch->sn.sn2.w_local_GP.get; in xpc_n_of_deliverable_payloads_sn2()
1820 if (ch_sn2->w_remote_GP.get == ch_sn2->remote_GP.get && in xpc_process_msg_chctl_flags_sn2()
1838 if (ch_sn2->w_remote_GP.get != ch_sn2->remote_GP.get) { in xpc_process_msg_chctl_flags_sn2()
1853 ch_sn2->remote_GP.get); in xpc_process_msg_chctl_flags_sn2()
1862 ch_sn2->w_remote_GP.get = ch_sn2->remote_GP.get; in xpc_process_msg_chctl_flags_sn2()
1865 "channel=%d\n", ch_sn2->w_remote_GP.get, ch->partid, in xpc_process_msg_chctl_flags_sn2()
1910 xpc_pull_remote_msg_sn2(struct xpc_channel *ch, s64 get) in xpc_pull_remote_msg_sn2() argument
1926 while (get >= ch_sn2->next_msg_to_pull) { in xpc_pull_remote_msg_sn2()
1965 msg_offset = (get % ch->remote_nentries) * ch->entry_size; in xpc_pull_remote_msg_sn2()
1980 s64 get; in xpc_get_deliverable_payload_sn2() local
1986 get = ch_sn2->w_local_GP.get; in xpc_get_deliverable_payload_sn2()
1988 if (get == ch_sn2->w_remote_GP.put) in xpc_get_deliverable_payload_sn2()
1998 if (cmpxchg(&ch_sn2->w_local_GP.get, get, get + 1) == get) { in xpc_get_deliverable_payload_sn2()
2002 "partid=%d, channel=%d\n", get + 1, in xpc_get_deliverable_payload_sn2()
2007 msg = xpc_pull_remote_msg_sn2(ch, get); in xpc_get_deliverable_payload_sn2()
2010 DBUG_ON(msg->number != get); in xpc_get_deliverable_payload_sn2()
2109 if (put - ch_sn2->w_remote_GP.get < ch->local_nentries) { in xpc_allocate_msg_sn2()
2267 s64 get = initial_get + 1; in xpc_acknowledge_msgs_sn2() local
2273 if (get == ch_sn2->w_local_GP.get) in xpc_acknowledge_msgs_sn2()
2277 remote_msgqueue + (get % in xpc_acknowledge_msgs_sn2()
2285 get++; in xpc_acknowledge_msgs_sn2()
2288 if (get == initial_get) { in xpc_acknowledge_msgs_sn2()
2293 if (cmpxchg_rel(&ch_sn2->local_GP->get, initial_get, get) != in xpc_acknowledge_msgs_sn2()
2296 DBUG_ON(ch_sn2->local_GP->get <= initial_get); in xpc_acknowledge_msgs_sn2()
2303 "channel=%d\n", get, ch->partid, ch->number); in xpc_acknowledge_msgs_sn2()
2312 initial_get = get; in xpc_acknowledge_msgs_sn2()
2324 s64 get; in xpc_received_payload_sn2() local
2349 get = ch->sn.sn2.local_GP->get; in xpc_received_payload_sn2()
2350 if (get == msg_number) in xpc_received_payload_sn2()
2351 xpc_acknowledge_msgs_sn2(ch, get, msg->flags); in xpc_received_payload_sn2()