NeoMutt  2024-10-02-37-gfa9146
Teaching an old dog new tricks
DOXYGEN
Loading...
Searching...
No Matches

Open a socket Connection. More...

+ Collaboration diagram for open():

Functions

static int tls_socket_open (struct Connection *conn)
 Open a TLS socket - Implements Connection::open() -.
 
static int ssl_socket_open_err (struct Connection *conn)
 Error callback for opening an SSL connection - Implements Connection::open() -.
 
static int ssl_socket_open (struct Connection *conn)
 Open an SSL socket - Implements Connection::open() -.
 
int raw_socket_open (struct Connection *conn)
 Open a socket - Implements Connection::open() -.
 
static int mutt_sasl_conn_open (struct Connection *conn)
 Empty wrapper for underlying open function - Implements Connection::open() -.
 
static int tunnel_socket_open (struct Connection *conn)
 Open a tunnel socket - Implements Connection::open() -.
 
static int zstrm_open (struct Connection *conn)
 Open a socket - Implements Connection::open() -.
 

Variables

int(* SaslSockData::open )(struct Connection *conn)
 Open a socket Connection - Implements Connection::open() -.
 

Detailed Description

Open a socket Connection.

Parameters
connConnection to a server
Return values
0Success
-1Error

Function Documentation

◆ tls_socket_open()

static int tls_socket_open ( struct Connection conn)
static

Open a TLS socket - Implements Connection::open() -.

Definition at line 1028 of file gnutls.c.

1029{
1030 if (raw_socket_open(conn) < 0)
1031 return -1;
1032
1033 if (tls_negotiate(conn) < 0)
1034 {
1035 tls_socket_close(conn);
1036 return -1;
1037 }
1038
1039 return 0;
1040}
static int tls_negotiate(struct Connection *conn)
Negotiate TLS connection.
Definition: gnutls.c:872
static int tls_socket_close(struct Connection *conn)
Close a TLS socket - Implements Connection::close() -.
Definition: gnutls.c:1003
int raw_socket_open(struct Connection *conn)
Open a socket - Implements Connection::open() -.
Definition: raw.c:148
+ Here is the call graph for this function:
+ Here is the caller graph for this function:

◆ ssl_socket_open_err()

static int ssl_socket_open_err ( struct Connection conn)
static

Error callback for opening an SSL connection - Implements Connection::open() -.

Return values
-1Always

Definition at line 356 of file openssl.c.

357{
358 mutt_error(_("SSL disabled due to the lack of entropy"));
359 return -1;
360}
#define mutt_error(...)
Definition: logging2.h:92
#define _(a)
Definition: message.h:28
+ Here is the caller graph for this function:

◆ ssl_socket_open()

static int ssl_socket_open ( struct Connection conn)
static

Open an SSL socket - Implements Connection::open() -.

Definition at line 1322 of file openssl.c.

1323{
1324 if (raw_socket_open(conn) < 0)
1325 return -1;
1326
1327 int rc = ssl_setup(conn);
1328 if (rc)
1329 raw_socket_close(conn);
1330
1331 return rc;
1332}
int raw_socket_close(struct Connection *conn)
Close a socket - Implements Connection::close() -.
Definition: raw.c:393
static int ssl_setup(struct Connection *conn)
Set up SSL on the Connection.
Definition: openssl.c:1205
+ Here is the call graph for this function:
+ Here is the caller graph for this function:

◆ raw_socket_open()

int raw_socket_open ( struct Connection conn)

Open a socket - Implements Connection::open() -.

Definition at line 148 of file raw.c.

