Lines Matching refs:get
1678 ch_sn2->local_GP->get = 0; in xpc_teardown_msg_structures_sn2()
1680 ch_sn2->remote_GP.get = 0; in xpc_teardown_msg_structures_sn2()
1682 ch_sn2->w_local_GP.get = 0; in xpc_teardown_msg_structures_sn2()
1684 ch_sn2->w_remote_GP.get = 0; in xpc_teardown_msg_structures_sn2()
1709 s64 get = ch->sn.sn2.w_remote_GP.get - 1; in xpc_notify_senders_sn2() local
1711 while (++get < put && atomic_read(&ch->n_to_notify) > 0) { in xpc_notify_senders_sn2()
1713 notify = &ch->sn.sn2.notify_queue[get % ch->local_nentries]; in xpc_notify_senders_sn2()
1734 (void *)notify, get, ch->partid, ch->number); in xpc_notify_senders_sn2()
1741 (void *)notify, get, ch->partid, ch->number); in xpc_notify_senders_sn2()
1760 s64 get; in xpc_clear_local_msgqueue_flags_sn2() local
1762 get = ch_sn2->w_remote_GP.get; in xpc_clear_local_msgqueue_flags_sn2()
1765 (get % ch->local_nentries) * in xpc_clear_local_msgqueue_flags_sn2()
1769 } while (++get < ch_sn2->remote_GP.get); in xpc_clear_local_msgqueue_flags_sn2()
1801 return ch->sn.sn2.w_remote_GP.put - ch->sn.sn2.w_local_GP.get; in xpc_n_of_deliverable_payloads_sn2()
1817 if (ch_sn2->w_remote_GP.get == ch_sn2->remote_GP.get && in xpc_process_msg_chctl_flags_sn2()
1835 if (ch_sn2->w_remote_GP.get != ch_sn2->remote_GP.get) { in xpc_process_msg_chctl_flags_sn2()
1850 ch_sn2->remote_GP.get); in xpc_process_msg_chctl_flags_sn2()
1859 ch_sn2->w_remote_GP.get = ch_sn2->remote_GP.get; in xpc_process_msg_chctl_flags_sn2()
1862 "channel=%d\n", ch_sn2->w_remote_GP.get, ch->partid, in xpc_process_msg_chctl_flags_sn2()
1907 xpc_pull_remote_msg_sn2(struct xpc_channel *ch, s64 get) in xpc_pull_remote_msg_sn2() argument
1923 while (get >= ch_sn2->next_msg_to_pull) { in xpc_pull_remote_msg_sn2()
1962 msg_offset = (get % ch->remote_nentries) * ch->entry_size; in xpc_pull_remote_msg_sn2()
1977 s64 get; in xpc_get_deliverable_payload_sn2() local
1983 get = ch_sn2->w_local_GP.get; in xpc_get_deliverable_payload_sn2()
1985 if (get == ch_sn2->w_remote_GP.put) in xpc_get_deliverable_payload_sn2()
1995 if (cmpxchg(&ch_sn2->w_local_GP.get, get, get + 1) == get) { in xpc_get_deliverable_payload_sn2()
1999 "partid=%d, channel=%d\n", get + 1, in xpc_get_deliverable_payload_sn2()
2004 msg = xpc_pull_remote_msg_sn2(ch, get); in xpc_get_deliverable_payload_sn2()
2007 DBUG_ON(msg->number != get); in xpc_get_deliverable_payload_sn2()
2106 if (put - ch_sn2->w_remote_GP.get < ch->local_nentries) { in xpc_allocate_msg_sn2()
2264 s64 get = initial_get + 1; in xpc_acknowledge_msgs_sn2() local
2270 if (get == ch_sn2->w_local_GP.get) in xpc_acknowledge_msgs_sn2()
2274 remote_msgqueue + (get % in xpc_acknowledge_msgs_sn2()
2282 get++; in xpc_acknowledge_msgs_sn2()
2285 if (get == initial_get) { in xpc_acknowledge_msgs_sn2()
2290 if (cmpxchg_rel(&ch_sn2->local_GP->get, initial_get, get) != in xpc_acknowledge_msgs_sn2()
2293 DBUG_ON(ch_sn2->local_GP->get <= initial_get); in xpc_acknowledge_msgs_sn2()
2300 "channel=%d\n", get, ch->partid, ch->number); in xpc_acknowledge_msgs_sn2()
2309 initial_get = get; in xpc_acknowledge_msgs_sn2()
2321 s64 get; in xpc_received_payload_sn2() local
2346 get = ch->sn.sn2.local_GP->get; in xpc_received_payload_sn2()
2347 if (get == msg_number) in xpc_received_payload_sn2()
2348 xpc_acknowledge_msgs_sn2(ch, get, msg->flags); in xpc_received_payload_sn2()