2000-10-19 11:12:44 +08:00
|
|
|
/* miscfuncs.cc: misc funcs that don't belong anywhere else
|
|
|
|
|
2013-01-21 12:34:52 +08:00
|
|
|
Copyright 1996, 1997, 1998, 1999, 2000, 2001, 2002, 2003, 2004, 2005, 2006,
|
2014-02-09 04:57:27 +08:00
|
|
|
2007, 2008, 2009, 2010, 2011, 2012, 2013, 2014 Red Hat, Inc.
|
2000-10-19 11:12:44 +08:00
|
|
|
|
|
|
|
This file is part of Cygwin.
|
|
|
|
|
|
|
|
This software is a copyrighted work licensed under the terms of the
|
|
|
|
Cygwin license. Please consult the file "CYGWIN_LICENSE" for
|
|
|
|
details. */
|
|
|
|
|
|
|
|
#include "winsup.h"
|
2008-04-08 00:15:45 +08:00
|
|
|
#include "miscfuncs.h"
|
2002-08-30 23:47:10 +08:00
|
|
|
#include <sys/uio.h>
|
|
|
|
#include <assert.h>
|
2007-12-12 20:12:24 +08:00
|
|
|
#include <alloca.h>
|
2002-08-30 23:47:10 +08:00
|
|
|
#include <limits.h>
|
2011-05-16 02:49:40 +08:00
|
|
|
#include <sys/param.h>
|
2007-12-12 20:12:24 +08:00
|
|
|
#include <wchar.h>
|
2005-07-03 10:40:30 +08:00
|
|
|
#include "cygtls.h"
|
2007-12-12 20:12:24 +08:00
|
|
|
#include "ntdll.h"
|
2011-05-16 02:49:40 +08:00
|
|
|
#include "path.h"
|
|
|
|
#include "fhandler.h"
|
|
|
|
#include "dtable.h"
|
|
|
|
#include "cygheap.h"
|
2011-05-20 15:23:11 +08:00
|
|
|
#include "pinfo.h"
|
|
|
|
#include "exception.h"
|
2012-12-22 05:30:56 +08:00
|
|
|
#include "sigproc.h"
|
2000-10-19 11:12:44 +08:00
|
|
|
|
2001-11-30 14:19:58 +08:00
|
|
|
long tls_ix = -1;
|
2000-10-19 11:12:44 +08:00
|
|
|
|
2013-04-23 17:44:36 +08:00
|
|
|
const unsigned char case_folded_lower[] = {
|
2000-10-19 11:12:44 +08:00
|
|
|
0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15,
|
|
|
|
16, 17, 18, 19, 20, 21, 22, 23, 24, 25, 26, 27, 28, 29, 30, 31,
|
|
|
|
32, '!', '"', '#', '$', '%', '&', 39, '(', ')', '*', '+', ',', '-', '.', '/',
|
|
|
|
'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', '[', 92, ']', '^', '_',
|
|
|
|
'`', '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', '{', '|', '}', '~', 127,
|
|
|
|
128, 129, 130, 131, 132, 133, 134, 135, 136, 137, 138, 139, 140, 141, 142, 143,
|
|
|
|
144, 145, 146, 147, 148, 149, 150, 151, 152, 153, 154, 155, 156, 157, 158, 159,
|
|
|
|
160, 161, 162, 163, 164, 165, 166, 167, 168, 169, 170, 171, 172, 173, 174, 175,
|
|
|
|
176, 177, 178, 179, 180, 181, 182, 183, 184, 185, 186, 187, 188, 189, 190, 191,
|
|
|
|
192, 193, 194, 195, 196, 197, 198, 199, 200, 201, 202, 203, 204, 205, 206, 207,
|
|
|
|
208, 209, 210, 211, 212, 213, 214, 215, 216, 217, 218, 219, 220, 221, 222, 223,
|
|
|
|
224, 225, 226, 227, 228, 229, 230, 231, 232, 233, 234, 235, 236, 237, 238, 239,
|
|
|
|
240, 241, 242, 243, 244, 245, 246, 247, 248, 249, 250, 251, 252, 253, 254, 255
|
|
|
|
};
|
|
|
|
|
2013-04-23 17:44:36 +08:00
|
|
|
const unsigned char case_folded_upper[] = {
|
2000-10-19 11:12:44 +08:00
|
|
|
0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15,
|
|
|
|
16, 17, 18, 19, 20, 21, 22, 23, 24, 25, 26, 27, 28, 29, 30, 31,
|
|
|
|
32, '!', '"', '#', '$', '%', '&', 39, '(', ')', '*', '+', ',', '-', '.', '/',
|
|
|
|
'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', '[', 92, ']', '^', '_',
|
|
|
|
'`', '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', '{', '|', '}', '~', 127,
|
|
|
|
128, 129, 130, 131, 132, 133, 134, 135, 136, 137, 138, 139, 140, 141, 142, 143,
|
|
|
|
144, 145, 146, 147, 148, 149, 150, 151, 152, 153, 154, 155, 156, 157, 158, 159,
|
|
|
|
160, 161, 162, 163, 164, 165, 166, 167, 168, 169, 170, 171, 172, 173, 174, 175,
|
|
|
|
176, 177, 178, 179, 180, 181, 182, 183, 184, 185, 186, 187, 188, 189, 190, 191,
|
|
|
|
192, 193, 194, 195, 196, 197, 198, 199, 200, 201, 202, 203, 204, 205, 206, 207,
|
|
|
|
208, 209, 210, 211, 212, 213, 214, 215, 216, 217, 218, 219, 220, 221, 222, 223,
|
|
|
|
224, 225, 226, 227, 228, 229, 230, 231, 232, 233, 234, 235, 236, 237, 238, 239,
|
|
|
|
240, 241, 242, 243, 244, 245, 246, 247, 248, 249, 250, 251, 252, 253, 254, 255
|
|
|
|
};
|
|
|
|
|
2013-04-23 17:44:36 +08:00
|
|
|
const char isalpha_array[] = {
|
2002-10-31 05:05:18 +08:00
|
|
|
0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
|
|
|
|
0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
|
|
|
|
0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
|
|
|
|
0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
|
|
|
|
0,0x20,0x20,0x20,0x20,0x20,0x20,0x20,0x20,0x20,0x20,0x20,0x20,0x20,0x20,0x20,
|
|
|
|
0x20,0x20,0x20,0x20,0x20,0x20,0x20,0x20,0x20,0x20,0x20, 0, 0, 0, 0, 0,
|
|
|
|
0,0x20,0x20,0x20,0x20,0x20,0x20,0x20,0x20,0x20,0x20,0x20,0x20,0x20,0x20,0x20,
|
|
|
|
0x20,0x20,0x20,0x20,0x20,0x20,0x20,0x20,0x20,0x20,0x20, 0, 0, 0, 0, 0,
|
|
|
|
0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
|
|
|
|
0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
|
|
|
|
0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
|
|
|
|
0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
|
|
|
|
0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
|
|
|
|
0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
|
|
|
|
0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
|
|
|
|
0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0
|
|
|
|
};
|
|
|
|
|
2007-12-12 20:12:24 +08:00
|
|
|
extern "C" int __stdcall
|
|
|
|
cygwin_wcscasecmp (const wchar_t *ws, const wchar_t *wt)
|
|
|
|
{
|
|
|
|
UNICODE_STRING us, ut;
|
2000-10-19 11:12:44 +08:00
|
|
|
|
2007-12-12 20:12:24 +08:00
|
|
|
RtlInitUnicodeString (&us, ws);
|
|
|
|
RtlInitUnicodeString (&ut, wt);
|
|
|
|
return RtlCompareUnicodeString (&us, &ut, TRUE);
|
|
|
|
}
|
2002-10-31 05:05:18 +08:00
|
|
|
|
2000-10-19 11:12:44 +08:00
|
|
|
extern "C" int __stdcall
|
2007-12-12 20:12:24 +08:00
|
|
|
cygwin_wcsncasecmp (const wchar_t *ws, const wchar_t *wt, size_t n)
|
2000-10-19 11:12:44 +08:00
|
|
|
{
|
2007-12-12 20:12:24 +08:00
|
|
|
UNICODE_STRING us, ut;
|
2008-02-01 21:11:57 +08:00
|
|
|
size_t ls = 0, lt = 0;
|
|
|
|
|
|
|
|
while (ws[ls] && ls < n)
|
|
|
|
++ls;
|
|
|
|
RtlInitCountedUnicodeString (&us, ws, ls * sizeof (WCHAR));
|
|
|
|
while (wt[lt] && lt < n)
|
|
|
|
++lt;
|
|
|
|
RtlInitCountedUnicodeString (&ut, wt, lt * sizeof (WCHAR));
|
2007-12-12 20:12:24 +08:00
|
|
|
return RtlCompareUnicodeString (&us, &ut, TRUE);
|
|
|
|
}
|
2000-10-19 11:12:44 +08:00
|
|
|
|
2007-12-12 20:12:24 +08:00
|
|
|
extern "C" int __stdcall
|
|
|
|
cygwin_strcasecmp (const char *cs, const char *ct)
|
|
|
|
{
|
|
|
|
UNICODE_STRING us, ut;
|
|
|
|
ULONG len;
|
|
|
|
|
|
|
|
len = (strlen (cs) + 1) * sizeof (WCHAR);
|
|
|
|
RtlInitEmptyUnicodeString (&us, (PWCHAR) alloca (len), len);
|
2008-02-26 02:32:23 +08:00
|
|
|
us.Length = sys_mbstowcs (us.Buffer, us.MaximumLength, cs) * sizeof (WCHAR);
|
2007-12-12 20:12:24 +08:00
|
|
|
len = (strlen (ct) + 1) * sizeof (WCHAR);
|
|
|
|
RtlInitEmptyUnicodeString (&ut, (PWCHAR) alloca (len), len);
|
2008-02-26 02:32:23 +08:00
|
|
|
ut.Length = sys_mbstowcs (ut.Buffer, ut.MaximumLength, ct) * sizeof (WCHAR);
|
2007-12-12 20:12:24 +08:00
|
|
|
return RtlCompareUnicodeString (&us, &ut, TRUE);
|
2000-10-19 11:12:44 +08:00
|
|
|
}
|
|
|
|
|
|
|
|
extern "C" int __stdcall
|
2007-12-12 20:12:24 +08:00
|
|
|
cygwin_strncasecmp (const char *cs, const char *ct, size_t n)
|
2000-10-19 11:12:44 +08:00
|
|
|
{
|
2007-12-12 20:12:24 +08:00
|
|
|
UNICODE_STRING us, ut;
|
|
|
|
ULONG len;
|
2008-02-01 21:11:57 +08:00
|
|
|
size_t ls = 0, lt = 0;
|
|
|
|
|
|
|
|
while (cs[ls] && ls < n)
|
|
|
|
++ls;
|
2008-07-15 03:58:16 +08:00
|
|
|
len = (ls + 1) * sizeof (WCHAR);
|
2007-12-12 20:12:24 +08:00
|
|
|
RtlInitEmptyUnicodeString (&us, (PWCHAR) alloca (len), len);
|
2008-07-15 03:58:16 +08:00
|
|
|
us.Length = sys_mbstowcs (us.Buffer, ls + 1, cs, ls) * sizeof (WCHAR);
|
2008-02-01 21:11:57 +08:00
|
|
|
while (ct[lt] && lt < n)
|
|
|
|
++lt;
|
2008-07-15 03:58:16 +08:00
|
|
|
len = (lt + 1) * sizeof (WCHAR);
|
2007-12-12 20:12:24 +08:00
|
|
|
RtlInitEmptyUnicodeString (&ut, (PWCHAR) alloca (len), len);
|
2008-07-15 03:58:16 +08:00
|
|
|
ut.Length = sys_mbstowcs (ut.Buffer, lt + 1, ct, lt) * sizeof (WCHAR);
|
2007-12-12 20:12:24 +08:00
|
|
|
return RtlCompareUnicodeString (&us, &ut, TRUE);
|
|
|
|
}
|
2000-10-19 11:12:44 +08:00
|
|
|
|
2014-08-19 02:24:06 +08:00
|
|
|
extern "C" char *
|
|
|
|
strlwr (char *string)
|
2000-10-19 11:12:44 +08:00
|
|
|
{
|
2007-12-12 20:12:24 +08:00
|
|
|
UNICODE_STRING us;
|
|
|
|
size_t len = (strlen (string) + 1) * sizeof (WCHAR);
|
|
|
|
|
|
|
|
us.MaximumLength = len; us.Buffer = (PWCHAR) alloca (len);
|
2008-02-26 02:32:23 +08:00
|
|
|
us.Length = sys_mbstowcs (us.Buffer, len, string) * sizeof (WCHAR)
|
2007-12-12 20:12:24 +08:00
|
|
|
- sizeof (WCHAR);
|
|
|
|
RtlDowncaseUnicodeString (&us, &us, FALSE);
|
|
|
|
sys_wcstombs (string, len / sizeof (WCHAR), us.Buffer);
|
|
|
|
return string;
|
|
|
|
}
|
2000-10-19 11:12:44 +08:00
|
|
|
|
2014-08-19 02:24:06 +08:00
|
|
|
extern "C" char *
|
|
|
|
strupr (char *string)
|
2007-12-12 20:12:24 +08:00
|
|
|
{
|
|
|
|
UNICODE_STRING us;
|
|
|
|
size_t len = (strlen (string) + 1) * sizeof (WCHAR);
|
|
|
|
|
|
|
|
us.MaximumLength = len; us.Buffer = (PWCHAR) alloca (len);
|
2008-02-26 02:32:23 +08:00
|
|
|
us.Length = sys_mbstowcs (us.Buffer, len, string) * sizeof (WCHAR)
|
2007-12-12 20:12:24 +08:00
|
|
|
- sizeof (WCHAR);
|
|
|
|
RtlUpcaseUnicodeString (&us, &us, FALSE);
|
|
|
|
sys_wcstombs (string, len / sizeof (WCHAR), us.Buffer);
|
|
|
|
return string;
|
2000-10-19 11:12:44 +08:00
|
|
|
}
|
2001-06-28 10:19:57 +08:00
|
|
|
|
2013-05-01 09:20:37 +08:00
|
|
|
int __reg2
|
2004-02-25 18:54:31 +08:00
|
|
|
check_invalid_virtual_addr (const void *s, unsigned sz)
|
|
|
|
{
|
|
|
|
MEMORY_BASIC_INFORMATION mbuf;
|
2004-02-26 19:32:20 +08:00
|
|
|
const void *end;
|
2004-02-25 18:54:31 +08:00
|
|
|
|
2004-02-26 19:32:20 +08:00
|
|
|
for (end = (char *) s + sz; s < end;
|
|
|
|
s = (char *) mbuf.BaseAddress + mbuf.RegionSize)
|
2004-02-25 18:54:31 +08:00
|
|
|
if (!VirtualQuery (s, &mbuf, sizeof mbuf))
|
|
|
|
return EINVAL;
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
2005-07-03 10:40:30 +08:00
|
|
|
static char __attribute__ ((noinline))
|
|
|
|
dummytest (volatile char *p)
|
2002-08-30 23:47:10 +08:00
|
|
|
{
|
2005-07-03 10:40:30 +08:00
|
|
|
return *p;
|
2002-08-30 23:47:10 +08:00
|
|
|
}
|
2007-08-02 22:21:53 +08:00
|
|
|
|
2002-08-30 23:47:10 +08:00
|
|
|
ssize_t
|
2005-07-03 10:40:30 +08:00
|
|
|
check_iovec (const struct iovec *iov, int iovcnt, bool forwrite)
|
2002-08-30 23:47:10 +08:00
|
|
|
{
|
2014-04-23 23:26:14 +08:00
|
|
|
if (iovcnt < 0 || iovcnt > IOV_MAX)
|
2002-08-30 23:47:10 +08:00
|
|
|
{
|
|
|
|
set_errno (EINVAL);
|
|
|
|
return -1;
|
|
|
|
}
|
|
|
|
|
2014-08-22 17:21:33 +08:00
|
|
|
__try
|
|
|
|
{
|
2002-08-30 23:47:10 +08:00
|
|
|
|
2014-08-22 17:21:33 +08:00
|
|
|
size_t tot = 0;
|
2002-08-30 23:47:10 +08:00
|
|
|
|
2014-08-22 17:21:33 +08:00
|
|
|
while (iovcnt != 0)
|
2002-08-30 23:47:10 +08:00
|
|
|
{
|
2014-08-22 17:21:33 +08:00
|
|
|
if (iov->iov_len > SSIZE_MAX || (tot += iov->iov_len) > SSIZE_MAX)
|
|
|
|
{
|
|
|
|
set_errno (EINVAL);
|
|
|
|
__leave;
|
|
|
|
}
|
2002-08-30 23:47:10 +08:00
|
|
|
|
2014-08-22 17:21:33 +08:00
|
|
|
volatile char *p = ((char *) iov->iov_base) + iov->iov_len - 1;
|
|
|
|
if (!iov->iov_len)
|
|
|
|
/* nothing to do */;
|
|
|
|
else if (!forwrite)
|
|
|
|
*p = dummytest (p);
|
|
|
|
else
|
|
|
|
dummytest (p);
|
2002-08-30 23:47:10 +08:00
|
|
|
|
2014-08-22 17:21:33 +08:00
|
|
|
iov++;
|
|
|
|
iovcnt--;
|
|
|
|
}
|
2002-08-30 23:47:10 +08:00
|
|
|
|
2014-08-22 17:21:33 +08:00
|
|
|
assert (tot <= SSIZE_MAX);
|
2002-08-30 23:47:10 +08:00
|
|
|
|
2014-08-22 17:21:33 +08:00
|
|
|
return (ssize_t) tot;
|
|
|
|
}
|
|
|
|
__except (EFAULT)
|
|
|
|
__endtry
|
|
|
|
return -1;
|
2002-08-30 23:47:10 +08:00
|
|
|
}
|
|
|
|
|
2013-06-09 00:39:52 +08:00
|
|
|
/* Try hard to schedule another thread.
|
|
|
|
Remember not to call this in a lock condition or you'll potentially
|
|
|
|
suffer starvation. */
|
2010-03-13 07:13:48 +08:00
|
|
|
void
|
|
|
|
yield ()
|
2002-11-14 03:36:12 +08:00
|
|
|
{
|
2011-07-07 14:21:24 +08:00
|
|
|
int prio = GetThreadPriority (GetCurrentThread ());
|
|
|
|
SetThreadPriority (GetCurrentThread (), THREAD_PRIORITY_IDLE);
|
2013-06-09 00:39:52 +08:00
|
|
|
/* MSDN implies that SleepEx will force scheduling of other threads.
|
|
|
|
Unlike SwitchToThread() the documentation does not mention other
|
|
|
|
cpus so, presumably (hah!), this + using a lower priority will
|
|
|
|
stall this thread temporarily and cause another to run.
|
|
|
|
(stackoverflow and others seem to confirm that setting this thread
|
|
|
|
to a lower priority and calling Sleep with a 0 paramenter will
|
|
|
|
have this desired effect) */
|
|
|
|
Sleep (0L);
|
2011-07-07 14:21:24 +08:00
|
|
|
SetThreadPriority (GetCurrentThread (), prio);
|
2002-11-14 03:36:12 +08:00
|
|
|
}
|
2005-01-26 06:45:11 +08:00
|
|
|
|
|
|
|
/* Get a default value for the nice factor. When changing these values,
|
|
|
|
have a look into the below function nice_to_winprio. The values must
|
|
|
|
match the layout of the static "priority" array. */
|
|
|
|
int
|
|
|
|
winprio_to_nice (DWORD prio)
|
|
|
|
{
|
|
|
|
switch (prio)
|
|
|
|
{
|
|
|
|
case REALTIME_PRIORITY_CLASS:
|
|
|
|
return -20;
|
|
|
|
case HIGH_PRIORITY_CLASS:
|
|
|
|
return -16;
|
|
|
|
case ABOVE_NORMAL_PRIORITY_CLASS:
|
|
|
|
return -8;
|
|
|
|
case NORMAL_PRIORITY_CLASS:
|
|
|
|
return 0;
|
|
|
|
case BELOW_NORMAL_PRIORITY_CLASS:
|
|
|
|
return 8;
|
|
|
|
case IDLE_PRIORITY_CLASS:
|
|
|
|
return 16;
|
|
|
|
}
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
|
|
|
/* Get a Win32 priority matching the incoming nice factor. The incoming
|
|
|
|
nice is limited to the interval [-NZERO,NZERO-1]. */
|
2005-02-14 02:17:29 +08:00
|
|
|
DWORD
|
2005-01-26 06:45:11 +08:00
|
|
|
nice_to_winprio (int &nice)
|
|
|
|
{
|
2013-04-23 17:44:36 +08:00
|
|
|
static const DWORD priority[] =
|
2005-01-26 06:45:11 +08:00
|
|
|
{
|
|
|
|
REALTIME_PRIORITY_CLASS, /* 0 */
|
|
|
|
HIGH_PRIORITY_CLASS, /* 1 */
|
|
|
|
HIGH_PRIORITY_CLASS,
|
|
|
|
HIGH_PRIORITY_CLASS,
|
|
|
|
HIGH_PRIORITY_CLASS,
|
|
|
|
HIGH_PRIORITY_CLASS,
|
|
|
|
HIGH_PRIORITY_CLASS,
|
|
|
|
HIGH_PRIORITY_CLASS, /* 7 */
|
|
|
|
ABOVE_NORMAL_PRIORITY_CLASS, /* 8 */
|
|
|
|
ABOVE_NORMAL_PRIORITY_CLASS,
|
|
|
|
ABOVE_NORMAL_PRIORITY_CLASS,
|
|
|
|
ABOVE_NORMAL_PRIORITY_CLASS,
|
|
|
|
ABOVE_NORMAL_PRIORITY_CLASS,
|
|
|
|
ABOVE_NORMAL_PRIORITY_CLASS,
|
|
|
|
ABOVE_NORMAL_PRIORITY_CLASS,
|
|
|
|
ABOVE_NORMAL_PRIORITY_CLASS, /* 15 */
|
|
|
|
NORMAL_PRIORITY_CLASS, /* 16 */
|
|
|
|
NORMAL_PRIORITY_CLASS,
|
|
|
|
NORMAL_PRIORITY_CLASS,
|
|
|
|
NORMAL_PRIORITY_CLASS,
|
|
|
|
NORMAL_PRIORITY_CLASS,
|
|
|
|
NORMAL_PRIORITY_CLASS,
|
|
|
|
NORMAL_PRIORITY_CLASS,
|
|
|
|
NORMAL_PRIORITY_CLASS, /* 23 */
|
|
|
|
BELOW_NORMAL_PRIORITY_CLASS, /* 24 */
|
|
|
|
BELOW_NORMAL_PRIORITY_CLASS,
|
|
|
|
BELOW_NORMAL_PRIORITY_CLASS,
|
|
|
|
BELOW_NORMAL_PRIORITY_CLASS,
|
|
|
|
BELOW_NORMAL_PRIORITY_CLASS,
|
|
|
|
BELOW_NORMAL_PRIORITY_CLASS,
|
|
|
|
BELOW_NORMAL_PRIORITY_CLASS,
|
|
|
|
BELOW_NORMAL_PRIORITY_CLASS, /* 31 */
|
|
|
|
IDLE_PRIORITY_CLASS, /* 32 */
|
|
|
|
IDLE_PRIORITY_CLASS,
|
|
|
|
IDLE_PRIORITY_CLASS,
|
|
|
|
IDLE_PRIORITY_CLASS,
|
|
|
|
IDLE_PRIORITY_CLASS,
|
|
|
|
IDLE_PRIORITY_CLASS,
|
|
|
|
IDLE_PRIORITY_CLASS,
|
|
|
|
IDLE_PRIORITY_CLASS /* 39 */
|
|
|
|
};
|
|
|
|
if (nice < -NZERO)
|
|
|
|
nice = -NZERO;
|
|
|
|
else if (nice > NZERO - 1)
|
|
|
|
nice = NZERO - 1;
|
|
|
|
DWORD prio = priority[nice + NZERO];
|
|
|
|
return prio;
|
|
|
|
}
|
2005-08-19 22:56:48 +08:00
|
|
|
|
2011-08-13 18:28:15 +08:00
|
|
|
/* Minimal overlapped pipe I/O implementation for signal and commune stuff. */
|
|
|
|
|
|
|
|
BOOL WINAPI
|
|
|
|
CreatePipeOverlapped (PHANDLE hr, PHANDLE hw, LPSECURITY_ATTRIBUTES sa)
|
|
|
|
{
|
2011-11-24 02:56:57 +08:00
|
|
|
int ret = fhandler_pipe::create (sa, hr, hw, 0, NULL,
|
|
|
|
FILE_FLAG_OVERLAPPED);
|
2011-08-13 18:28:15 +08:00
|
|
|
if (ret)
|
|
|
|
SetLastError (ret);
|
|
|
|
return ret == 0;
|
|
|
|
}
|
|
|
|
|
|
|
|
BOOL WINAPI
|
|
|
|
ReadPipeOverlapped (HANDLE h, PVOID buf, DWORD len, LPDWORD ret_len,
|
|
|
|
DWORD timeout)
|
2011-12-18 07:39:47 +08:00
|
|
|
{
|
2011-08-13 18:28:15 +08:00
|
|
|
OVERLAPPED ov;
|
2011-12-18 07:39:47 +08:00
|
|
|
BOOL ret;
|
|
|
|
|
2011-08-13 18:28:15 +08:00
|
|
|
memset (&ov, 0, sizeof ov);
|
|
|
|
ov.hEvent = CreateEvent (NULL, TRUE, FALSE, NULL);
|
|
|
|
ret = ReadFile (h, buf, len, NULL, &ov);
|
|
|
|
if (ret || GetLastError () == ERROR_IO_PENDING)
|
|
|
|
{
|
|
|
|
if (!ret && WaitForSingleObject (ov.hEvent, timeout) != WAIT_OBJECT_0)
|
|
|
|
CancelIo (h);
|
|
|
|
ret = GetOverlappedResult (h, &ov, ret_len, FALSE);
|
2011-12-18 07:39:47 +08:00
|
|
|
}
|
2011-08-13 18:28:15 +08:00
|
|
|
CloseHandle (ov.hEvent);
|
2011-12-18 07:39:47 +08:00
|
|
|
return ret;
|
|
|
|
}
|
|
|
|
|
2011-08-13 18:28:15 +08:00
|
|
|
BOOL WINAPI
|
2012-06-27 21:35:48 +08:00
|
|
|
WritePipeOverlapped (HANDLE h, LPCVOID buf, DWORD len, LPDWORD ret_len,
|
2011-08-13 18:28:15 +08:00
|
|
|
DWORD timeout)
|
|
|
|
{
|
2011-12-18 07:39:47 +08:00
|
|
|
OVERLAPPED ov;
|
|
|
|
BOOL ret;
|
2011-08-13 18:28:15 +08:00
|
|
|
|
|
|
|
memset (&ov, 0, sizeof ov);
|
|
|
|
ov.hEvent = CreateEvent (NULL, TRUE, FALSE, NULL);
|
|
|
|
ret = WriteFile (h, buf, len, NULL, &ov);
|
|
|
|
if (ret || GetLastError () == ERROR_IO_PENDING)
|
|
|
|
{
|
|
|
|
if (!ret && WaitForSingleObject (ov.hEvent, timeout) != WAIT_OBJECT_0)
|
|
|
|
CancelIo (h);
|
|
|
|
ret = GetOverlappedResult (h, &ov, ret_len, FALSE);
|
2011-12-18 07:39:47 +08:00
|
|
|
}
|
2011-08-13 18:28:15 +08:00
|
|
|
CloseHandle (ov.hEvent);
|
|
|
|
return ret;
|
|
|
|
}
|
|
|
|
|
2014-02-09 04:57:27 +08:00
|
|
|
bool
|
|
|
|
NT_readline::init (POBJECT_ATTRIBUTES attr, PCHAR in_buf, ULONG in_buflen)
|
|
|
|
{
|
|
|
|
NTSTATUS status;
|
|
|
|
IO_STATUS_BLOCK io;
|
|
|
|
|
|
|
|
status = NtOpenFile (&fh, SYNCHRONIZE | FILE_READ_DATA, attr, &io,
|
|
|
|
FILE_SHARE_VALID_FLAGS,
|
|
|
|
FILE_SYNCHRONOUS_IO_NONALERT
|
|
|
|
| FILE_OPEN_FOR_BACKUP_INTENT);
|
|
|
|
if (!NT_SUCCESS (status))
|
|
|
|
{
|
|
|
|
paranoid_printf ("NtOpenFile(%S) failed, status %y",
|
2014-02-12 01:45:09 +08:00
|
|
|
attr->ObjectName, status);
|
2014-02-09 04:57:27 +08:00
|
|
|
return false;
|
|
|
|
}
|
|
|
|
buf = in_buf;
|
|
|
|
buflen = in_buflen;
|
|
|
|
got = end = buf;
|
|
|
|
len = 0;
|
|
|
|
line = 1;
|
|
|
|
return true;
|
|
|
|
}
|
|
|
|
|
|
|
|
PCHAR
|
|
|
|
NT_readline::gets ()
|
|
|
|
{
|
|
|
|
IO_STATUS_BLOCK io;
|
|
|
|
|
|
|
|
while (true)
|
|
|
|
{
|
|
|
|
/* len == 0 indicates we have to read from the file. */
|
|
|
|
if (!len)
|
|
|
|
{
|
|
|
|
if (!NT_SUCCESS (NtReadFile (fh, NULL, NULL, NULL, &io, got,
|
|
|
|
(buflen - 2) - (got - buf), NULL, NULL)))
|
|
|
|
return NULL;
|
|
|
|
len = io.Information;
|
|
|
|
/* Set end marker. */
|
|
|
|
got[len] = got[len + 1] = '\0';
|
|
|
|
/* Set len to the absolute len of bytes in buf. */
|
|
|
|
len += got - buf;
|
|
|
|
/* Reset got to start reading at the start of the buffer again. */
|
|
|
|
got = end = buf;
|
|
|
|
}
|
|
|
|
else
|
|
|
|
{
|
|
|
|
got = end + 1;
|
|
|
|
++line;
|
|
|
|
}
|
|
|
|
/* Still some valid full line? */
|
|
|
|
if (got < buf + len)
|
|
|
|
{
|
|
|
|
if ((end = strchr (got, '\n')))
|
|
|
|
{
|
|
|
|
end[end[-1] == '\r' ? -1 : 0] = '\0';
|
|
|
|
return got;
|
|
|
|
}
|
|
|
|
/* Last line missing a \n at EOF? */
|
|
|
|
if (len < buflen - 2)
|
|
|
|
{
|
|
|
|
len = 0;
|
|
|
|
return got;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
/* We have to read once more. Move remaining bytes to the start of
|
|
|
|
the buffer and reposition got so that it points to the end of
|
|
|
|
the remaining bytes. */
|
|
|
|
len = buf + len - got;
|
|
|
|
memmove (buf, got, len);
|
|
|
|
got = buf + len;
|
|
|
|
buf[len] = buf[len + 1] = '\0';
|
|
|
|
len = 0;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2008-04-08 00:15:45 +08:00
|
|
|
/* backslashify: Convert all forward slashes in src path to back slashes
|
|
|
|
in dst path. Add a trailing slash to dst when trailing_slash_p arg
|
|
|
|
is set to 1. */
|
|
|
|
|
|
|
|
void
|
|
|
|
backslashify (const char *src, char *dst, bool trailing_slash_p)
|
|
|
|
{
|
|
|
|
const char *start = src;
|
|
|
|
|
|
|
|
while (*src)
|
|
|
|
{
|
|
|
|
if (*src == '/')
|
|
|
|
*dst++ = '\\';
|
|
|
|
else
|
|
|
|
*dst++ = *src;
|
|
|
|
++src;
|
|
|
|
}
|
|
|
|
if (trailing_slash_p
|
|
|
|
&& src > start
|
|
|
|
&& !isdirsep (src[-1]))
|
|
|
|
*dst++ = '\\';
|
|
|
|
*dst++ = 0;
|
|
|
|
}
|
|
|
|
|
|
|
|
/* slashify: Convert all back slashes in src path to forward slashes
|
|
|
|
in dst path. Add a trailing slash to dst when trailing_slash_p arg
|
|
|
|
is set to 1. */
|
|
|
|
|
|
|
|
void
|
|
|
|
slashify (const char *src, char *dst, bool trailing_slash_p)
|
|
|
|
{
|
|
|
|
const char *start = src;
|
|
|
|
|
|
|
|
while (*src)
|
|
|
|
{
|
|
|
|
if (*src == '\\')
|
|
|
|
*dst++ = '/';
|
|
|
|
else
|
|
|
|
*dst++ = *src;
|
|
|
|
++src;
|
|
|
|
}
|
|
|
|
if (trailing_slash_p
|
|
|
|
&& src > start
|
|
|
|
&& !isdirsep (src[-1]))
|
|
|
|
*dst++ = '/';
|
|
|
|
*dst++ = 0;
|
|
|
|
}
|
2011-05-16 02:49:40 +08:00
|
|
|
|
2013-01-21 06:59:58 +08:00
|
|
|
/* Return an address from the import jmp table of main program. */
|
2013-01-21 12:34:52 +08:00
|
|
|
void * __reg1
|
2013-01-21 06:59:58 +08:00
|
|
|
__import_address (void *imp)
|
|
|
|
{
|
2014-08-22 17:21:33 +08:00
|
|
|
__try
|
|
|
|
{
|
|
|
|
if (*((uint16_t *) imp) == 0x25ff)
|
|
|
|
{
|
|
|
|
const char *ptr = (const char *) imp;
|
2013-04-23 17:44:36 +08:00
|
|
|
#ifdef __x86_64__
|
2014-08-22 17:21:33 +08:00
|
|
|
const uintptr_t *jmpto = (uintptr_t *)
|
|
|
|
(ptr + 6 + *(int32_t *)(ptr + 2));
|
2013-04-23 17:44:36 +08:00
|
|
|
#else
|
2014-08-22 17:21:33 +08:00
|
|
|
const uintptr_t *jmpto = (uintptr_t *) *((uintptr_t *) (ptr + 2));
|
2013-04-23 17:44:36 +08:00
|
|
|
#endif
|
2014-08-22 17:21:33 +08:00
|
|
|
return (void *) *jmpto;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
__except (NO_ERROR) {}
|
|
|
|
__endtry
|
|
|
|
return NULL;
|
2013-01-21 06:59:58 +08:00
|
|
|
}
|
|
|
|
|
2011-05-16 02:49:40 +08:00
|
|
|
/* CygwinCreateThread.
|
|
|
|
|
|
|
|
Replacement function for CreateThread. What we do here is to remove
|
|
|
|
parameters we don't use and instead to add parameters we need to make
|
|
|
|
the function pthreads compatible. */
|
|
|
|
|
|
|
|
struct thread_wrapper_arg
|
|
|
|
{
|
|
|
|
LPTHREAD_START_ROUTINE func;
|
|
|
|
PVOID arg;
|
2012-02-13 23:23:03 +08:00
|
|
|
PBYTE stackaddr;
|
|
|
|
PBYTE stackbase;
|
2012-02-16 05:34:06 +08:00
|
|
|
PBYTE stacklimit;
|
2011-05-16 02:49:40 +08:00
|
|
|
};
|
|
|
|
|
2013-01-21 06:59:58 +08:00
|
|
|
static DWORD WINAPI
|
2013-04-23 17:44:36 +08:00
|
|
|
thread_wrapper (PVOID arg)
|
2011-05-16 02:49:40 +08:00
|
|
|
{
|
2011-05-20 15:23:11 +08:00
|
|
|
/* Just plain paranoia. */
|
2011-05-16 02:49:40 +08:00
|
|
|
if (!arg)
|
|
|
|
return ERROR_INVALID_PARAMETER;
|
|
|
|
|
2013-05-22 02:53:23 +08:00
|
|
|
/* The process is now threaded. Note the fact for later usage. */
|
|
|
|
__isthreaded = 1;
|
|
|
|
|
2011-05-20 15:23:11 +08:00
|
|
|
/* Fetch thread wrapper info and free from cygheap. */
|
2011-05-16 02:49:40 +08:00
|
|
|
thread_wrapper_arg wrapper_arg = *(thread_wrapper_arg *) arg;
|
|
|
|
cfree (arg);
|
|
|
|
|
2012-02-16 05:34:06 +08:00
|
|
|
/* Remove _cygtls from this stack since it won't be used anymore. */
|
|
|
|
_my_tls.remove (0);
|
2012-02-13 23:23:03 +08:00
|
|
|
|
2012-02-16 05:34:06 +08:00
|
|
|
/* Set stack values in TEB */
|
|
|
|
PTEB teb = NtCurrentTeb ();
|
|
|
|
teb->Tib.StackBase = wrapper_arg.stackbase;
|
|
|
|
teb->Tib.StackLimit = wrapper_arg.stacklimit ?: wrapper_arg.stackaddr;
|
|
|
|
/* Set DeallocationStack value. If we have an application-provided stack,
|
|
|
|
we set DeallocationStack to NULL, so NtTerminateThread does not deallocate
|
|
|
|
any stack. If we created the stack in CygwinCreateThread, we set
|
|
|
|
DeallocationStack to the stackaddr of our own stack, so it's automatically
|
|
|
|
deallocated when the thread is terminated. */
|
|
|
|
PBYTE dealloc_addr = (PBYTE) teb->DeallocationStack;
|
|
|
|
teb->DeallocationStack = wrapper_arg.stacklimit ? wrapper_arg.stackaddr
|
|
|
|
: NULL;
|
|
|
|
/* Store the OS-provided DeallocationStack address in wrapper_arg.stackaddr.
|
|
|
|
The below assembler code will release the OS stack after switching to our
|
|
|
|
new stack. */
|
|
|
|
wrapper_arg.stackaddr = dealloc_addr;
|
|
|
|
|
|
|
|
/* Initialize new _cygtls. */
|
|
|
|
_my_tls.init_thread (wrapper_arg.stackbase - CYGTLS_PADSIZE,
|
|
|
|
(DWORD (*)(void*, void*)) wrapper_arg.func);
|
2013-04-23 17:44:36 +08:00
|
|
|
#ifndef __x86_64__
|
2012-02-16 05:34:06 +08:00
|
|
|
/* Copy exception list over to new stack. I'm not quite sure how the
|
|
|
|
exception list is extended by Windows itself. What's clear is that it
|
|
|
|
always grows downwards and that it starts right at the stackbase.
|
|
|
|
Therefore we first count the number of exception records and place
|
|
|
|
the copy at the stackbase, too, so there's still a lot of room to
|
|
|
|
extend the list up to where our _cygtls region starts. */
|
|
|
|
_exception_list *old_start = (_exception_list *) teb->Tib.ExceptionList;
|
|
|
|
unsigned count = 0;
|
|
|
|
teb->Tib.ExceptionList = NULL;
|
|
|
|
for (_exception_list *e_ptr = old_start;
|
|
|
|
e_ptr && e_ptr != (_exception_list *) -1;
|
|
|
|
e_ptr = e_ptr->prev)
|
|
|
|
++count;
|
|
|
|
if (count)
|
2011-05-16 02:49:40 +08:00
|
|
|
{
|
2012-02-16 05:34:06 +08:00
|
|
|
_exception_list *new_start = (_exception_list *) wrapper_arg.stackbase
|
|
|
|
- count;
|
|
|
|
teb->Tib.ExceptionList = (struct _EXCEPTION_REGISTRATION_RECORD *)
|
|
|
|
new_start;
|
|
|
|
while (true)
|
2011-05-20 15:23:11 +08:00
|
|
|
{
|
2012-02-16 05:34:06 +08:00
|
|
|
new_start->handler = old_start->handler;
|
|
|
|
if (old_start->prev == (_exception_list *) -1)
|
2011-05-20 15:23:11 +08:00
|
|
|
{
|
2012-02-16 05:34:06 +08:00
|
|
|
new_start->prev = (_exception_list *) -1;
|
|
|
|
break;
|
2011-05-20 15:23:11 +08:00
|
|
|
}
|
2012-02-16 05:34:06 +08:00
|
|
|
new_start->prev = new_start + 1;
|
|
|
|
new_start = new_start->prev;
|
|
|
|
old_start = old_start->prev;
|
2011-05-20 15:23:11 +08:00
|
|
|
}
|
2012-02-13 23:23:03 +08:00
|
|
|
}
|
2013-04-23 17:44:36 +08:00
|
|
|
#endif
|
|
|
|
#ifdef __x86_64__
|
2012-02-16 05:34:06 +08:00
|
|
|
__asm__ ("\n\
|
2013-04-23 17:44:36 +08:00
|
|
|
movq %[WRAPPER_ARG], %%rbx # Load &wrapper_arg into rbx \n\
|
|
|
|
movq (%%rbx), %%r12 # Load thread func into r12 \n\
|
|
|
|
movq 8(%%rbx), %%r13 # Load thread arg into r13 \n\
|
|
|
|
movq 16(%%rbx), %%rcx # Load stackaddr into rcx \n\
|
|
|
|
movq 24(%%rbx), %%rsp # Load stackbase into rsp \n\
|
|
|
|
subq %[CYGTLS], %%rsp # Subtract CYGTLS_PADSIZE \n\
|
|
|
|
# (here we are 16 bytes aligned)\n\
|
|
|
|
subq $32, %%rsp # Subtract another 32 bytes \n\
|
|
|
|
# (shadow space for arg regs) \n\
|
|
|
|
xorq %%rbp, %%rbp # Set rbp to 0 \n\
|
|
|
|
# We moved to the new stack. \n\
|
|
|
|
# Now it's safe to release the OS stack. \n\
|
|
|
|
movl $0x8000, %%r8d # dwFreeType: MEM_RELEASE \n\
|
|
|
|
xorl %%edx, %%edx # dwSize: 0 \n\
|
|
|
|
# dwAddress is already in the correct arg register rcx \n\
|
|
|
|
call VirtualFree \n\
|
|
|
|
# All set. We can copy the thread arg from the safe \n\
|
|
|
|
# register r13 and then just call the function. \n\
|
|
|
|
movq %%r13, %%rcx # Move thread arg to 1st arg reg\n\
|
|
|
|
call *%%r12 # Call thread func \n"
|
|
|
|
: : [WRAPPER_ARG] "r" (&wrapper_arg),
|
|
|
|
[CYGTLS] "i" (CYGTLS_PADSIZE));
|
|
|
|
#else
|
|
|
|
__asm__ ("\n\
|
|
|
|
movl %[WRAPPER_ARG], %%ebx # Load &wrapper_arg into ebx \n\
|
2012-08-17 07:34:45 +08:00
|
|
|
movl (%%ebx), %%eax # Load thread func into eax \n\
|
|
|
|
movl 4(%%ebx), %%ecx # Load thread arg into ecx \n\
|
|
|
|
movl 8(%%ebx), %%edx # Load stackaddr into edx \n\
|
|
|
|
movl 12(%%ebx), %%ebx # Load stackbase into ebx \n\
|
|
|
|
subl %[CYGTLS], %%ebx # Subtract CYGTLS_PADSIZE \n\
|
|
|
|
subl $4, %%ebx # Subtract another 4 bytes \n\
|
|
|
|
movl %%ebx, %%esp # Set esp \n\
|
|
|
|
xorl %%ebp, %%ebp # Set ebp to 0 \n\
|
|
|
|
# Make gcc 3.x happy and align the stack so that it is \n\
|
|
|
|
# 16 byte aligned right before the final call opcode. \n\
|
|
|
|
andl $-16, %%esp # 16 byte align \n\
|
|
|
|
addl $-12, %%esp # 12 bytes + 4 byte arg = 16 \n\
|
|
|
|
# Now we moved to the new stack. Save thread func address \n\
|
|
|
|
# and thread arg on new stack \n\
|
|
|
|
pushl %%ecx # Push thread arg onto stack \n\
|
|
|
|
pushl %%eax # Push thread func onto stack \n\
|
|
|
|
# Now it's safe to release the OS stack. \n\
|
|
|
|
pushl $0x8000 # dwFreeType: MEM_RELEASE \n\
|
|
|
|
pushl $0x0 # dwSize: 0 \n\
|
|
|
|
pushl %%edx # lpAddress: stackaddr \n\
|
|
|
|
call _VirtualFree@12 # Shoot \n\
|
|
|
|
# All set. We can pop the thread function address from \n\
|
|
|
|
# the stack and call it. The thread arg is still on the \n\
|
|
|
|
# stack in the expected spot. \n\
|
|
|
|
popl %%eax # Pop thread_func address \n\
|
|
|
|
call *%%eax # Call thread func \n"
|
2012-02-16 05:34:06 +08:00
|
|
|
: : [WRAPPER_ARG] "r" (&wrapper_arg),
|
|
|
|
[CYGTLS] "i" (CYGTLS_PADSIZE));
|
2013-04-23 17:44:36 +08:00
|
|
|
#endif
|
2011-05-20 15:23:11 +08:00
|
|
|
/* Never return from here. */
|
2012-12-22 03:32:43 +08:00
|
|
|
ExitThread (0);
|
2011-05-16 02:49:40 +08:00
|
|
|
}
|
|
|
|
|
2013-04-23 17:44:36 +08:00
|
|
|
#ifdef __x86_64__
|
|
|
|
/* The memory region used for thread stacks */
|
|
|
|
#define THREAD_STORAGE_LOW 0x080000000L
|
|
|
|
#define THREAD_STORAGE_HIGH 0x100000000L
|
|
|
|
/* We provide the stacks always in 1 Megabyte slots */
|
|
|
|
#define THREAD_STACK_SLOT 0x100000L /* 1 Meg */
|
|
|
|
/* Maximum stack size returned from the pool. */
|
|
|
|
#define THREAD_STACK_MAX 0x20000000L /* 512 Megs */
|
|
|
|
|
|
|
|
class thread_allocator
|
|
|
|
{
|
|
|
|
UINT_PTR current;
|
|
|
|
public:
|
|
|
|
thread_allocator () : current (THREAD_STORAGE_HIGH) {}
|
|
|
|
PVOID alloc (SIZE_T size)
|
|
|
|
{
|
|
|
|
SIZE_T real_size = roundup2 (size, THREAD_STACK_SLOT);
|
|
|
|
BOOL overflow = FALSE;
|
|
|
|
PVOID real_stackaddr = NULL;
|
|
|
|
|
|
|
|
/* If an application requests a monster stack, we fulfill this request
|
|
|
|
from outside of our pool, top down. */
|
|
|
|
if (real_size > THREAD_STACK_MAX)
|
|
|
|
return VirtualAlloc (NULL, real_size, MEM_RESERVE | MEM_TOP_DOWN,
|
|
|
|
PAGE_READWRITE);
|
|
|
|
/* Simple round-robin. Keep looping until VirtualAlloc succeeded, or
|
|
|
|
until we overflowed and hit the current address. */
|
|
|
|
for (UINT_PTR addr = current - real_size;
|
|
|
|
!real_stackaddr && (!overflow || addr >= current);
|
|
|
|
addr -= THREAD_STACK_SLOT)
|
|
|
|
{
|
|
|
|
if (addr < THREAD_STORAGE_LOW)
|
|
|
|
{
|
|
|
|
addr = THREAD_STORAGE_HIGH - real_size;
|
|
|
|
overflow = TRUE;
|
|
|
|
}
|
|
|
|
real_stackaddr = VirtualAlloc ((PVOID) addr, real_size,
|
|
|
|
MEM_RESERVE, PAGE_READWRITE);
|
|
|
|
if (!real_stackaddr)
|
|
|
|
{
|
|
|
|
/* So we couldn't grab this space. Let's check the state.
|
|
|
|
If this area is free, simply try the next lower 1 Meg slot.
|
|
|
|
Otherwise, shift the next try down to the AllocationBase
|
|
|
|
of the current address, minus the requested slot size.
|
|
|
|
Add THREAD_STACK_SLOT since that's subtracted in the next
|
|
|
|
run of the loop anyway. */
|
|
|
|
MEMORY_BASIC_INFORMATION mbi;
|
|
|
|
VirtualQuery ((PVOID) addr, &mbi, sizeof mbi);
|
|
|
|
if (mbi.State != MEM_FREE)
|
|
|
|
addr = (UINT_PTR) mbi.AllocationBase - real_size
|
|
|
|
+ THREAD_STACK_SLOT;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
/* If we got an address, remember it for the next allocation attempt. */
|
|
|
|
if (real_stackaddr)
|
|
|
|
current = (UINT_PTR) real_stackaddr;
|
|
|
|
return real_stackaddr;
|
|
|
|
}
|
|
|
|
};
|
|
|
|
|
|
|
|
thread_allocator thr_alloc NO_COPY;
|
|
|
|
#endif
|
|
|
|
|
2011-05-16 02:49:40 +08:00
|
|
|
HANDLE WINAPI
|
|
|
|
CygwinCreateThread (LPTHREAD_START_ROUTINE thread_func, PVOID thread_arg,
|
|
|
|
PVOID stackaddr, ULONG stacksize, ULONG guardsize,
|
|
|
|
DWORD creation_flags, LPDWORD thread_id)
|
|
|
|
{
|
2012-02-16 05:34:06 +08:00
|
|
|
PVOID real_stackaddr = NULL;
|
2011-05-16 02:49:40 +08:00
|
|
|
ULONG real_stacksize = 0;
|
|
|
|
ULONG real_guardsize = 0;
|
|
|
|
thread_wrapper_arg *wrapper_arg;
|
2012-02-16 05:34:06 +08:00
|
|
|
HANDLE thread = NULL;
|
2011-06-06 13:02:13 +08:00
|
|
|
|
2011-05-16 02:49:40 +08:00
|
|
|
wrapper_arg = (thread_wrapper_arg *) ccalloc (HEAP_STR, 1,
|
|
|
|
sizeof *wrapper_arg);
|
|
|
|
if (!wrapper_arg)
|
|
|
|
{
|
|
|
|
SetLastError (ERROR_OUTOFMEMORY);
|
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
wrapper_arg->func = thread_func;
|
|
|
|
wrapper_arg->arg = thread_arg;
|
|
|
|
|
|
|
|
if (stackaddr)
|
|
|
|
{
|
2011-05-21 02:15:12 +08:00
|
|
|
/* If the application provided the stack, just use it. */
|
2012-02-13 23:23:03 +08:00
|
|
|
wrapper_arg->stackaddr = (PBYTE) stackaddr;
|
|
|
|
wrapper_arg->stackbase = (PBYTE) stackaddr + stacksize;
|
2011-05-16 02:49:40 +08:00
|
|
|
}
|
|
|
|
else
|
|
|
|
{
|
2012-02-16 05:34:06 +08:00
|
|
|
PBYTE real_stacklimit;
|
|
|
|
|
|
|
|
/* If not, we have to create the stack here. */
|
2012-02-12 01:37:02 +08:00
|
|
|
real_stacksize = roundup2 (stacksize, wincap.page_size ());
|
|
|
|
real_guardsize = roundup2 (guardsize, wincap.page_size ());
|
|
|
|
/* Add the guardsize to the stacksize */
|
|
|
|
real_stacksize += real_guardsize;
|
2012-02-13 21:12:37 +08:00
|
|
|
/* If we use the default Windows guardpage method, we have to take
|
|
|
|
the 2 pages dead zone into account. */
|
|
|
|
if (real_guardsize == wincap.page_size ())
|
|
|
|
real_stacksize += 2 * wincap.page_size ();
|
2011-05-16 02:49:40 +08:00
|
|
|
/* Now roundup the result to the next allocation boundary. */
|
|
|
|
real_stacksize = roundup2 (real_stacksize,
|
|
|
|
wincap.allocation_granularity ());
|
2013-04-23 17:44:36 +08:00
|
|
|
/* Reserve stack. */
|
|
|
|
#ifdef __x86_64__
|
|
|
|
real_stackaddr = thr_alloc.alloc (real_stacksize);
|
|
|
|
#else
|
|
|
|
/* FIXME? If the TOP_DOWN method tends to collide too much with
|
2012-02-16 05:34:06 +08:00
|
|
|
other stuff, we should provide our own mechanism to find a
|
|
|
|
suitable place for the stack. Top down from the start of
|
|
|
|
the Cygwin DLL comes to mind. */
|
|
|
|
real_stackaddr = VirtualAlloc (NULL, real_stacksize,
|
|
|
|
MEM_RESERVE | MEM_TOP_DOWN,
|
|
|
|
PAGE_READWRITE);
|
2013-04-23 17:44:36 +08:00
|
|
|
#endif
|
2012-02-16 05:34:06 +08:00
|
|
|
if (!real_stackaddr)
|
|
|
|
return NULL;
|
|
|
|
/* Set up committed region. Two cases: */
|
|
|
|
if (real_guardsize != wincap.page_size ())
|
|
|
|
{
|
|
|
|
/* If guardsize is set to something other than the page size, we
|
|
|
|
commit the entire stack and, if guardsize is > 0, we set up a
|
|
|
|
POSIX guardpage. We don't set up a Windows guardpage. */
|
|
|
|
if (!VirtualAlloc (real_stackaddr, real_guardsize, MEM_COMMIT,
|
|
|
|
PAGE_NOACCESS))
|
|
|
|
goto err;
|
|
|
|
real_stacklimit = (PBYTE) real_stackaddr + real_guardsize;
|
|
|
|
if (!VirtualAlloc (real_stacklimit, real_stacksize - real_guardsize,
|
|
|
|
MEM_COMMIT, PAGE_READWRITE))
|
|
|
|
goto err;
|
|
|
|
}
|
|
|
|
else
|
|
|
|
{
|
|
|
|
/* If guardsize is exactly the page_size, we can assume that the
|
|
|
|
application will behave Windows conformant in terms of stack usage.
|
|
|
|
We can especially assume that it never allocates more than one
|
|
|
|
page at a time (alloca/_chkstk). Therefore, this is the default
|
|
|
|
case which allows a Windows compatible stack setup with a
|
|
|
|
reserved region, a guard page, and a commited region. We don't
|
|
|
|
need to set up a POSIX guardpage since Windows already handles
|
|
|
|
stack overflow: Trying to extend the stack into the last three
|
|
|
|
pages of the stack results in a SEGV.
|
|
|
|
We always commit 64K here, starting with the guardpage. */
|
|
|
|
real_stacklimit = (PBYTE) real_stackaddr + real_stacksize
|
|
|
|
- wincap.allocation_granularity ();
|
|
|
|
if (!VirtualAlloc (real_stacklimit, wincap.page_size (), MEM_COMMIT,
|
|
|
|
PAGE_READWRITE | PAGE_GUARD))
|
|
|
|
goto err;
|
|
|
|
real_stacklimit += wincap.page_size ();
|
|
|
|
if (!VirtualAlloc (real_stacklimit, wincap.allocation_granularity ()
|
|
|
|
- wincap.page_size (), MEM_COMMIT,
|
|
|
|
PAGE_READWRITE))
|
|
|
|
goto err;
|
|
|
|
}
|
|
|
|
wrapper_arg->stackaddr = (PBYTE) real_stackaddr;
|
|
|
|
wrapper_arg->stackbase = (PBYTE) real_stackaddr + real_stacksize;
|
|
|
|
wrapper_arg->stacklimit = real_stacklimit;
|
|
|
|
}
|
|
|
|
/* Use the STACK_SIZE_PARAM_IS_A_RESERVATION parameter so only the
|
2013-04-23 17:44:36 +08:00
|
|
|
minimum size for a thread stack is reserved by the OS. Note that we
|
|
|
|
reserve a 256K stack, not 64K, otherwise the thread creation might
|
|
|
|
crash the process due to a stack overflow. */
|
2012-02-16 05:34:06 +08:00
|
|
|
thread = CreateThread (&sec_none_nih, 4 * PTHREAD_STACK_MIN,
|
|
|
|
thread_wrapper, wrapper_arg,
|
|
|
|
creation_flags | STACK_SIZE_PARAM_IS_A_RESERVATION,
|
|
|
|
thread_id);
|
|
|
|
|
|
|
|
err:
|
|
|
|
if (!thread && real_stackaddr)
|
|
|
|
{
|
|
|
|
/* Don't report the wrong error even though VirtualFree is very unlikely
|
|
|
|
to fail. */
|
|
|
|
DWORD err = GetLastError ();
|
|
|
|
VirtualFree (real_stackaddr, 0, MEM_RELEASE);
|
|
|
|
SetLastError (err);
|
2011-05-16 02:49:40 +08:00
|
|
|
}
|
2012-02-16 05:34:06 +08:00
|
|
|
return thread;
|
2011-05-16 02:49:40 +08:00
|
|
|
}
|
2013-04-23 17:44:36 +08:00
|
|
|
|
|
|
|
#ifdef __x86_64__
|
|
|
|
// TODO: The equivalent newlib functions only work for SYSV ABI so far.
|
|
|
|
#undef RtlFillMemory
|
|
|
|
#undef RtlCopyMemory
|
|
|
|
extern "C" void NTAPI RtlFillMemory (PVOID, SIZE_T, BYTE);
|
|
|
|
extern "C" void NTAPI RtlCopyMemory (PVOID, const VOID *, SIZE_T);
|
|
|
|
|
|
|
|
extern "C" void *
|
|
|
|
memset (void *s, int c, size_t n)
|
|
|
|
{
|
|
|
|
RtlFillMemory (s, n, c);
|
|
|
|
return s;
|
|
|
|
}
|
|
|
|
|
|
|
|
extern "C" void *
|
2013-11-25 19:38:08 +08:00
|
|
|
memcpy(void *__restrict dest, const void *__restrict src, size_t n)
|
2013-04-23 17:44:36 +08:00
|
|
|
{
|
|
|
|
RtlCopyMemory (dest, src, n);
|
|
|
|
return dest;
|
|
|
|
}
|
|
|
|
#endif
|