8e510d5afa
Now that we have the address arbiter extracted to its own class, we can fix an innaccuracy with the kernel. Said inaccuracy being that there isn't only one address arbiter. Each process instance contains its own AddressArbiter instance in the actual kernel. This fixes that and gets rid of another long-standing issue that could arise when attempting to create more than one process.
80 lines
2.5 KiB
C++
80 lines
2.5 KiB
C++
// Copyright 2018 yuzu emulator team
|
|
// Licensed under GPLv2 or any later version
|
|
// Refer to the license.txt file included.
|
|
|
|
#pragma once
|
|
|
|
#include <vector>
|
|
|
|
#include "common/common_types.h"
|
|
#include "core/hle/kernel/object.h"
|
|
|
|
union ResultCode;
|
|
|
|
namespace Core {
|
|
class System;
|
|
}
|
|
|
|
namespace Kernel {
|
|
|
|
class Thread;
|
|
|
|
class AddressArbiter {
|
|
public:
|
|
enum class ArbitrationType {
|
|
WaitIfLessThan = 0,
|
|
DecrementAndWaitIfLessThan = 1,
|
|
WaitIfEqual = 2,
|
|
};
|
|
|
|
enum class SignalType {
|
|
Signal = 0,
|
|
IncrementAndSignalIfEqual = 1,
|
|
ModifyByWaitingCountAndSignalIfEqual = 2,
|
|
};
|
|
|
|
explicit AddressArbiter(Core::System& system);
|
|
~AddressArbiter();
|
|
|
|
AddressArbiter(const AddressArbiter&) = delete;
|
|
AddressArbiter& operator=(const AddressArbiter&) = delete;
|
|
|
|
AddressArbiter(AddressArbiter&&) = default;
|
|
AddressArbiter& operator=(AddressArbiter&&) = delete;
|
|
|
|
/// Signals an address being waited on with a particular signaling type.
|
|
ResultCode SignalToAddress(VAddr address, SignalType type, s32 value, s32 num_to_wake);
|
|
|
|
/// Waits on an address with a particular arbitration type.
|
|
ResultCode WaitForAddress(VAddr address, ArbitrationType type, s32 value, s64 timeout_ns);
|
|
|
|
private:
|
|
/// Signals an address being waited on.
|
|
ResultCode SignalToAddressOnly(VAddr address, s32 num_to_wake);
|
|
|
|
/// Signals an address being waited on and increments its value if equal to the value argument.
|
|
ResultCode IncrementAndSignalToAddressIfEqual(VAddr address, s32 value, s32 num_to_wake);
|
|
|
|
/// Signals an address being waited on and modifies its value based on waiting thread count if
|
|
/// equal to the value argument.
|
|
ResultCode ModifyByWaitingCountAndSignalToAddressIfEqual(VAddr address, s32 value,
|
|
s32 num_to_wake);
|
|
|
|
/// Waits on an address if the value passed is less than the argument value,
|
|
/// optionally decrementing.
|
|
ResultCode WaitForAddressIfLessThan(VAddr address, s32 value, s64 timeout,
|
|
bool should_decrement);
|
|
|
|
/// Waits on an address if the value passed is equal to the argument value.
|
|
ResultCode WaitForAddressIfEqual(VAddr address, s32 value, s64 timeout);
|
|
|
|
// Waits on the given address with a timeout in nanoseconds
|
|
ResultCode WaitForAddressImpl(VAddr address, s64 timeout);
|
|
|
|
// Gets the threads waiting on an address.
|
|
std::vector<SharedPtr<Thread>> GetThreadsWaitingOnAddress(VAddr address) const;
|
|
|
|
Core::System& system;
|
|
};
|
|
|
|
} // namespace Kernel
|