summaryrefslogtreecommitdiffstatshomepage
path: root/3rdparty/libuv/test/test-pipe-sendmsg.c
diff options
context:
space:
mode:
author Miodrag Milanovic <mmicko@gmail.com>2016-10-07 14:14:08 +0200
committer Miodrag Milanovic <mmicko@gmail.com>2016-10-07 14:14:08 +0200
commit85f4741fcf642f52ac4fa56f0aff1728727c901b (patch)
treeda8cca02913839152d2eb04c0e85a83018bcaed3 /3rdparty/libuv/test/test-pipe-sendmsg.c
parentff01b716711b97c2fcaa709ea97f7650f106aa10 (diff)
Remove libuv library (nw)
Diffstat (limited to '3rdparty/libuv/test/test-pipe-sendmsg.c')
-rw-r--r--3rdparty/libuv/test/test-pipe-sendmsg.c169
1 files changed, 0 insertions, 169 deletions
diff --git a/3rdparty/libuv/test/test-pipe-sendmsg.c b/3rdparty/libuv/test/test-pipe-sendmsg.c
deleted file mode 100644
index f6d893b4494..00000000000
--- a/3rdparty/libuv/test/test-pipe-sendmsg.c
+++ /dev/null
@@ -1,169 +0,0 @@
-/* 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.
- */
-
-#include "uv.h"
-#include "task.h"
-
-
-#ifndef _WIN32
-
-#include <fcntl.h>
-#include <errno.h>
-#include <stdio.h>
-#include <stdlib.h>
-#include <string.h>
-#include <sys/socket.h>
-#include <unistd.h>
-
-
-/* NOTE: size should be divisible by 2 */
-static uv_pipe_t incoming[4];
-static unsigned int incoming_count;
-static unsigned int close_called;
-
-
-static void set_nonblocking(uv_os_sock_t sock) {
- int r;
-#ifdef _WIN32
- unsigned long on = 1;
- r = ioctlsocket(sock, FIONBIO, &on);
- ASSERT(r == 0);
-#else
- int flags = fcntl(sock, F_GETFL, 0);
- ASSERT(flags >= 0);
- r = fcntl(sock, F_SETFL, flags | O_NONBLOCK);
- ASSERT(r >= 0);
-#endif
-}
-
-
-
-
-static void close_cb(uv_handle_t* handle) {
- close_called++;
-}
-
-
-static void alloc_cb(uv_handle_t* handle, size_t size, uv_buf_t* buf) {
- static char base[1];
-
- buf->base = base;
- buf->len = sizeof(base);
-}
-
-
-static void read_cb(uv_stream_t* handle,
- ssize_t nread,
- const uv_buf_t* buf) {
- uv_pipe_t* p;
- uv_pipe_t* inc;
- uv_handle_type pending;
- unsigned int i;
-
- p = (uv_pipe_t*) handle;
- ASSERT(nread >= 0);
-
- while (uv_pipe_pending_count(p) != 0) {
- pending = uv_pipe_pending_type(p);
- ASSERT(pending == UV_NAMED_PIPE);
-
- ASSERT(incoming_count < ARRAY_SIZE(incoming));
- inc = &incoming[incoming_count++];
- ASSERT(0 == uv_pipe_init(p->loop, inc, 0));
- ASSERT(0 == uv_accept(handle, (uv_stream_t*) inc));
- }
-
- if (incoming_count != ARRAY_SIZE(incoming))
- return;
-
- ASSERT(0 == uv_read_stop((uv_stream_t*) p));
- uv_close((uv_handle_t*) p, close_cb);
- for (i = 0; i < ARRAY_SIZE(incoming); i++)
- uv_close((uv_handle_t*) &incoming[i], close_cb);
-}
-
-
-TEST_IMPL(pipe_sendmsg) {
- uv_pipe_t p;
- int r;
- int fds[2];
- int send_fds[ARRAY_SIZE(incoming)];
- struct msghdr msg;
- char scratch[64];
- struct cmsghdr *cmsg;
- unsigned int i;
- uv_buf_t buf;
-
- ASSERT(0 == socketpair(AF_UNIX, SOCK_STREAM, 0, fds));
- for (i = 0; i < ARRAY_SIZE(send_fds); i += 2)
- ASSERT(0 == socketpair(AF_UNIX, SOCK_STREAM, 0, send_fds + i));
- ASSERT(i == ARRAY_SIZE(send_fds));
- ASSERT(0 == uv_pipe_init(uv_default_loop(), &p, 1));
- ASSERT(0 == uv_pipe_open(&p, fds[1]));
-
- buf = uv_buf_init("X", 1);
- memset(&msg, 0, sizeof(msg));
- msg.msg_iov = (struct iovec*) &buf;
- msg.msg_iovlen = 1;
- msg.msg_flags = 0;
-
- msg.msg_control = (void*) scratch;
- msg.msg_controllen = CMSG_LEN(sizeof(send_fds));
- ASSERT(sizeof(scratch) >= msg.msg_controllen);
-
- cmsg = CMSG_FIRSTHDR(&msg);
- cmsg->cmsg_level = SOL_SOCKET;
- cmsg->cmsg_type = SCM_RIGHTS;
- cmsg->cmsg_len = msg.msg_controllen;
-
- /* silence aliasing warning */
- {
- void* pv = CMSG_DATA(cmsg);
- int* pi = pv;
- for (i = 0; i < ARRAY_SIZE(send_fds); i++)
- pi[i] = send_fds[i];
- }
-
- set_nonblocking(fds[1]);
- ASSERT(0 == uv_read_start((uv_stream_t*) &p, alloc_cb, read_cb));
-
- do
- r = sendmsg(fds[0], &msg, 0);
- while (r == -1 && errno == EINTR);
- ASSERT(r == 1);
-
- uv_run(uv_default_loop(), UV_RUN_DEFAULT);
- ASSERT(ARRAY_SIZE(incoming) == incoming_count);
- ASSERT(ARRAY_SIZE(incoming) + 1 == close_called);
- close(fds[0]);
-
- MAKE_VALGRIND_HAPPY();
- return 0;
-}
-
-#else /* !_WIN32 */
-
-TEST_IMPL(pipe_sendmsg) {
- MAKE_VALGRIND_HAPPY();
- return 0;
-}
-
-#endif /* _WIN32 */