Lines Matching refs:get
92 /* !!! The following should get moved into SAL. */
135 /* !!! The following should get moved into SAL. */
521 * Send activate IRQ to get other side to see that we've cleared our
870 * Send activate IRQ to get other side to see that we've set our
1005 dev_warn(xpc_part, "unable to get reserved page from nasid %d, "
1024 dev_warn(xpc_part, "unable to get XPC variables from nasid %d, "
1185 dev_err(xpc_chan, "can't get memory for local get/put "
1194 dev_err(xpc_chan, "can't get memory for remote get/put "
1209 dev_err(xpc_chan, "can't get memory for local connect args\n");
1458 * we should get the same page for remote_amos_page_pa after module
1472 * Send activate IRQ to get other side to activate if they've not
1597 dev_dbg(xpc_chan, "can't get memory for local message queue and notify "
1636 dev_dbg(xpc_chan, "can't get memory for cached remote message queue, "
1681 ch_sn2->local_GP->get = 0;
1683 ch_sn2->remote_GP.get = 0;
1685 ch_sn2->w_local_GP.get = 0;
1687 ch_sn2->w_remote_GP.get = 0;
1712 s64 get = ch->sn.sn2.w_remote_GP.get - 1;
1714 while (++get < put && atomic_read(&ch->n_to_notify) > 0) {
1716 notify = &ch->sn.sn2.notify_queue[get % ch->local_nentries];
1737 (void *)notify, get, ch->partid, ch->number);
1744 (void *)notify, get, ch->partid, ch->number);
1763 s64 get;
1765 get = ch_sn2->w_remote_GP.get;
1768 (get % ch->local_nentries) *
1772 } while (++get < ch_sn2->remote_GP.get);
1804 return ch->sn.sn2.w_remote_GP.put - ch->sn.sn2.w_local_GP.get;
1820 if (ch_sn2->w_remote_GP.get == ch_sn2->remote_GP.get &&
1838 if (ch_sn2->w_remote_GP.get != ch_sn2->remote_GP.get) {
1844 * w_remote_GP.get so that we don't allocate the same message
1853 ch_sn2->remote_GP.get);
1862 ch_sn2->w_remote_GP.get = ch_sn2->remote_GP.get;
1864 dev_dbg(xpc_chan, "w_remote_GP.get changed to %lld, partid=%d, "
1865 "channel=%d\n", ch_sn2->w_remote_GP.get, ch->partid,
1910 xpc_pull_remote_msg_sn2(struct xpc_channel *ch, s64 get)
1926 while (get >= ch_sn2->next_msg_to_pull) {
1965 msg_offset = (get % ch->remote_nentries) * ch->entry_size;
1980 s64 get;
1986 get = ch_sn2->w_local_GP.get;
1987 smp_rmb(); /* guarantee that .get loads before .put */
1988 if (get == ch_sn2->w_remote_GP.put)
1993 * by trying to increment w_local_GP.get and hope that no one
1998 if (cmpxchg(&ch_sn2->w_local_GP.get, get, get + 1) == get) {
1999 /* we got the entry referenced by get */
2001 dev_dbg(xpc_chan, "w_local_GP.get changed to %lld, "
2002 "partid=%d, channel=%d\n", get + 1,
2007 msg = xpc_pull_remote_msg_sn2(ch, get);
2010 DBUG_ON(msg->number != get);
2108 smp_rmb(); /* guarantee that .put loads before .get */
2109 if (put - ch_sn2->w_remote_GP.get < ch->local_nentries) {
2145 /* get the message's address and initialize it */
2267 s64 get = initial_get + 1;
2273 if (get == ch_sn2->w_local_GP.get)
2277 remote_msgqueue + (get %
2285 get++;
2288 if (get == initial_get) {
2293 if (cmpxchg_rel(&ch_sn2->local_GP->get, initial_get, get) !=
2296 DBUG_ON(ch_sn2->local_GP->get <= initial_get);
2300 /* we just set the new value of local_GP->get */
2302 dev_dbg(xpc_chan, "local_GP->get changed to %lld, partid=%d, "
2303 "channel=%d\n", get, ch->partid, ch->number);
2309 * local_GP->get is not XPC_M_SN2_DONE or that local_GP->get
2310 * equals w_local_GP.get, so we'll go have a look.
2312 initial_get = get;
2324 s64 get;
2341 * load of local_GP->get.
2349 get = ch->sn.sn2.local_GP->get;
2350 if (get == msg_number)
2351 xpc_acknowledge_msgs_sn2(ch, get, msg->flags);
2431 dev_err(xpc_part, "can't get memory for remote copy buffer\n");