diff options
Diffstat (limited to 'extras/vcl-ldpreload/src/libvcl-ldpreload/vcom_socket_wrapper.c')
| -rw-r--r-- | extras/vcl-ldpreload/src/libvcl-ldpreload/vcom_socket_wrapper.c | 906 |
1 files changed, 0 insertions, 906 deletions
diff --git a/extras/vcl-ldpreload/src/libvcl-ldpreload/vcom_socket_wrapper.c b/extras/vcl-ldpreload/src/libvcl-ldpreload/vcom_socket_wrapper.c deleted file mode 100644 index 9b961af6bad..00000000000 --- a/extras/vcl-ldpreload/src/libvcl-ldpreload/vcom_socket_wrapper.c +++ /dev/null @@ -1,906 +0,0 @@ -/* - * Copyright (c) 2016 Cisco and/or its affiliates. - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at: - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -/* - * Copyright (c) 2005-2008 Jelmer Vernooij <jelmer@samba.org> - * Copyright (C) 2006-2014 Stefan Metzmacher <metze@samba.org> - * Copyright (C) 2013-2014 Andreas Schneider <asn@samba.org> - * - * All rights reserved. - * - * Redistribution and use in source and binary forms, with or without - * modification, are permitted provided that the following conditions - * are met: - * - * 1. Redistributions of source code must retain the above copyright - * notice, this list of conditions and the following disclaimer. - * - * 2. Redistributions in binary form must reproduce the above copyright - * notice, this list of conditions and the following disclaimer in the - * documentation and/or other materials provided with the distribution. - * - * 3. Neither the name of the author nor the names of its contributors - * may be used to endorse or promote products derived from this software - * without specific prior written permission. - * - * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND - * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE - * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE - * ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE - * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL - * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS - * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) - * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT - * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY - * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF - * SUCH DAMAGE. - * - */ - -/* - Socket wrapper library. Passes all socket communication over - unix domain sockets if the environment variable SOCKET_WRAPPER_DIR - is set. -*/ - -#include <signal.h> -#include <dlfcn.h> - -#include <stdio.h> -#include <stdarg.h> -#include <unistd.h> -#include <pthread.h> - -#include <libvcl-ldpreload/vcom_socket_wrapper.h> - - -enum swrap_dbglvl_e -{ - SWRAP_LOG_ERROR = 0, - SWRAP_LOG_WARN, - SWRAP_LOG_DEBUG, - SWRAP_LOG_TRACE -}; - - -/* Macros for accessing mutexes */ -#define SWRAP_LOCK(m) do { \ - pthread_mutex_lock(&(m ## _mutex)); \ -} while(0) - -#define SWRAP_UNLOCK(m) do { \ - pthread_mutex_unlock(&(m ## _mutex)); \ -} while(0) - -/* Add new global locks here please */ -#define SWRAP_LOCK_ALL \ - SWRAP_LOCK(libc_symbol_binding); \ - -#define SWRAP_UNLOCK_ALL \ - SWRAP_UNLOCK(libc_symbol_binding); \ - - - -/* The mutex for accessing the global libc.symbols */ -static pthread_mutex_t libc_symbol_binding_mutex = PTHREAD_MUTEX_INITIALIZER; - -/* Function prototypes */ - -#ifdef NDEBUG -#define SWRAP_LOG(...) -#else -static void -swrap_log (enum swrap_dbglvl_e dbglvl, const char *func, - const char *format, ...) -PRINTF_ATTRIBUTE (3, 4); -#define SWRAP_LOG(dbglvl, ...) swrap_log((dbglvl), __func__, __VA_ARGS__) - - static void - swrap_log (enum swrap_dbglvl_e dbglvl, - const char *func, const char *format, ...) -{ - char buffer[1024]; - va_list va; - unsigned int lvl = SWRAP_LOG_WARN; - - va_start (va, format); - vsnprintf (buffer, sizeof (buffer), format, va); - va_end (va); - - if (lvl >= dbglvl) - { - switch (dbglvl) - { - case SWRAP_LOG_ERROR: - fprintf (stderr, - "SWRAP_ERROR(%d) - %s: %s\n", - (int) getpid (), func, buffer); - break; - case SWRAP_LOG_WARN: - fprintf (stderr, - "SWRAP_WARN(%d) - %s: %s\n", - (int) getpid (), func, buffer); - break; - case SWRAP_LOG_DEBUG: - fprintf (stderr, - "SWRAP_DEBUG(%d) - %s: %s\n", - (int) getpid (), func, buffer); - break; - case SWRAP_LOG_TRACE: - fprintf (stderr, - "SWRAP_TRACE(%d) - %s: %s\n", - (int) getpid (), func, buffer); - break; - } - } -} -#endif - - -/********************************************************* - * SWRAP LOADING LIBC FUNCTIONS - *********************************************************/ - -#ifdef HAVE_ACCEPT4 -typedef int (*__libc_accept4) (int sockfd, - struct sockaddr * addr, - socklen_t * addrlen, int flags); -#else -typedef int (*__libc_accept) (int sockfd, - struct sockaddr * addr, socklen_t * addrlen); -#endif -typedef int (*__libc_bind) (int sockfd, - const struct sockaddr * addr, socklen_t addrlen); -typedef int (*__libc_close) (int fd); -typedef int (*__libc_connect) (int sockfd, - const struct sockaddr * addr, - socklen_t addrlen); - -#if 0 -/* TBD: dup and dup2 to be implemented later */ -typedef int (*__libc_dup) (int fd); -typedef int (*__libc_dup2) (int oldfd, int newfd); -#endif - -typedef int (*__libc_fcntl) (int fd, int cmd, ...); -typedef FILE *(*__libc_fopen) (const char *name, const char *mode); -#ifdef HAVE_FOPEN64 -typedef FILE *(*__libc_fopen64) (const char *name, const char *mode); -#endif -#ifdef HAVE_EVENTFD -typedef int (*__libc_eventfd) (int count, int flags); -#endif -typedef int (*__libc_getpeername) (int sockfd, - struct sockaddr * addr, - socklen_t * addrlen); -typedef int (*__libc_getsockname) (int sockfd, - struct sockaddr * addr, - socklen_t * addrlen); -typedef int (*__libc_getsockopt) (int sockfd, - int level, - int optname, - void *optval, socklen_t * optlen); -typedef int (*__libc_ioctl) (int d, unsigned long int request, ...); -typedef int (*__libc_listen) (int sockfd, int backlog); -typedef int (*__libc_open) (const char *pathname, int flags, mode_t mode); -#ifdef HAVE_OPEN64 -typedef int (*__libc_open64) (const char *pathname, int flags, mode_t mode); -#endif /* HAVE_OPEN64 */ -typedef int (*__libc_openat) (int dirfd, const char *path, int flags, ...); -typedef int (*__libc_pipe) (int pipefd[2]); -typedef int (*__libc_read) (int fd, void *buf, size_t count); -typedef ssize_t (*__libc_readv) (int fd, const struct iovec * iov, - int iovcnt); -typedef int (*__libc_recv) (int sockfd, void *buf, size_t len, int flags); -typedef int (*__libc_recvfrom) (int sockfd, - void *buf, - size_t len, - int flags, - struct sockaddr * src_addr, - socklen_t * addrlen); -typedef int (*__libc_recvmsg) (int sockfd, const struct msghdr * msg, - int flags); -typedef int (*__libc_send) (int sockfd, const void *buf, size_t len, - int flags); -typedef int (*__libc_sendmsg) (int sockfd, const struct msghdr * msg, - int flags); -typedef int (*__libc_sendto) (int sockfd, const void *buf, size_t len, - int flags, const struct sockaddr * dst_addr, - socklen_t addrlen); -typedef int (*__libc_setsockopt) (int sockfd, int level, int optname, - const void *optval, socklen_t optlen); -#ifdef HAVE_SIGNALFD -typedef int (*__libc_signalfd) (int fd, const sigset_t * mask, int flags); -#endif -typedef int (*__libc_socket) (int domain, int type, int protocol); -typedef int (*__libc_socketpair) (int domain, int type, int protocol, - int sv[2]); -#ifdef HAVE_TIMERFD_CREATE -typedef int (*__libc_timerfd_create) (int clockid, int flags); -#endif -typedef ssize_t (*__libc_write) (int fd, const void *buf, size_t count); -typedef ssize_t (*__libc_writev) (int fd, const struct iovec * iov, - int iovcnt); - -typedef int (*__libc_shutdown) (int fd, int how); - -typedef int (*__libc_select) (int __nfds, fd_set * __restrict __readfds, - fd_set * __restrict __writefds, - fd_set * __restrict __exceptfds, - struct timeval * __restrict __timeout); - -#ifdef __USE_XOPEN2K -typedef int (*__libc_pselect) (int __nfds, fd_set * __restrict __readfds, - fd_set * __restrict __writefds, - fd_set * __restrict __exceptfds, - const struct timespec * __restrict __timeout, - const __sigset_t * __restrict __sigmask); -#endif - -typedef int (*__libc_epoll_create) (int __size); - -typedef int (*__libc_epoll_create1) (int __flags); - -typedef int (*__libc_epoll_ctl) (int __epfd, int __op, int __fd, - struct epoll_event * __event); - -typedef int (*__libc_epoll_wait) (int __epfd, struct epoll_event * __events, - int __maxevents, int __timeout); - -typedef int (*__libc_epoll_pwait) (int __epfd, struct epoll_event * __events, - int __maxevents, int __timeout, - const __sigset_t * __ss); - -typedef int (*__libc_poll) (struct pollfd * __fds, nfds_t __nfds, - int __timeout); - -#ifdef __USE_GNU -typedef int (*__libc_ppoll) (struct pollfd * __fds, nfds_t __nfds, - const struct timespec * __timeout, - const __sigset_t * __ss); -#endif - - -#define SWRAP_SYMBOL_ENTRY(i) \ - union { \ - __libc_##i f; \ - void *obj; \ - } _libc_##i - -struct swrap_libc_symbols -{ -#ifdef HAVE_ACCEPT4 - SWRAP_SYMBOL_ENTRY (accept4); -#else - SWRAP_SYMBOL_ENTRY (accept); -#endif - SWRAP_SYMBOL_ENTRY (bind); - SWRAP_SYMBOL_ENTRY (close); - SWRAP_SYMBOL_ENTRY (connect); -#if 0 - /* TBD: dup and dup2 to be implemented later */ - SWRAP_SYMBOL_ENTRY (dup); - SWRAP_SYMBOL_ENTRY (dup2); -#endif - SWRAP_SYMBOL_ENTRY (fcntl); - SWRAP_SYMBOL_ENTRY (fopen); -#ifdef HAVE_FOPEN64 - SWRAP_SYMBOL_ENTRY (fopen64); -#endif -#ifdef HAVE_EVENTFD - SWRAP_SYMBOL_ENTRY (eventfd); -#endif - SWRAP_SYMBOL_ENTRY (getpeername); - SWRAP_SYMBOL_ENTRY (getsockname); - SWRAP_SYMBOL_ENTRY (getsockopt); - SWRAP_SYMBOL_ENTRY (ioctl); - SWRAP_SYMBOL_ENTRY (listen); - SWRAP_SYMBOL_ENTRY (open); -#ifdef HAVE_OPEN64 - SWRAP_SYMBOL_ENTRY (open64); -#endif - SWRAP_SYMBOL_ENTRY (openat); - SWRAP_SYMBOL_ENTRY (pipe); - SWRAP_SYMBOL_ENTRY (read); - SWRAP_SYMBOL_ENTRY (readv); - SWRAP_SYMBOL_ENTRY (recv); - SWRAP_SYMBOL_ENTRY (recvfrom); - SWRAP_SYMBOL_ENTRY (recvmsg); - SWRAP_SYMBOL_ENTRY (send); - SWRAP_SYMBOL_ENTRY (sendmsg); - SWRAP_SYMBOL_ENTRY (sendto); - SWRAP_SYMBOL_ENTRY (setsockopt); -#ifdef HAVE_SIGNALFD - SWRAP_SYMBOL_ENTRY (signalfd); -#endif - SWRAP_SYMBOL_ENTRY (socket); - SWRAP_SYMBOL_ENTRY (socketpair); -#ifdef HAVE_TIMERFD_CREATE - SWRAP_SYMBOL_ENTRY (timerfd_create); -#endif - SWRAP_SYMBOL_ENTRY (write); - SWRAP_SYMBOL_ENTRY (writev); - - SWRAP_SYMBOL_ENTRY (shutdown); - SWRAP_SYMBOL_ENTRY (select); -#ifdef __USE_XOPEN2K - SWRAP_SYMBOL_ENTRY (pselect); -#endif - SWRAP_SYMBOL_ENTRY (epoll_create); - SWRAP_SYMBOL_ENTRY (epoll_create1); - SWRAP_SYMBOL_ENTRY (epoll_ctl); - SWRAP_SYMBOL_ENTRY (epoll_wait); - SWRAP_SYMBOL_ENTRY (epoll_pwait); - SWRAP_SYMBOL_ENTRY (poll); -#ifdef __USE_GNU - SWRAP_SYMBOL_ENTRY (ppoll); -#endif -}; - -struct swrap -{ - struct - { - void *handle; - void *socket_handle; - struct swrap_libc_symbols symbols; - } libc; -}; - -static struct swrap swrap; - -#define LIBC_NAME "libc.so" - -enum swrap_lib -{ - SWRAP_LIBC, -}; - -#ifndef NDEBUG -static const char * -swrap_str_lib (enum swrap_lib lib) -{ - switch (lib) - { - case SWRAP_LIBC: - return "libc"; - } - - /* Compiler would warn us about unhandled enum value if we get here */ - return "unknown"; -} -#endif - -static void * -swrap_load_lib_handle (enum swrap_lib lib) -{ - int flags = RTLD_LAZY; - void *handle = NULL; - int i; - -#ifdef RTLD_DEEPBIND - flags |= RTLD_DEEPBIND; -#endif - - switch (lib) - { - case SWRAP_LIBC: - handle = swrap.libc.handle; -#ifdef LIBC_SO - if (handle == NULL) - { - handle = dlopen (LIBC_SO, flags); - - swrap.libc.handle = handle; - } -#endif - if (handle == NULL) - { - for (i = 10; i >= 0; i--) - { - char soname[256] = { 0 }; - - snprintf (soname, sizeof (soname), "libc.so.%d", i); - handle = dlopen (soname, flags); - if (handle != NULL) - { - break; - } - } - - swrap.libc.handle = handle; - } - break; - } - - if (handle == NULL) - { - SWRAP_LOG (SWRAP_LOG_ERROR, - "Failed to dlopen library: %s\n", dlerror ()); - exit (-1); - } - - return handle; -} - -static void * -_swrap_bind_symbol (enum swrap_lib lib, const char *fn_name) -{ - void *handle; - void *func; - - handle = swrap_load_lib_handle (lib); - - func = dlsym (handle, fn_name); - if (func == NULL) - { - SWRAP_LOG (SWRAP_LOG_ERROR, - "Failed to find %s: %s\n", fn_name, dlerror ()); - exit (-1); - } - - SWRAP_LOG (SWRAP_LOG_TRACE, - "Loaded %s from %s", fn_name, swrap_str_lib (lib)); - - return func; -} - -#define swrap_bind_symbol_libc(sym_name) \ - SWRAP_LOCK(libc_symbol_binding); \ - if (swrap.libc.symbols._libc_##sym_name.obj == NULL) { \ - swrap.libc.symbols._libc_##sym_name.obj = \ - _swrap_bind_symbol(SWRAP_LIBC, #sym_name); \ - } \ - SWRAP_UNLOCK(libc_symbol_binding) - -/* - * IMPORTANT - * - * Functions especially from libc need to be loaded individually, you can't load - * all at once or gdb will segfault at startup. The same applies to valgrind and - * has probably something todo with with the linker. - * So we need load each function at the point it is called the first time. - */ -#ifdef HAVE_ACCEPT4 -int -libc_accept4 (int sockfd, - struct sockaddr *addr, socklen_t * addrlen, int flags) -{ - swrap_bind_symbol_libc (accept4); - - return swrap.libc.symbols._libc_accept4.f (sockfd, addr, addrlen, flags); -} - -#else /* HAVE_ACCEPT4 */ - -int -libc_accept (int sockfd, struct sockaddr *addr, socklen_t * addrlen) -{ - swrap_bind_symbol_libc (accept); - - return swrap.libc.symbols._libc_accept.f (sockfd, addr, addrlen); -} -#endif /* HAVE_ACCEPT4 */ - -int -libc_bind (int sockfd, const struct sockaddr *addr, socklen_t addrlen) -{ - swrap_bind_symbol_libc (bind); - - return swrap.libc.symbols._libc_bind.f (sockfd, addr, addrlen); -} - -int -libc_close (int fd) -{ - swrap_bind_symbol_libc (close); - - return swrap.libc.symbols._libc_close.f (fd); -} - -int -libc_connect (int sockfd, const struct sockaddr *addr, socklen_t addrlen) -{ - swrap_bind_symbol_libc (connect); - - return swrap.libc.symbols._libc_connect.f (sockfd, addr, addrlen); -} - -#if 0 -/* TBD: dup and dup2 to be implemented later */ -int -libc_dup (int fd) -{ - swrap_bind_symbol_libc (dup); - - return swrap.libc.symbols._libc_dup.f (fd); -} - -int -libc_dup2 (int oldfd, int newfd) -{ - swrap_bind_symbol_libc (dup2); - - return swrap.libc.symbols._libc_dup2.f (oldfd, newfd); -} -#endif - -#ifdef HAVE_EVENTFD -int -libc_eventfd (int count, int flags) -{ - swrap_bind_symbol_libc (eventfd); - - return swrap.libc.symbols._libc_eventfd.f (count, flags); -} -#endif - -DO_NOT_SANITIZE_ADDRESS_ATTRIBUTE int -libc_vfcntl (int fd, int cmd, va_list ap) -{ - long int args[4]; - int rc; - int i; - - swrap_bind_symbol_libc (fcntl); - - for (i = 0; i < 4; i++) - { - args[i] = va_arg (ap, long int); - } - - rc = swrap.libc.symbols._libc_fcntl.f (fd, - cmd, - args[0], args[1], args[2], args[3]); - - return rc; -} - -DO_NOT_SANITIZE_ADDRESS_ATTRIBUTE int -libc_vioctl (int fd, int cmd, va_list ap) -{ - long int args[4]; - int rc; - int i; - - swrap_bind_symbol_libc (ioctl); - - for (i = 0; i < 4; i++) - { - args[i] = va_arg (ap, long int); - } - - rc = swrap.libc.symbols._libc_ioctl.f (fd, - cmd, - args[0], args[1], args[2], args[3]); - - return rc; -} - -int -libc_getpeername (int sockfd, struct sockaddr *addr, socklen_t * addrlen) -{ - swrap_bind_symbol_libc (getpeername); - - return swrap.libc.symbols._libc_getpeername.f (sockfd, addr, addrlen); -} - -int -libc_getsockname (int sockfd, struct sockaddr *addr, socklen_t * addrlen) -{ - swrap_bind_symbol_libc (getsockname); - - return swrap.libc.symbols._libc_getsockname.f (sockfd, addr, addrlen); -} - -int -libc_getsockopt (int sockfd, - int level, int optname, void *optval, socklen_t * optlen) -{ - swrap_bind_symbol_libc (getsockopt); - - return swrap.libc.symbols._libc_getsockopt.f (sockfd, - level, - optname, optval, optlen); -} - -int -libc_listen (int sockfd, int backlog) -{ - swrap_bind_symbol_libc (listen); - - return swrap.libc.symbols._libc_listen.f (sockfd, backlog); -} - -int -libc_read (int fd, void *buf, size_t count) -{ - swrap_bind_symbol_libc (read); - - return swrap.libc.symbols._libc_read.f (fd, buf, count); -} - -ssize_t -libc_readv (int fd, const struct iovec * iov, int iovcnt) -{ - swrap_bind_symbol_libc (readv); - - return swrap.libc.symbols._libc_readv.f (fd, iov, iovcnt); -} - -int -libc_recv (int sockfd, void *buf, size_t len, int flags) -{ - swrap_bind_symbol_libc (recv); - - return swrap.libc.symbols._libc_recv.f (sockfd, buf, len, flags); -} - -int -libc_recvfrom (int sockfd, - void *buf, - size_t len, - int flags, struct sockaddr *src_addr, socklen_t * addrlen) -{ - swrap_bind_symbol_libc (recvfrom); - - return swrap.libc.symbols._libc_recvfrom.f (sockfd, - buf, - len, flags, src_addr, addrlen); -} - -int -libc_recvmsg (int sockfd, struct msghdr *msg, int flags) -{ - swrap_bind_symbol_libc (recvmsg); - - return swrap.libc.symbols._libc_recvmsg.f (sockfd, msg, flags); -} - -int -libc_send (int sockfd, const void *buf, size_t len, int flags) -{ - swrap_bind_symbol_libc (send); - - return swrap.libc.symbols._libc_send.f (sockfd, buf, len, flags); -} - -int -libc_sendmsg (int sockfd, const struct msghdr *msg, int flags) -{ - swrap_bind_symbol_libc (sendmsg); - - return swrap.libc.symbols._libc_sendmsg.f (sockfd, msg, flags); -} - -int -libc_sendto (int sockfd, - const void *buf, - size_t len, - int flags, const struct sockaddr *dst_addr, socklen_t addrlen) -{ - swrap_bind_symbol_libc (sendto); - - return swrap.libc.symbols._libc_sendto.f (sockfd, - buf, - len, flags, dst_addr, addrlen); -} - -int -libc_setsockopt (int sockfd, - int level, int optname, const void *optval, socklen_t optlen) -{ - swrap_bind_symbol_libc (setsockopt); - - return swrap.libc.symbols._libc_setsockopt.f (sockfd, - level, - optname, optval, optlen); -} - -int -libc_socket (int domain, int type, int protocol) -{ - swrap_bind_symbol_libc (socket); - - return swrap.libc.symbols._libc_socket.f (domain, type, protocol); -} - -int -libc_socketpair (int domain, int type, int protocol, int sv[2]) -{ - swrap_bind_symbol_libc (socketpair); - - return swrap.libc.symbols._libc_socketpair.f (domain, type, protocol, sv); -} - -ssize_t -libc_write (int fd, const void *buf, size_t count) -{ - swrap_bind_symbol_libc (write); - - return swrap.libc.symbols._libc_write.f (fd, buf, count); -} - -ssize_t -libc_writev (int fd, const struct iovec * iov, int iovcnt) -{ - swrap_bind_symbol_libc (writev); - - return swrap.libc.symbols._libc_writev.f (fd, iov, iovcnt); -} - -int -libc_shutdown (int fd, int how) -{ - swrap_bind_symbol_libc (shutdown); - - return swrap.libc.symbols._libc_shutdown.f (fd, how); -} - -int -libc_select (int __nfds, fd_set * __restrict __readfds, - fd_set * __restrict __writefds, - fd_set * __restrict __exceptfds, - struct timeval *__restrict __timeout) -{ - swrap_bind_symbol_libc (select); - - return swrap.libc.symbols._libc_select.f (__nfds, __readfds, - __writefds, - __exceptfds, __timeout); -} - -#ifdef __USE_XOPEN2K -int -libc_pselect (int __nfds, fd_set * __restrict __readfds, - fd_set * __restrict __writefds, - fd_set * __restrict __exceptfds, - const struct timespec *__restrict __timeout, - const __sigset_t * __restrict __sigmask) -{ - swrap_bind_symbol_libc (pselect); - - return swrap.libc.symbols._libc_pselect.f (__nfds, __readfds, - __writefds, - __exceptfds, - __timeout, __sigmask); -} -#endif - -int -libc_epoll_create (int __size) -{ - swrap_bind_symbol_libc (epoll_create); - - return swrap.libc.symbols._libc_epoll_create.f (__size); -} - -int -libc_epoll_create1 (int __flags) -{ - swrap_bind_symbol_libc (epoll_create1); - - return swrap.libc.symbols._libc_epoll_create1.f (__flags); -} - -int -libc_epoll_ctl (int __epfd, int __op, int __fd, struct epoll_event *__event) -{ - swrap_bind_symbol_libc (epoll_ctl); - - return swrap.libc.symbols._libc_epoll_ctl.f (__epfd, __op, __fd, __event); -} - -int -libc_epoll_wait (int __epfd, struct epoll_event *__events, - int __maxevents, int __timeout) -{ - swrap_bind_symbol_libc (epoll_wait); - - return swrap.libc.symbols._libc_epoll_wait.f (__epfd, __events, - __maxevents, __timeout); -} - -int -libc_epoll_pwait (int __epfd, struct epoll_event *__events, - int __maxevents, int __timeout, const __sigset_t * __ss) -{ - swrap_bind_symbol_libc (epoll_pwait); - - return swrap.libc.symbols._libc_epoll_pwait.f (__epfd, __events, - __maxevents, __timeout, - __ss); -} - -int -libc_poll (struct pollfd *__fds, nfds_t __nfds, int __timeout) -{ - swrap_bind_symbol_libc (poll); - - return swrap.libc.symbols._libc_poll.f (__fds, __nfds, __timeout); -} - -#ifdef __USE_GNU -int -libc_ppoll (struct pollfd *__fds, nfds_t __nfds, - const struct timespec *__timeout, const __sigset_t * __ss) -{ - swrap_bind_symbol_libc (ppoll); - - return swrap.libc.symbols._libc_ppoll.f (__fds, __nfds, __timeout, __ss); -} -#endif - -static void -swrap_thread_prepare (void) -{ - SWRAP_LOCK_ALL; -} - -static void -swrap_thread_parent (void) -{ - SWRAP_UNLOCK_ALL; -} - -static void -swrap_thread_child (void) -{ - SWRAP_UNLOCK_ALL; -} - -/**************************** - * CONSTRUCTOR - ***************************/ -void -swrap_constructor (void) -{ - /* - * If we hold a lock and the application forks, then the child - * is not able to unlock the mutex and we are in a deadlock. - * This should prevent such deadlocks. - */ - pthread_atfork (&swrap_thread_prepare, - &swrap_thread_parent, &swrap_thread_child); -} - -/**************************** - * DESTRUCTOR - ***************************/ - -/* - * This function is called when the library is unloaded and makes sure that - * sockets get closed and the unix file for the socket are unlinked. - */ -void -swrap_destructor (void) -{ - if (swrap.libc.handle != NULL) - { - dlclose (swrap.libc.handle); - } - if (swrap.libc.socket_handle) - { - dlclose (swrap.libc.socket_handle); - } -} - -/* - * fd.io coding-style-patch-verification: ON - * - * Local Variables: - * eval: (c-set-style "gnu") - * End: - */ |