RGBCube/serenity
1
Fork 0
mirror of https://github.com/RGBCube/serenity synced 2025-07-25 14:57:35 +00:00
Code Issues Activity Actions

Kernel: Rename Processor::smp_queue_message() => smp_enqueue_message()

Browse source
This commit is contained in:
Andreas Kling 2021-08-08 16:59:11 +02:00
parent 46215a8183
commit f3fed411d4
2 changed files with 4 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

2
Kernel/Arch/x86/Processor.h
View file

@ -154,7 +154,7 @@ class Processor {
static void smp_return_to_pool(ProcessorMessage& msg); static void smp_return_to_pool(ProcessorMessage& msg);
static ProcessorMessage& smp_get_from_pool(); static ProcessorMessage& smp_get_from_pool();
static void smp_cleanup_message(ProcessorMessage& msg); static void smp_cleanup_message(ProcessorMessage& msg);
bool smp_queue_message(ProcessorMessage& msg); bool smp_enqueue_message(ProcessorMessage&);
static void smp_unicast_message(u32 cpu, ProcessorMessage& msg, bool async); static void smp_unicast_message(u32 cpu, ProcessorMessage& msg, bool async);
static void smp_broadcast_message(ProcessorMessage& msg); static void smp_broadcast_message(ProcessorMessage& msg);
static void smp_broadcast_wait_sync(ProcessorMessage& msg); static void smp_broadcast_wait_sync(ProcessorMessage& msg);

6
Kernel/Arch/x86/common/Processor.cpp
View file

@ -855,7 +855,7 @@ bool Processor::smp_process_pending_messages()
return did_process; return did_process;
} }
bool Processor::smp_queue_message(ProcessorMessage& msg) bool Processor::smp_enqueue_message(ProcessorMessage& msg)
{ {
// Note that it's quite possible that the other processor may pop // Note that it's quite possible that the other processor may pop
// the queue at any given time. We rely on the fact that the messages // the queue at any given time. We rely on the fact that the messages
@ -881,7 +881,7 @@ void Processor::smp_broadcast_message(ProcessorMessage& msg)
for_each( for_each(
[&](Processor& proc) { [&](Processor& proc) {
if (&proc != &cur_proc) { if (&proc != &cur_proc) {
if (proc.smp_queue_message(msg)) if (proc.smp_enqueue_message(msg))
need_broadcast = true; need_broadcast = true;
} }
}); });
@ -920,7 +920,7 @@ void Processor::smp_unicast_message(u32 cpu, ProcessorMessage& msg, bool async)
dbgln_if(SMP_DEBUG, "SMP[{}]: Send message {} to cpu #{} proc: {}", cur_proc.get_id(), VirtualAddress(&msg), cpu, VirtualAddress(&target_proc)); dbgln_if(SMP_DEBUG, "SMP[{}]: Send message {} to cpu #{} proc: {}", cur_proc.get_id(), VirtualAddress(&msg), cpu, VirtualAddress(&target_proc));
msg.refs.store(1u, AK::MemoryOrder::memory_order_release); msg.refs.store(1u, AK::MemoryOrder::memory_order_release);
if (target_proc->smp_queue_message(msg)) { if (target_proc->smp_enqueue_message(msg)) {
APIC::the().send_ipi(cpu); APIC::the().send_ipi(cpu);
} }