task.h revision 1.1.1.2.4.2
1 1.1.1.2.4.2 martin /* Copyright Joyent, Inc. and other Node contributors. All rights reserved. 2 1.1.1.2.4.2 martin * 3 1.1.1.2.4.2 martin * Permission is hereby granted, free of charge, to any person obtaining a copy 4 1.1.1.2.4.2 martin * of this software and associated documentation files (the "Software"), to 5 1.1.1.2.4.2 martin * deal in the Software without restriction, including without limitation the 6 1.1.1.2.4.2 martin * rights to use, copy, modify, merge, publish, distribute, sublicense, and/or 7 1.1.1.2.4.2 martin * sell copies of the Software, and to permit persons to whom the Software is 8 1.1.1.2.4.2 martin * furnished to do so, subject to the following conditions: 9 1.1.1.2.4.2 martin * 10 1.1.1.2.4.2 martin * The above copyright notice and this permission notice shall be included in 11 1.1.1.2.4.2 martin * all copies or substantial portions of the Software. 12 1.1.1.2.4.2 martin * 13 1.1.1.2.4.2 martin * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR 14 1.1.1.2.4.2 martin * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, 15 1.1.1.2.4.2 martin * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE 16 1.1.1.2.4.2 martin * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER 17 1.1.1.2.4.2 martin * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING 18 1.1.1.2.4.2 martin * FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS 19 1.1.1.2.4.2 martin * IN THE SOFTWARE. 20 1.1.1.2.4.2 martin */ 21 1.1.1.2.4.2 martin 22 1.1.1.2.4.2 martin #ifndef TASK_H_ 23 1.1.1.2.4.2 martin #define TASK_H_ 24 1.1.1.2.4.2 martin 25 1.1.1.2.4.2 martin #include "uv.h" 26 1.1.1.2.4.2 martin 27 1.1.1.2.4.2 martin #include <stdio.h> 28 1.1.1.2.4.2 martin #include <stddef.h> 29 1.1.1.2.4.2 martin #include <stdlib.h> 30 1.1.1.2.4.2 martin #include <string.h> 31 1.1.1.2.4.2 martin #include <inttypes.h> 32 1.1.1.2.4.2 martin 33 1.1.1.2.4.2 martin #if defined(_MSC_VER) && _MSC_VER < 1600 34 1.1.1.2.4.2 martin # include "uv/stdint-msvc2008.h" 35 1.1.1.2.4.2 martin #else 36 1.1.1.2.4.2 martin # include <stdint.h> 37 1.1.1.2.4.2 martin #endif 38 1.1.1.2.4.2 martin 39 1.1.1.2.4.2 martin #if !defined(_WIN32) 40 1.1.1.2.4.2 martin # include <sys/time.h> 41 1.1.1.2.4.2 martin # include <sys/resource.h> /* setrlimit() */ 42 1.1.1.2.4.2 martin #endif 43 1.1.1.2.4.2 martin 44 1.1.1.2.4.2 martin #ifdef __clang__ 45 1.1.1.2.4.2 martin # pragma clang diagnostic ignored "-Wvariadic-macros" 46 1.1.1.2.4.2 martin # pragma clang diagnostic ignored "-Wc99-extensions" 47 1.1.1.2.4.2 martin #endif 48 1.1.1.2.4.2 martin 49 1.1.1.2.4.2 martin #ifdef __GNUC__ 50 1.1.1.2.4.2 martin # pragma GCC diagnostic ignored "-Wvariadic-macros" 51 1.1.1.2.4.2 martin #endif 52 1.1.1.2.4.2 martin 53 1.1.1.2.4.2 martin #define TEST_PORT 9123 54 1.1.1.2.4.2 martin #define TEST_PORT_2 9124 55 1.1.1.2.4.2 martin #define TEST_PORT_3 9125 56 1.1.1.2.4.2 martin 57 1.1.1.2.4.2 martin #ifdef _WIN32 58 1.1.1.2.4.2 martin # define TEST_PIPENAME "\\\\?\\pipe\\uv-test" 59 1.1.1.2.4.2 martin # define TEST_PIPENAME_2 "\\\\?\\pipe\\uv-test2" 60 1.1.1.2.4.2 martin # define TEST_PIPENAME_3 "\\\\?\\pipe\\uv-test3" 61 1.1.1.2.4.2 martin #else 62 1.1.1.2.4.2 martin # define TEST_PIPENAME "/tmp/uv-test-sock" 63 1.1.1.2.4.2 martin # define TEST_PIPENAME_2 "/tmp/uv-test-sock2" 64 1.1.1.2.4.2 martin # define TEST_PIPENAME_3 "/tmp/uv-test-sock3" 65 1.1.1.2.4.2 martin #endif 66 1.1.1.2.4.2 martin 67 1.1.1.2.4.2 martin #ifdef _WIN32 68 1.1.1.2.4.2 martin # include <io.h> 69 1.1.1.2.4.2 martin # ifndef S_IRUSR 70 1.1.1.2.4.2 martin # define S_IRUSR _S_IREAD 71 1.1.1.2.4.2 martin # endif 72 1.1.1.2.4.2 martin # ifndef S_IWUSR 73 1.1.1.2.4.2 martin # define S_IWUSR _S_IWRITE 74 1.1.1.2.4.2 martin # endif 75 1.1.1.2.4.2 martin #endif 76 1.1.1.2.4.2 martin 77 1.1.1.2.4.2 martin #define ARRAY_SIZE(a) (sizeof(a) / sizeof((a)[0])) 78 1.1.1.2.4.2 martin 79 1.1.1.2.4.2 martin #define container_of(ptr, type, member) \ 80 1.1.1.2.4.2 martin ((type *) ((char *) (ptr) - offsetof(type, member))) 81 1.1.1.2.4.2 martin 82 1.1.1.2.4.2 martin typedef enum { 83 1.1.1.2.4.2 martin TCP = 0, 84 1.1.1.2.4.2 martin UDP, 85 1.1.1.2.4.2 martin PIPE 86 1.1.1.2.4.2 martin } stream_type; 87 1.1.1.2.4.2 martin 88 1.1.1.2.4.2 martin /* Die with fatal error. */ 89 1.1.1.2.4.2 martin #define FATAL(msg) \ 90 1.1.1.2.4.2 martin do { \ 91 1.1.1.2.4.2 martin fprintf(stderr, \ 92 1.1.1.2.4.2 martin "Fatal error in %s on line %d: %s\n", \ 93 1.1.1.2.4.2 martin __FILE__, \ 94 1.1.1.2.4.2 martin __LINE__, \ 95 1.1.1.2.4.2 martin msg); \ 96 1.1.1.2.4.2 martin fflush(stderr); \ 97 1.1.1.2.4.2 martin abort(); \ 98 1.1.1.2.4.2 martin } while (0) 99 1.1.1.2.4.2 martin 100 1.1.1.2.4.2 martin /* Have our own assert, so we are sure it does not get optimized away in 101 1.1.1.2.4.2 martin * a release build. 102 1.1.1.2.4.2 martin */ 103 1.1.1.2.4.2 martin #define ASSERT(expr) \ 104 1.1.1.2.4.2 martin do { \ 105 1.1.1.2.4.2 martin if (!(expr)) { \ 106 1.1.1.2.4.2 martin fprintf(stderr, \ 107 1.1.1.2.4.2 martin "Assertion failed in %s on line %d: %s\n", \ 108 1.1.1.2.4.2 martin __FILE__, \ 109 1.1.1.2.4.2 martin __LINE__, \ 110 1.1.1.2.4.2 martin #expr); \ 111 1.1.1.2.4.2 martin abort(); \ 112 1.1.1.2.4.2 martin } \ 113 1.1.1.2.4.2 martin } while (0) 114 1.1.1.2.4.2 martin 115 1.1.1.2.4.2 martin #define ASSERT_BASE(a, operator, b, type, conv) \ 116 1.1.1.2.4.2 martin do { \ 117 1.1.1.2.4.2 martin volatile type eval_a = (type) (a); \ 118 1.1.1.2.4.2 martin volatile type eval_b = (type) (b); \ 119 1.1.1.2.4.2 martin if (!(eval_a operator eval_b)) { \ 120 1.1.1.2.4.2 martin fprintf(stderr, \ 121 1.1.1.2.4.2 martin "Assertion failed in %s on line %d: `%s %s %s` " \ 122 1.1.1.2.4.2 martin "(%"conv" %s %"conv")\n", \ 123 1.1.1.2.4.2 martin __FILE__, \ 124 1.1.1.2.4.2 martin __LINE__, \ 125 1.1.1.2.4.2 martin #a, \ 126 1.1.1.2.4.2 martin #operator, \ 127 1.1.1.2.4.2 martin #b, \ 128 1.1.1.2.4.2 martin eval_a, \ 129 1.1.1.2.4.2 martin #operator, \ 130 1.1.1.2.4.2 martin eval_b); \ 131 1.1.1.2.4.2 martin abort(); \ 132 1.1.1.2.4.2 martin } \ 133 1.1.1.2.4.2 martin } while (0) 134 1.1.1.2.4.2 martin 135 1.1.1.2.4.2 martin #define ASSERT_BASE_STR(expr, a, operator, b, type, conv) \ 136 1.1.1.2.4.2 martin do { \ 137 1.1.1.2.4.2 martin if (!(expr)) { \ 138 1.1.1.2.4.2 martin fprintf(stderr, \ 139 1.1.1.2.4.2 martin "Assertion failed in %s on line %d: `%s %s %s` " \ 140 1.1.1.2.4.2 martin "(%"conv" %s %"conv")\n", \ 141 1.1.1.2.4.2 martin __FILE__, \ 142 1.1.1.2.4.2 martin __LINE__, \ 143 1.1.1.2.4.2 martin #a, \ 144 1.1.1.2.4.2 martin #operator, \ 145 1.1.1.2.4.2 martin #b, \ 146 1.1.1.2.4.2 martin (type)a, \ 147 1.1.1.2.4.2 martin #operator, \ 148 1.1.1.2.4.2 martin (type)b); \ 149 1.1.1.2.4.2 martin abort(); \ 150 1.1.1.2.4.2 martin } \ 151 1.1.1.2.4.2 martin } while (0) 152 1.1.1.2.4.2 martin 153 1.1.1.2.4.2 martin #define ASSERT_BASE_LEN(expr, a, operator, b, conv, len) \ 154 1.1.1.2.4.2 martin do { \ 155 1.1.1.2.4.2 martin if (!(expr)) { \ 156 1.1.1.2.4.2 martin fprintf(stderr, \ 157 1.1.1.2.4.2 martin "Assertion failed in %s on line %d: `%s %s %s` " \ 158 1.1.1.2.4.2 martin "(%.*"#conv" %s %.*"#conv")\n", \ 159 1.1.1.2.4.2 martin __FILE__, \ 160 1.1.1.2.4.2 martin __LINE__, \ 161 1.1.1.2.4.2 martin #a, \ 162 1.1.1.2.4.2 martin #operator, \ 163 1.1.1.2.4.2 martin #b, \ 164 1.1.1.2.4.2 martin (int)len, \ 165 1.1.1.2.4.2 martin a, \ 166 1.1.1.2.4.2 martin #operator, \ 167 1.1.1.2.4.2 martin (int)len, \ 168 1.1.1.2.4.2 martin b); \ 169 1.1.1.2.4.2 martin abort(); \ 170 1.1.1.2.4.2 martin } \ 171 1.1.1.2.4.2 martin } while (0) 172 1.1.1.2.4.2 martin 173 1.1.1.2.4.2 martin #define ASSERT_BASE_HEX(expr, a, operator, b, size) \ 174 1.1.1.2.4.2 martin do { \ 175 1.1.1.2.4.2 martin if (!(expr)) { \ 176 1.1.1.2.4.2 martin int i; \ 177 1.1.1.2.4.2 martin unsigned char* a_ = (unsigned char*)a; \ 178 1.1.1.2.4.2 martin unsigned char* b_ = (unsigned char*)b; \ 179 1.1.1.2.4.2 martin fprintf(stderr, \ 180 1.1.1.2.4.2 martin "Assertion failed in %s on line %d: `%s %s %s` (", \ 181 1.1.1.2.4.2 martin __FILE__, \ 182 1.1.1.2.4.2 martin __LINE__, \ 183 1.1.1.2.4.2 martin #a, \ 184 1.1.1.2.4.2 martin #operator, \ 185 1.1.1.2.4.2 martin #b); \ 186 1.1.1.2.4.2 martin for (i = 0; i < size; ++i) { \ 187 1.1.1.2.4.2 martin if (i > 0) fprintf(stderr, ":"); \ 188 1.1.1.2.4.2 martin fprintf(stderr, "%02X", a_[i]); \ 189 1.1.1.2.4.2 martin } \ 190 1.1.1.2.4.2 martin fprintf(stderr, " %s ", #operator); \ 191 1.1.1.2.4.2 martin for (i = 0; i < size; ++i) { \ 192 1.1.1.2.4.2 martin if (i > 0) fprintf(stderr, ":"); \ 193 1.1.1.2.4.2 martin fprintf(stderr, "%02X", b_[i]); \ 194 1.1.1.2.4.2 martin } \ 195 1.1.1.2.4.2 martin fprintf(stderr, ")\n"); \ 196 1.1.1.2.4.2 martin abort(); \ 197 1.1.1.2.4.2 martin } \ 198 1.1.1.2.4.2 martin } while (0) 199 1.1.1.2.4.2 martin 200 1.1.1.2.4.2 martin #define ASSERT_EQ(a, b) ASSERT_BASE(a, ==, b, int64_t, PRId64) 201 1.1.1.2.4.2 martin #define ASSERT_GE(a, b) ASSERT_BASE(a, >=, b, int64_t, PRId64) 202 1.1.1.2.4.2 martin #define ASSERT_GT(a, b) ASSERT_BASE(a, >, b, int64_t, PRId64) 203 1.1.1.2.4.2 martin #define ASSERT_LE(a, b) ASSERT_BASE(a, <=, b, int64_t, PRId64) 204 1.1.1.2.4.2 martin #define ASSERT_LT(a, b) ASSERT_BASE(a, <, b, int64_t, PRId64) 205 1.1.1.2.4.2 martin #define ASSERT_NE(a, b) ASSERT_BASE(a, !=, b, int64_t, PRId64) 206 1.1.1.2.4.2 martin 207 1.1.1.2.4.2 martin #define ASSERT_UINT64_EQ(a, b) ASSERT_BASE(a, ==, b, uint64_t, PRIu64) 208 1.1.1.2.4.2 martin #define ASSERT_UINT64_GE(a, b) ASSERT_BASE(a, >=, b, uint64_t, PRIu64) 209 1.1.1.2.4.2 martin #define ASSERT_UINT64_GT(a, b) ASSERT_BASE(a, >, b, uint64_t, PRIu64) 210 1.1.1.2.4.2 martin #define ASSERT_UINT64_LE(a, b) ASSERT_BASE(a, <=, b, uint64_t, PRIu64) 211 1.1.1.2.4.2 martin #define ASSERT_UINT64_LT(a, b) ASSERT_BASE(a, <, b, uint64_t, PRIu64) 212 1.1.1.2.4.2 martin #define ASSERT_UINT64_NE(a, b) ASSERT_BASE(a, !=, b, uint64_t, PRIu64) 213 1.1.1.2.4.2 martin 214 1.1.1.2.4.2 martin #define ASSERT_DOUBLE_EQ(a, b) ASSERT_BASE(a, ==, b, double, "f") 215 1.1.1.2.4.2 martin #define ASSERT_DOUBLE_GE(a, b) ASSERT_BASE(a, >=, b, double, "f") 216 1.1.1.2.4.2 martin #define ASSERT_DOUBLE_GT(a, b) ASSERT_BASE(a, >, b, double, "f") 217 1.1.1.2.4.2 martin #define ASSERT_DOUBLE_LE(a, b) ASSERT_BASE(a, <=, b, double, "f") 218 1.1.1.2.4.2 martin #define ASSERT_DOUBLE_LT(a, b) ASSERT_BASE(a, <, b, double, "f") 219 1.1.1.2.4.2 martin #define ASSERT_DOUBLE_NE(a, b) ASSERT_BASE(a, !=, b, double, "f") 220 1.1.1.2.4.2 martin 221 1.1.1.2.4.2 martin #define ASSERT_STR_EQ(a, b) \ 222 1.1.1.2.4.2 martin ASSERT_BASE_STR(strcmp(a, b) == 0, a, == , b, char*, "s") 223 1.1.1.2.4.2 martin 224 1.1.1.2.4.2 martin #define ASSERT_STR_NE(a, b) \ 225 1.1.1.2.4.2 martin ASSERT_BASE_STR(strcmp(a, b) != 0, a, !=, b, char*, "s") 226 1.1.1.2.4.2 martin 227 1.1.1.2.4.2 martin #define ASSERT_MEM_EQ(a, b, size) \ 228 1.1.1.2.4.2 martin ASSERT_BASE_LEN(memcmp(a, b, size) == 0, a, ==, b, s, size) 229 1.1.1.2.4.2 martin 230 1.1.1.2.4.2 martin #define ASSERT_MEM_NE(a, b, size) \ 231 1.1.1.2.4.2 martin ASSERT_BASE_LEN(memcmp(a, b, size) != 0, a, !=, b, s, size) 232 1.1.1.2.4.2 martin 233 1.1.1.2.4.2 martin #define ASSERT_MEM_HEX_EQ(a, b, size) \ 234 1.1.1.2.4.2 martin ASSERT_BASE_HEX(memcmp(a, b, size) == 0, a, ==, b, size) 235 1.1.1.2.4.2 martin 236 1.1.1.2.4.2 martin #define ASSERT_MEM_HEX_NE(a, b, size) \ 237 1.1.1.2.4.2 martin ASSERT_BASE_HEX(memcmp(a, b, size) != 0, a, !=, b, size) 238 1.1.1.2.4.2 martin 239 1.1.1.2.4.2 martin #define ASSERT_NULL(a) \ 240 1.1.1.2.4.2 martin ASSERT_BASE(a, ==, NULL, void*, "p") 241 1.1.1.2.4.2 martin 242 1.1.1.2.4.2 martin #define ASSERT_NOT_NULL(a) \ 243 1.1.1.2.4.2 martin ASSERT_BASE(a, !=, NULL, void*, "p") 244 1.1.1.2.4.2 martin 245 1.1.1.2.4.2 martin #define ASSERT_PTR_EQ(a, b) \ 246 1.1.1.2.4.2 martin ASSERT_BASE(a, ==, b, void*, "p") 247 1.1.1.2.4.2 martin 248 1.1.1.2.4.2 martin #define ASSERT_PTR_NE(a, b) \ 249 1.1.1.2.4.2 martin ASSERT_BASE(a, !=, b, void*, "p") 250 1.1.1.2.4.2 martin 251 1.1.1.2.4.2 martin /* This macro cleans up the main loop. This is used to avoid valgrind 252 1.1.1.2.4.2 martin * warnings about memory being "leaked" by the main event loop. 253 1.1.1.2.4.2 martin */ 254 1.1.1.2.4.2 martin #define MAKE_VALGRIND_HAPPY() \ 255 1.1.1.2.4.2 martin do { \ 256 1.1.1.2.4.2 martin close_loop(uv_default_loop()); \ 257 1.1.1.2.4.2 martin ASSERT(0 == uv_loop_close(uv_default_loop())); \ 258 1.1.1.2.4.2 martin uv_library_shutdown(); \ 259 1.1.1.2.4.2 martin } while (0) 260 1.1.1.2.4.2 martin 261 1.1.1.2.4.2 martin /* Just sugar for wrapping the main() for a task or helper. */ 262 1.1.1.2.4.2 martin #define TEST_IMPL(name) \ 263 1.1.1.2.4.2 martin int run_test_##name(void); \ 264 1.1.1.2.4.2 martin int run_test_##name(void) 265 1.1.1.2.4.2 martin 266 1.1.1.2.4.2 martin #define BENCHMARK_IMPL(name) \ 267 1.1.1.2.4.2 martin int run_benchmark_##name(void); \ 268 1.1.1.2.4.2 martin int run_benchmark_##name(void) 269 1.1.1.2.4.2 martin 270 1.1.1.2.4.2 martin #define HELPER_IMPL(name) \ 271 1.1.1.2.4.2 martin int run_helper_##name(void); \ 272 1.1.1.2.4.2 martin int run_helper_##name(void) 273 1.1.1.2.4.2 martin 274 1.1.1.2.4.2 martin /* Format big numbers nicely. WARNING: leaks memory. */ 275 1.1.1.2.4.2 martin const char* fmt(double d); 276 1.1.1.2.4.2 martin 277 1.1.1.2.4.2 martin /* Reserved test exit codes. */ 278 1.1.1.2.4.2 martin enum test_status { 279 1.1.1.2.4.2 martin TEST_OK = 0, 280 1.1.1.2.4.2 martin TEST_SKIP = 7 281 1.1.1.2.4.2 martin }; 282 1.1.1.2.4.2 martin 283 1.1.1.2.4.2 martin #define RETURN_OK() \ 284 1.1.1.2.4.2 martin do { \ 285 1.1.1.2.4.2 martin return TEST_OK; \ 286 1.1.1.2.4.2 martin } while (0) 287 1.1.1.2.4.2 martin 288 1.1.1.2.4.2 martin #define RETURN_SKIP(explanation) \ 289 1.1.1.2.4.2 martin do { \ 290 1.1.1.2.4.2 martin fprintf(stderr, "%s\n", explanation); \ 291 1.1.1.2.4.2 martin fflush(stderr); \ 292 1.1.1.2.4.2 martin return TEST_SKIP; \ 293 1.1.1.2.4.2 martin } while (0) 294 1.1.1.2.4.2 martin 295 1.1.1.2.4.2 martin #if !defined(_WIN32) 296 1.1.1.2.4.2 martin 297 1.1.1.2.4.2 martin # define TEST_FILE_LIMIT(num) \ 298 1.1.1.2.4.2 martin do { \ 299 1.1.1.2.4.2 martin struct rlimit lim; \ 300 1.1.1.2.4.2 martin lim.rlim_cur = (num); \ 301 1.1.1.2.4.2 martin lim.rlim_max = lim.rlim_cur; \ 302 1.1.1.2.4.2 martin if (setrlimit(RLIMIT_NOFILE, &lim)) \ 303 1.1.1.2.4.2 martin RETURN_SKIP("File descriptor limit too low."); \ 304 1.1.1.2.4.2 martin } while (0) 305 1.1.1.2.4.2 martin 306 1.1.1.2.4.2 martin #else /* defined(_WIN32) */ 307 1.1.1.2.4.2 martin 308 1.1.1.2.4.2 martin # define TEST_FILE_LIMIT(num) do {} while (0) 309 1.1.1.2.4.2 martin 310 1.1.1.2.4.2 martin #endif 311 1.1.1.2.4.2 martin 312 1.1.1.2.4.2 martin #if !defined(snprintf) && defined(_MSC_VER) && _MSC_VER < 1900 313 1.1.1.2.4.2 martin extern int snprintf(char*, size_t, const char*, ...); 314 1.1.1.2.4.2 martin #endif 315 1.1.1.2.4.2 martin 316 1.1.1.2.4.2 martin #if defined(__clang__) || \ 317 1.1.1.2.4.2 martin defined(__GNUC__) || \ 318 1.1.1.2.4.2 martin defined(__INTEL_COMPILER) 319 1.1.1.2.4.2 martin # define UNUSED __attribute__((unused)) 320 1.1.1.2.4.2 martin #else 321 1.1.1.2.4.2 martin # define UNUSED 322 1.1.1.2.4.2 martin #endif 323 1.1.1.2.4.2 martin 324 1.1.1.2.4.2 martin #if defined(_WIN32) 325 1.1.1.2.4.2 martin #define notify_parent_process() ((void) 0) 326 1.1.1.2.4.2 martin #else 327 1.1.1.2.4.2 martin extern void notify_parent_process(void); 328 1.1.1.2.4.2 martin #endif 329 1.1.1.2.4.2 martin 330 1.1.1.2.4.2 martin /* Fully close a loop */ 331 1.1.1.2.4.2 martin static void close_walk_cb(uv_handle_t* handle, void* arg) { 332 1.1.1.2.4.2 martin if (!uv_is_closing(handle)) 333 1.1.1.2.4.2 martin uv_close(handle, NULL); 334 1.1.1.2.4.2 martin } 335 1.1.1.2.4.2 martin 336 1.1.1.2.4.2 martin UNUSED static void close_loop(uv_loop_t* loop) { 337 1.1.1.2.4.2 martin uv_walk(loop, close_walk_cb, NULL); 338 1.1.1.2.4.2 martin uv_run(loop, UV_RUN_DEFAULT); 339 1.1.1.2.4.2 martin } 340 1.1.1.2.4.2 martin 341 1.1.1.2.4.2 martin UNUSED static int can_ipv6(void) { 342 1.1.1.2.4.2 martin uv_interface_address_t* addr; 343 1.1.1.2.4.2 martin int supported; 344 1.1.1.2.4.2 martin int count; 345 1.1.1.2.4.2 martin int i; 346 1.1.1.2.4.2 martin 347 1.1.1.2.4.2 martin if (uv_interface_addresses(&addr, &count)) 348 1.1.1.2.4.2 martin return 0; /* Assume no IPv6 support on failure. */ 349 1.1.1.2.4.2 martin 350 1.1.1.2.4.2 martin supported = 0; 351 1.1.1.2.4.2 martin for (i = 0; supported == 0 && i < count; i += 1) 352 1.1.1.2.4.2 martin supported = (AF_INET6 == addr[i].address.address6.sin6_family); 353 1.1.1.2.4.2 martin 354 1.1.1.2.4.2 martin uv_free_interface_addresses(addr, count); 355 1.1.1.2.4.2 martin return supported; 356 1.1.1.2.4.2 martin } 357 1.1.1.2.4.2 martin 358 1.1.1.2.4.2 martin #if defined(__CYGWIN__) || defined(__MSYS__) || defined(__PASE__) 359 1.1.1.2.4.2 martin # define NO_FS_EVENTS "Filesystem watching not supported on this platform." 360 1.1.1.2.4.2 martin #endif 361 1.1.1.2.4.2 martin 362 1.1.1.2.4.2 martin #if defined(__MSYS__) 363 1.1.1.2.4.2 martin # define NO_SEND_HANDLE_ON_PIPE \ 364 1.1.1.2.4.2 martin "MSYS2 runtime does not support sending handles on pipes." 365 1.1.1.2.4.2 martin #elif defined(__CYGWIN__) 366 1.1.1.2.4.2 martin # define NO_SEND_HANDLE_ON_PIPE \ 367 1.1.1.2.4.2 martin "Cygwin runtime does not support sending handles on pipes." 368 1.1.1.2.4.2 martin #endif 369 1.1.1.2.4.2 martin 370 1.1.1.2.4.2 martin #if defined(__MSYS__) 371 1.1.1.2.4.2 martin # define NO_SELF_CONNECT \ 372 1.1.1.2.4.2 martin "MSYS2 runtime hangs on listen+connect in same process." 373 1.1.1.2.4.2 martin #elif defined(__CYGWIN__) 374 1.1.1.2.4.2 martin # define NO_SELF_CONNECT \ 375 1.1.1.2.4.2 martin "Cygwin runtime hangs on listen+connect in same process." 376 1.1.1.2.4.2 martin #endif 377 1.1.1.2.4.2 martin 378 1.1.1.2.4.2 martin #endif /* TASK_H_ */ 379
Indexes created Thu Jul 09 00:25:44 UTC 2026