mirrors/cosmopolitan
1
0
Fork 0
mirror of https://github.com/jart/cosmopolitan.git synced 2025-05-28 00:02:28 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

Polyfill SIGCHLD on the New Technology

Browse source 
redbean will now cleanup child processes properly. New accounting
information is available too, such as page faults and memory usage. The
way it works is Cosmopolitan Libc samples the process collection on
entry into read() and poll() to see if SIGCHLD needs to be raised.

This change also fixes an issue with chibicc /tmp cleanup. There was
also a regression in MODE=dbg because STL needed ASAN runtime support.
This commit is contained in:
Justine Tunney 2022-03-22 21:04:08 -07:00
parent c23b6ecc31
commit 393ca4be40
18 changed files with 182 additions and 44 deletions
Download patch file Download diff file Expand all files Collapse all files

17
tool/net/redbean.c
View file

@ -506,6 +506,13 @@ static long ParseInt(const char *s) {
return strtol(s, 0, 0);
}
static void SyncSharedMemory(void) {
if (IsWindows() && !uniprocess) {
LOGIFNEG1(
msync(shared, ROUNDUP(sizeof(struct Shared), FRAMESIZE), MS_ASYNC));
}
}
static void *FreeLater(void *p) {
if (p) {
if (++freelist.n > freelist.c) {
@ -1163,6 +1170,7 @@ static void ReportWorkerResources(int pid, struct rusage *ru) {
}
static void HandleWorkerExit(int pid, int ws, struct rusage *ru) {
SyncSharedMemory();
LockInc(&shared->c.connectionshandled);
AddRusage(&shared->children, ru);
ReportWorkerExit(pid, ws);
@ -1170,6 +1178,7 @@ static void HandleWorkerExit(int pid, int ws, struct rusage *ru) {
if (hasonprocessdestroy) {
LuaOnProcessDestroy(pid);
}
SyncSharedMemory();
}
static void WaitAll(void) {
@ -2670,7 +2679,7 @@ static void LaunchBrowser(const char *path) {
sigaction(SIGQUIT, &savequit, 0);
sigprocmask(SIG_SETMASK, &savemask, 0);
execv(prog, (char *const[]){prog, u, 0});
_exit(127);
_Exit(127);
}
while (wait4(pid, &ws, 0, 0) == -1) {
CHECK_EQ(EINTR, errno);
@ -6243,7 +6252,7 @@ static bool StreamResponse(char *p) {
return true;
}
static bool HandleMessageAcutal(void) {
static bool HandleMessageActual(void) {
int rc;
char *p;
if ((rc = ParseHttpMessage(&msg, inbuf.p, amtread)) != -1) {
@ -6300,8 +6309,9 @@ static bool HandleMessageAcutal(void) {
static bool HandleMessage(void) {
bool r;
ishandlingrequest = true;
r = HandleMessageAcutal();
r = HandleMessageActual();
ishandlingrequest = false;
SyncSharedMemory();
return r;
}
@ -6812,6 +6822,7 @@ static wontreturn void ExitWorker(void) {
MemDestroy();
CheckForMemoryLeaks();
}
SyncSharedMemory();
_Exit(0);
}