149{
150 int rc;
151
152 char *host_idna = NULL;
153
154#ifdef HAVE_GETADDRINFO
155 /* --- IPv4/6 --- */
156
157 /* "65536\0" */
158 char port[6] = { 0 };
159 struct addrinfo hints = { 0 };
160 struct addrinfo *res = NULL;
161 struct addrinfo *cur = NULL;
162
163 /* we accept v4 or v6 STREAM sockets */
164 const bool c_use_ipv6 = cs_subset_bool(NeoMutt->sub, "use_ipv6");
165 if (c_use_ipv6)
166 hints.ai_family = AF_UNSPEC;
167 else
168 hints.ai_family = AF_INET;
169
170 hints.ai_socktype = SOCK_STREAM;
171
172 snprintf(port, sizeof(port), "%d", conn->account.port);
173
174#ifdef HAVE_LIBIDN
175 if (mutt_idna_to_ascii_lz(conn->account.host, &host_idna, 1) != 0)
176 {
177 mutt_error(_("Bad IDN: '%s'"), conn->account.host);
178 return -1;
179 }
180#else
181 host_idna = conn->account.host;
182#endif
183
184 if (!OptNoCurses)
185 mutt_message(_("Looking up %s..."), conn->account.host);
186
187 rc = getaddrinfo(host_idna, port, &hints, &res);
188
189#ifdef HAVE_LIBIDN
190 FREE(&host_idna);
191#endif
192
193 if (rc)
194 {
195 mutt_error(_("Could not find the host \"%s\""), conn->account.host);
196 return -1;
197 }
198
199 if (!OptNoCurses)
200 mutt_message(_("Connecting to %s..."), conn->account.host);
201
202 rc = -1;
203 for (cur = res; cur; cur = cur->ai_next)
204 {
205 int fd = socket(cur->ai_family, cur->ai_socktype, cur->ai_protocol);
206 if (fd >= 0)
207 {
208 rc = socket_connect(fd, cur->ai_addr);
209 if (rc == 0)
210 {
211 (void) fcntl(fd, F_SETFD, FD_CLOEXEC);
212 conn->fd = fd;
213 break;
214 }
215 else
216 {
217 close(fd);
218 }
219 }
220 }
221
222 freeaddrinfo(res);
223#else
224 /* --- IPv4 only --- */
225
226 struct hostent *he = NULL;
227 struct sockaddr_in sin = { 0 };
228 sin.sin_port = htons(conn->account.port);
229 sin.sin_family = AF_INET;
230
231#ifdef HAVE_LIBIDN
232 if (mutt_idna_to_ascii_lz(conn->account.host, &host_idna, 1) != 0)
233 {
234 mutt_error(_("Bad IDN: '%s'"), conn->account.host);
235 return -1;
236 }
237#else
238 host_idna = conn->account.host;
239#endif
240
241 if (!OptNoCurses)
242 mutt_message(_("Looking up %s..."), conn->account.host);
243
244 he = gethostbyname(host_idna);
245
246#ifdef HAVE_LIBIDN
247 FREE(&host_idna);
248#endif
249
250 if (!he)
251 {
252 mutt_error(_("Could not find the host \"%s\""), conn->account.host);
253
254 return -1;
255 }
256
257 if (!OptNoCurses)
258 mutt_message(_("Connecting to %s..."), conn->account.host);
259
260 rc = -1;
261 for (int i = 0; he->h_addr_list[i]; i++)
262 {
263 memcpy(&sin.sin_addr, he->h_addr_list[i], he->h_length);
264 int fd = socket(PF_INET, SOCK_STREAM, IPPROTO_IP);
265
266 if (fd >= 0)
267 {
268 rc = socket_connect(fd, (struct sockaddr *) &sin);
269 if (rc == 0)
270 {
271 fcntl(fd, F_SETFD, FD_CLOEXEC);
272 conn->fd = fd;
273 break;
274 }
275 else
276 {
277 close(fd);
278 }
279 }
280 }
281#endif
282 if (rc)
283 {
284 mutt_error(_("Could not connect to %s (%s)"), conn->account.host,
285 (rc > 0) ? strerror(rc) : _("unknown error"));
286 return -1;
287 }
288
289 return 0;
290}
bool cs_subset_bool(const struct ConfigSubset *sub, const char *name)
Get a boolean config item by name.
Definition: helpers.c:47
bool OptNoCurses
(pseudo) when sending in batch mode
Definition: globals.c:69
#define mutt_message(...)
Definition: logging2.h:91
int mutt_idna_to_ascii_lz(const char *input, char **output, uint8_t flags)
Convert a domain to Punycode.
Definition: idna.c:90
#define FREE(x)
Definition: memory.h:45
static int socket_connect(int fd, struct sockaddr *sa)
Set up to connect to a socket fd.
Definition: raw.c:68
char host[128]
Server to login to.
Definition: connaccount.h:54
unsigned short port
Port to connect to.
Definition: connaccount.h:58
struct ConnAccount account
Account details: username, password, etc.
Definition: connection.h:49
int fd
Socket file descriptor.
Definition: connection.h:53
Container for Accounts, Notifications.
Definition: neomutt.h:42
struct ConfigSubset * sub
Inherited config items.
Definition: neomutt.h:46
+ Here is the call graph for this function:
+ Here is the caller graph for this function:

◆ mutt_sasl_conn_open()

static int mutt_sasl_conn_open ( struct Connection conn)
static

Empty wrapper for underlying open function - Implements Connection::open() -.

We don't know in advance that a connection will use SASL, so we replace conn's methods with sasl methods when authentication is successful, using mutt_sasl_setup_conn

Definition at line 427 of file sasl.c.

428{
429 struct SaslSockData *sasldata = conn->sockdata;
430 conn->sockdata = sasldata->sockdata;
431 int rc = sasldata->open(conn);
432 conn->sockdata = sasldata;
433
434 return rc;
435}
int(* open)(struct Connection *conn)
Open a socket Connection - Implements Connection::open() -.
Definition: sasl.c:80
void * sockdata
Backend-specific socket data.
Definition: connection.h:55
SASL authentication API -.
Definition: sasl.c:65
void * sockdata
Underlying socket data.
Definition: sasl.c:75
+ Here is the caller graph for this function:

