1 | #ifndef HEADER_CURL_CF_SOCKET_H
|
---|
2 | #define HEADER_CURL_CF_SOCKET_H
|
---|
3 | /***************************************************************************
|
---|
4 | * _ _ ____ _
|
---|
5 | * Project ___| | | | _ \| |
|
---|
6 | * / __| | | | |_) | |
|
---|
7 | * | (__| |_| | _ <| |___
|
---|
8 | * \___|\___/|_| \_\_____|
|
---|
9 | *
|
---|
10 | * Copyright (C) Daniel Stenberg, <[email protected]>, et al.
|
---|
11 | *
|
---|
12 | * This software is licensed as described in the file COPYING, which
|
---|
13 | * you should have received as part of this distribution. The terms
|
---|
14 | * are also available at https://curl.se/docs/copyright.html.
|
---|
15 | *
|
---|
16 | * You may opt to use, copy, modify, merge, publish, distribute and/or sell
|
---|
17 | * copies of the Software, and permit persons to whom the Software is
|
---|
18 | * furnished to do so, under the terms of the COPYING file.
|
---|
19 | *
|
---|
20 | * This software is distributed on an "AS IS" basis, WITHOUT WARRANTY OF ANY
|
---|
21 | * KIND, either express or implied.
|
---|
22 | *
|
---|
23 | * SPDX-License-Identifier: curl
|
---|
24 | *
|
---|
25 | ***************************************************************************/
|
---|
26 | #include "curl_setup.h"
|
---|
27 |
|
---|
28 | #include "nonblock.h" /* for curlx_nonblock(), formerly Curl_nonblock() */
|
---|
29 | #include "sockaddr.h"
|
---|
30 |
|
---|
31 | struct Curl_addrinfo;
|
---|
32 | struct Curl_cfilter;
|
---|
33 | struct Curl_easy;
|
---|
34 | struct connectdata;
|
---|
35 | struct Curl_sockaddr_ex;
|
---|
36 |
|
---|
37 | /*
|
---|
38 | * The Curl_sockaddr_ex structure is basically libcurl's external API
|
---|
39 | * curl_sockaddr structure with enough space available to directly hold any
|
---|
40 | * protocol-specific address structures. The variable declared here will be
|
---|
41 | * used to pass / receive data to/from the fopensocket callback if this has
|
---|
42 | * been set, before that, it is initialized from parameters.
|
---|
43 | */
|
---|
44 | struct Curl_sockaddr_ex {
|
---|
45 | int family;
|
---|
46 | int socktype;
|
---|
47 | int protocol;
|
---|
48 | unsigned int addrlen;
|
---|
49 | union {
|
---|
50 | struct sockaddr addr;
|
---|
51 | struct Curl_sockaddr_storage buff;
|
---|
52 | } _sa_ex_u;
|
---|
53 | };
|
---|
54 | #define sa_addr _sa_ex_u.addr
|
---|
55 |
|
---|
56 |
|
---|
57 | /*
|
---|
58 | * Create a socket based on info from 'conn' and 'ai'.
|
---|
59 | *
|
---|
60 | * Fill in 'addr' and 'sockfd' accordingly if OK is returned. If the open
|
---|
61 | * socket callback is set, used that!
|
---|
62 | *
|
---|
63 | */
|
---|
64 | CURLcode Curl_socket_open(struct Curl_easy *data,
|
---|
65 | const struct Curl_addrinfo *ai,
|
---|
66 | struct Curl_sockaddr_ex *addr,
|
---|
67 | int transport,
|
---|
68 | curl_socket_t *sockfd);
|
---|
69 |
|
---|
70 | int Curl_socket_close(struct Curl_easy *data, struct connectdata *conn,
|
---|
71 | curl_socket_t sock);
|
---|
72 |
|
---|
73 | /**
|
---|
74 | * Determine the curl code for a socket connect() == -1 with errno.
|
---|
75 | */
|
---|
76 | CURLcode Curl_socket_connect_result(struct Curl_easy *data,
|
---|
77 | const char *ipaddress, int error);
|
---|
78 |
|
---|
79 | #ifdef USE_WINSOCK
|
---|
80 | /* When you run a program that uses the Windows Sockets API, you may
|
---|
81 | experience slow performance when you copy data to a TCP server.
|
---|
82 |
|
---|
83 | https://support.microsoft.com/kb/823764
|
---|
84 |
|
---|
85 | Work-around: Make the Socket Send Buffer Size Larger Than the Program Send
|
---|
86 | Buffer Size
|
---|
87 |
|
---|
88 | */
|
---|
89 | void Curl_sndbufset(curl_socket_t sockfd);
|
---|
90 | #else
|
---|
91 | #define Curl_sndbufset(y) Curl_nop_stmt
|
---|
92 | #endif
|
---|
93 |
|
---|
94 | /**
|
---|
95 | * Assign the address `ai` to the Curl_sockaddr_ex `dest` and
|
---|
96 | * set the transport used.
|
---|
97 | */
|
---|
98 | void Curl_sock_assign_addr(struct Curl_sockaddr_ex *dest,
|
---|
99 | const struct Curl_addrinfo *ai,
|
---|
100 | int transport);
|
---|
101 |
|
---|
102 | /**
|
---|
103 | * Creates a cfilter that opens a TCP socket to the given address
|
---|
104 | * when calling its `connect` implementation.
|
---|
105 | * The filter will not touch any connection/data flags and can be
|
---|
106 | * used in happy eyeballing. Once selected for use, its `_active()`
|
---|
107 | * method needs to be called.
|
---|
108 | */
|
---|
109 | CURLcode Curl_cf_tcp_create(struct Curl_cfilter **pcf,
|
---|
110 | struct Curl_easy *data,
|
---|
111 | struct connectdata *conn,
|
---|
112 | const struct Curl_addrinfo *ai,
|
---|
113 | int transport);
|
---|
114 |
|
---|
115 | /**
|
---|
116 | * Creates a cfilter that opens a UDP socket to the given address
|
---|
117 | * when calling its `connect` implementation.
|
---|
118 | * The filter will not touch any connection/data flags and can be
|
---|
119 | * used in happy eyeballing. Once selected for use, its `_active()`
|
---|
120 | * method needs to be called.
|
---|
121 | */
|
---|
122 | CURLcode Curl_cf_udp_create(struct Curl_cfilter **pcf,
|
---|
123 | struct Curl_easy *data,
|
---|
124 | struct connectdata *conn,
|
---|
125 | const struct Curl_addrinfo *ai,
|
---|
126 | int transport);
|
---|
127 |
|
---|
128 | /**
|
---|
129 | * Creates a cfilter that opens a UNIX socket to the given address
|
---|
130 | * when calling its `connect` implementation.
|
---|
131 | * The filter will not touch any connection/data flags and can be
|
---|
132 | * used in happy eyeballing. Once selected for use, its `_active()`
|
---|
133 | * method needs to be called.
|
---|
134 | */
|
---|
135 | CURLcode Curl_cf_unix_create(struct Curl_cfilter **pcf,
|
---|
136 | struct Curl_easy *data,
|
---|
137 | struct connectdata *conn,
|
---|
138 | const struct Curl_addrinfo *ai,
|
---|
139 | int transport);
|
---|
140 |
|
---|
141 | /**
|
---|
142 | * Creates a cfilter that keeps a listening socket.
|
---|
143 | */
|
---|
144 | CURLcode Curl_conn_tcp_listen_set(struct Curl_easy *data,
|
---|
145 | struct connectdata *conn,
|
---|
146 | int sockindex,
|
---|
147 | curl_socket_t *s);
|
---|
148 |
|
---|
149 | /**
|
---|
150 | * Replace the listen socket with the accept()ed one.
|
---|
151 | */
|
---|
152 | CURLcode Curl_conn_tcp_accepted_set(struct Curl_easy *data,
|
---|
153 | struct connectdata *conn,
|
---|
154 | int sockindex,
|
---|
155 | curl_socket_t *s);
|
---|
156 |
|
---|
157 | /**
|
---|
158 | * Return TRUE iff `cf` is a socket filter.
|
---|
159 | */
|
---|
160 | bool Curl_cf_is_socket(struct Curl_cfilter *cf);
|
---|
161 |
|
---|
162 | /**
|
---|
163 | * Peek at the socket and remote ip/port the socket filter is using.
|
---|
164 | * The filter owns all returned values.
|
---|
165 | * @param psock pointer to hold socket descriptor or NULL
|
---|
166 | * @param paddr pointer to hold addr reference or NULL
|
---|
167 | * @param pr_ip_str pointer to hold remote addr as string or NULL
|
---|
168 | * @param pr_port pointer to hold remote port number or NULL
|
---|
169 | * @param pl_ip_str pointer to hold local addr as string or NULL
|
---|
170 | * @param pl_port pointer to hold local port number or NULL
|
---|
171 | * Returns error if the filter is of invalid type.
|
---|
172 | */
|
---|
173 | CURLcode Curl_cf_socket_peek(struct Curl_cfilter *cf,
|
---|
174 | struct Curl_easy *data,
|
---|
175 | curl_socket_t *psock,
|
---|
176 | const struct Curl_sockaddr_ex **paddr,
|
---|
177 | const char **pr_ip_str, int *pr_port,
|
---|
178 | const char **pl_ip_str, int *pl_port);
|
---|
179 |
|
---|
180 | extern struct Curl_cftype Curl_cft_tcp;
|
---|
181 | extern struct Curl_cftype Curl_cft_udp;
|
---|
182 | extern struct Curl_cftype Curl_cft_unix;
|
---|
183 | extern struct Curl_cftype Curl_cft_tcp_accept;
|
---|
184 |
|
---|
185 | #endif /* HEADER_CURL_CF_SOCKET_H */
|
---|