2014-07-06 20:15:40 -07:00
|
|
|
// Copyright 2014 Citra Emulator Project
|
2014-12-16 21:38:14 -08:00
|
|
|
// Licensed under GPLv2 or any later version
|
2014-07-06 20:15:40 -07:00
|
|
|
// Refer to the license.txt file included.
|
|
|
|
|
|
|
|
#include "common/common_types.h"
|
2015-05-06 00:06:12 -07:00
|
|
|
#include "common/logging/log.h"
|
2014-07-06 20:15:40 -07:00
|
|
|
|
2015-05-12 18:38:29 -07:00
|
|
|
#include "core/memory.h"
|
2014-07-06 20:15:40 -07:00
|
|
|
|
|
|
|
#include "core/hle/hle.h"
|
|
|
|
#include "core/hle/kernel/address_arbiter.h"
|
|
|
|
#include "core/hle/kernel/thread.h"
|
|
|
|
|
|
|
|
////////////////////////////////////////////////////////////////////////////////////////////////////
|
|
|
|
// Kernel namespace
|
|
|
|
|
|
|
|
namespace Kernel {
|
|
|
|
|
2015-01-31 16:56:59 -08:00
|
|
|
AddressArbiter::AddressArbiter() {}
|
|
|
|
AddressArbiter::~AddressArbiter() {}
|
|
|
|
|
2015-01-31 18:14:40 -08:00
|
|
|
SharedPtr<AddressArbiter> AddressArbiter::Create(std::string name) {
|
2015-01-11 08:46:49 -08:00
|
|
|
SharedPtr<AddressArbiter> address_arbiter(new AddressArbiter);
|
2014-07-06 20:15:40 -07:00
|
|
|
|
2015-01-11 08:46:49 -08:00
|
|
|
address_arbiter->name = std::move(name);
|
2014-07-06 20:15:40 -07:00
|
|
|
|
2015-01-31 18:14:40 -08:00
|
|
|
return address_arbiter;
|
2015-01-11 08:46:49 -08:00
|
|
|
}
|
2014-12-22 05:07:22 -08:00
|
|
|
|
2015-01-11 08:46:49 -08:00
|
|
|
ResultCode AddressArbiter::ArbitrateAddress(ArbitrationType type, VAddr address, s32 value,
|
|
|
|
u64 nanoseconds) {
|
2014-07-06 20:15:40 -07:00
|
|
|
switch (type) {
|
|
|
|
|
|
|
|
// Signal thread(s) waiting for arbitrate address...
|
|
|
|
case ArbitrationType::Signal:
|
|
|
|
// Negative value means resume all threads
|
|
|
|
if (value < 0) {
|
2015-01-18 10:56:40 -08:00
|
|
|
ArbitrateAllThreads(address);
|
2014-07-06 20:15:40 -07:00
|
|
|
} else {
|
|
|
|
// Resume first N threads
|
|
|
|
for(int i = 0; i < value; i++)
|
2015-01-18 10:56:40 -08:00
|
|
|
ArbitrateHighestPriorityThread(address);
|
2014-07-06 20:15:40 -07:00
|
|
|
}
|
2014-07-21 18:31:21 -07:00
|
|
|
break;
|
2014-07-06 20:15:40 -07:00
|
|
|
|
|
|
|
// Wait current thread (acquire the arbiter)...
|
|
|
|
case ArbitrationType::WaitIfLessThan:
|
2015-12-27 15:44:42 -08:00
|
|
|
if ((s32)Memory::Read32(address) < value) {
|
2015-01-18 10:56:40 -08:00
|
|
|
Kernel::WaitCurrentThread_ArbitrateAddress(address);
|
2014-07-06 20:15:40 -07:00
|
|
|
}
|
2014-07-21 18:31:21 -07:00
|
|
|
break;
|
2015-01-13 11:49:26 -08:00
|
|
|
case ArbitrationType::WaitIfLessThanWithTimeout:
|
2015-12-27 15:44:42 -08:00
|
|
|
if ((s32)Memory::Read32(address) < value) {
|
2015-01-18 10:56:40 -08:00
|
|
|
Kernel::WaitCurrentThread_ArbitrateAddress(address);
|
2015-01-30 17:07:54 -08:00
|
|
|
GetCurrentThread()->WakeAfterDelay(nanoseconds);
|
2015-01-13 11:49:26 -08:00
|
|
|
}
|
|
|
|
break;
|
2015-01-03 09:09:11 -08:00
|
|
|
case ArbitrationType::DecrementAndWaitIfLessThan:
|
|
|
|
{
|
2015-12-27 15:44:42 -08:00
|
|
|
s32 memory_value = Memory::Read32(address);
|
|
|
|
if (memory_value < value) {
|
|
|
|
// Only change the memory value if the thread should wait
|
|
|
|
Memory::Write32(address, (s32)memory_value - 1);
|
2015-01-18 10:56:40 -08:00
|
|
|
Kernel::WaitCurrentThread_ArbitrateAddress(address);
|
2015-01-03 09:09:11 -08:00
|
|
|
}
|
|
|
|
break;
|
|
|
|
}
|
2015-01-13 11:49:26 -08:00
|
|
|
case ArbitrationType::DecrementAndWaitIfLessThanWithTimeout:
|
|
|
|
{
|
2015-12-27 15:44:42 -08:00
|
|
|
s32 memory_value = Memory::Read32(address);
|
|
|
|
if (memory_value < value) {
|
|
|
|
// Only change the memory value if the thread should wait
|
|
|
|
Memory::Write32(address, (s32)memory_value - 1);
|
2015-01-18 10:56:40 -08:00
|
|
|
Kernel::WaitCurrentThread_ArbitrateAddress(address);
|
2015-01-30 17:07:54 -08:00
|
|
|
GetCurrentThread()->WakeAfterDelay(nanoseconds);
|
2015-01-13 11:49:26 -08:00
|
|
|
}
|
|
|
|
break;
|
|
|
|
}
|
2014-07-06 20:15:40 -07:00
|
|
|
|
|
|
|
default:
|
2014-12-05 17:53:49 -08:00
|
|
|
LOG_ERROR(Kernel, "unknown type=%d", type);
|
2014-10-22 20:20:01 -07:00
|
|
|
return ResultCode(ErrorDescription::InvalidEnumValue, ErrorModule::Kernel, ErrorSummary::WrongArgument, ErrorLevel::Usage);
|
2014-07-06 20:15:40 -07:00
|
|
|
}
|
2015-05-19 17:24:30 -07:00
|
|
|
|
|
|
|
HLE::Reschedule(__func__);
|
|
|
|
|
2015-12-27 15:44:42 -08:00
|
|
|
// The calls that use a timeout seem to always return a Timeout error even if they did not put the thread to sleep
|
|
|
|
if (type == ArbitrationType::WaitIfLessThanWithTimeout ||
|
|
|
|
type == ArbitrationType::DecrementAndWaitIfLessThanWithTimeout) {
|
|
|
|
|
|
|
|
return ResultCode(ErrorDescription::Timeout, ErrorModule::OS,
|
|
|
|
ErrorSummary::StatusChanged, ErrorLevel::Info);
|
|
|
|
}
|
2014-10-22 20:20:01 -07:00
|
|
|
return RESULT_SUCCESS;
|
2014-07-06 20:15:40 -07:00
|
|
|
}
|
|
|
|
|
|
|
|
} // namespace Kernel
|