|
Packit |
b5b901 |
/* Copyright Joyent, Inc. and other Node contributors. All rights reserved.
|
|
Packit |
b5b901 |
*
|
|
Packit |
b5b901 |
* Permission is hereby granted, free of charge, to any person obtaining a copy
|
|
Packit |
b5b901 |
* of this software and associated documentation files (the "Software"), to
|
|
Packit |
b5b901 |
* deal in the Software without restriction, including without limitation the
|
|
Packit |
b5b901 |
* rights to use, copy, modify, merge, publish, distribute, sublicense, and/or
|
|
Packit |
b5b901 |
* sell copies of the Software, and to permit persons to whom the Software is
|
|
Packit |
b5b901 |
* furnished to do so, subject to the following conditions:
|
|
Packit |
b5b901 |
*
|
|
Packit |
b5b901 |
* The above copyright notice and this permission notice shall be included in
|
|
Packit |
b5b901 |
* all copies or substantial portions of the Software.
|
|
Packit |
b5b901 |
*
|
|
Packit |
b5b901 |
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
|
|
Packit |
b5b901 |
* IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
|
|
Packit |
b5b901 |
* FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
|
|
Packit |
b5b901 |
* AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
|
|
Packit |
b5b901 |
* LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
|
|
Packit |
b5b901 |
* FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS
|
|
Packit |
b5b901 |
* IN THE SOFTWARE.
|
|
Packit |
b5b901 |
*/
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
#ifndef TASK_H_
|
|
Packit |
b5b901 |
#define TASK_H_
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
#include "uv.h"
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
#include <stdio.h>
|
|
Packit |
b5b901 |
#include <stddef.h>
|
|
Packit |
b5b901 |
#include <stdlib.h>
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
#if defined(_MSC_VER) && _MSC_VER < 1600
|
|
Packit |
b5b901 |
# include "uv/stdint-msvc2008.h"
|
|
Packit |
b5b901 |
#else
|
|
Packit |
b5b901 |
# include <stdint.h>
|
|
Packit |
b5b901 |
#endif
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
#if !defined(_WIN32)
|
|
Packit |
b5b901 |
# include <sys/time.h>
|
|
Packit |
b5b901 |
# include <sys/resource.h> /* setrlimit() */
|
|
Packit |
b5b901 |
#endif
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
#ifdef __clang__
|
|
Packit |
b5b901 |
# pragma clang diagnostic ignored "-Wvariadic-macros"
|
|
Packit |
b5b901 |
# pragma clang diagnostic ignored "-Wc99-extensions"
|
|
Packit |
b5b901 |
#endif
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
#define TEST_PORT 9123
|
|
Packit |
b5b901 |
#define TEST_PORT_2 9124
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
#ifdef _WIN32
|
|
Packit |
b5b901 |
# define TEST_PIPENAME "\\\\?\\pipe\\uv-test"
|
|
Packit |
b5b901 |
# define TEST_PIPENAME_2 "\\\\?\\pipe\\uv-test2"
|
|
Packit |
b5b901 |
# define TEST_PIPENAME_3 "\\\\?\\pipe\\uv-test3"
|
|
Packit |
b5b901 |
#else
|
|
Packit |
b5b901 |
# define TEST_PIPENAME "/tmp/uv-test-sock"
|
|
Packit |
b5b901 |
# define TEST_PIPENAME_2 "/tmp/uv-test-sock2"
|
|
Packit |
b5b901 |
# define TEST_PIPENAME_3 "/tmp/uv-test-sock3"
|
|
Packit |
b5b901 |
#endif
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
#ifdef _WIN32
|
|
Packit |
b5b901 |
# include <io.h>
|
|
Packit |
b5b901 |
# ifndef S_IRUSR
|
|
Packit |
b5b901 |
# define S_IRUSR _S_IREAD
|
|
Packit |
b5b901 |
# endif
|
|
Packit |
b5b901 |
# ifndef S_IWUSR
|
|
Packit |
b5b901 |
# define S_IWUSR _S_IWRITE
|
|
Packit |
b5b901 |
# endif
|
|
Packit |
b5b901 |
#endif
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
#define ARRAY_SIZE(a) (sizeof(a) / sizeof((a)[0]))
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
#define container_of(ptr, type, member) \
|
|
Packit |
b5b901 |
((type *) ((char *) (ptr) - offsetof(type, member)))
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
typedef enum {
|
|
Packit |
b5b901 |
TCP = 0,
|
|
Packit |
b5b901 |
UDP,
|
|
Packit |
b5b901 |
PIPE
|
|
Packit |
b5b901 |
} stream_type;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
/* Die with fatal error. */
|
|
Packit |
b5b901 |
#define FATAL(msg) \
|
|
Packit |
b5b901 |
do { \
|
|
Packit |
b5b901 |
fprintf(stderr, \
|
|
Packit |
b5b901 |
"Fatal error in %s on line %d: %s\n", \
|
|
Packit |
b5b901 |
__FILE__, \
|
|
Packit |
b5b901 |
__LINE__, \
|
|
Packit |
b5b901 |
msg); \
|
|
Packit |
b5b901 |
fflush(stderr); \
|
|
Packit |
b5b901 |
abort(); \
|
|
Packit |
b5b901 |
} while (0)
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
/* Have our own assert, so we are sure it does not get optimized away in
|
|
Packit |
b5b901 |
* a release build.
|
|
Packit |
b5b901 |
*/
|
|
Packit |
b5b901 |
#define ASSERT(expr) \
|
|
Packit |
b5b901 |
do { \
|
|
Packit |
b5b901 |
if (!(expr)) { \
|
|
Packit |
b5b901 |
fprintf(stderr, \
|
|
Packit |
b5b901 |
"Assertion failed in %s on line %d: %s\n", \
|
|
Packit |
b5b901 |
__FILE__, \
|
|
Packit |
b5b901 |
__LINE__, \
|
|
Packit |
b5b901 |
#expr); \
|
|
Packit |
b5b901 |
abort(); \
|
|
Packit |
b5b901 |
} \
|
|
Packit |
b5b901 |
} while (0)
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
/* This macro cleans up the main loop. This is used to avoid valgrind
|
|
Packit |
b5b901 |
* warnings about memory being "leaked" by the main event loop.
|
|
Packit |
b5b901 |
*/
|
|
Packit |
b5b901 |
#define MAKE_VALGRIND_HAPPY() \
|
|
Packit |
b5b901 |
do { \
|
|
Packit |
b5b901 |
close_loop(uv_default_loop()); \
|
|
Packit |
b5b901 |
ASSERT(0 == uv_loop_close(uv_default_loop())); \
|
|
Packit |
b5b901 |
} while (0)
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
/* Just sugar for wrapping the main() for a task or helper. */
|
|
Packit |
b5b901 |
#define TEST_IMPL(name) \
|
|
Packit |
b5b901 |
int run_test_##name(void); \
|
|
Packit |
b5b901 |
int run_test_##name(void)
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
#define BENCHMARK_IMPL(name) \
|
|
Packit |
b5b901 |
int run_benchmark_##name(void); \
|
|
Packit |
b5b901 |
int run_benchmark_##name(void)
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
#define HELPER_IMPL(name) \
|
|
Packit |
b5b901 |
int run_helper_##name(void); \
|
|
Packit |
b5b901 |
int run_helper_##name(void)
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
/* Pause the calling thread for a number of milliseconds. */
|
|
Packit |
b5b901 |
void uv_sleep(int msec);
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
/* Format big numbers nicely. WARNING: leaks memory. */
|
|
Packit |
b5b901 |
const char* fmt(double d);
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
/* Reserved test exit codes. */
|
|
Packit |
b5b901 |
enum test_status {
|
|
Packit |
b5b901 |
TEST_OK = 0,
|
|
Packit |
b5b901 |
TEST_SKIP
|
|
Packit |
b5b901 |
};
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
#define RETURN_OK() \
|
|
Packit |
b5b901 |
do { \
|
|
Packit |
b5b901 |
return TEST_OK; \
|
|
Packit |
b5b901 |
} while (0)
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
#define RETURN_SKIP(explanation) \
|
|
Packit |
b5b901 |
do { \
|
|
Packit |
b5b901 |
fprintf(stderr, "%s\n", explanation); \
|
|
Packit |
b5b901 |
fflush(stderr); \
|
|
Packit |
b5b901 |
return TEST_SKIP; \
|
|
Packit |
b5b901 |
} while (0)
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
#if !defined(_WIN32)
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
# define TEST_FILE_LIMIT(num) \
|
|
Packit |
b5b901 |
do { \
|
|
Packit |
b5b901 |
struct rlimit lim; \
|
|
Packit |
b5b901 |
lim.rlim_cur = (num); \
|
|
Packit |
b5b901 |
lim.rlim_max = lim.rlim_cur; \
|
|
Packit |
b5b901 |
if (setrlimit(RLIMIT_NOFILE, &lim)) \
|
|
Packit |
b5b901 |
RETURN_SKIP("File descriptor limit too low."); \
|
|
Packit |
b5b901 |
} while (0)
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
#else /* defined(_WIN32) */
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
# define TEST_FILE_LIMIT(num) do {} while (0)
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
#endif
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
#if !defined(snprintf) && defined(_MSC_VER) && _MSC_VER < 1900
|
|
Packit |
b5b901 |
extern int snprintf(char*, size_t, const char*, ...);
|
|
Packit |
b5b901 |
#endif
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
#if defined(__clang__) || \
|
|
Packit |
b5b901 |
defined(__GNUC__) || \
|
|
Packit |
b5b901 |
defined(__INTEL_COMPILER) || \
|
|
Packit |
b5b901 |
defined(__SUNPRO_C)
|
|
Packit |
b5b901 |
# define UNUSED __attribute__((unused))
|
|
Packit |
b5b901 |
#else
|
|
Packit |
b5b901 |
# define UNUSED
|
|
Packit |
b5b901 |
#endif
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
/* Fully close a loop */
|
|
Packit |
b5b901 |
static void close_walk_cb(uv_handle_t* handle, void* arg) {
|
|
Packit |
b5b901 |
if (!uv_is_closing(handle))
|
|
Packit |
b5b901 |
uv_close(handle, NULL);
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
UNUSED static void close_loop(uv_loop_t* loop) {
|
|
Packit |
b5b901 |
uv_walk(loop, close_walk_cb, NULL);
|
|
Packit |
b5b901 |
uv_run(loop, UV_RUN_DEFAULT);
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
UNUSED static int can_ipv6(void) {
|
|
Packit |
b5b901 |
uv_interface_address_t* addr;
|
|
Packit |
b5b901 |
int supported;
|
|
Packit |
b5b901 |
int count;
|
|
Packit |
b5b901 |
int i;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (uv_interface_addresses(&addr, &count))
|
|
Packit |
b5b901 |
return 0; /* Assume no IPv6 support on failure. */
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
supported = 0;
|
|
Packit |
b5b901 |
for (i = 0; supported == 0 && i < count; i += 1)
|
|
Packit |
b5b901 |
supported = (AF_INET6 == addr[i].address.address6.sin6_family);
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
uv_free_interface_addresses(addr, count);
|
|
Packit |
b5b901 |
return supported;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
#if defined(__CYGWIN__) || defined(__MSYS__)
|
|
Packit |
b5b901 |
# define NO_FS_EVENTS "Filesystem watching not supported on this platform."
|
|
Packit |
b5b901 |
#endif
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
#if defined(__MSYS__)
|
|
Packit |
b5b901 |
# define NO_SEND_HANDLE_ON_PIPE \
|
|
Packit |
b5b901 |
"MSYS2 runtime does not support sending handles on pipes."
|
|
Packit |
b5b901 |
#elif defined(__CYGWIN__)
|
|
Packit |
b5b901 |
# define NO_SEND_HANDLE_ON_PIPE \
|
|
Packit |
b5b901 |
"Cygwin runtime does not support sending handles on pipes."
|
|
Packit |
b5b901 |
#endif
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
#if defined(__MSYS__)
|
|
Packit |
b5b901 |
# define NO_SELF_CONNECT \
|
|
Packit |
b5b901 |
"MSYS2 runtime hangs on listen+connect in same process."
|
|
Packit |
b5b901 |
#elif defined(__CYGWIN__)
|
|
Packit |
b5b901 |
# define NO_SELF_CONNECT \
|
|
Packit |
b5b901 |
"Cygwin runtime hangs on listen+connect in same process."
|
|
Packit |
b5b901 |
#endif
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
#endif /* TASK_H_ */
|