• Home
  • Raw
  • Download

Lines Matching refs:put

1682 	ch_sn2->local_GP->put = 0;  in xpc_teardown_msg_structures_sn2()
1684 ch_sn2->remote_GP.put = 0; in xpc_teardown_msg_structures_sn2()
1686 ch_sn2->w_local_GP.put = 0; in xpc_teardown_msg_structures_sn2()
1688 ch_sn2->w_remote_GP.put = 0; in xpc_teardown_msg_structures_sn2()
1708 xpc_notify_senders_sn2(struct xpc_channel *ch, enum xp_retval reason, s64 put) in xpc_notify_senders_sn2() argument
1714 while (++get < put && atomic_read(&ch->n_to_notify) > 0) { in xpc_notify_senders_sn2()
1752 xpc_notify_senders_sn2(ch, ch->reason, ch->sn.sn2.w_local_GP.put); in xpc_notify_senders_of_disconnect_sn2()
1783 s64 put, remote_nentries = ch->remote_nentries; in xpc_clear_remote_msgqueue_flags_sn2() local
1786 if (ch_sn2->remote_GP.put < remote_nentries) in xpc_clear_remote_msgqueue_flags_sn2()
1789 put = max(ch_sn2->w_remote_GP.put, remote_nentries); in xpc_clear_remote_msgqueue_flags_sn2()
1792 (put % remote_nentries) * in xpc_clear_remote_msgqueue_flags_sn2()
1796 DBUG_ON(msg->number != put - remote_nentries); in xpc_clear_remote_msgqueue_flags_sn2()
1798 } while (++put < ch_sn2->remote_GP.put); in xpc_clear_remote_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()
1821 ch_sn2->w_remote_GP.put == ch_sn2->remote_GP.put) { in xpc_process_msg_chctl_flags_sn2()
1881 if (ch_sn2->w_remote_GP.put != ch_sn2->remote_GP.put) { in xpc_process_msg_chctl_flags_sn2()
1889 ch_sn2->w_remote_GP.put = ch_sn2->remote_GP.put; in xpc_process_msg_chctl_flags_sn2()
1892 "channel=%d\n", ch_sn2->w_remote_GP.put, ch->partid, in xpc_process_msg_chctl_flags_sn2()
1932 DBUG_ON(ch_sn2->next_msg_to_pull >= ch_sn2->w_remote_GP.put); in xpc_pull_remote_msg_sn2()
1933 nmsgs = ch_sn2->w_remote_GP.put - ch_sn2->next_msg_to_pull; in xpc_pull_remote_msg_sn2()
1988 if (get == ch_sn2->w_remote_GP.put) in xpc_get_deliverable_payload_sn2()
2034 s64 put = initial_put + 1; in xpc_send_msgs_sn2() local
2040 if (put == ch_sn2->w_local_GP.put) in xpc_send_msgs_sn2()
2044 local_msgqueue + (put % in xpc_send_msgs_sn2()
2051 put++; in xpc_send_msgs_sn2()
2054 if (put == initial_put) { in xpc_send_msgs_sn2()
2059 if (cmpxchg_rel(&ch_sn2->local_GP->put, initial_put, put) != in xpc_send_msgs_sn2()
2062 DBUG_ON(ch_sn2->local_GP->put < initial_put); in xpc_send_msgs_sn2()
2069 "channel=%d\n", put, ch->partid, ch->number); in xpc_send_msgs_sn2()
2078 initial_put = put; in xpc_send_msgs_sn2()
2096 s64 put; in xpc_allocate_msg_sn2() local
2107 put = ch_sn2->w_local_GP.put; in xpc_allocate_msg_sn2()
2109 if (put - ch_sn2->w_remote_GP.get < ch->local_nentries) { in xpc_allocate_msg_sn2()
2117 if (cmpxchg(&ch_sn2->w_local_GP.put, put, put + 1) == in xpc_allocate_msg_sn2()
2118 put) { in xpc_allocate_msg_sn2()
2147 (put % ch->local_nentries) * in xpc_allocate_msg_sn2()
2151 msg->number = put; in xpc_allocate_msg_sn2()
2154 "msg_number=%lld, partid=%d, channel=%d\n", put + 1, in xpc_allocate_msg_sn2()
2176 s64 put; in xpc_send_payload_sn2() local
2245 put = ch_sn2->local_GP->put; in xpc_send_payload_sn2()
2246 if (put == msg_number) in xpc_send_payload_sn2()
2247 xpc_send_msgs_sn2(ch, put); in xpc_send_payload_sn2()