| 1 | /***************************************************************************
|
|---|
| 2 | * _ _ ____ _
|
|---|
| 3 | * Project ___| | | | _ \| |
|
|---|
| 4 | * / __| | | | |_) | |
|
|---|
| 5 | * | (__| |_| | _ <| |___
|
|---|
| 6 | * \___|\___/|_| \_\_____|
|
|---|
| 7 | *
|
|---|
| 8 | * Copyright (C) 2019 - 2022, Daniel Stenberg, <[email protected]>, et al.
|
|---|
| 9 | *
|
|---|
| 10 | * This software is licensed as described in the file COPYING, which
|
|---|
| 11 | * you should have received as part of this distribution. The terms
|
|---|
| 12 | * are also available at https://curl.se/docs/copyright.html.
|
|---|
| 13 | *
|
|---|
| 14 | * You may opt to use, copy, modify, merge, publish, distribute and/or sell
|
|---|
| 15 | * copies of the Software, and permit persons to whom the Software is
|
|---|
| 16 | * furnished to do so, under the terms of the COPYING file.
|
|---|
| 17 | *
|
|---|
| 18 | * This software is distributed on an "AS IS" basis, WITHOUT WARRANTY OF ANY
|
|---|
| 19 | * KIND, either express or implied.
|
|---|
| 20 | *
|
|---|
| 21 | * SPDX-License-Identifier: curl
|
|---|
| 22 | *
|
|---|
| 23 | ***************************************************************************/
|
|---|
| 24 |
|
|---|
| 25 | #include "curl_setup.h"
|
|---|
| 26 | #include "socketpair.h"
|
|---|
| 27 |
|
|---|
| 28 | #if !defined(HAVE_SOCKETPAIR) && !defined(CURL_DISABLE_SOCKETPAIR)
|
|---|
| 29 | #ifdef WIN32
|
|---|
| 30 | /*
|
|---|
| 31 | * This is a socketpair() implementation for Windows.
|
|---|
| 32 | */
|
|---|
| 33 | #include <string.h>
|
|---|
| 34 | #include <winsock2.h>
|
|---|
| 35 | #include <ws2tcpip.h>
|
|---|
| 36 | #include <windows.h>
|
|---|
| 37 | #include <io.h>
|
|---|
| 38 | #else
|
|---|
| 39 | #ifdef HAVE_NETDB_H
|
|---|
| 40 | #include <netdb.h>
|
|---|
| 41 | #endif
|
|---|
| 42 | #ifdef HAVE_NETINET_IN_H
|
|---|
| 43 | #include <netinet/in.h> /* IPPROTO_TCP */
|
|---|
| 44 | #endif
|
|---|
| 45 | #ifdef HAVE_ARPA_INET_H
|
|---|
| 46 | #include <arpa/inet.h>
|
|---|
| 47 | #endif
|
|---|
| 48 | #ifndef INADDR_LOOPBACK
|
|---|
| 49 | #define INADDR_LOOPBACK 0x7f000001
|
|---|
| 50 | #endif /* !INADDR_LOOPBACK */
|
|---|
| 51 | #endif /* !WIN32 */
|
|---|
| 52 |
|
|---|
| 53 | #include "nonblock.h" /* for curlx_nonblock */
|
|---|
| 54 | #include "timeval.h" /* needed before select.h */
|
|---|
| 55 | #include "select.h" /* for Curl_poll */
|
|---|
| 56 |
|
|---|
| 57 | /* The last 3 #include files should be in this order */
|
|---|
| 58 | #include "curl_printf.h"
|
|---|
| 59 | #include "curl_memory.h"
|
|---|
| 60 | #include "memdebug.h"
|
|---|
| 61 |
|
|---|
| 62 | int Curl_socketpair(int domain, int type, int protocol,
|
|---|
| 63 | curl_socket_t socks[2])
|
|---|
| 64 | {
|
|---|
| 65 | union {
|
|---|
| 66 | struct sockaddr_in inaddr;
|
|---|
| 67 | struct sockaddr addr;
|
|---|
| 68 | } a, a2;
|
|---|
| 69 | curl_socket_t listener;
|
|---|
| 70 | curl_socklen_t addrlen = sizeof(a.inaddr);
|
|---|
| 71 | int reuse = 1;
|
|---|
| 72 | struct pollfd pfd[1];
|
|---|
| 73 | (void)domain;
|
|---|
| 74 | (void)type;
|
|---|
| 75 | (void)protocol;
|
|---|
| 76 |
|
|---|
| 77 | listener = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
|
|---|
| 78 | if(listener == CURL_SOCKET_BAD)
|
|---|
| 79 | return -1;
|
|---|
| 80 |
|
|---|
| 81 | memset(&a, 0, sizeof(a));
|
|---|
| 82 | a.inaddr.sin_family = AF_INET;
|
|---|
| 83 | a.inaddr.sin_addr.s_addr = htonl(INADDR_LOOPBACK);
|
|---|
| 84 | a.inaddr.sin_port = 0;
|
|---|
| 85 |
|
|---|
| 86 | socks[0] = socks[1] = CURL_SOCKET_BAD;
|
|---|
| 87 |
|
|---|
| 88 | if(setsockopt(listener, SOL_SOCKET, SO_REUSEADDR,
|
|---|
| 89 | (char *)&reuse, (curl_socklen_t)sizeof(reuse)) == -1)
|
|---|
| 90 | goto error;
|
|---|
| 91 | if(bind(listener, &a.addr, sizeof(a.inaddr)) == -1)
|
|---|
| 92 | goto error;
|
|---|
| 93 | if(getsockname(listener, &a.addr, &addrlen) == -1 ||
|
|---|
| 94 | addrlen < (int)sizeof(a.inaddr))
|
|---|
| 95 | goto error;
|
|---|
| 96 | if(listen(listener, 1) == -1)
|
|---|
| 97 | goto error;
|
|---|
| 98 | socks[0] = socket(AF_INET, SOCK_STREAM, 0);
|
|---|
| 99 | if(socks[0] == CURL_SOCKET_BAD)
|
|---|
| 100 | goto error;
|
|---|
| 101 | if(connect(socks[0], &a.addr, sizeof(a.inaddr)) == -1)
|
|---|
| 102 | goto error;
|
|---|
| 103 |
|
|---|
| 104 | /* use non-blocking accept to make sure we don't block forever */
|
|---|
| 105 | if(curlx_nonblock(listener, TRUE) < 0)
|
|---|
| 106 | goto error;
|
|---|
| 107 | pfd[0].fd = listener;
|
|---|
| 108 | pfd[0].events = POLLIN;
|
|---|
| 109 | pfd[0].revents = 0;
|
|---|
| 110 | (void)Curl_poll(pfd, 1, 10*1000); /* 10 seconds */
|
|---|
| 111 | socks[1] = accept(listener, NULL, NULL);
|
|---|
| 112 | if(socks[1] == CURL_SOCKET_BAD)
|
|---|
| 113 | goto error;
|
|---|
| 114 |
|
|---|
| 115 | /* verify that nothing else connected */
|
|---|
| 116 | addrlen = sizeof(a.inaddr);
|
|---|
| 117 | if(getsockname(socks[0], &a.addr, &addrlen) == -1 ||
|
|---|
| 118 | addrlen < (int)sizeof(a.inaddr))
|
|---|
| 119 | goto error;
|
|---|
| 120 | addrlen = sizeof(a2.inaddr);
|
|---|
| 121 | if(getpeername(socks[1], &a2.addr, &addrlen) == -1 ||
|
|---|
| 122 | addrlen < (int)sizeof(a2.inaddr))
|
|---|
| 123 | goto error;
|
|---|
| 124 | if(a.inaddr.sin_family != a2.inaddr.sin_family ||
|
|---|
| 125 | a.inaddr.sin_addr.s_addr != a2.inaddr.sin_addr.s_addr ||
|
|---|
| 126 | a.inaddr.sin_port != a2.inaddr.sin_port)
|
|---|
| 127 | goto error;
|
|---|
| 128 |
|
|---|
| 129 | sclose(listener);
|
|---|
| 130 | return 0;
|
|---|
| 131 |
|
|---|
| 132 | error:
|
|---|
| 133 | sclose(listener);
|
|---|
| 134 | sclose(socks[0]);
|
|---|
| 135 | sclose(socks[1]);
|
|---|
| 136 | return -1;
|
|---|
| 137 | }
|
|---|
| 138 |
|
|---|
| 139 | #endif /* ! HAVE_SOCKETPAIR */
|
|---|
