mirror of
https://git.code.sf.net/p/quake/quakeforge
synced 2024-11-14 00:40:55 +00:00
097d44e270
If Sys_Shutdown gets called twice, particularly if a shutdown callback hangs and the program is killed with INT or QUIT, shutdown_list would be in an invalid state. Thus, get the required data (function pointer and data pointer) from the list element, then unlink the element before calling the function. This ensures that a reinvocation of Sys_Shutdown continues from the next callback or ends cleanly. Fixes a segfault when killing testsound while using the oss output (it hangs on shutdown).
1033 lines
22 KiB
C
1033 lines
22 KiB
C
/*
|
|
sys.c
|
|
|
|
virtual filesystem functions
|
|
|
|
Copyright (C) 1996-1997 Id Software, Inc.
|
|
|
|
This program is free software; you can redistribute it and/or
|
|
modify it under the terms of the GNU General Public License
|
|
as published by the Free Software Foundation; either version 2
|
|
of the License, or (at your option) any later version.
|
|
|
|
This program is distributed in the hope that it will be useful,
|
|
but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
|
|
|
|
See the GNU General Public License for more details.
|
|
|
|
You should have received a copy of the GNU General Public License
|
|
along with this program; if not, write to:
|
|
|
|
Free Software Foundation, Inc.
|
|
59 Temple Place - Suite 330
|
|
Boston, MA 02111-1307, USA
|
|
|
|
*/
|
|
#ifdef HAVE_CONFIG_H
|
|
# include "config.h"
|
|
#endif
|
|
|
|
#ifdef HAVE_STRING_H
|
|
# include <string.h>
|
|
#endif
|
|
#ifdef HAVE_STRINGS_H
|
|
# include <strings.h>
|
|
#endif
|
|
#ifdef HAVE_UNISTD_H
|
|
# include <unistd.h>
|
|
#endif
|
|
#ifdef HAVE_LIMITS_H
|
|
# include <limits.h>
|
|
#endif
|
|
#ifdef HAVE_CONIO_H
|
|
# include <conio.h>
|
|
#endif
|
|
#ifdef HAVE_IO_H
|
|
# include <io.h>
|
|
#endif
|
|
#ifdef HAVE_WINDOWS_H
|
|
# include "winquake.h"
|
|
# include "shlobj.h"
|
|
#endif
|
|
#ifdef HAVE_SYS_MMAN_H
|
|
# include <sys/mman.h>
|
|
#endif
|
|
#ifdef HAVE_SYS_SELECT_H
|
|
# include <sys/select.h>
|
|
#endif
|
|
#ifdef HAVE_PWD_H
|
|
# include <pwd.h>
|
|
#endif
|
|
|
|
#include <signal.h>
|
|
#include <setjmp.h>
|
|
#include <errno.h>
|
|
#include <fcntl.h>
|
|
#include <stdarg.h>
|
|
#include <time.h>
|
|
#include <sys/types.h>
|
|
#include <sys/stat.h>
|
|
#ifdef HAVE_SYS_TIME_H
|
|
#include <sys/time.h>
|
|
#endif
|
|
#include <sys/types.h>
|
|
|
|
#ifdef HAVE_DIRECT_H
|
|
#include <direct.h>
|
|
#endif
|
|
|
|
#include "qfalloca.h"
|
|
|
|
#include "QF/alloc.h"
|
|
#include "QF/cmd.h"
|
|
#include "QF/cvar.h"
|
|
#include "QF/dstring.h"
|
|
#include "QF/mathlib.h"
|
|
#include "QF/sys.h"
|
|
#include "QF/quakefs.h"
|
|
#include "QF/va.h"
|
|
|
|
#include "compat.h"
|
|
|
|
static void Sys_StdPrintf (const char *fmt, va_list args) __attribute__((format(PRINTF, 1, 0)));
|
|
static void Sys_ErrPrintf (const char *fmt, va_list args) __attribute__((format(PRINTF, 1, 0)));
|
|
|
|
VISIBLE cvar_t *sys_nostdout;
|
|
VISIBLE cvar_t *sys_extrasleep;
|
|
cvar_t *sys_dead_sleep;
|
|
cvar_t *sys_sleep;
|
|
|
|
int sys_checksum;
|
|
|
|
static sys_printf_t sys_std_printf_function = Sys_StdPrintf;
|
|
static sys_printf_t sys_err_printf_function = Sys_ErrPrintf;
|
|
|
|
typedef struct shutdown_list_s {
|
|
struct shutdown_list_s *next;
|
|
void (*func) (void *);
|
|
void *data;
|
|
} shutdown_list_t;
|
|
|
|
typedef struct error_handler_s {
|
|
struct error_handler_s *next;
|
|
sys_error_t func;
|
|
void *data;
|
|
} error_handler_t;
|
|
|
|
static shutdown_list_t *shutdown_list;
|
|
|
|
static error_handler_t *error_handler_freelist;
|
|
static error_handler_t *error_handler;
|
|
|
|
#ifndef _WIN32
|
|
static int do_stdin = 1;
|
|
qboolean stdin_ready;
|
|
#endif
|
|
|
|
/* The translation table between the graphical font and plain ASCII --KB */
|
|
VISIBLE const char sys_char_map[256] = {
|
|
0, '#', '#', '#', '#', '.', '#', '#',
|
|
'#', 9, 10, '#', ' ', 13, '.', '.',
|
|
'[', ']', '0', '1', '2', '3', '4', '5',
|
|
'6', '7', '8', '9', '.', '<', '=', '>',
|
|
' ', '!', '"', '#', '$', '%', '&','\'',
|
|
'(', ')', '*', '+', ',', '-', '.', '/',
|
|
'0', '1', '2', '3', '4', '5', '6', '7',
|
|
'8', '9', ':', ';', '<', '=', '>', '?',
|
|
'@', 'A', 'B', 'C', 'D', 'E', 'F', 'G',
|
|
'H', 'I', 'J', 'K', 'L', 'M', 'N', 'O',
|
|
'P', 'Q', 'R', 'S', 'T', 'U', 'V', 'W',
|
|
'X', 'Y', 'Z', '[','\\', ']', '^', '_',
|
|
'`', 'a', 'b', 'c', 'd', 'e', 'f', 'g',
|
|
'h', 'i', 'j', 'k', 'l', 'm', 'n', 'o',
|
|
'p', 'q', 'r', 's', 't', 'u', 'v', 'w',
|
|
'x', 'y', 'z', '{', '|', '}', '~', '<',
|
|
|
|
'<', '=', '>', '#', '#', '.', '#', '#',
|
|
'#', '#', ' ', '#', ' ', '>', '.', '.',
|
|
'[', ']', '0', '1', '2', '3', '4', '5',
|
|
'6', '7', '8', '9', '.', '<', '=', '>',
|
|
' ', '!', '"', '#', '$', '%', '&','\'',
|
|
'(', ')', '*', '+', ',', '-', '.', '/',
|
|
'0', '1', '2', '3', '4', '5', '6', '7',
|
|
'8', '9', ':', ';', '<', '=', '>', '?',
|
|
'@', 'A', 'B', 'C', 'D', 'E', 'F', 'G',
|
|
'H', 'I', 'J', 'K', 'L', 'M', 'N', 'O',
|
|
'P', 'Q', 'R', 'S', 'T', 'U', 'V', 'W',
|
|
'X', 'Y', 'Z', '[','\\', ']', '^', '_',
|
|
'`', 'a', 'b', 'c', 'd', 'e', 'f', 'g',
|
|
'h', 'i', 'j', 'k', 'l', 'm', 'n', 'o',
|
|
'p', 'q', 'r', 's', 't', 'u', 'v', 'w',
|
|
'x', 'y', 'z', '{', '|', '}', '~', '<'
|
|
};
|
|
|
|
#define MAXPRINTMSG 4096
|
|
|
|
|
|
#ifndef USE_INTEL_ASM
|
|
void
|
|
Sys_MaskFPUExceptions (void)
|
|
{
|
|
}
|
|
#endif
|
|
|
|
int
|
|
Sys_isdir (const char *path)
|
|
{
|
|
int res;
|
|
#ifdef _WIN32
|
|
struct _stat st;
|
|
res = _stat (path, &st);
|
|
#else
|
|
struct stat st;
|
|
res = stat (path, &st);
|
|
#endif
|
|
if (res < 0) {
|
|
// assume any error means path does not refer to a directory. certainly
|
|
// true if errno == ENOENT
|
|
return 0;
|
|
}
|
|
return S_ISDIR (st.st_mode);
|
|
}
|
|
|
|
int
|
|
Sys_mkdir (const char *path)
|
|
{
|
|
#ifdef HAVE_MKDIR
|
|
# ifdef _WIN32
|
|
if (mkdir (path) == 0)
|
|
return 0;
|
|
# else
|
|
if (mkdir (path, 0777) == 0)
|
|
return 0;
|
|
# endif
|
|
#else
|
|
# ifdef HAVE__MKDIR
|
|
if (_mkdir (path) == 0)
|
|
return 0;
|
|
# else
|
|
# error do not know how to make directories
|
|
# endif
|
|
#endif
|
|
return -1;
|
|
}
|
|
|
|
VISIBLE int
|
|
Sys_FileExists (const char *path)
|
|
{
|
|
#ifdef HAVE_ACCESS
|
|
if (access (path, R_OK) == 0)
|
|
return 0;
|
|
#else
|
|
# ifdef HAVE__ACCESS
|
|
if (_access (path, R_OK) == 0)
|
|
return 0;
|
|
# else
|
|
int fd;
|
|
|
|
if ((fd = open (path, O_RDONLY)) >= 0) {
|
|
close (fd);
|
|
return 0;
|
|
}
|
|
# endif
|
|
#endif
|
|
return -1;
|
|
}
|
|
|
|
/*
|
|
Sys_SetPrintf
|
|
|
|
for want of a better name, but it sets the function pointer for the
|
|
actual implementation of Sys_Printf.
|
|
*/
|
|
VISIBLE sys_printf_t
|
|
Sys_SetStdPrintf (sys_printf_t func)
|
|
{
|
|
sys_printf_t prev = sys_std_printf_function;
|
|
sys_std_printf_function = func;
|
|
return prev;
|
|
}
|
|
|
|
VISIBLE sys_printf_t
|
|
Sys_SetErrPrintf (sys_printf_t func)
|
|
{
|
|
sys_printf_t prev = sys_err_printf_function;
|
|
sys_err_printf_function = func;
|
|
return prev;
|
|
}
|
|
|
|
void
|
|
Sys_Print (FILE *stream, const char *fmt, va_list args)
|
|
{
|
|
static dstring_t *msg;
|
|
unsigned char *p;
|
|
|
|
if (!msg)
|
|
msg = dstring_new ();
|
|
|
|
dvsprintf (msg, fmt, args);
|
|
|
|
if (stream == stderr) {
|
|
#ifdef _WIN32
|
|
MessageBox (NULL, msg->str, "Fatal Error", 0 /* MB_OK */ );
|
|
#endif
|
|
fputs ("Fatal Error: ", stream);
|
|
}
|
|
|
|
/* translate to ASCII instead of printing [xx] --KB */
|
|
for (p = (unsigned char *) msg->str; *p; p++)
|
|
putc (sys_char_map[*p], stream);
|
|
|
|
if (stream == stderr) {
|
|
fputs ("\n", stream);
|
|
}
|
|
fflush (stream);
|
|
}
|
|
|
|
static void
|
|
Sys_StdPrintf (const char *fmt, va_list args)
|
|
{
|
|
if (sys_nostdout && sys_nostdout->int_val)
|
|
return;
|
|
Sys_Print (stdout, fmt, args);
|
|
}
|
|
|
|
static void
|
|
Sys_ErrPrintf (const char *fmt, va_list args)
|
|
{
|
|
Sys_Print (stderr, fmt, args);
|
|
}
|
|
|
|
VISIBLE void
|
|
Sys_Printf (const char *fmt, ...)
|
|
{
|
|
va_list args;
|
|
va_start (args, fmt);
|
|
sys_std_printf_function (fmt, args);
|
|
va_end (args);
|
|
}
|
|
|
|
VISIBLE void
|
|
Sys_MaskPrintf (int mask, const char *fmt, ...)
|
|
{
|
|
va_list args;
|
|
|
|
if (!developer || !(developer->int_val & mask))
|
|
return;
|
|
va_start (args, fmt);
|
|
sys_std_printf_function (fmt, args);
|
|
va_end (args);
|
|
}
|
|
|
|
VISIBLE int64_t
|
|
Sys_LongTime (void)
|
|
{
|
|
static qboolean first = true;
|
|
#ifdef _WIN32
|
|
# if 0
|
|
static DWORD starttime;
|
|
DWORD now;
|
|
|
|
now = timeGetTime ();
|
|
|
|
if (first) {
|
|
first = false;
|
|
starttime = now;
|
|
return 0.0;
|
|
}
|
|
|
|
if (now < starttime) // wrapped?
|
|
return (now / 1000.0) + (LONG_MAX - starttime / 1000.0);
|
|
|
|
if (now - starttime == 0)
|
|
return 0.0;
|
|
|
|
return (now - starttime) / 1000.0;
|
|
# else
|
|
// MH's solution combining timeGetTime for stability and
|
|
// QueryPerformanceCounter for precision.
|
|
static int64_t qpcfreq = 0;
|
|
static int64_t currqpccount = 0;
|
|
static int64_t lastqpccount = 0;
|
|
static int64_t qpcfudge = 0;
|
|
int64_t currtime = 0;
|
|
static int64_t lasttime = 0;
|
|
static int64_t starttime = 0;
|
|
|
|
if (first) {
|
|
timeBeginPeriod (1);
|
|
starttime = lasttime = timeGetTime ();
|
|
QueryPerformanceFrequency ((LARGE_INTEGER *) &qpcfreq);
|
|
QueryPerformanceCounter ((LARGE_INTEGER *) &lastqpccount);
|
|
first = false;
|
|
return 0;
|
|
}
|
|
|
|
// get the current time from both counters
|
|
currtime = timeGetTime ();
|
|
QueryPerformanceCounter ((LARGE_INTEGER *) &currqpccount);
|
|
|
|
if (currtime != lasttime) {
|
|
// requery the frequency in case it changes (which it can on multicore
|
|
// machines)
|
|
QueryPerformanceFrequency ((LARGE_INTEGER *) &qpcfreq);
|
|
|
|
// store back times and calc a fudge factor as timeGetTime can
|
|
// overshoot on a sub-millisecond scale
|
|
qpcfudge = (( (currqpccount - lastqpccount) * 1000000 / qpcfreq))
|
|
- ((currtime - lasttime) * 1000);
|
|
lastqpccount = currqpccount;
|
|
lasttime = currtime;
|
|
} else {
|
|
qpcfudge = 0;
|
|
}
|
|
|
|
// the final time is the base from timeGetTime plus an addition from QPC
|
|
return (((currtime - starttime) * 1000)
|
|
+ ((currqpccount - lastqpccount) * 1000000 / qpcfreq) + qpcfudge);
|
|
# endif
|
|
#else
|
|
struct timeval tp;
|
|
struct timezone tzp;
|
|
int64_t now;
|
|
static int64_t start_time;
|
|
|
|
gettimeofday (&tp, &tzp);
|
|
|
|
now = tp.tv_sec * 1000000 + tp.tv_usec;
|
|
|
|
if (first) {
|
|
first = false;
|
|
start_time = now;
|
|
}
|
|
|
|
return now - start_time;
|
|
#endif
|
|
}
|
|
|
|
VISIBLE double
|
|
Sys_DoubleTime (void)
|
|
{
|
|
return (__INT64_C (4294967296000000) + Sys_LongTime ()) / 1e6;
|
|
}
|
|
|
|
VISIBLE void
|
|
Sys_TimeOfDay (date_t *date)
|
|
{
|
|
struct tm *newtime;
|
|
time_t long_time;
|
|
|
|
time (&long_time);
|
|
newtime = localtime (&long_time);
|
|
|
|
date->day = newtime->tm_mday;
|
|
date->mon = newtime->tm_mon;
|
|
date->year = newtime->tm_year + 1900;
|
|
date->hour = newtime->tm_hour;
|
|
date->min = newtime->tm_min;
|
|
date->sec = newtime->tm_sec;
|
|
strftime (date->str, 128, "%a %b %d, %H:%M %Y", newtime);
|
|
}
|
|
|
|
VISIBLE void
|
|
Sys_MakeCodeWriteable (uintptr_t startaddr, size_t length)
|
|
{
|
|
#ifdef _WIN32
|
|
DWORD flOldProtect;
|
|
|
|
if (!VirtualProtect
|
|
((LPVOID) startaddr, length, PAGE_EXECUTE_READWRITE, &flOldProtect))
|
|
Sys_Error ("Protection change failed");
|
|
#else
|
|
# ifdef HAVE_MPROTECT
|
|
int r;
|
|
long psize = Sys_PageSize ();
|
|
unsigned long endaddr = startaddr + length;
|
|
startaddr &= ~(psize - 1);
|
|
endaddr = (endaddr + psize - 1) & ~(psize - 1);
|
|
// systems with mprotect but not getpagesize (or similar) probably don't
|
|
// need to page align the arguments to mprotect (eg, QNX)
|
|
r = mprotect ((char *) startaddr, endaddr - startaddr,
|
|
PROT_EXEC | PROT_READ | PROT_WRITE);
|
|
|
|
if (r < 0)
|
|
Sys_Error ("Protection change failed");
|
|
# endif
|
|
#endif
|
|
}
|
|
|
|
VISIBLE void
|
|
Sys_Init_Cvars (void)
|
|
{
|
|
sys_nostdout = Cvar_Get ("sys_nostdout", "0", CVAR_NONE, NULL,
|
|
"Set to disable std out");
|
|
sys_extrasleep = Cvar_Get ("sys_extrasleep", "0", CVAR_NONE, NULL,
|
|
"Set to cause whatever amount delay in "
|
|
"microseconds you want. Mostly "
|
|
"useful to generate simulated bad "
|
|
"connections.");
|
|
sys_dead_sleep = Cvar_Get ("sys_dead_sleep", "0", CVAR_NONE, NULL,
|
|
"When set, the server gets NO cpu if no "
|
|
"clients are connected and there's no other "
|
|
"activity. *MIGHT* cause problems with some "
|
|
"mods.");
|
|
sys_sleep = Cvar_Get ("sys_sleep", "8", CVAR_NONE, NULL, "Sleep how long "
|
|
"in seconds between checking for connections. "
|
|
"Minimum is 0, maximum is 13");
|
|
}
|
|
|
|
void
|
|
Sys_Shutdown (void)
|
|
{
|
|
shutdown_list_t *t;
|
|
|
|
while (shutdown_list) {
|
|
void (*func) (void *) = shutdown_list->func;
|
|
void *data = shutdown_list->data;
|
|
t = shutdown_list;
|
|
shutdown_list = shutdown_list->next;
|
|
free (t);
|
|
|
|
func (data);
|
|
}
|
|
}
|
|
|
|
VISIBLE void
|
|
Sys_Quit (void)
|
|
{
|
|
Sys_Shutdown ();
|
|
|
|
exit (0);
|
|
}
|
|
|
|
VISIBLE void
|
|
Sys_PushErrorHandler (sys_error_t func, void *data)
|
|
{
|
|
error_handler_t *eh;
|
|
ALLOC (16, error_handler_t, error_handler, eh);
|
|
eh->func = func;
|
|
eh->data = data;
|
|
eh->next = error_handler;
|
|
error_handler = eh;
|
|
}
|
|
|
|
VISIBLE void
|
|
Sys_PopErrorHandler (void)
|
|
{
|
|
error_handler_t *eh;
|
|
|
|
if (!error_handler) {
|
|
Sys_Error ("Sys_PopErrorHandler: no handler to pop");
|
|
}
|
|
eh = error_handler;
|
|
error_handler = eh->next;
|
|
FREE (error_handler, eh);
|
|
}
|
|
|
|
|
|
VISIBLE void
|
|
Sys_Error (const char *error, ...)
|
|
{
|
|
va_list args;
|
|
va_list tmp_args;
|
|
static int in_sys_error = 0;
|
|
|
|
if (in_sys_error) {
|
|
ssize_t cnt;
|
|
const char *msg = "\nSys_Error: recursive error condition\n";
|
|
cnt = write (2, msg, strlen (msg));
|
|
if (cnt < 0)
|
|
perror ("write failed");
|
|
abort ();
|
|
}
|
|
in_sys_error = 1;
|
|
|
|
va_start (args, error);
|
|
va_copy (tmp_args, args);
|
|
sys_err_printf_function (error, args);
|
|
va_end (args);
|
|
|
|
if (error_handler) {
|
|
error_handler->func (error_handler->data);
|
|
}
|
|
|
|
Sys_Shutdown ();
|
|
|
|
if (sys_err_printf_function != Sys_ErrPrintf) {
|
|
// print the message again using the default error printer to increase
|
|
// the chances of the error being seen.
|
|
va_copy (args, tmp_args);
|
|
Sys_ErrPrintf (error, args);
|
|
}
|
|
|
|
exit (1);
|
|
}
|
|
|
|
VISIBLE void
|
|
Sys_RegisterShutdown (void (*func) (void *), void *data)
|
|
{
|
|
shutdown_list_t *p;
|
|
if (!func)
|
|
return;
|
|
p = malloc (sizeof (*p));
|
|
if (!p)
|
|
Sys_Error ("Sys_RegisterShutdown: insufficient memory");
|
|
p->func = func;
|
|
p->data = data;
|
|
p->next = shutdown_list;
|
|
shutdown_list = p;
|
|
}
|
|
|
|
VISIBLE int
|
|
Sys_TimeID (void) //FIXME I need a new name, one that doesn't make me feel 3 feet thick
|
|
{
|
|
int val;
|
|
#ifdef HAVE_GETUID
|
|
val = ((int) (getpid () + getuid () * 1000) * time (NULL)) & 0xffff;
|
|
#else
|
|
val = ((int) (Sys_DoubleTime () * 1000) * time (NULL)) & 0xffff;
|
|
#endif
|
|
return val;
|
|
}
|
|
|
|
VISIBLE void
|
|
Sys_PageIn (void *ptr, size_t size)
|
|
{
|
|
//may or may not be useful in linux #ifdef _WIN32
|
|
byte *x;
|
|
size_t m, n;
|
|
|
|
// touch all the memory to make sure it's there. The 16-page skip is to
|
|
// keep Win 95 from thinking we're trying to page ourselves in (we are
|
|
// doing that, of course, but there's no reason we shouldn't)
|
|
x = (byte *) ptr;
|
|
|
|
for (n = 0; n < 4; n++) {
|
|
for (m = 0; m < (size - 16 * 0x1000); m += 4) {
|
|
sys_checksum += *(int *) &x[m];
|
|
sys_checksum += *(int *) &x[m + 16 * 0x1000];
|
|
}
|
|
}
|
|
//#endif
|
|
}
|
|
|
|
VISIBLE long
|
|
Sys_PageSize (void)
|
|
{
|
|
#ifdef _WIN32
|
|
SYSTEM_INFO si;
|
|
GetSystemInfo (&si);
|
|
return si.dwPageSize;
|
|
#else
|
|
# ifdef HAVE__SC_PAGESIZE
|
|
return sysconf (_SC_PAGESIZE);
|
|
# else
|
|
# ifdef HAVE_GETPAGESIZE
|
|
return getpagesize ();
|
|
# endif
|
|
# endif
|
|
#endif
|
|
}
|
|
|
|
VISIBLE void *
|
|
Sys_Alloc (size_t size)
|
|
{
|
|
size_t page_size = Sys_PageSize ();
|
|
size_t page_mask = page_size - 1;
|
|
size = (size + page_mask) & ~page_mask;
|
|
#ifdef _WIN32
|
|
return VirtualAlloc (0, size, MEM_COMMIT | MEM_RESERVE, PAGE_READWRITE);
|
|
#else
|
|
return mmap (0, size, PROT_READ | PROT_WRITE, MAP_PRIVATE | MAP_ANONYMOUS,
|
|
-1, 0);
|
|
#endif
|
|
}
|
|
|
|
VISIBLE void
|
|
Sys_DebugLog (const char *file, const char *fmt, ...)
|
|
{
|
|
va_list args;
|
|
static dstring_t *data;
|
|
int fd;
|
|
|
|
if (!data)
|
|
data = dstring_newstr ();
|
|
|
|
va_start (args, fmt);
|
|
dvsprintf (data, fmt, args);
|
|
va_end (args);
|
|
if ((fd = open (file, O_WRONLY | O_CREAT | O_APPEND, 0644)) >= 0) {
|
|
if (write (fd, data->str, data->size - 1) != (ssize_t) (data->size - 1))
|
|
Sys_Printf ("Error writing %s: %s\n", file, strerror(errno));
|
|
close (fd);
|
|
}
|
|
}
|
|
|
|
VISIBLE int
|
|
Sys_CheckInput (int idle, int net_socket)
|
|
{
|
|
fd_set fdset;
|
|
int res;
|
|
struct timeval _timeout;
|
|
struct timeval *timeout = 0;
|
|
|
|
#ifdef _WIN32
|
|
int sleep_msec;
|
|
// Now we want to give some processing time to other applications,
|
|
// such as qw_client, running on this machine.
|
|
sleep_msec = sys_sleep->int_val;
|
|
if (sleep_msec > 0) {
|
|
if (sleep_msec > 13)
|
|
sleep_msec = 13;
|
|
Sleep (sleep_msec);
|
|
}
|
|
|
|
_timeout.tv_sec = 0;
|
|
_timeout.tv_usec = net_socket < 0 ? 0 : 20;
|
|
#else
|
|
_timeout.tv_sec = 0;
|
|
_timeout.tv_usec = net_socket < 0 ? 0 : 2000;
|
|
#endif
|
|
// select on the net socket and stdin
|
|
// the only reason we have a timeout at all is so that if the last
|
|
// connected client times out, the message would not otherwise
|
|
// be printed until the next event.
|
|
FD_ZERO (&fdset);
|
|
#ifndef _WIN32
|
|
if (do_stdin)
|
|
FD_SET (0, &fdset);
|
|
#endif
|
|
if (net_socket >= 0)
|
|
FD_SET (((unsigned) net_socket), &fdset); // cast needed for windows
|
|
|
|
if (!idle || !sys_dead_sleep->int_val)
|
|
timeout = &_timeout;
|
|
|
|
res = select (max (net_socket, 0) + 1, &fdset, NULL, NULL, timeout);
|
|
if (res == 0 || res == -1)
|
|
return 0;
|
|
#ifndef _WIN32
|
|
stdin_ready = FD_ISSET (0, &fdset);
|
|
#endif
|
|
return 1;
|
|
}
|
|
|
|
/*
|
|
Sys_ConsoleInput
|
|
|
|
Checks for a complete line of text typed in at the console, then forwards
|
|
it to the host command processor
|
|
*/
|
|
VISIBLE const char *
|
|
Sys_ConsoleInput (void)
|
|
{
|
|
static char text[256];
|
|
static int len = 0;
|
|
|
|
#ifdef _WIN32
|
|
int c;
|
|
|
|
// read a line out
|
|
while (_kbhit ()) {
|
|
c = _getch ();
|
|
putch (c);
|
|
if (c == '\r') {
|
|
text[len] = 0;
|
|
putch ('\n');
|
|
len = 0;
|
|
return text;
|
|
}
|
|
if (c == 8) {
|
|
if (len) {
|
|
putch (' ');
|
|
putch (c);
|
|
len--;
|
|
text[len] = 0;
|
|
}
|
|
continue;
|
|
}
|
|
text[len] = c;
|
|
len++;
|
|
if (len < (int) sizeof (text))
|
|
text[len] = 0;
|
|
else {
|
|
// buffer is full
|
|
len = 0;
|
|
text[sizeof (text) - 1] = 0;
|
|
return text;
|
|
}
|
|
}
|
|
|
|
return NULL;
|
|
#else
|
|
if (!stdin_ready || !do_stdin)
|
|
return NULL; // the select didn't say it was ready
|
|
stdin_ready = false;
|
|
|
|
len = read (0, text, sizeof (text));
|
|
if (len == 0) {
|
|
// end of file
|
|
do_stdin = 0;
|
|
return NULL;
|
|
}
|
|
if (len < 1)
|
|
return NULL;
|
|
text[len - 1] = 0; // rip off the \n and terminate
|
|
|
|
return text;
|
|
#endif
|
|
}
|
|
|
|
static jmp_buf aiee_abort;
|
|
|
|
typedef struct sh_stack_s {
|
|
struct sh_stack_s *next;
|
|
int (*signal_hook)(int,void*);
|
|
void *data;
|
|
} sh_stack_t;
|
|
|
|
static sh_stack_t *sh_stack;
|
|
static sh_stack_t *free_sh;
|
|
static int (*signal_hook)(int,void*);
|
|
static void *signal_hook_data;
|
|
|
|
VISIBLE void
|
|
Sys_PushSignalHook (int (*hook)(int, void *), void *data)
|
|
{
|
|
sh_stack_t *s;
|
|
|
|
if (free_sh) {
|
|
s = free_sh;
|
|
} else {
|
|
s = malloc (sizeof (sh_stack_t));
|
|
s->next = 0;
|
|
}
|
|
s->signal_hook = signal_hook;
|
|
s->data = signal_hook_data;
|
|
signal_hook = hook;
|
|
signal_hook_data = data;
|
|
|
|
free_sh = s->next;
|
|
s->next = sh_stack;
|
|
sh_stack = s;
|
|
}
|
|
|
|
VISIBLE void
|
|
Sys_PopSignalHook (void)
|
|
{
|
|
if (sh_stack) {
|
|
sh_stack_t *s;
|
|
|
|
signal_hook = sh_stack->signal_hook;
|
|
signal_hook_data = sh_stack->data;
|
|
|
|
s = sh_stack->next;
|
|
sh_stack->next = free_sh;
|
|
free_sh = sh_stack;
|
|
sh_stack = s;
|
|
}
|
|
}
|
|
|
|
static void __attribute__((noreturn))
|
|
aiee (int sig)
|
|
{
|
|
printf ("AIEE, signal %d in shutdown code, giving up\n", sig);
|
|
#ifdef _WIN32
|
|
longjmp (aiee_abort, 1);
|
|
#else
|
|
siglongjmp (aiee_abort, 1);
|
|
#endif
|
|
}
|
|
|
|
#ifdef _WIN32
|
|
static void
|
|
signal_handler (int sig)
|
|
{
|
|
int volatile recover = 0; // volatile for longjump
|
|
static volatile int in_signal_handler = 0;
|
|
|
|
if (in_signal_handler) {
|
|
aiee (sig);
|
|
}
|
|
printf ("Received signal %d, exiting...\n", sig);
|
|
|
|
switch (sig) {
|
|
case SIGINT:
|
|
case SIGTERM:
|
|
signal (SIGINT, SIG_DFL);
|
|
signal (SIGTERM, SIG_DFL);
|
|
Sys_Quit ();
|
|
default:
|
|
if (!setjmp (aiee_abort)) {
|
|
if (signal_hook)
|
|
recover = signal_hook (sig, signal_hook_data);
|
|
Sys_Shutdown ();
|
|
}
|
|
|
|
if (!recover) {
|
|
signal (SIGILL, SIG_DFL);
|
|
signal (SIGSEGV, SIG_DFL);
|
|
signal (SIGFPE, SIG_DFL);
|
|
}
|
|
}
|
|
}
|
|
|
|
static void
|
|
hook_signlas (void)
|
|
{
|
|
// catch signals
|
|
signal (SIGINT, signal_handler);
|
|
signal (SIGILL, signal_handler);
|
|
signal (SIGSEGV, signal_handler);
|
|
signal (SIGTERM, signal_handler);
|
|
signal (SIGFPE, signal_handler);
|
|
}
|
|
#else
|
|
|
|
static struct sigaction save_hup;
|
|
static struct sigaction save_quit;
|
|
static struct sigaction save_trap;
|
|
static struct sigaction save_iot;
|
|
static struct sigaction save_bus;
|
|
static struct sigaction save_int;
|
|
static struct sigaction save_ill;
|
|
static struct sigaction save_segv;
|
|
static struct sigaction save_term;
|
|
static struct sigaction save_fpe;
|
|
|
|
static void
|
|
signal_handler (int sig, siginfo_t *info, void *ucontext)
|
|
{
|
|
int volatile recover = 0; // volatile for longjump
|
|
static volatile int in_signal_handler = 0;
|
|
|
|
if (in_signal_handler) {
|
|
aiee (sig);
|
|
}
|
|
printf ("Received signal %d, exiting...\n", sig);
|
|
|
|
switch (sig) {
|
|
case SIGINT:
|
|
case SIGTERM:
|
|
case SIGHUP:
|
|
sigaction (SIGHUP, &save_hup, 0);
|
|
sigaction (SIGINT, &save_int, 0);
|
|
sigaction (SIGTERM, &save_term, 0);
|
|
Sys_Quit ();
|
|
default:
|
|
if (!sigsetjmp (aiee_abort, 1)) {
|
|
if (signal_hook)
|
|
recover = signal_hook (sig, signal_hook_data);
|
|
Sys_Shutdown ();
|
|
}
|
|
|
|
if (!recover) {
|
|
sigaction (SIGQUIT, &save_quit, 0);
|
|
sigaction (SIGTRAP, &save_trap, 0);
|
|
sigaction (SIGIOT, &save_iot, 0);
|
|
sigaction (SIGBUS, &save_bus, 0);
|
|
sigaction (SIGILL, &save_ill, 0);
|
|
sigaction (SIGSEGV, &save_segv, 0);
|
|
sigaction (SIGFPE, &save_fpe, 0);
|
|
}
|
|
}
|
|
}
|
|
|
|
static void
|
|
hook_signlas (void)
|
|
{
|
|
// catch signals
|
|
struct sigaction action = {};
|
|
action.sa_flags = SA_SIGINFO;
|
|
action.sa_sigaction = signal_handler;
|
|
#ifndef _WIN32
|
|
sigaction (SIGHUP, &action, &save_hup);
|
|
sigaction (SIGQUIT, &action, &save_quit);
|
|
sigaction (SIGTRAP, &action, &save_trap);
|
|
sigaction (SIGIOT, &action, &save_iot);
|
|
sigaction (SIGBUS, &action, &save_bus);
|
|
#endif
|
|
sigaction (SIGINT, &action, &save_int);
|
|
sigaction (SIGILL, &action, &save_ill);
|
|
sigaction (SIGSEGV, &action, &save_segv);
|
|
sigaction (SIGTERM, &action, &save_term);
|
|
sigaction (SIGFPE, &action, &save_fpe);
|
|
}
|
|
#endif
|
|
|
|
VISIBLE void
|
|
Sys_Init (void)
|
|
{
|
|
hook_signlas ();
|
|
|
|
Cvar_Init_Hash ();
|
|
Cmd_Init_Hash ();
|
|
Cvar_Init ();
|
|
Sys_Init_Cvars ();
|
|
|
|
Cmd_Init ();
|
|
}
|
|
|
|
VISIBLE int
|
|
Sys_CreatePath (const char *path)
|
|
{
|
|
char *ofs;
|
|
char *e_path = alloca (strlen (path) + 1);
|
|
|
|
strcpy (e_path, path);
|
|
for (ofs = e_path + 1; *ofs; ofs++) {
|
|
if (*ofs == '/') {
|
|
*ofs = 0;
|
|
if (!Sys_isdir (e_path)) {
|
|
// create the directory
|
|
if (Sys_mkdir (e_path) == -1)
|
|
return -1;
|
|
}
|
|
*ofs = '/';
|
|
}
|
|
}
|
|
return 0;
|
|
}
|
|
|
|
char *
|
|
Sys_ExpandSquiggle (const char *path)
|
|
{
|
|
const char *home = 0;
|
|
#ifdef _WIN32
|
|
char userpath[MAX_PATH]; // sigh, why can't windows give the size?
|
|
#else
|
|
# ifdef HAVE_GETUID
|
|
struct passwd *pwd_ent;
|
|
# endif
|
|
#endif
|
|
|
|
if (strncmp (path, "~/", 2) != 0) {
|
|
return strdup (path);
|
|
}
|
|
|
|
#ifdef _WIN32
|
|
if (SHGetFolderPathA (0, CSIDL_LOCAL_APPDATA, 0, 0, userpath) == S_OK) {
|
|
home = userpath;
|
|
}
|
|
// LordHavoc: first check HOME to duplicate previous version behavior
|
|
// (also handy if someone wants it elsewhere than their windows directory)
|
|
if (!home)
|
|
home = getenv ("HOME");
|
|
if (!home || !home[0])
|
|
home = getenv ("USERPROFILE");
|
|
if (!home || !home[0])
|
|
home = 0;
|
|
#else
|
|
# ifdef HAVE_GETUID
|
|
if ((pwd_ent = getpwuid (getuid ()))) {
|
|
home = pwd_ent->pw_dir;
|
|
} else
|
|
home = getenv ("HOME");
|
|
# endif
|
|
#endif
|
|
|
|
if (!home)
|
|
home = ".";
|
|
return nva ("%s%s", home, path + 1); // skip leading ~
|
|
}
|