ref: bbd6a23c4f306339b4a6285cb419b2da339de397
dir: /emu/OpenBSD/os.c/
#include "dat.h" #include "fns.h" #include "error.h" #undef getwd #include <sys/types.h> #include <sys/mman.h> #include <sys/param.h> #include <sys/resource.h> #include <sys/socket.h> #include <sys/time.h> #include <signal.h> #include <time.h> #include <termios.h> #include <sched.h> #include <pwd.h> #include <errno.h> #include <unistd.h> enum { DELETE = 0x7F, NSTACKSPERALLOC = 16, X11STACK= 256*1024 }; char *hosttype = "OpenBSD"; extern int dflag; void trapBUS(int signo, siginfo_t *info, void *context) { if(info) print("trapBUS: signo: %d code: %d addr: %lx\n", info->si_signo, info->si_code, info->si_addr); else print("trapBUS: no info\n"); disfault(nil, "Bus error"); } static void trapUSR1(int signo) { int intwait; USED(signo); intwait = up->intwait; up->intwait = 0; /* clear it to let proc continue in osleave */ if(up->type != Interp) /* Used to unblock pending I/O */ return; if(intwait == 0) /* Not posted so its a sync error */ disfault(nil, Eintr); /* Should never happen */ } static void trapUSR2(int signo) { USED(signo); /* we've done our work of interrupting sigsuspend */ } static void trapILL(int signo) { disfault(nil, "Illegal instruction"); } static void trapSEGV(int signo) { disfault(nil, "Segmentation violation"); } static void trapFPE(int signo) { char buf[64]; USED(signo); snprint(buf, sizeof(buf), "sys: fp: exception status=%.4lux", getfsr()); disfault(nil, buf); } static sigset_t initmask; static void setsigs(void) { struct sigaction act; sigset_t mask; memset(&act, 0 , sizeof(act)); sigemptyset(&initmask); signal(SIGPIPE, SIG_IGN); /* prevent signal when devcmd child exits */ if(signal(SIGTERM, SIG_IGN) != SIG_IGN) signal(SIGTERM, cleanexit); act.sa_handler = trapUSR1; act.sa_mask = initmask; sigaction(SIGUSR1, &act, nil); act.sa_handler = trapUSR2; sigaction(SIGUSR2, &act, nil); sigemptyset(&mask); sigaddset(&mask, SIGUSR2); sigaddset(&initmask, SIGUSR2); sigprocmask(SIG_BLOCK, &mask, NULL); /* * prevent Zombies forming when any process terminates */ act.sa_sigaction = 0; act.sa_flags |= SA_NOCLDWAIT; if(sigaction(SIGCHLD, &act, nil)) panic("sigaction SIGCHLD"); if(sflag == 0) { act.sa_sigaction = trapBUS; act.sa_flags |= SA_SIGINFO; if(sigaction(SIGBUS, &act, nil)) panic("sigaction SIGBUS"); act.sa_handler = trapILL; if(sigaction(SIGILL, &act, nil)) panic("sigaction SIGBUS"); act.sa_handler = trapSEGV; if(sigaction(SIGSEGV, &act, nil)) panic("sigaction SIGSEGV"); act.sa_handler = trapFPE; if(sigaction(SIGFPE, &act, nil)) panic("sigaction SIGFPE"); if(sigaddset(&initmask, SIGINT) == -1) panic("sigaddset"); } if(sigprocmask(SIG_BLOCK, &initmask, nil)!= 0) panic("sigprocmask"); } void oslongjmp(void *regs, osjmpbuf env, int val) { USED(regs); siglongjmp(env, val); } struct termios tinit; static void termset(void) { struct termios t; tcgetattr(0, &t); tinit = t; t.c_lflag &= ~(ICANON|ECHO|ISIG); t.c_cc[VMIN] = 1; t.c_cc[VTIME] = 0; tcsetattr(0, TCSANOW, &t); } static void termrestore(void) { tcsetattr(0, TCSANOW, &tinit); } void cleanexit(int x) { USED(x); if(up->intwait) { up->intwait = 0; return; } if(dflag == 0) termrestore(); kill(0, SIGKILL); exit(0); } void osreboot(char *file, char **argv) { if(dflag == 0) termrestore(); execvp(file, argv); panic("reboot failure"); } int gidnobody= -1, uidnobody= -1; void getnobody() { struct passwd *pwd; if(pwd = getpwnam("nobody")) { uidnobody = pwd->pw_uid; gidnobody = pwd->pw_gid; } } void libinit(char *imod) { struct passwd *pw; Proc *p; char sys[64]; setsid(); gethostname(sys, sizeof(sys)); kstrdup(&ossysname, sys); getnobody(); if(dflag == 0) termset(); setsigs(); p = newproc(); kprocinit(p); pw = getpwuid(getuid()); if(pw != nil) kstrdup(&eve, pw->pw_name); else print("cannot getpwuid\n"); p->env->uid = getuid(); p->env->gid = getgid(); emuinit(imod); } int readkbd(void) { int n; char buf[1]; n = read(0, buf, sizeof(buf)); if(n < 0) print("keyboard close (n=%d, %s)\n", n, strerror(errno)); if(n <= 0) pexit("keyboard thread", 0); switch(buf[0]) { case '\r': buf[0] = '\n'; break; case DELETE: cleanexit(0); break; } return buf[0]; } /* * Return an abitrary millisecond clock time */ long osmillisec(void) { static long sec0 = 0, usec0; struct timeval t; if(gettimeofday(&t,(struct timezone*)0)<0) return 0; if(sec0==0) { sec0 = t.tv_sec; usec0 = t.tv_usec; } return (t.tv_sec-sec0)*1000+(t.tv_usec-usec0+500)/1000; } int limbosleep(ulong milsec) { return osmillisleep(milsec); } /* * Return the time since the epoch in nanoseconds and microseconds * The epoch is defined at 1 Jan 1970 */ vlong osnsec(void) { struct timeval t; gettimeofday(&t, nil); return (vlong)t.tv_sec*1000000000L + t.tv_usec*1000; } vlong osusectime(void) { struct timeval t; gettimeofday(&t, nil); return (vlong)t.tv_sec * 1000000 + t.tv_usec; } int osmillisleep(ulong milsec) { struct timespec time; time.tv_sec = milsec / 1000; time.tv_nsec = (milsec % 1000) * 1000000; nanosleep(&time, 0); return 0; } int segflush(void *p, ulong n) { return mprotect(p, n, PROT_EXEC|PROT_READ|PROT_WRITE); }