Lines Matching refs:part
167 struct xpc_partition *part = timer_container_of(part, t, in xpc_timeout_partition_disengage() local
170 DBUG_ON(time_is_after_jiffies(part->disengage_timeout)); in xpc_timeout_partition_disengage()
172 xpc_partition_disengaged_from_timer(part); in xpc_timeout_partition_disengage()
174 DBUG_ON(part->disengage_timeout != 0); in xpc_timeout_partition_disengage()
175 DBUG_ON(xpc_arch_ops.partition_engaged(XPC_PARTID(part))); in xpc_timeout_partition_disengage()
217 struct xpc_partition *part; in xpc_check_remote_hb() local
229 part = &xpc_partitions[partid]; in xpc_check_remote_hb()
231 if (part->act_state == XPC_P_AS_INACTIVE || in xpc_check_remote_hb()
232 part->act_state == XPC_P_AS_DEACTIVATING) { in xpc_check_remote_hb()
236 ret = xpc_arch_ops.get_remote_heartbeat(part); in xpc_check_remote_hb()
238 XPC_DEACTIVATE_PARTITION(part, ret); in xpc_check_remote_hb()
330 xpc_channel_mgr(struct xpc_partition *part) in xpc_channel_mgr() argument
332 while (part->act_state != XPC_P_AS_DEACTIVATING || in xpc_channel_mgr()
333 atomic_read(&part->nchannels_active) > 0 || in xpc_channel_mgr()
334 !xpc_partition_disengaged(part)) { in xpc_channel_mgr()
336 xpc_process_sent_chctl_flags(part); in xpc_channel_mgr()
351 atomic_dec(&part->channel_mgr_requests); in xpc_channel_mgr()
352 (void)wait_event_interruptible(part->channel_mgr_wq, in xpc_channel_mgr()
353 (atomic_read(&part->channel_mgr_requests) > 0 || in xpc_channel_mgr()
354 part->chctl.all_flags != 0 || in xpc_channel_mgr()
355 (part->act_state == XPC_P_AS_DEACTIVATING && in xpc_channel_mgr()
356 atomic_read(&part->nchannels_active) == 0 && in xpc_channel_mgr()
357 xpc_partition_disengaged(part)))); in xpc_channel_mgr()
358 atomic_set(&part->channel_mgr_requests, 1); in xpc_channel_mgr()
391 xpc_setup_ch_structures(struct xpc_partition *part) in xpc_setup_ch_structures() argument
396 short partid = XPC_PARTID(part); in xpc_setup_ch_structures()
402 DBUG_ON(part->channels != NULL); in xpc_setup_ch_structures()
403 part->channels = kcalloc(XPC_MAX_NCHANNELS, in xpc_setup_ch_structures()
406 if (part->channels == NULL) { in xpc_setup_ch_structures()
413 part->remote_openclose_args = in xpc_setup_ch_structures()
415 GFP_KERNEL, &part-> in xpc_setup_ch_structures()
417 if (part->remote_openclose_args == NULL) { in xpc_setup_ch_structures()
423 part->chctl.all_flags = 0; in xpc_setup_ch_structures()
424 spin_lock_init(&part->chctl_lock); in xpc_setup_ch_structures()
426 atomic_set(&part->channel_mgr_requests, 1); in xpc_setup_ch_structures()
427 init_waitqueue_head(&part->channel_mgr_wq); in xpc_setup_ch_structures()
429 part->nchannels = XPC_MAX_NCHANNELS; in xpc_setup_ch_structures()
431 atomic_set(&part->nchannels_active, 0); in xpc_setup_ch_structures()
432 atomic_set(&part->nchannels_engaged, 0); in xpc_setup_ch_structures()
434 for (ch_number = 0; ch_number < part->nchannels; ch_number++) { in xpc_setup_ch_structures()
435 ch = &part->channels[ch_number]; in xpc_setup_ch_structures()
456 ret = xpc_arch_ops.setup_ch_structures(part); in xpc_setup_ch_structures()
464 part->setup_state = XPC_P_SS_SETUP; in xpc_setup_ch_structures()
470 kfree(part->remote_openclose_args_base); in xpc_setup_ch_structures()
471 part->remote_openclose_args = NULL; in xpc_setup_ch_structures()
473 kfree(part->channels); in xpc_setup_ch_structures()
474 part->channels = NULL; in xpc_setup_ch_structures()
483 xpc_teardown_ch_structures(struct xpc_partition *part) in xpc_teardown_ch_structures() argument
485 DBUG_ON(atomic_read(&part->nchannels_engaged) != 0); in xpc_teardown_ch_structures()
486 DBUG_ON(atomic_read(&part->nchannels_active) != 0); in xpc_teardown_ch_structures()
493 DBUG_ON(part->setup_state != XPC_P_SS_SETUP); in xpc_teardown_ch_structures()
494 part->setup_state = XPC_P_SS_WTEARDOWN; in xpc_teardown_ch_structures()
496 wait_event(part->teardown_wq, (atomic_read(&part->references) == 0)); in xpc_teardown_ch_structures()
500 xpc_arch_ops.teardown_ch_structures(part); in xpc_teardown_ch_structures()
502 kfree(part->remote_openclose_args_base); in xpc_teardown_ch_structures()
503 part->remote_openclose_args = NULL; in xpc_teardown_ch_structures()
504 kfree(part->channels); in xpc_teardown_ch_structures()
505 part->channels = NULL; in xpc_teardown_ch_structures()
507 part->setup_state = XPC_P_SS_TORNDOWN; in xpc_teardown_ch_structures()
525 struct xpc_partition *part = &xpc_partitions[partid]; in xpc_activating() local
530 spin_lock_irqsave(&part->act_lock, irq_flags); in xpc_activating()
532 if (part->act_state == XPC_P_AS_DEACTIVATING) { in xpc_activating()
533 part->act_state = XPC_P_AS_INACTIVE; in xpc_activating()
534 spin_unlock_irqrestore(&part->act_lock, irq_flags); in xpc_activating()
535 part->remote_rp_pa = 0; in xpc_activating()
540 DBUG_ON(part->act_state != XPC_P_AS_ACTIVATION_REQ); in xpc_activating()
541 part->act_state = XPC_P_AS_ACTIVATING; in xpc_activating()
543 XPC_SET_REASON(part, 0, 0); in xpc_activating()
544 spin_unlock_irqrestore(&part->act_lock, irq_flags); in xpc_activating()
550 if (xpc_setup_ch_structures(part) == xpSuccess) { in xpc_activating()
551 (void)xpc_part_ref(part); /* this will always succeed */ in xpc_activating()
553 if (xpc_arch_ops.make_first_contact(part) == xpSuccess) { in xpc_activating()
554 xpc_mark_partition_active(part); in xpc_activating()
555 xpc_channel_mgr(part); in xpc_activating()
559 xpc_part_deref(part); in xpc_activating()
560 xpc_teardown_ch_structures(part); in xpc_activating()
564 xpc_mark_partition_inactive(part); in xpc_activating()
566 if (part->reason == xpReactivating) { in xpc_activating()
568 xpc_arch_ops.request_partition_reactivation(part); in xpc_activating()
575 xpc_activate_partition(struct xpc_partition *part) in xpc_activate_partition() argument
577 short partid = XPC_PARTID(part); in xpc_activate_partition()
581 spin_lock_irqsave(&part->act_lock, irq_flags); in xpc_activate_partition()
583 DBUG_ON(part->act_state != XPC_P_AS_INACTIVE); in xpc_activate_partition()
585 part->act_state = XPC_P_AS_ACTIVATION_REQ; in xpc_activate_partition()
586 XPC_SET_REASON(part, xpCloneKThread, __LINE__); in xpc_activate_partition()
588 spin_unlock_irqrestore(&part->act_lock, irq_flags); in xpc_activate_partition()
593 spin_lock_irqsave(&part->act_lock, irq_flags); in xpc_activate_partition()
594 part->act_state = XPC_P_AS_INACTIVE; in xpc_activate_partition()
595 XPC_SET_REASON(part, xpCloneKThreadFailed, __LINE__); in xpc_activate_partition()
596 spin_unlock_irqrestore(&part->act_lock, irq_flags); in xpc_activate_partition()
639 xpc_kthread_waitmsgs(struct xpc_partition *part, struct xpc_channel *ch) in xpc_kthread_waitmsgs() argument
676 struct xpc_partition *part = &xpc_partitions[partid]; in xpc_kthread_start() local
686 ch = &part->channels[ch_number]; in xpc_kthread_start()
718 xpc_kthread_waitmsgs(part, ch); in xpc_kthread_start()
737 atomic_dec_return(&part->nchannels_engaged) == 0) { in xpc_kthread_start()
738 xpc_arch_ops.indicate_partition_disengaged(part); in xpc_kthread_start()
746 xpc_part_deref(part); in xpc_kthread_start()
768 struct xpc_partition *part = &xpc_partitions[ch->partid]; in xpc_create_kthreads() local
792 atomic_inc_return(&part->nchannels_engaged) == 1) { in xpc_create_kthreads()
793 xpc_arch_ops.indicate_partition_engaged(part); in xpc_create_kthreads()
795 (void)xpc_part_ref(part); in xpc_create_kthreads()
814 atomic_dec_return(&part->nchannels_engaged) == 0) { in xpc_create_kthreads()
815 indicate_partition_disengaged(part); in xpc_create_kthreads()
818 xpc_part_deref(part); in xpc_create_kthreads()
842 struct xpc_partition *part; in xpc_disconnect_wait() local
848 part = &xpc_partitions[partid]; in xpc_disconnect_wait()
850 if (!xpc_part_ref(part)) in xpc_disconnect_wait()
853 ch = &part->channels[ch_number]; in xpc_disconnect_wait()
856 xpc_part_deref(part); in xpc_disconnect_wait()
867 if (part->act_state != XPC_P_AS_DEACTIVATING) { in xpc_disconnect_wait()
868 spin_lock(&part->chctl_lock); in xpc_disconnect_wait()
869 part->chctl.flags[ch->number] |= in xpc_disconnect_wait()
871 spin_unlock(&part->chctl_lock); in xpc_disconnect_wait()
881 xpc_wakeup_channel_mgr(part); in xpc_disconnect_wait()
883 xpc_part_deref(part); in xpc_disconnect_wait()
891 struct xpc_partition *part; in xpc_setup_partitions() local
910 part = &xpc_partitions[partid]; in xpc_setup_partitions()
912 DBUG_ON((u64)part != L1_CACHE_ALIGN((u64)part)); in xpc_setup_partitions()
914 part->activate_IRQ_rcvd = 0; in xpc_setup_partitions()
915 spin_lock_init(&part->act_lock); in xpc_setup_partitions()
916 part->act_state = XPC_P_AS_INACTIVE; in xpc_setup_partitions()
917 XPC_SET_REASON(part, 0, 0); in xpc_setup_partitions()
919 timer_setup(&part->disengage_timer, in xpc_setup_partitions()
922 part->setup_state = XPC_P_SS_UNSET; in xpc_setup_partitions()
923 init_waitqueue_head(&part->teardown_wq); in xpc_setup_partitions()
924 atomic_set(&part->references, 0); in xpc_setup_partitions()
942 struct xpc_partition *part; in xpc_do_exit() local
974 part = &xpc_partitions[partid]; in xpc_do_exit()
976 if (xpc_partition_disengaged(part) && in xpc_do_exit()
977 part->act_state == XPC_P_AS_INACTIVE) { in xpc_do_exit()
983 XPC_DEACTIVATE_PARTITION(part, reason); in xpc_do_exit()
985 if (part->disengage_timeout > disengage_timeout) in xpc_do_exit()
986 disengage_timeout = part->disengage_timeout; in xpc_do_exit()
1079 struct xpc_partition *part; in xpc_die_deactivate() local
1094 part = &xpc_partitions[partid]; in xpc_die_deactivate()
1097 part->act_state != XPC_P_AS_INACTIVE) { in xpc_die_deactivate()
1098 xpc_arch_ops.request_partition_deactivation(part); in xpc_die_deactivate()
1099 xpc_arch_ops.indicate_partition_disengaged(part); in xpc_die_deactivate()