misc/sgi-xp/xpc_channel.c

12  *	This is the part of XPC that manages the channels and
82 	struct xpc_partition *part = &xpc_partitions[ch->partid];
101 	if (part->act_state == XPC_P_AS_DEACTIVATING) {
157 	atomic_dec(&part->nchannels_active);
168 		if (part->act_state != XPC_P_AS_DEACTIVATING) {
170 			spin_lock(&part->chctl_lock);
171 			part->chctl.flags[ch->number] |=
173 			spin_unlock(&part->chctl_lock);
183 xpc_process_openclose_chctl_flags(struct xpc_partition *part, int ch_number,
188 	    &part->remote_openclose_args[ch_number];
189 	struct xpc_channel *ch = &part->channels[ch_number];
238 				if (part->chctl.flags[ch_number] &
242 					spin_lock(&part->chctl_lock);
243 					part->chctl.flags[ch_number] |=
245 					spin_unlock(&part->chctl_lock);
253 			atomic_inc(&part->nchannels_active);
289 			DBUG_ON(part->act_state != XPC_P_AS_DEACTIVATING);
296 			if (part->chctl.flags[ch_number] &
300 				spin_lock(&part->chctl_lock);
301 				part->chctl.flags[ch_number] |=
303 				spin_unlock(&part->chctl_lock);
323 		if (part->act_state == XPC_P_AS_DEACTIVATING ||
362 			atomic_inc(&part->nchannels_active);
511 			 * done with the part that required the registration
546 xpc_process_sent_chctl_flags(struct xpc_partition *part)
554 	chctl.all_flags = xpc_arch_ops.get_chctl_all_flags(part);
563 	for (ch_number = 0; ch_number < part->nchannels; ch_number++) {
564 		ch = &part->channels[ch_number];
572 			xpc_process_openclose_chctl_flags(part, ch_number,
585 		if (part->act_state == XPC_P_AS_DEACTIVATING)
603 			xpc_arch_ops.process_msg_chctl_flags(part, ch_number);
617 xpc_partition_going_down(struct xpc_partition *part, enum xp_retval reason)
624 		XPC_PARTID(part), reason);
626 	if (!xpc_part_ref(part)) {
633 	for (ch_number = 0; ch_number < part->nchannels; ch_number++) {
634 		ch = &part->channels[ch_number];
645 	xpc_wakeup_channel_mgr(part);
647 	xpc_part_deref(part);
658 	struct xpc_partition *part;
663 		part = &xpc_partitions[partid];
665 		if (xpc_part_ref(part)) {
670 			xpc_wakeup_channel_mgr(part);
671 			xpc_part_deref(part);
711 	struct xpc_partition *part;
718 		part = &xpc_partitions[partid];
720 		if (xpc_part_ref(part)) {
721 			ch = &part->channels[ch_number];
736 			xpc_part_deref(part);
875 	struct xpc_partition *part = &xpc_partitions[partid];
882 	DBUG_ON(ch_number < 0 || ch_number >= part->nchannels);
885 	if (xpc_part_ref(part)) {
886 		ret = xpc_arch_ops.send_payload(&part->channels[ch_number],
888 		xpc_part_deref(part);
926 	struct xpc_partition *part = &xpc_partitions[partid];
933 	DBUG_ON(ch_number < 0 || ch_number >= part->nchannels);
937 	if (xpc_part_ref(part)) {
938 		ret = xpc_arch_ops.send_payload(&part->channels[ch_number],
940 		xpc_part_deref(part);
1000 	struct xpc_partition *part = &xpc_partitions[partid];
1004 	DBUG_ON(ch_number < 0 || ch_number >= part->nchannels);
1006 	ch = &part->channels[ch_number];