system/kernel/smp.cpp

109 static int32 process_pending_ici(int32 currentCPU);
292 process_all_pending_ici(int32 currentCPU)
294 	while (process_pending_ici(currentCPU) != B_ENTRY_NOT_FOUND)
342 		int currentCPU = smp_get_current_cpu();
359 				process_all_pending_ici(currentCPU);
453 /*!	Equivalent to acquire_spinlock(), save for currentCPU parameter. */
455 acquire_spinlock_cpu(int32 currentCPU, spinlock *lock)
484 				process_all_pending_ici(currentCPU);
578 	int currentCPU = smp_get_current_cpu();
590 			process_all_pending_ici(currentCPU);
643 	int currentCPU = smp_get_current_cpu();
655 			process_all_pending_ici(currentCPU);
769 find_free_message_interrupts_disabled(int32 currentCPU,
774 	acquire_spinlock_cpu(currentCPU, &sFreeMessageSpinlock);
777 		process_all_pending_ici(currentCPU);
779 		acquire_spinlock_cpu(currentCPU, &sFreeMessageSpinlock);
807 check_for_message(int currentCPU, mailbox_source& sourceMailbox)
812 	struct smp_msg* msg = atomic_pointer_get(&sCPUMessages[currentCPU]);
816 			msg = atomic_pointer_get(&sCPUMessages[currentCPU]);
818 		} while (atomic_pointer_test_and_set(&sCPUMessages[currentCPU],
821 		TRACE(" cpu %d: found msg %p in cpu mailbox\n", currentCPU, msg);
831 			if (!msg->proc_bitmap.GetBit(currentCPU)) {
838 			msg->proc_bitmap.ClearBitAtomic(currentCPU);
839 			atomic_add(&gCPU[currentCPU].ici_counter, 1);
847 			TRACE(" cpu %d: found msg %p in broadcast mailbox\n", currentCPU,
856 finish_message_processing(int currentCPU, struct smp_msg* msg,
914 process_pending_ici(int32 currentCPU)
917 	struct smp_msg* msg = check_for_message(currentCPU, sourceMailbox);
921 	TRACE("  cpu %ld message = %ld\n", currentCPU, msg->message);
944 			func(msg->data, currentCPU, msg->data2, msg->data3);
958 	finish_message_processing(currentCPU, msg, sourceMailbox);
962 		debug_trap_cpu_in_kdl(currentCPU, false);
1055 		int currentCPU;
1060 		currentCPU = smp_get_current_cpu();
1061 		if (targetCPU == currentCPU) {
1093 				process_all_pending_ici(currentCPU);
1113 	int currentCPU = smp_get_current_cpu();
1120 	msg->proc_bitmap.ClearBit(currentCPU);
1166 			process_all_pending_ici(currentCPU);
1191 		int currentCPU;
1196 		currentCPU = smp_get_current_cpu();
1206 		msg->proc_bitmap.ClearBit(currentCPU);
1210 			"mbox\n", currentCPU, msg);
1219 		atomic_add(&gCPU[currentCPU].ici_counter, 1);
1232 				process_all_pending_ici(currentCPU);
1251 smp_send_broadcast_ici_interrupts_disabled(int32 currentCPU, int32 message,
1259 		currentCPU, message, data, data2, data3, dataPointer, flags);
1262 	find_free_message_interrupts_disabled(currentCPU, &msg);
1272 	msg->proc_bitmap.ClearBit(currentCPU);
1276 		"into broadcast mbox\n", currentCPU, msg);
1285 	atomic_add(&gCPU[currentCPU].ici_counter, 1);
1290 		currentCPU);
1297 			"ack\n", currentCPU);
1300 			process_all_pending_ici(currentCPU);
1305 			"message to free list\n", currentCPU);