1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
|
/* Copyright (C) 2024 CZ.NIC, z.s.p.o. <knot-dns@labs.nic.cz>
This program is free software: you can redistribute it and/or modify
it under the terms of the GNU General Public License as published by
the Free Software Foundation, either version 3 of the License, or
(at your option) any later version.
This program is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
GNU General Public License for more details.
You should have received a copy of the GNU General Public License
along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
#pragma once
#include <netdb.h>
#include <stdint.h>
#include <sys/socket.h>
#include "libknot/probe/data.h"
#include "utils/common/https.h"
#include "utils/common/params.h"
#include "utils/common/quic.h"
#include "utils/common/tls.h"
/*! \brief Structure containing server information. */
typedef struct {
/*! List node (for list container). */
node_t n;
/*! Name or address of the server. */
char *name;
/*! Name or number of the service. */
char *service;
} srv_info_t;
typedef enum {
NET_FLAGS_NONE = 0,
NET_FLAGS_FASTOPEN = 1 << 0,
} net_flags_t;
typedef struct {
/*! Socket descriptor. */
int sockfd;
/*! IP protocol type. */
int iptype;
/*! Socket type. */
int socktype;
/*! Timeout for all network operations. */
int wait;
/*! Connection flags. */
net_flags_t flags;
/*! Local interface parameters. */
const srv_info_t *local;
/*! Remote server parameters. */
const srv_info_t *remote;
/*! Local description string (used for logging). */
char *local_str;
/*! Remote description string (used for logging). */
char *remote_str;
/*! Output from getaddrinfo for remote server. If the server is
* specified using domain name, this structure may contain more
* results.
*/
struct addrinfo *remote_info;
/*! Currently used result from remote_info. */
struct addrinfo *srv;
/*! Output from getaddrinfo for local address. Only first result is
* used.
*/
struct addrinfo *local_info;
/*! TLS context. */
tls_ctx_t tls;
#ifdef LIBNGHTTP2
/*! HTTPS context. */
https_ctx_t https;
#endif
#ifdef ENABLE_QUIC
/*! QUIC context. */
quic_ctx_t quic;
#endif
struct {
const struct sockaddr *src;
const struct sockaddr *dst;
} proxy;
} net_t;
/*!
* \brief Creates and fills server structure.
*
* \param name Address or host name.
* \param service Port number or service name.
*
* \retval server if success.
* \retval NULL if error.
*/
srv_info_t *srv_info_create(const char *name, const char *service);
/*!
* \brief Destroys server structure.
*
* \param server Server structure to destroy.
*/
void srv_info_free(srv_info_t *server);
/*!
* \brief Translates enum IP version type to int version.
*
* \param ip IP version to convert.
* \param server Server structure.
*
* \retval AF_INET, AF_INET6, AF_UNIX, or AF_UNSPEC.
*/
int get_iptype(const ip_t ip, const srv_info_t *server);
/*!
* \brief Translates enum IP protocol type to int version in context to the
* current DNS query type.
*
* \param proto IP protocol type to convert.
* \param type DNS query type number.
*
* \retval SOCK_STREAM or SOCK_DGRAM.
*/
int get_socktype(const protocol_t proto, const uint16_t type);
/*!
* \brief Translates int socket type to the common string one.
*
* \param socktype Socket type (SOCK_STREAM or SOCK_DGRAM).
*
* \retval "TCP" or "UDP".
*/
const char *get_sockname(const int socktype);
/*!
* \brief Translates protocol type to a common string.
*
* \param ss Socket address storage.
* \param socktype Protocol type.
* \param dst Output string.
*/
void get_addr_str(const struct sockaddr_storage *ss,
const knot_probe_proto_t socktype,
char **dst);
/*!
* \brief Initializes network structure and resolves local and remote addresses.
*
* \param local Local address and service description.
* \param remote Remote address and service description.
* \param iptype IP version.
* \param socktype Socket type.
* \param wait Network timeout interval.
* \param flags Connection flags.
* \param proxy_src Proxy source address.
* \param proxy_dst Proxy destination address.
* \param net Network structure to initialize.
*
* \retval KNOT_EOK if success.
* \retval errcode if error.
*/
int net_init(const srv_info_t *local,
const srv_info_t *remote,
const int iptype,
const int socktype,
const int wait,
const net_flags_t flags,
const struct sockaddr *proxy_src,
const struct sockaddr *proxy_dst,
net_t *net);
/*!
* \brief (Re)initializes crypto protocols in network structure.
*
* \param net Network structure to initialize.
* \param tls_params TLS parameters.
* \param https_params HTTPS parameters.
* \param quic_params QUIC parameters.
*
* \retval KNOT_EOK if success.
* \retval errcode if error.
*/
int net_init_crypto(net_t *net,
const tls_params_t *tls_params,
const https_params_t *https_params,
const quic_params_t *quic_params);
/*!
* \brief Creates socket and connects (if TCP) to remote address specified
* by net->srv.
*
* \param net Connection parameters.
*
* \retval KNOT_EOK if success.
* \retval errcode if error.
*/
int net_connect(net_t *net);
/*!
* \brief Fills in local address information.
*
* \param net Connection parameters.
*
* \retval KNOT_EOK if success.
* \retval errcode if error.
*/
int net_set_local_info(net_t *net);
/*!
* \brief Sends data to connected remote server.
*
* \param net Connection parameters.
* \param buf Data to send.
* \param buf_len Length of the data to send.
*
* \retval KNOT_EOK if success.
* \retval errcode if error.
*/
int net_send(const net_t *net, const uint8_t *buf, const size_t buf_len);
/*!
* \brief Receives data from connected remote server.
*
* \param net Connection parameters.
* \param buf Buffer for incoming data.
* \param buf_len Length of the buffer.
*
* \retval >=0 length of successfully received data.
* \retval errcode if error.
*/
int net_receive(const net_t *net, uint8_t *buf, const size_t buf_len);
/*!
* \brief Closes current network connection.
*
* \param net Connection parameters.
*/
void net_close(net_t *net);
/*!
* \brief Cleans up network structure.
*
* \param net Connection parameters.
*/
void net_clean(net_t *net);
|
