Lines Matching refs:part
177 struct xpc_partition *part = (struct xpc_partition *)data; in xpc_timeout_partition_disengage() local
179 DBUG_ON(time_is_after_jiffies(part->disengage_timeout)); in xpc_timeout_partition_disengage()
181 (void)xpc_partition_disengaged(part); in xpc_timeout_partition_disengage()
183 DBUG_ON(part->disengage_timeout != 0); in xpc_timeout_partition_disengage()
184 DBUG_ON(xpc_arch_ops.partition_engaged(XPC_PARTID(part))); in xpc_timeout_partition_disengage()
227 struct xpc_partition *part; in xpc_check_remote_hb() local
239 part = &xpc_partitions[partid]; in xpc_check_remote_hb()
241 if (part->act_state == XPC_P_AS_INACTIVE || in xpc_check_remote_hb()
242 part->act_state == XPC_P_AS_DEACTIVATING) { in xpc_check_remote_hb()
246 ret = xpc_arch_ops.get_remote_heartbeat(part); in xpc_check_remote_hb()
248 XPC_DEACTIVATE_PARTITION(part, ret); in xpc_check_remote_hb()
347 xpc_channel_mgr(struct xpc_partition *part) in xpc_channel_mgr() argument
349 while (part->act_state != XPC_P_AS_DEACTIVATING || in xpc_channel_mgr()
350 atomic_read(&part->nchannels_active) > 0 || in xpc_channel_mgr()
351 !xpc_partition_disengaged(part)) { in xpc_channel_mgr()
353 xpc_process_sent_chctl_flags(part); in xpc_channel_mgr()
368 atomic_dec(&part->channel_mgr_requests); in xpc_channel_mgr()
369 (void)wait_event_interruptible(part->channel_mgr_wq, in xpc_channel_mgr()
370 (atomic_read(&part->channel_mgr_requests) > 0 || in xpc_channel_mgr()
371 part->chctl.all_flags != 0 || in xpc_channel_mgr()
372 (part->act_state == XPC_P_AS_DEACTIVATING && in xpc_channel_mgr()
373 atomic_read(&part->nchannels_active) == 0 && in xpc_channel_mgr()
374 xpc_partition_disengaged(part)))); in xpc_channel_mgr()
375 atomic_set(&part->channel_mgr_requests, 1); in xpc_channel_mgr()
408 xpc_setup_ch_structures(struct xpc_partition *part) in xpc_setup_ch_structures() argument
413 short partid = XPC_PARTID(part); in xpc_setup_ch_structures()
419 DBUG_ON(part->channels != NULL); in xpc_setup_ch_structures()
420 part->channels = kzalloc(sizeof(struct xpc_channel) * XPC_MAX_NCHANNELS, in xpc_setup_ch_structures()
422 if (part->channels == NULL) { in xpc_setup_ch_structures()
429 part->remote_openclose_args = in xpc_setup_ch_structures()
431 GFP_KERNEL, &part-> in xpc_setup_ch_structures()
433 if (part->remote_openclose_args == NULL) { in xpc_setup_ch_structures()
439 part->chctl.all_flags = 0; in xpc_setup_ch_structures()
440 spin_lock_init(&part->chctl_lock); in xpc_setup_ch_structures()
442 atomic_set(&part->channel_mgr_requests, 1); in xpc_setup_ch_structures()
443 init_waitqueue_head(&part->channel_mgr_wq); in xpc_setup_ch_structures()
445 part->nchannels = XPC_MAX_NCHANNELS; in xpc_setup_ch_structures()
447 atomic_set(&part->nchannels_active, 0); in xpc_setup_ch_structures()
448 atomic_set(&part->nchannels_engaged, 0); in xpc_setup_ch_structures()
450 for (ch_number = 0; ch_number < part->nchannels; ch_number++) { in xpc_setup_ch_structures()
451 ch = &part->channels[ch_number]; in xpc_setup_ch_structures()
472 ret = xpc_arch_ops.setup_ch_structures(part); in xpc_setup_ch_structures()
480 part->setup_state = XPC_P_SS_SETUP; in xpc_setup_ch_structures()
486 kfree(part->remote_openclose_args_base); in xpc_setup_ch_structures()
487 part->remote_openclose_args = NULL; in xpc_setup_ch_structures()
489 kfree(part->channels); in xpc_setup_ch_structures()
490 part->channels = NULL; in xpc_setup_ch_structures()
499 xpc_teardown_ch_structures(struct xpc_partition *part) in xpc_teardown_ch_structures() argument
501 DBUG_ON(atomic_read(&part->nchannels_engaged) != 0); in xpc_teardown_ch_structures()
502 DBUG_ON(atomic_read(&part->nchannels_active) != 0); in xpc_teardown_ch_structures()
509 DBUG_ON(part->setup_state != XPC_P_SS_SETUP); in xpc_teardown_ch_structures()
510 part->setup_state = XPC_P_SS_WTEARDOWN; in xpc_teardown_ch_structures()
512 wait_event(part->teardown_wq, (atomic_read(&part->references) == 0)); in xpc_teardown_ch_structures()
516 xpc_arch_ops.teardown_ch_structures(part); in xpc_teardown_ch_structures()
518 kfree(part->remote_openclose_args_base); in xpc_teardown_ch_structures()
519 part->remote_openclose_args = NULL; in xpc_teardown_ch_structures()
520 kfree(part->channels); in xpc_teardown_ch_structures()
521 part->channels = NULL; in xpc_teardown_ch_structures()
523 part->setup_state = XPC_P_SS_TORNDOWN; in xpc_teardown_ch_structures()
541 struct xpc_partition *part = &xpc_partitions[partid]; in xpc_activating() local
546 spin_lock_irqsave(&part->act_lock, irq_flags); in xpc_activating()
548 if (part->act_state == XPC_P_AS_DEACTIVATING) { in xpc_activating()
549 part->act_state = XPC_P_AS_INACTIVE; in xpc_activating()
550 spin_unlock_irqrestore(&part->act_lock, irq_flags); in xpc_activating()
551 part->remote_rp_pa = 0; in xpc_activating()
556 DBUG_ON(part->act_state != XPC_P_AS_ACTIVATION_REQ); in xpc_activating()
557 part->act_state = XPC_P_AS_ACTIVATING; in xpc_activating()
559 XPC_SET_REASON(part, 0, 0); in xpc_activating()
560 spin_unlock_irqrestore(&part->act_lock, irq_flags); in xpc_activating()
566 if (xpc_setup_ch_structures(part) == xpSuccess) { in xpc_activating()
567 (void)xpc_part_ref(part); /* this will always succeed */ in xpc_activating()
569 if (xpc_arch_ops.make_first_contact(part) == xpSuccess) { in xpc_activating()
570 xpc_mark_partition_active(part); in xpc_activating()
571 xpc_channel_mgr(part); in xpc_activating()
575 xpc_part_deref(part); in xpc_activating()
576 xpc_teardown_ch_structures(part); in xpc_activating()
580 xpc_mark_partition_inactive(part); in xpc_activating()
582 if (part->reason == xpReactivating) { in xpc_activating()
584 xpc_arch_ops.request_partition_reactivation(part); in xpc_activating()
591 xpc_activate_partition(struct xpc_partition *part) in xpc_activate_partition() argument
593 short partid = XPC_PARTID(part); in xpc_activate_partition()
597 spin_lock_irqsave(&part->act_lock, irq_flags); in xpc_activate_partition()
599 DBUG_ON(part->act_state != XPC_P_AS_INACTIVE); in xpc_activate_partition()
601 part->act_state = XPC_P_AS_ACTIVATION_REQ; in xpc_activate_partition()
602 XPC_SET_REASON(part, xpCloneKThread, __LINE__); in xpc_activate_partition()
604 spin_unlock_irqrestore(&part->act_lock, irq_flags); in xpc_activate_partition()
609 spin_lock_irqsave(&part->act_lock, irq_flags); in xpc_activate_partition()
610 part->act_state = XPC_P_AS_INACTIVE; in xpc_activate_partition()
611 XPC_SET_REASON(part, xpCloneKThreadFailed, __LINE__); in xpc_activate_partition()
612 spin_unlock_irqrestore(&part->act_lock, irq_flags); in xpc_activate_partition()
655 xpc_kthread_waitmsgs(struct xpc_partition *part, struct xpc_channel *ch) in xpc_kthread_waitmsgs() argument
692 struct xpc_partition *part = &xpc_partitions[partid]; in xpc_kthread_start() local
702 ch = &part->channels[ch_number]; in xpc_kthread_start()
734 xpc_kthread_waitmsgs(part, ch); in xpc_kthread_start()
753 atomic_dec_return(&part->nchannels_engaged) == 0) { in xpc_kthread_start()
754 xpc_arch_ops.indicate_partition_disengaged(part); in xpc_kthread_start()
762 xpc_part_deref(part); in xpc_kthread_start()
784 struct xpc_partition *part = &xpc_partitions[ch->partid]; in xpc_create_kthreads() local
808 atomic_inc_return(&part->nchannels_engaged) == 1) { in xpc_create_kthreads()
809 xpc_arch_ops.indicate_partition_engaged(part); in xpc_create_kthreads()
811 (void)xpc_part_ref(part); in xpc_create_kthreads()
830 atomic_dec_return(&part->nchannels_engaged) == 0) { in xpc_create_kthreads()
831 indicate_partition_disengaged(part); in xpc_create_kthreads()
834 xpc_part_deref(part); in xpc_create_kthreads()
858 struct xpc_partition *part; in xpc_disconnect_wait() local
864 part = &xpc_partitions[partid]; in xpc_disconnect_wait()
866 if (!xpc_part_ref(part)) in xpc_disconnect_wait()
869 ch = &part->channels[ch_number]; in xpc_disconnect_wait()
872 xpc_part_deref(part); in xpc_disconnect_wait()
883 if (part->act_state != XPC_P_AS_DEACTIVATING) { in xpc_disconnect_wait()
884 spin_lock(&part->chctl_lock); in xpc_disconnect_wait()
885 part->chctl.flags[ch->number] |= in xpc_disconnect_wait()
887 spin_unlock(&part->chctl_lock); in xpc_disconnect_wait()
897 xpc_wakeup_channel_mgr(part); in xpc_disconnect_wait()
899 xpc_part_deref(part); in xpc_disconnect_wait()
907 struct xpc_partition *part; in xpc_setup_partitions() local
925 part = &xpc_partitions[partid]; in xpc_setup_partitions()
927 DBUG_ON((u64)part != L1_CACHE_ALIGN((u64)part)); in xpc_setup_partitions()
929 part->activate_IRQ_rcvd = 0; in xpc_setup_partitions()
930 spin_lock_init(&part->act_lock); in xpc_setup_partitions()
931 part->act_state = XPC_P_AS_INACTIVE; in xpc_setup_partitions()
932 XPC_SET_REASON(part, 0, 0); in xpc_setup_partitions()
934 init_timer(&part->disengage_timer); in xpc_setup_partitions()
935 part->disengage_timer.function = in xpc_setup_partitions()
937 part->disengage_timer.data = (unsigned long)part; in xpc_setup_partitions()
939 part->setup_state = XPC_P_SS_UNSET; in xpc_setup_partitions()
940 init_waitqueue_head(&part->teardown_wq); in xpc_setup_partitions()
941 atomic_set(&part->references, 0); in xpc_setup_partitions()
959 struct xpc_partition *part; in xpc_do_exit() local
991 part = &xpc_partitions[partid]; in xpc_do_exit()
993 if (xpc_partition_disengaged(part) && in xpc_do_exit()
994 part->act_state == XPC_P_AS_INACTIVE) { in xpc_do_exit()
1000 XPC_DEACTIVATE_PARTITION(part, reason); in xpc_do_exit()
1002 if (part->disengage_timeout > disengage_timeout) in xpc_do_exit()
1003 disengage_timeout = part->disengage_timeout; in xpc_do_exit()
1096 struct xpc_partition *part; in xpc_die_deactivate() local
1111 part = &xpc_partitions[partid]; in xpc_die_deactivate()
1114 part->act_state != XPC_P_AS_INACTIVE) { in xpc_die_deactivate()
1115 xpc_arch_ops.request_partition_deactivation(part); in xpc_die_deactivate()
1116 xpc_arch_ops.indicate_partition_disengaged(part); in xpc_die_deactivate()