4fe755bc5b
Changes since version 1.41.0:
* doc: fix code highlighting (Darshan Sen)
* test: move to ASSERT_NULL and ASSERT_NOT_NULL test macros (tjarlama)
* zos: build in ascii code page (Shuowang (Wayne) Zhang)
* zos: don't use nanosecond timestamp fields (Shuowang (Wayne) Zhang)
* zos: introduce zoslib (Shuowang (Wayne) Zhang)
* zos: use strnlen() from zoslib (Shuowang (Wayne) Zhang)
* zos: use nanosleep() from zoslib (Shuowang (Wayne) Zhang)
* zos: use __getargv() from zoslib to get exe path (Shuowang (Wayne) Zhang)
* zos: treat __rfim_utok as binary (Shuowang (Wayne) Zhang)
* zos: use execvpe() to set environ explictly (Shuowang (Wayne) Zhang)
* zos: use custom proctitle implementation (Shuowang (Wayne) Zhang)
* doc: add instructions for building on z/OS (Shuowang (Wayne) Zhang)
* linux,udp: enable full ICMP error reporting (Ondřej Surý)
* test: fix test-udp-send-unreachable (Ondřej Surý)
* include: fix typo in documentation (Tobias Nießen)
* chore: use for(;;) instead of while (Yash Ladha)
* test: remove string + int warning on udp-pummel (Juan José Arboleda)
* cmake: fix linker flags (Zhao Zhili)
* test: fix stack-use-after-scope (Zhao Zhili)
* unix: expose thread_stack_size() internally (Brandon Cheng)
* darwin: use RLIMIT_STACK for fsevents pthread (Brandon Cheng)
* darwin: abort on pthread_attr_init fail (Brandon Cheng)
* benchmark: remove unreachable code (Matvii Hodovaniuk)
* macos: fix memleaks in uv__get_cpu_speed (George Zhao)
* Make Thread Sanitizer aware of file descriptor close in uv__close() (Ondřej
Surý)
* darwin: fix iOS compilation and functionality (Hayden)
* linux: work around copy_file_range() cephfs bug (Ben Noordhuis)
* zos: implement uv_get_constrained_memory() (Shuowang (Wayne) Zhang)
* zos: fix uv_get_free_memory() (Shuowang (Wayne) Zhang)
* zos: use CVTRLSTG to get total memory accurately (Shuowang (Wayne) Zhang)
* ibmi: Handle interface names longer than 10 chars (Kevin Adler)
* docs: update read-the-docs version of sphinx (Jameson Nash)
* unix: refactor uv_try_write (twosee)
* linux-core: add proper divide by zero assert (yiyuaner)
* misc: remove unnecessary _GNU_SOURCE macros (Darshan Sen)
* test: log to stdout to conform TAP spec (bbara)
* win,fs: fix C4090 warning with MSVC (SeverinLeonhardt)
* build: some systems provide dlopen() in libc (Andy Fiddaman)
* include: add EOVERFLOW status code mapping (Darshan Sen)
* unix,fs: use uv__load_relaxed and uv__store_relaxed (Darshan Sen)
* win: fix string encoding issue of uv_os_gethostname (Eagle Liang)
* unix,process: add uv__write_errno helper function (Ricky Zhou)
* Re-merge "unix,stream: clear read/write states on close/eof" (Jameson Nash)
* unix,core: fix errno handling in uv__getpwuid_r (Darshan Sen)
* errors: map ESOCKTNOSUPPORT errno (Ryan Liptak)
* doc: uv_read_stop always succeeds (Simon Kissane)
* inet: fix inconsistent return value of inet_ntop6 (twosee)
* darwin: fix -Wsometimes-uninitialized warning (twosee)
* stream: introduce uv_try_write2 function (twosee)
* poll,win: UV_PRIORITIZED option should not assert (twosee)
* src: DragonFlyBSD has mmsghdr struct too (David Carlier)
* cleanup,win: Remove _WIN32 guards on threadpool (James M Snell)
* freebsd: fix an incompatible pointer type warning (Darshan Sen)
* core: Correct the conditionals for {cloexec,nonblock}_ioctl (Ali Mohammad
Pur)
* win,tcp: make uv_close work more like unix (Jameson Nash)
* doc: more accurate list of valid send_handle's (twosee)
* win,tcp: translate system errors correctly (twosee)
* unix: implement cpu_relax() on ppc64 (Ben Noordhuis)
* docs: move list of project links under PR control (Jameson Nash)
* test: wrong pointer arithmetic multiplier (Erkhes N)
* doc: switch discussion forum to github (Jameson Nash)
* idna: fix OOB read in punycode decoder (Ben Noordhuis)
* build: make sure -fvisibility=hidden is set (Santiago Gimeno)
* illumos: event ports to epoll (tjarlama)
* illumos,tty: UV_TTY_MODE_IO waits for 4 bytes (Joshua M. Clulow)
* doc: add vtjnash GPG ID (Jameson Nash)
* linux: read CPU model information on ppc (Richard Lau)
* darwin: fix uv_barrier race condition (Guilherme Íscaro)
* unix,stream: fix loop hang after uv_shutdown (Jameson Nash)
* doc,udp: note that suggested_size is 1 max-sized dgram (Ryan Liptak)
* mingw: fix building for ARM/AArch64 (Martin Storsjö)
* unix: strnlen is not available on Solaris 10 (Claes Nästén)
* sunos: restore use of event ports (Andy Fiddaman)
* sunos,cmake: use thread-safe errno (Andy Fiddaman)
-----BEGIN PGP SIGNATURE-----
iQJGBAABCAAwFiEErq0KS2hnZ3UaDkrvNKJfsSgkZRQFAmD2OHUSHHZ0am5hc2hA
Z21haWwuY29tAAoJEDSiX7EoJGUU6XsQAJqkq5qV54EEFQAIf/AV9e4pt5uua2iF
bTyExNGyty5TW4OCytSxakLWS/9lN5vQo6/bjeUEfhq8a1BmLzJq5Nnmc8ntlYM6
n89vZSRjgLNwQ2WuRV9akCMTPYydeJc6RboEjTDVlWtSr4QDCwK+fKgaMil+9uow
Y8biEme/vIcpJNOE3IdhivUoS1Hl1PJrVbhJapHBQ6j4xf8CIrFBwn9qF0IX+Ngp
9xZVvJFXQkZzqLqkHeMasGCp+hmQDnAiXKO3vbUJbeVwoCukDYmVG8Pb3H3RIyo9
yZkdBpOZ1GEmnPY766IkArThM+/WBWTgz6pTOl59Zx0Wa5Dmr8ASUiauE/EEARS4
v/QUQA13MS8cgOBhmPjrLQ9Kv6HPvLuZSjshEJz4RdL8aSThoQ7Om+AlR679wnyK
vlcfNLoh+Jw1zCWKWO6c5BiqcB/8J/JPT2N0vMmT6+RZ8AiqyjGpBw+t1HeBkdW5
CPJX06CXk7vsvCKbw4w8i8Xl40zm9yws5tO7ukG/lkmB5EUKhMe1z/5pTAWoFJV/
srs6S+g3xmJ1oBeytjjEra/iJji/6jQ/oLbYeA+mvBxV5+hu7Mtnpzl0vWKrN5M2
ewxOvJJtggT1V2WcVqYLmHdZpug+pspG6Uwm6/TG/379IFot3O4OjPZ8wlrLgaNt
PU0FlUDCxyvT
=gkXG
-----END PGP SIGNATURE-----
Merge tag 'v1.42.0' into merge_1.42.0
PR-URL: https://github.com/libuv/libuv/pull/3245
Reviewed-By: Santiago Gimeno <santiago.gimeno@gmail.com>
368 lines
14 KiB
C
368 lines
14 KiB
C
/* Copyright Joyent, Inc. and other Node contributors. All rights reserved.
|
|
*
|
|
* Permission is hereby granted, free of charge, to any person obtaining a copy
|
|
* of this software and associated documentation files (the "Software"), to
|
|
* deal in the Software without restriction, including without limitation the
|
|
* rights to use, copy, modify, merge, publish, distribute, sublicense, and/or
|
|
* sell copies of the Software, and to permit persons to whom the Software is
|
|
* furnished to do so, subject to the following conditions:
|
|
*
|
|
* The above copyright notice and this permission notice shall be included in
|
|
* all copies or substantial portions of the Software.
|
|
*
|
|
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
|
|
* IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
|
|
* FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
|
|
* AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
|
|
* LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
|
|
* FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS
|
|
* IN THE SOFTWARE.
|
|
*/
|
|
|
|
#ifndef TASK_H_
|
|
#define TASK_H_
|
|
|
|
#include "uv.h"
|
|
|
|
#include <stdio.h>
|
|
#include <stddef.h>
|
|
#include <stdlib.h>
|
|
#include <stdint.h>
|
|
#include <string.h>
|
|
#include <inttypes.h>
|
|
|
|
#if !defined(_WIN32)
|
|
# include <sys/time.h>
|
|
# include <sys/resource.h> /* setrlimit() */
|
|
#endif
|
|
|
|
#define TEST_PORT 9123
|
|
#define TEST_PORT_2 9124
|
|
#define TEST_PORT_3 9125
|
|
|
|
#ifdef _WIN32
|
|
# define TEST_PIPENAME "\\\\?\\pipe\\uv-test"
|
|
# define TEST_PIPENAME_2 "\\\\?\\pipe\\uv-test2"
|
|
# define TEST_PIPENAME_3 "\\\\?\\pipe\\uv-test3"
|
|
#else
|
|
# define TEST_PIPENAME "/tmp/uv-test-sock"
|
|
# define TEST_PIPENAME_2 "/tmp/uv-test-sock2"
|
|
# define TEST_PIPENAME_3 "/tmp/uv-test-sock3"
|
|
#endif
|
|
|
|
#ifdef _WIN32
|
|
# include <sys/stat.h>
|
|
# ifndef S_IRUSR
|
|
# define S_IRUSR _S_IREAD
|
|
# endif
|
|
# ifndef S_IWUSR
|
|
# define S_IWUSR _S_IWRITE
|
|
# endif
|
|
#endif
|
|
|
|
#define ARRAY_SIZE(a) (sizeof(a) / sizeof((a)[0]))
|
|
|
|
#define container_of(ptr, type, member) \
|
|
((type *) ((char *) (ptr) - offsetof(type, member)))
|
|
|
|
typedef enum {
|
|
TCP = 0,
|
|
UDP,
|
|
PIPE
|
|
} stream_type;
|
|
|
|
/* Die with fatal error. */
|
|
#define FATAL(msg) \
|
|
do { \
|
|
fprintf(stderr, \
|
|
"Fatal error in %s on line %d: %s\n", \
|
|
__FILE__, \
|
|
__LINE__, \
|
|
msg); \
|
|
fflush(stderr); \
|
|
abort(); \
|
|
} while (0)
|
|
|
|
/* Have our own assert, so we are sure it does not get optimized away in
|
|
* a release build.
|
|
*/
|
|
#define ASSERT(expr) \
|
|
do { \
|
|
if (!(expr)) { \
|
|
fprintf(stderr, \
|
|
"Assertion failed in %s on line %d: %s\n", \
|
|
__FILE__, \
|
|
__LINE__, \
|
|
#expr); \
|
|
abort(); \
|
|
} \
|
|
} while (0)
|
|
|
|
#define ASSERT_BASE(a, operator, b, type, conv) \
|
|
do { \
|
|
volatile type eval_a = (type) (a); \
|
|
volatile type eval_b = (type) (b); \
|
|
if (!(eval_a operator eval_b)) { \
|
|
fprintf(stderr, \
|
|
"Assertion failed in %s on line %d: `%s %s %s` " \
|
|
"(%"conv" %s %"conv")\n", \
|
|
__FILE__, \
|
|
__LINE__, \
|
|
#a, \
|
|
#operator, \
|
|
#b, \
|
|
eval_a, \
|
|
#operator, \
|
|
eval_b); \
|
|
abort(); \
|
|
} \
|
|
} while (0)
|
|
|
|
#define ASSERT_BASE_STR(expr, a, operator, b, type, conv) \
|
|
do { \
|
|
if (!(expr)) { \
|
|
fprintf(stderr, \
|
|
"Assertion failed in %s on line %d: `%s %s %s` " \
|
|
"(%"conv" %s %"conv")\n", \
|
|
__FILE__, \
|
|
__LINE__, \
|
|
#a, \
|
|
#operator, \
|
|
#b, \
|
|
(type)a, \
|
|
#operator, \
|
|
(type)b); \
|
|
abort(); \
|
|
} \
|
|
} while (0)
|
|
|
|
#define ASSERT_BASE_LEN(expr, a, operator, b, conv, len) \
|
|
do { \
|
|
if (!(expr)) { \
|
|
fprintf(stderr, \
|
|
"Assertion failed in %s on line %d: `%s %s %s` " \
|
|
"(%.*"#conv" %s %.*"#conv")\n", \
|
|
__FILE__, \
|
|
__LINE__, \
|
|
#a, \
|
|
#operator, \
|
|
#b, \
|
|
(int)len, \
|
|
a, \
|
|
#operator, \
|
|
(int)len, \
|
|
b); \
|
|
abort(); \
|
|
} \
|
|
} while (0)
|
|
|
|
#define ASSERT_BASE_HEX(expr, a, operator, b, size) \
|
|
do { \
|
|
if (!(expr)) { \
|
|
int i; \
|
|
unsigned char* a_ = (unsigned char*)a; \
|
|
unsigned char* b_ = (unsigned char*)b; \
|
|
fprintf(stderr, \
|
|
"Assertion failed in %s on line %d: `%s %s %s` (", \
|
|
__FILE__, \
|
|
__LINE__, \
|
|
#a, \
|
|
#operator, \
|
|
#b); \
|
|
for (i = 0; i < size; ++i) { \
|
|
if (i > 0) fprintf(stderr, ":"); \
|
|
fprintf(stderr, "%02X", a_[i]); \
|
|
} \
|
|
fprintf(stderr, " %s ", #operator); \
|
|
for (i = 0; i < size; ++i) { \
|
|
if (i > 0) fprintf(stderr, ":"); \
|
|
fprintf(stderr, "%02X", b_[i]); \
|
|
} \
|
|
fprintf(stderr, ")\n"); \
|
|
abort(); \
|
|
} \
|
|
} while (0)
|
|
|
|
#define ASSERT_EQ(a, b) ASSERT_BASE(a, ==, b, int64_t, PRId64)
|
|
#define ASSERT_GE(a, b) ASSERT_BASE(a, >=, b, int64_t, PRId64)
|
|
#define ASSERT_GT(a, b) ASSERT_BASE(a, >, b, int64_t, PRId64)
|
|
#define ASSERT_LE(a, b) ASSERT_BASE(a, <=, b, int64_t, PRId64)
|
|
#define ASSERT_LT(a, b) ASSERT_BASE(a, <, b, int64_t, PRId64)
|
|
#define ASSERT_NE(a, b) ASSERT_BASE(a, !=, b, int64_t, PRId64)
|
|
|
|
#define ASSERT_UINT64_EQ(a, b) ASSERT_BASE(a, ==, b, uint64_t, PRIu64)
|
|
#define ASSERT_UINT64_GE(a, b) ASSERT_BASE(a, >=, b, uint64_t, PRIu64)
|
|
#define ASSERT_UINT64_GT(a, b) ASSERT_BASE(a, >, b, uint64_t, PRIu64)
|
|
#define ASSERT_UINT64_LE(a, b) ASSERT_BASE(a, <=, b, uint64_t, PRIu64)
|
|
#define ASSERT_UINT64_LT(a, b) ASSERT_BASE(a, <, b, uint64_t, PRIu64)
|
|
#define ASSERT_UINT64_NE(a, b) ASSERT_BASE(a, !=, b, uint64_t, PRIu64)
|
|
|
|
#define ASSERT_DOUBLE_EQ(a, b) ASSERT_BASE(a, ==, b, double, "f")
|
|
#define ASSERT_DOUBLE_GE(a, b) ASSERT_BASE(a, >=, b, double, "f")
|
|
#define ASSERT_DOUBLE_GT(a, b) ASSERT_BASE(a, >, b, double, "f")
|
|
#define ASSERT_DOUBLE_LE(a, b) ASSERT_BASE(a, <=, b, double, "f")
|
|
#define ASSERT_DOUBLE_LT(a, b) ASSERT_BASE(a, <, b, double, "f")
|
|
#define ASSERT_DOUBLE_NE(a, b) ASSERT_BASE(a, !=, b, double, "f")
|
|
|
|
#define ASSERT_STR_EQ(a, b) \
|
|
ASSERT_BASE_STR(strcmp(a, b) == 0, a, == , b, char*, "s")
|
|
|
|
#define ASSERT_STR_NE(a, b) \
|
|
ASSERT_BASE_STR(strcmp(a, b) != 0, a, !=, b, char*, "s")
|
|
|
|
#define ASSERT_MEM_EQ(a, b, size) \
|
|
ASSERT_BASE_LEN(memcmp(a, b, size) == 0, a, ==, b, s, size)
|
|
|
|
#define ASSERT_MEM_NE(a, b, size) \
|
|
ASSERT_BASE_LEN(memcmp(a, b, size) != 0, a, !=, b, s, size)
|
|
|
|
#define ASSERT_MEM_HEX_EQ(a, b, size) \
|
|
ASSERT_BASE_HEX(memcmp(a, b, size) == 0, a, ==, b, size)
|
|
|
|
#define ASSERT_MEM_HEX_NE(a, b, size) \
|
|
ASSERT_BASE_HEX(memcmp(a, b, size) != 0, a, !=, b, size)
|
|
|
|
#define ASSERT_NULL(a) \
|
|
ASSERT_BASE(a, ==, NULL, void*, "p")
|
|
|
|
#define ASSERT_NOT_NULL(a) \
|
|
ASSERT_BASE(a, !=, NULL, void*, "p")
|
|
|
|
#define ASSERT_PTR_EQ(a, b) \
|
|
ASSERT_BASE(a, ==, b, void*, "p")
|
|
|
|
#define ASSERT_PTR_NE(a, b) \
|
|
ASSERT_BASE(a, !=, b, void*, "p")
|
|
|
|
/* This macro cleans up the main loop. This is used to avoid valgrind
|
|
* warnings about memory being "leaked" by the main event loop.
|
|
*/
|
|
#define MAKE_VALGRIND_HAPPY() \
|
|
do { \
|
|
close_loop(uv_default_loop()); \
|
|
ASSERT(0 == uv_loop_close(uv_default_loop())); \
|
|
uv_library_shutdown(); \
|
|
} while (0)
|
|
|
|
/* Just sugar for wrapping the main() for a task or helper. */
|
|
#define TEST_IMPL(name) \
|
|
int run_test_##name(void); \
|
|
int run_test_##name(void)
|
|
|
|
#define BENCHMARK_IMPL(name) \
|
|
int run_benchmark_##name(void); \
|
|
int run_benchmark_##name(void)
|
|
|
|
#define HELPER_IMPL(name) \
|
|
int run_helper_##name(void); \
|
|
int run_helper_##name(void)
|
|
|
|
/* Format big numbers nicely. WARNING: leaks memory. */
|
|
const char* fmt(double d);
|
|
|
|
/* Reserved test exit codes. */
|
|
enum test_status {
|
|
TEST_OK = 0,
|
|
TEST_SKIP
|
|
};
|
|
|
|
#define RETURN_OK() \
|
|
do { \
|
|
return TEST_OK; \
|
|
} while (0)
|
|
|
|
#define RETURN_SKIP(explanation) \
|
|
do { \
|
|
fprintf(stderr, "%s\n", explanation); \
|
|
fflush(stderr); \
|
|
return TEST_SKIP; \
|
|
} while (0)
|
|
|
|
#if !defined(_WIN32)
|
|
|
|
# define TEST_FILE_LIMIT(num) \
|
|
do { \
|
|
struct rlimit lim; \
|
|
lim.rlim_cur = (num); \
|
|
lim.rlim_max = lim.rlim_cur; \
|
|
if (setrlimit(RLIMIT_NOFILE, &lim)) \
|
|
RETURN_SKIP("File descriptor limit too low."); \
|
|
} while (0)
|
|
|
|
#else /* defined(_WIN32) */
|
|
|
|
# define TEST_FILE_LIMIT(num) do {} while (0)
|
|
|
|
#endif
|
|
|
|
#if defined(__clang__) || \
|
|
defined(__GNUC__) || \
|
|
defined(__INTEL_COMPILER)
|
|
# define UNUSED __attribute__((unused))
|
|
#else
|
|
# define UNUSED
|
|
#endif
|
|
|
|
#if defined(_WIN32)
|
|
#define notify_parent_process() ((void) 0)
|
|
#else
|
|
extern void notify_parent_process(void);
|
|
#endif
|
|
|
|
/* Fully close a loop */
|
|
static void close_walk_cb(uv_handle_t* handle, void* arg) {
|
|
if (!uv_is_closing(handle))
|
|
uv_close(handle, NULL);
|
|
}
|
|
|
|
UNUSED static void close_loop(uv_loop_t* loop) {
|
|
uv_walk(loop, close_walk_cb, NULL);
|
|
uv_run(loop, UV_RUN_DEFAULT);
|
|
}
|
|
|
|
UNUSED static int can_ipv6(void) {
|
|
uv_interface_address_t* addr;
|
|
int supported;
|
|
int count;
|
|
int i;
|
|
|
|
if (uv_interface_addresses(&addr, &count))
|
|
return 0; /* Assume no IPv6 support on failure. */
|
|
|
|
supported = 0;
|
|
for (i = 0; supported == 0 && i < count; i += 1)
|
|
supported = (AF_INET6 == addr[i].address.address6.sin6_family);
|
|
|
|
uv_free_interface_addresses(addr, count);
|
|
return supported;
|
|
}
|
|
|
|
#if defined(__CYGWIN__) || defined(__MSYS__) || defined(__PASE__)
|
|
# define NO_FS_EVENTS "Filesystem watching not supported on this platform."
|
|
#endif
|
|
|
|
#if defined(__MSYS__)
|
|
# define NO_SEND_HANDLE_ON_PIPE \
|
|
"MSYS2 runtime does not support sending handles on pipes."
|
|
#elif defined(__CYGWIN__)
|
|
# define NO_SEND_HANDLE_ON_PIPE \
|
|
"Cygwin runtime does not support sending handles on pipes."
|
|
#endif
|
|
|
|
#if defined(__MSYS__)
|
|
# define NO_SELF_CONNECT \
|
|
"MSYS2 runtime hangs on listen+connect in same process."
|
|
#elif defined(__CYGWIN__)
|
|
# define NO_SELF_CONNECT \
|
|
"Cygwin runtime hangs on listen+connect in same process."
|
|
#endif
|
|
|
|
#if !defined(__linux__) && \
|
|
!defined(__FreeBSD__) && \
|
|
!defined(_WIN32)
|
|
# define NO_CPU_AFFINITY \
|
|
"affinity not supported on this platform."
|
|
#endif
|
|
|
|
#endif /* TASK_H_ */
|