Lines Matching defs:part
268 xpc_check_for_sent_chctl_flags_sn2(struct xpc_partition *part)
273 chctl.all_flags = xpc_receive_IRQ_amo_sn2(part->sn.sn2.
278 spin_lock_irqsave(&part->chctl_lock, irq_flags);
279 part->chctl.all_flags |= chctl.all_flags;
280 spin_unlock_irqrestore(&part->chctl_lock, irq_flags);
283 "0x%llx\n", XPC_PARTID(part), chctl.all_flags);
285 xpc_wakeup_channel_mgr(part);
308 struct xpc_partition *part = &xpc_partitions[partid];
312 if (xpc_part_ref(part)) {
313 xpc_check_for_sent_chctl_flags_sn2(part);
315 xpc_part_deref(part);
326 xpc_check_for_dropped_notify_IRQ_sn2(struct xpc_partition *part)
328 struct xpc_partition_sn2 *part_sn2 = &part->sn.sn2;
330 if (xpc_part_ref(part)) {
331 xpc_check_for_sent_chctl_flags_sn2(part);
336 xpc_part_deref(part);
348 struct xpc_partition *part = &xpc_partitions[ch->partid];
349 struct xpc_partition_sn2 *part_sn2 = &part->sn.sn2;
353 if (likely(part->act_state != XPC_P_AS_DEACTIVATING)) {
365 XPC_DEACTIVATE_PARTITION(part, ret);
384 struct xpc_partition *part = &xpc_partitions[ch->partid];
388 FETCHOP_STORE_OP(TO_AMO((u64)&part->sn.sn2.local_chctl_amo_va->
467 xpc_indicate_partition_engaged_sn2(struct xpc_partition *part)
470 struct amo *amo = (struct amo *)__va(part->sn.sn2.remote_amos_page_pa +
494 xpc_indicate_partition_disengaged_sn2(struct xpc_partition *part)
496 struct xpc_partition_sn2 *part_sn2 = &part->sn.sn2;
768 xpc_get_remote_heartbeat_sn2(struct xpc_partition *part)
777 part->sn.sn2.remote_vars_pa,
783 "heartbeat_offline=%lld, HB_mask[0]=0x%lx\n", XPC_PARTID(part),
784 remote_vars->heartbeat, part->last_heartbeat,
788 if ((remote_vars->heartbeat == part->last_heartbeat &&
794 part->last_heartbeat = remote_vars->heartbeat;
837 xpc_request_partition_reactivation_sn2(struct xpc_partition *part)
839 xpc_send_local_activate_IRQ_sn2(part->sn.sn2.activate_IRQ_nasid);
843 xpc_request_partition_deactivation_sn2(struct xpc_partition *part)
845 struct xpc_partition_sn2 *part_sn2 = &part->sn.sn2;
880 xpc_cancel_partition_deactivation_request_sn2(struct xpc_partition *part)
883 struct amo *amo = (struct amo *)__va(part->sn.sn2.remote_amos_page_pa +
921 xpc_update_partition_info_sn2(struct xpc_partition *part, u8 remote_rp_version,
927 struct xpc_partition_sn2 *part_sn2 = &part->sn.sn2;
929 part->remote_rp_version = remote_rp_version;
931 part->remote_rp_version);
933 part->remote_rp_ts_jiffies = *remote_rp_ts_jiffies;
935 part->remote_rp_ts_jiffies);
937 part->remote_rp_pa = remote_rp_pa;
938 dev_dbg(xpc_part, " remote_rp_pa = 0x%016lx\n", part->remote_rp_pa);
944 part->last_heartbeat = remote_vars->heartbeat - 1;
946 part->last_heartbeat);
995 struct xpc_partition *part;
1015 part = &xpc_partitions[partid];
1016 part_sn2 = &part->sn.sn2;
1027 XPC_DEACTIVATE_PARTITION(part, ret);
1031 part->activate_IRQ_rcvd++;
1035 part->activate_IRQ_rcvd,
1038 if (xpc_partition_disengaged(part) &&
1039 part->act_state == XPC_P_AS_INACTIVE) {
1041 xpc_update_partition_info_sn2(part, remote_rp_version,
1054 xpc_activate_partition(part);
1058 DBUG_ON(part->remote_rp_version == 0);
1061 if (remote_rp_ts_jiffies != part->remote_rp_ts_jiffies) {
1068 xpc_update_partition_info_sn2(part, remote_rp_version,
1075 if (part->disengage_timeout > 0 && !xpc_partition_disengaged(part)) {
1081 XPC_DEACTIVATE_PARTITION(part, xpReactivating);
1083 XPC_DEACTIVATE_PARTITION(part, xpOtherGoingDown);
1168 xpc_setup_ch_structures_sn2(struct xpc_partition *part)
1170 struct xpc_partition_sn2 *part_sn2 = &part->sn.sn2;
1177 short partid = XPC_PARTID(part);
1238 timer->data = (unsigned long)part;
1242 for (ch_number = 0; ch_number < part->nchannels; ch_number++) {
1243 ch_sn2 = &part->channels[ch_number].sn.sn2;
1268 xpc_vars_part_sn2[partid].nchannels = part->nchannels;
1290 xpc_teardown_ch_structures_sn2(struct xpc_partition *part)
1292 struct xpc_partition_sn2 *part_sn2 = &part->sn.sn2;
1293 short partid = XPC_PARTID(part);
1324 xpc_pull_remote_cachelines_sn2(struct xpc_partition *part, void *dst,
1333 if (part->act_state == XPC_P_AS_DEACTIVATING)
1334 return part->reason;
1339 " ret=%d\n", XPC_PARTID(part), ret);
1349 xpc_pull_remote_vars_part_sn2(struct xpc_partition *part)
1351 struct xpc_partition_sn2 *part_sn2 = &part->sn.sn2;
1358 short partid = XPC_PARTID(part);
1376 ret = xpc_pull_remote_cachelines_sn2(part, pulled_entry_cacheline,
1426 if (part->nchannels > pulled_entry->nchannels)
1427 part->nchannels = pulled_entry->nchannels;
1446 xpc_make_first_contact_sn2(struct xpc_partition *part)
1448 struct xpc_partition_sn2 *part_sn2 = &part->sn.sn2;
1464 "xp_addr region\n", XPC_PARTID(part));
1467 XPC_DEACTIVATE_PARTITION(part, ret);
1480 while ((ret = xpc_pull_remote_vars_part_sn2(part)) != xpSuccess) {
1482 XPC_DEACTIVATE_PARTITION(part, ret);
1487 "partition %d\n", XPC_PARTID(part));
1492 if (part->act_state == XPC_P_AS_DEACTIVATING)
1493 return part->reason;
1503 xpc_get_chctl_all_flags_sn2(struct xpc_partition *part)
1505 struct xpc_partition_sn2 *part_sn2 = &part->sn.sn2;
1514 spin_lock_irqsave(&part->chctl_lock, irq_flags);
1515 chctl = part->chctl;
1517 part->chctl.all_flags = 0;
1519 spin_unlock_irqrestore(&part->chctl_lock, irq_flags);
1522 ret = xpc_pull_remote_cachelines_sn2(part, part->
1528 XPC_DEACTIVATE_PARTITION(part, ret);
1531 "partition %d, ret=%d\n", XPC_PARTID(part),
1540 ret = xpc_pull_remote_cachelines_sn2(part, part_sn2->remote_GPs,
1544 XPC_DEACTIVATE_PARTITION(part, ret);
1547 "%d, ret=%d\n", XPC_PARTID(part), ret);
1808 xpc_process_msg_chctl_flags_sn2(struct xpc_partition *part, int ch_number)
1810 struct xpc_channel *ch = &part->channels[ch_number];
1814 ch_sn2->remote_GP = part->sn.sn2.remote_GPs[ch_number];
1912 struct xpc_partition *part = &xpc_partitions[ch->partid];
1944 ret = xpc_pull_remote_cachelines_sn2(part, msg, remote_msg_pa,
1953 XPC_DEACTIVATE_PARTITION(part, ret);