mirror of https://github.com/red-prig/fpPS4.git
367 lines
6.4 KiB
Plaintext
367 lines
6.4 KiB
Plaintext
unit game_run;
|
|
|
|
{$mode ObjFPC}{$H+}
|
|
|
|
interface
|
|
|
|
uses
|
|
windows,
|
|
Classes,
|
|
SysUtils,
|
|
Dialogs,
|
|
kern_thr,
|
|
md_sleep,
|
|
md_pipe,
|
|
host_ipc,
|
|
md_host_ipc,
|
|
game_info;
|
|
|
|
type
|
|
TGameRunConfig=record
|
|
hOutput:THandle;
|
|
hError :THandle;
|
|
|
|
fork_proc:Boolean;
|
|
end;
|
|
|
|
TGameProcessSimple=class(TGameProcess)
|
|
Ftd:p_kthread;
|
|
procedure suspend; override;
|
|
procedure resume; override;
|
|
Destructor Destroy; override;
|
|
end;
|
|
|
|
function run_item(const cfg:TGameRunConfig;Item:TGameItem):TGameProcess;
|
|
|
|
implementation
|
|
|
|
uses
|
|
sys_sysinit,
|
|
kern_param,
|
|
kern_thread,
|
|
kern_exec,
|
|
vfs_mountroot,
|
|
sys_crt, //<- init writeln redirect
|
|
sys_tty,
|
|
md_exception, //<- install custom
|
|
|
|
sys_event,
|
|
|
|
kern_proc,
|
|
md_systm,
|
|
|
|
md_game_process,
|
|
|
|
dev_dce,
|
|
display_soft,
|
|
|
|
//internal libs
|
|
ps4_libSceSystemService,
|
|
ps4_libSceUserService,
|
|
ps4_libSceIpmi,
|
|
ps4_libSceMbus,
|
|
ps4_libSceDialogs,
|
|
ps4_libSceAvSetting,
|
|
//internal libs
|
|
|
|
kern_authinfo,
|
|
sys_bootparam,
|
|
subr_backtrace;
|
|
|
|
//
|
|
|
|
procedure TGameProcessSimple.suspend;
|
|
begin
|
|
thread_suspend_all(nil);
|
|
end;
|
|
|
|
procedure TGameProcessSimple.resume;
|
|
begin
|
|
thread_resume_all(nil);
|
|
end;
|
|
|
|
Destructor TGameProcessSimple.Destroy;
|
|
begin
|
|
thread_dec_ref(Ftd);
|
|
inherited;
|
|
end;
|
|
|
|
procedure re_init_tty; register;
|
|
var
|
|
i:Integer;
|
|
begin
|
|
For i:=0 to High(std_tty) do
|
|
begin
|
|
//std_tty[i].t_rd_handle:=GetStdHandle(STD_INPUT_HANDLE);
|
|
//std_tty[i].t_wr_handle:=t_wr_handle;
|
|
//std_tty[i].t_update :=@WakeMainThread;
|
|
end;
|
|
|
|
For i:=0 to High(deci_tty) do
|
|
begin
|
|
//deci_tty[i].t_rd_handle:=GetStdHandle(STD_INPUT_HANDLE);
|
|
//deci_tty[i].t_wr_handle:=t_wr_handle;
|
|
//deci_tty[i].t_update :=@WakeMainThread;
|
|
end;
|
|
|
|
//debug_tty.t_wr_handle:=t_wr_handle;
|
|
//debug_tty.t_update :=@WakeMainThread;
|
|
end;
|
|
|
|
procedure prepare(Item:TGameItem); SysV_ABI_CDecl;
|
|
var
|
|
td:p_kthread;
|
|
err:Integer;
|
|
len:Integer;
|
|
exec:array[0..PATH_MAX] of Char;
|
|
argv:array[0..1] of PChar;
|
|
begin
|
|
//re_init_tty;
|
|
//init_tty:=@re_init_tty;
|
|
|
|
//init all
|
|
sys_init;
|
|
|
|
if (p_host_ipc<>nil) then
|
|
begin
|
|
THostIpcConnect(p_host_ipc).thread_new;
|
|
end;
|
|
|
|
//p_cpuid :=CPUID_NEO_MODE;
|
|
//p_base_ps4_mode:=0;
|
|
//p_neomode :=1;
|
|
|
|
dev_dce.dce_interface:=display_soft.TDisplayHandleSoft;
|
|
|
|
g_appinfo.CUSANAME:=Item.FGameInfo.TitleId;
|
|
//g_appinfo.hasParamSfo
|
|
//g_appinfo.debug_level:=1;
|
|
|
|
Writeln(Item.FGameInfo.Exec);
|
|
Writeln(Item.FMountList.app0);
|
|
Writeln(Item.FMountList.system);
|
|
Writeln(Item.FMountList.data);
|
|
|
|
|
|
|
|
//fs guest host
|
|
err:=vfs_mount_mkdir('ufs','/app0' ,pchar(Item.FMountList.app0 ),nil,0);
|
|
if (err<>0) then
|
|
begin
|
|
print_error_td('error mount "'+Item.FMountList.app0+'" to "/app0" code='+IntToStr(err));
|
|
end;
|
|
|
|
err:=vfs_mount_mkdir('ufs','/system',pchar(Item.FMountList.system),nil,0);
|
|
if (err<>0) then
|
|
begin
|
|
print_error_td('error mount "'+Item.FMountList.system+'" to "/system" code='+IntToStr(err));
|
|
end;
|
|
|
|
err:=vfs_mount_mkdir('ufs','/data' ,pchar(Item.FMountList.data ),nil,0);
|
|
if (err<>0) then
|
|
begin
|
|
print_error_td('error mount "'+Item.FMountList.data+'" to "/data" code='+IntToStr(err));
|
|
end;
|
|
|
|
///argv
|
|
FillChar(exec,SizeOf(exec),0);
|
|
|
|
len:=Length(Item.FGameInfo.Exec);
|
|
if (len>PATH_MAX) then len:=PATH_MAX;
|
|
|
|
Move(pchar(Item.FGameInfo.Exec)^,exec,len);
|
|
|
|
argv[0]:=@exec;
|
|
argv[1]:=nil;
|
|
///argv
|
|
|
|
//unset sys mark
|
|
td:=curkthread;
|
|
td^.td_pflags:=td^.td_pflags and (not TDP_KTHREAD);
|
|
|
|
err:=main_execve(argv[0],@argv[0],nil);
|
|
if (err<>0) then
|
|
begin
|
|
print_error_td('error execve "'+Item.FGameInfo.Exec+'" code='+IntToStr(err));
|
|
end;
|
|
//
|
|
|
|
end;
|
|
|
|
type
|
|
TPCharStream=class(TCustomMemoryStream)
|
|
public
|
|
constructor Create(P:PChar;len:SizeUint); virtual; overload;
|
|
procedure SetNew(P:PChar;len:SizeUint);
|
|
end;
|
|
|
|
constructor TPCharStream.Create(P:PChar;len:SizeUint);
|
|
begin
|
|
inherited Create;
|
|
SetPointer(P,len);
|
|
end;
|
|
|
|
procedure TPCharStream.SetNew(P:PChar;len:SizeUint);
|
|
begin
|
|
SetPosition(0);
|
|
SetPointer(P,len);
|
|
end;
|
|
|
|
procedure fork_process(data:Pointer;size:QWORD); SysV_ABI_CDecl;
|
|
var
|
|
td:p_kthread;
|
|
r:Integer;
|
|
|
|
pipefd:THandle;
|
|
parent:THandle;
|
|
|
|
kipc:THostIpcPipeKERN;
|
|
|
|
mem:TPCharStream;
|
|
Item:TGameItem;
|
|
begin
|
|
mem:=TPCharStream.Create(data,size);
|
|
|
|
mem.Read(pipefd,SizeOf(THandle));
|
|
|
|
Item:=TGameItem.Create;
|
|
Item.Deserialize(mem);
|
|
|
|
mem.Free;
|
|
|
|
//free shared
|
|
md_fork_unshare;
|
|
|
|
parent:=md_pidfd_open(md_getppid);
|
|
|
|
pipefd:=md_pidfd_getfd(parent,pipefd);
|
|
|
|
kipc:=THostIpcPipeKERN.Create;
|
|
kipc.set_pipe(pipefd);
|
|
|
|
p_host_ipc :=kipc;
|
|
p_host_ipc_td:=kipc.Ftd;
|
|
|
|
td:=nil;
|
|
r:=kthread_add(@prepare,Item,@td,0,'[main]');
|
|
Assert(r=0);
|
|
|
|
msleep_td(0);
|
|
end;
|
|
|
|
function run_item(const cfg:TGameRunConfig;Item:TGameItem):TGameProcess;
|
|
var
|
|
r:Integer;
|
|
|
|
kern2mgui:array[0..1] of THandle;
|
|
|
|
fork_info:t_fork_proc;
|
|
|
|
kev:t_kevent;
|
|
|
|
p_mgui_ipc:THostIpcPipeMGUI;
|
|
|
|
s_kern_ipc:THostIpcSimpleKERN;
|
|
s_mgui_ipc:THostIpcSimpleMGUI;
|
|
|
|
mem:TMemoryStream;
|
|
begin
|
|
Result:=nil;
|
|
|
|
SetStdHandle(STD_OUTPUT_HANDLE,cfg.hOutput);
|
|
SetStdHandle(STD_ERROR_HANDLE ,cfg.hError );
|
|
|
|
fork_info:=Default(t_fork_proc);
|
|
|
|
if cfg.fork_proc then
|
|
begin
|
|
Result:=TGameProcessPipe.Create;
|
|
Result.g_fork:=cfg.fork_proc;
|
|
|
|
with TGameProcessPipe(Result) do
|
|
begin
|
|
md_pipe2(@kern2mgui,MD_PIPE_ASYNC0 or MD_PIPE_ASYNC1);
|
|
|
|
p_mgui_ipc:=THostIpcPipeMGUI.Create;
|
|
p_mgui_ipc.set_pipe(kern2mgui[0]);
|
|
|
|
g_ipc:=p_mgui_ipc;
|
|
FChildpip:=kern2mgui[1];
|
|
end;
|
|
|
|
//
|
|
|
|
mem:=TMemoryStream.Create;
|
|
|
|
mem.Write(kern2mgui[1],SizeOf(THandle));
|
|
|
|
Item.Serialize(mem);
|
|
|
|
fork_info.hInput :=GetStdHandle(STD_INPUT_HANDLE);
|
|
fork_info.hOutput:=cfg.hOutput;
|
|
fork_info.hError :=cfg.hError;
|
|
|
|
fork_info.proc:=@fork_process;
|
|
fork_info.data:=mem.Memory;
|
|
fork_info.size:=mem.Size;
|
|
|
|
r:=md_fork_process(fork_info);
|
|
|
|
mem.Free;
|
|
end else
|
|
begin
|
|
Result:=TGameProcessSimple.Create;
|
|
Result.g_fork:=cfg.fork_proc;
|
|
|
|
with TGameProcessSimple(Result) do
|
|
begin
|
|
|
|
s_kern_ipc:=THostIpcSimpleKERN.Create;
|
|
s_mgui_ipc:=THostIpcSimpleMGUI.Create;
|
|
|
|
s_kern_ipc.FDest:=s_mgui_ipc;
|
|
s_mgui_ipc.FDest:=s_kern_ipc;
|
|
|
|
g_ipc:=s_mgui_ipc;
|
|
|
|
p_host_ipc :=s_kern_ipc;
|
|
p_host_ipc_td:=s_kern_ipc.Ftd;
|
|
|
|
Ftd:=nil;
|
|
r:=kthread_add(@prepare,Item,@Ftd,0,'[main]');
|
|
|
|
fork_info.fork_pid:=GetProcessID;
|
|
end;
|
|
|
|
end;
|
|
|
|
if (r<>0) then
|
|
begin
|
|
ShowMessage('error run process code='+IntToStr(r));
|
|
FreeAndNil(Result);
|
|
Exit;
|
|
end;
|
|
|
|
Result.g_proc :=fork_info.hProcess;
|
|
Result.g_p_pid:=fork_info.fork_pid;
|
|
|
|
Result.g_ipc.thread_new;
|
|
|
|
kev.ident :=fork_info.fork_pid;
|
|
kev.filter:=EVFILT_PROC;
|
|
kev.flags :=EV_ADD;
|
|
kev.fflags:=NOTE_EXIT or NOTE_EXEC;
|
|
kev.data :=0;
|
|
kev.udata :=nil;
|
|
|
|
Result.g_ipc.kevent(@kev,1);
|
|
|
|
end;
|
|
|
|
|
|
|
|
end.
|
|
|
|
|
|
|