mirror of
https://github.com/ryujinx-mirror/ryujinx.git
synced 2024-12-13 00:41:06 +01:00
22bacc6188
* Implement some IPC related kernel SVCs properly * Fix BLZ decompression when the segment also has a uncompressed chunck * Set default cpu core on process start from ProgramLoader, remove debug message * Load process capabilities properly on KIPs * Fix a copy/paste error in UnmapPhysicalMemory64 * Implement smarter switching between old and new IPC system to support the old HLE services implementation without the manual switch * Implement RegisterService on sm and AcceptSession (partial) * Misc fixes and improvements on new IPC methods * Move IPC related SVCs into a separate file, and logging on RegisterService (sm) * Some small fixes related to receive list buffers and error cases * Load NSOs using the correct pool partition * Fix corner case on GetMaskFromMinMax where range is 64, doesn't happen in pratice however * Fix send static buffer copy * Session release, implement closing requests on client disconnect * Implement ConnectToPort SVC * KLightSession init
71 lines
1.7 KiB
C#
71 lines
1.7 KiB
C#
using Ryujinx.HLE.HOS.Kernel.Common;
|
|
|
|
namespace Ryujinx.HLE.HOS.Kernel.Ipc
|
|
{
|
|
class KPort : KAutoObject
|
|
{
|
|
public KServerPort ServerPort { get; }
|
|
public KClientPort ClientPort { get; }
|
|
|
|
private long _nameAddress;
|
|
|
|
private ChannelState _state;
|
|
|
|
public bool IsLight { get; private set; }
|
|
|
|
public KPort(Horizon system, int maxSessions, bool isLight, long nameAddress) : base(system)
|
|
{
|
|
ServerPort = new KServerPort(system, this);
|
|
ClientPort = new KClientPort(system, this, maxSessions);
|
|
|
|
IsLight = isLight;
|
|
_nameAddress = nameAddress;
|
|
|
|
_state = ChannelState.Open;
|
|
}
|
|
|
|
public KernelResult EnqueueIncomingSession(KServerSession session)
|
|
{
|
|
KernelResult result;
|
|
|
|
System.CriticalSection.Enter();
|
|
|
|
if (_state == ChannelState.Open)
|
|
{
|
|
ServerPort.EnqueueIncomingSession(session);
|
|
|
|
result = KernelResult.Success;
|
|
}
|
|
else
|
|
{
|
|
result = KernelResult.PortClosed;
|
|
}
|
|
|
|
System.CriticalSection.Leave();
|
|
|
|
return result;
|
|
}
|
|
|
|
public KernelResult EnqueueIncomingLightSession(KLightServerSession session)
|
|
{
|
|
KernelResult result;
|
|
|
|
System.CriticalSection.Enter();
|
|
|
|
if (_state == ChannelState.Open)
|
|
{
|
|
ServerPort.EnqueueIncomingLightSession(session);
|
|
|
|
result = KernelResult.Success;
|
|
}
|
|
else
|
|
{
|
|
result = KernelResult.PortClosed;
|
|
}
|
|
|
|
System.CriticalSection.Leave();
|
|
|
|
return result;
|
|
}
|
|
}
|
|
} |