mirror of
https://github.com/RKX1209/nsemu.git
synced 2024-05-11 00:55:24 -04:00
173 lines
5.5 KiB
C++
173 lines
5.5 KiB
C++
/* nsemu - LGPL - Copyright 2018 rkx1209<rkx1209dev@gmail.com> */
|
|
#define DEFINE_STUBS
|
|
#include "Nsemu.hpp"
|
|
#include "IpcStubs.hpp"
|
|
|
|
void IpcMessage::ParseMessage() {
|
|
uint32_t *buf = (uint32_t *) raw_ptr;
|
|
type = buf[0] & 0xFFFF;
|
|
x_cnt = (buf[0] >> 16) & 0xF;
|
|
a_cnt = (buf[0] >> 20) & 0xF;
|
|
b_cnt = (buf[0] >> 24) & 0xF;
|
|
w_cnt = buf[1] & 0x3FF;
|
|
has_c = ((buf[1] >> 10) & 0x3) != 0;
|
|
// domainHandle = 0;
|
|
// domainCommand = 0;
|
|
bool has_hd = (buf[1] >> 31) == 1; //Handle descriptor enabled?
|
|
int pos = 2;
|
|
if (has_hd) {
|
|
uint32_t hd = buf[pos++];
|
|
has_pid = hd & 1;
|
|
copy_cnt = (hd >> 1) & 0xf;
|
|
move_cnt = hd >> 5;
|
|
if(has_pid) {
|
|
pid = *((uint64_t *) &buf[pos]);
|
|
pos += 2;
|
|
}
|
|
copy_off = pos * 4;
|
|
pos += copy_cnt;
|
|
move_off = pos * 4;
|
|
pos += move_cnt;
|
|
}
|
|
desc_off = pos * 4;
|
|
pos += x_cnt * 2;
|
|
pos += a_cnt * 3;
|
|
pos += b_cnt * 3;
|
|
raw_off = pos * 4;
|
|
if(pos & 3)
|
|
pos += 4 - (pos & 3);
|
|
if (is_domainobj && type == 4) {
|
|
domain_cmd = buf[pos] & 0xff;
|
|
domain_handle = buf[pos + 1];
|
|
pos += 4;
|
|
}
|
|
payload_off = pos * 4;
|
|
cmd_id = GetData<uint32_t>(0);
|
|
}
|
|
|
|
void IpcMessage::GenBuf(unsigned int _move_cnt, unsigned int _copy_cnt, unsigned int data_bytes) {
|
|
move_cnt = _move_cnt;
|
|
copy_cnt = _copy_cnt;
|
|
uint32_t *obuf = (uint32_t *) raw_ptr;
|
|
obuf[0] = 0;
|
|
ns_print("is_domain: %u, move: %u, copy: %u, bytes: %u\n", is_domainobj, move_cnt, copy_cnt, data_bytes);
|
|
if(move_cnt != 0 || copy_cnt != 0) {
|
|
obuf[1] = ((move_cnt != 0 && !is_domainobj) || copy_cnt != 0) ? (1U << 31) : 0;
|
|
obuf[2] = (copy_cnt << 1) | ((is_domainobj ? 0 : move_cnt) << 5);
|
|
}
|
|
auto pos = 2 + (((move_cnt != 0 && !is_domainobj) || copy_cnt != 0) ? (1 + move_cnt + copy_cnt) : 0);
|
|
auto start = pos;
|
|
if(pos & 3)
|
|
pos += 4 - (pos & 3);
|
|
if(is_domainobj) {
|
|
obuf[pos] = move_cnt;
|
|
pos += 4;
|
|
}
|
|
realdata_off = is_domainobj ? move_cnt << 2 : 0;
|
|
auto data_words = (realdata_off >> 2) + (data_bytes & 3) ? (data_bytes >> 2) + 1 : (data_bytes >> 2);
|
|
|
|
obuf[1] |= 4 + (is_domainobj ? 4 : 0) + 4 + data_words;
|
|
|
|
payload_off = pos * 4;
|
|
obuf[pos] = byte_swap32_str("SFCO");
|
|
}
|
|
|
|
void IpcMessage::SetErrorCode() {
|
|
uint32_t *buf = (uint32_t *) raw_ptr;
|
|
if (buf) {
|
|
buf[(payload_off >> 2) + 2] = error_code;
|
|
}
|
|
}
|
|
|
|
namespace IPC {
|
|
|
|
static SmService sm;
|
|
std::unordered_map<std::string, IpcService *> services;
|
|
bool is_domainobj = false;
|
|
//std::unordered_map<uint32_t, KObject *> handles;
|
|
|
|
#define SERVICE(str, iface) do { services[str] = new iface(); } while(0)
|
|
|
|
void InitIPC() {
|
|
sm.Initialize();
|
|
SERVICE_MAPPING(); // From IpcStubs.hpp
|
|
}
|
|
|
|
uint32_t ConnectToPort(std::string name) {
|
|
if (name != "sm:") {
|
|
ns_abort("Attempt to connect to unknown service\n");
|
|
}
|
|
return NewHandle(&sm);
|
|
}
|
|
|
|
uint32_t ProcMessage(IpcService *handler, uint8_t buf[]) {
|
|
uint8_t obuf[0x100];
|
|
memset(obuf, 0, 0x100);
|
|
IpcMessage req(buf, is_domainobj);
|
|
req.ParseMessage();
|
|
IpcMessage resp(obuf, is_domainobj);
|
|
uint32_t ret = 0xf601;
|
|
|
|
//#if 0
|
|
ns_print("Incoming message\n");
|
|
bindump(buf, 0x100);
|
|
//#endif
|
|
switch(req.type) {
|
|
case 2: //Close
|
|
resp.GenBuf(0, 0, 0);
|
|
resp.error_code = 0;
|
|
ret = 0x25a0b;
|
|
break;
|
|
case 4: //Normal
|
|
ret = handler->Dispatch(&req, &resp);
|
|
break;
|
|
case 5: //Control
|
|
switch(req.cmd_id) {
|
|
case 0: // ConvertSessionToDomain
|
|
debug_print("IPC: ConvertSessionToDomain\n");
|
|
resp.GenBuf(0, 0, 4);
|
|
is_domainobj = true;
|
|
*resp.GetDataPointer<uint32_t*>(8) = handler->handle;
|
|
resp.error_code = 0;
|
|
break;
|
|
case 2: // DuplicateSession
|
|
debug_print("DuplicateSession\n");
|
|
is_domainobj = false;
|
|
resp.GenBuf(1, 0, 0);
|
|
resp.SetMove(0, NewHandle(handler));
|
|
resp.error_code = 0;
|
|
ret = 0;
|
|
break;
|
|
case 3: // QueryPointerBufferSize
|
|
debug_print("QueryPointerBufferSize\n");
|
|
resp.GenBuf(0, 0, 4);
|
|
*resp.GetDataPointer<uint32_t *>(8) = 0x500;
|
|
resp.error_code = 0;
|
|
ret = 0;
|
|
break;
|
|
case 4: // DuplicateSession
|
|
debug_print("DuplicateSessionEx\n");
|
|
is_domainobj = false;
|
|
resp.GenBuf(1, 0, 0);
|
|
resp.SetMove(0, NewHandle(handler));
|
|
resp.error_code = 0;
|
|
ret = 0;
|
|
break;
|
|
default:
|
|
ns_abort("Unknown cmdId to control %u\n", req.cmd_id);
|
|
}
|
|
}
|
|
if (ret == 0) {
|
|
resp.SetErrorCode();
|
|
memcpy (buf, obuf, 0x100);
|
|
}
|
|
//#if 0
|
|
ns_print("Out message\n");
|
|
bindump(buf, 0x100);
|
|
//#endif
|
|
|
|
return ret;
|
|
}
|
|
|
|
};
|