◆ tunnel_socket_open()

static int tunnel_socket_open ( struct Connection conn)
static

Open a tunnel socket - Implements Connection::open() -.

Definition at line 59 of file tunnel.c.

60{
61 int pin[2], pout[2];
62
63 struct TunnelSockData *tunnel = mutt_mem_malloc(sizeof(struct TunnelSockData));
64 conn->sockdata = tunnel;
65
66 const char *const c_tunnel = cs_subset_string(NeoMutt->sub, "tunnel");
67 mutt_message(_("Connecting with \"%s\"..."), c_tunnel);
68
69 int rc = pipe(pin);
70 if (rc == -1)
71 {
72 mutt_perror("pipe");
73 FREE(&conn->sockdata);
74 return -1;
75 }
76 rc = pipe(pout);
77 if (rc == -1)
78 {
79 mutt_perror("pipe");
80 close(pin[0]);
81 close(pin[1]);
82 FREE(&conn->sockdata);
83 return -1;
84 }
85
87 int pid = fork();
88 if (pid == 0)
89 {
92 const int fd_null = open("/dev/null", O_RDWR);
93 if ((fd_null < 0) || (dup2(pout[0], STDIN_FILENO) < 0) ||
94 (dup2(pin[1], STDOUT_FILENO) < 0) || (dup2(fd_null, STDERR_FILENO) < 0))
95 {
96 _exit(127);
97 }
98 close(pin[0]);
99 close(pin[1]);
100 close(pout[0]);
101 close(pout[1]);
102 close(fd_null);
103
104 /* Don't let the subprocess think it can use the controlling tty */
105 setsid();
106
107 execle(EXEC_SHELL, "sh", "-c", c_tunnel, NULL, EnvList);
108 _exit(127);
109 }
111
112 if (pid == -1)
113 {
114 mutt_perror("fork");
115 close(pin[0]);
116 close(pin[1]);
117 close(pout[0]);
118 close(pout[1]);
119 FREE(&conn->sockdata);
120 return -1;
121 }
122 if ((close(pin[1]) < 0) || (close(pout[0]) < 0))
123 mutt_perror("close");
124
125 fcntl(pin[0], F_SETFD, FD_CLOEXEC);
126 fcntl(pout[1], F_SETFD, FD_CLOEXEC);
127
128 tunnel->fd_read = pin[0];
129 tunnel->fd_write = pout[1];
130 tunnel->pid = pid;
131
132 conn->fd = 42; /* stupid hack */
133
134 /* Note we are using ssf as a boolean in this case. See the notes in
135 * conn/connection.h */
136 const bool c_tunnel_is_secure = cs_subset_bool(NeoMutt->sub, "tunnel_is_secure");
137 if (c_tunnel_is_secure)
138 conn->ssf = 1;
139
140 return 0;
141}
const char * cs_subset_string(const struct ConfigSubset *sub, const char *name)
Get a string config item by name.
Definition: helpers.c:291
char ** EnvList
Private copy of the environment variables.
Definition: globals.c:75
#define mutt_perror(...)
Definition: logging2.h:93
void * mutt_mem_malloc(size_t size)
Allocate memory on the heap.
Definition: memory.c:91
#define EXEC_SHELL
Definition: filter.h:29
void mutt_sig_reset_child_signals(void)
Reset ignored signals back to the default.
Definition: signal.c:321
void mutt_sig_block_system(void)
Block signals before calling exec()
Definition: signal.c:245
void mutt_sig_unblock_system(bool restore)
Restore previously blocked signals.
Definition: signal.c:269
unsigned int ssf
Security strength factor, in bits (see notes)
Definition: connection.h:50
A network tunnel (pair of sockets)
Definition: tunnel.c:50
int fd_read
File descriptor to read from.
Definition: tunnel.c:52
pid_t pid
Process ID of tunnel program.
Definition: tunnel.c:51
int fd_write
File descriptor to write to.
Definition: tunnel.c:53
+ Here is the call graph for this function:
+ Here is the caller graph for this function:

◆ zstrm_open()

static int zstrm_open ( struct Connection conn)
static

Open a socket - Implements Connection::open() -.

Return values
-1Always

Cannot open a zlib connection, must wrap an existing one

Definition at line 92 of file zstrm.c.

93{
94 return -1;
95}
+ Here is the caller graph for this function:

Variable Documentation

◆ open

int(* SaslSockData::open) (struct Connection *conn)

Open a socket Connection - Implements Connection::open() -.

Definition at line 80 of file sasl.c.