winhttp: Avoid testing errno when it isn't set.
[wine.git] / dlls / winhttp / net.c
blob90950cbe65a92a96bf7006bc88810464669956e0
1 /*
2 * Copyright 2008 Hans Leidekker for CodeWeavers
4 * This library is free software; you can redistribute it and/or
5 * modify it under the terms of the GNU Lesser General Public
6 * License as published by the Free Software Foundation; either
7 * version 2.1 of the License, or (at your option) any later version.
9 * This library is distributed in the hope that it will be useful,
10 * but WITHOUT ANY WARRANTY; without even the implied warranty of
11 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
12 * Lesser General Public License for more details.
14 * You should have received a copy of the GNU Lesser General Public
15 * License along with this library; if not, write to the Free Software
16 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301, USA
19 #include "config.h"
20 #include "wine/port.h"
22 #include <stdarg.h>
23 #include <stdio.h>
24 #include <errno.h>
26 #include <sys/types.h>
27 #ifdef HAVE_SYS_SOCKET_H
28 # include <sys/socket.h>
29 #endif
30 #ifdef HAVE_SYS_IOCTL_H
31 # include <sys/ioctl.h>
32 #endif
33 #ifdef HAVE_SYS_FILIO_H
34 # include <sys/filio.h>
35 #endif
36 #ifdef HAVE_POLL_H
37 # include <poll.h>
38 #endif
39 #ifdef HAVE_OPENSSL_SSL_H
40 # include <openssl/ssl.h>
41 #undef FAR
42 #undef DSA
43 #endif
45 #include "wine/debug.h"
46 #include "wine/library.h"
48 #include "windef.h"
49 #include "winbase.h"
50 #include "winhttp.h"
52 /* to avoid conflicts with the Unix socket headers */
53 #define USE_WS_PREFIX
54 #include "winsock2.h"
56 #include "winhttp_private.h"
58 WINE_DEFAULT_DEBUG_CHANNEL(winhttp);
60 #define DEFAULT_SEND_TIMEOUT 30
61 #define DEFAULT_RECEIVE_TIMEOUT 30
63 #ifndef HAVE_GETADDRINFO
65 /* critical section to protect non-reentrant gethostbyname() */
66 static CRITICAL_SECTION cs_gethostbyname;
67 static CRITICAL_SECTION_DEBUG critsect_debug =
69 0, 0, &cs_gethostbyname,
70 { &critsect_debug.ProcessLocksList, &critsect_debug.ProcessLocksList },
71 0, 0, { (DWORD_PTR)(__FILE__ ": cs_gethostbyname") }
73 static CRITICAL_SECTION cs_gethostbyname = { &critsect_debug, -1, 0, 0, 0, 0 };
75 #endif
77 #ifdef SONAME_LIBSSL
79 #include <openssl/err.h>
81 static void *libssl_handle;
82 static void *libcrypto_handle;
84 static SSL_METHOD *method;
86 #define MAKE_FUNCPTR(f) static typeof(f) * p##f
88 MAKE_FUNCPTR( SSL_library_init );
89 MAKE_FUNCPTR( SSL_load_error_strings );
90 MAKE_FUNCPTR( SSLv23_method );
91 MAKE_FUNCPTR( SSL_CTX_new );
92 MAKE_FUNCPTR( SSL_CTX_free );
93 MAKE_FUNCPTR( SSL_new );
94 MAKE_FUNCPTR( SSL_free );
95 MAKE_FUNCPTR( SSL_set_fd );
96 MAKE_FUNCPTR( SSL_connect );
97 MAKE_FUNCPTR( SSL_shutdown );
98 MAKE_FUNCPTR( SSL_write );
99 MAKE_FUNCPTR( SSL_read );
100 MAKE_FUNCPTR( SSL_get_verify_result );
101 MAKE_FUNCPTR( SSL_get_peer_certificate );
102 MAKE_FUNCPTR( SSL_CTX_get_timeout );
103 MAKE_FUNCPTR( SSL_CTX_set_timeout );
104 MAKE_FUNCPTR( SSL_CTX_set_default_verify_paths );
106 MAKE_FUNCPTR( BIO_new_fp );
107 MAKE_FUNCPTR( ERR_get_error );
108 MAKE_FUNCPTR( ERR_error_string );
109 #undef MAKE_FUNCPTR
111 #endif
113 /* translate a unix error code into a winsock error code */
114 static int sock_get_error( int err )
116 switch (err)
118 case EINTR: return WSAEINTR;
119 case EBADF: return WSAEBADF;
120 case EPERM:
121 case EACCES: return WSAEACCES;
122 case EFAULT: return WSAEFAULT;
123 case EINVAL: return WSAEINVAL;
124 case EMFILE: return WSAEMFILE;
125 case EWOULDBLOCK: return WSAEWOULDBLOCK;
126 case EINPROGRESS: return WSAEINPROGRESS;
127 case EALREADY: return WSAEALREADY;
128 case ENOTSOCK: return WSAENOTSOCK;
129 case EDESTADDRREQ: return WSAEDESTADDRREQ;
130 case EMSGSIZE: return WSAEMSGSIZE;
131 case EPROTOTYPE: return WSAEPROTOTYPE;
132 case ENOPROTOOPT: return WSAENOPROTOOPT;
133 case EPROTONOSUPPORT: return WSAEPROTONOSUPPORT;
134 case ESOCKTNOSUPPORT: return WSAESOCKTNOSUPPORT;
135 case EOPNOTSUPP: return WSAEOPNOTSUPP;
136 case EPFNOSUPPORT: return WSAEPFNOSUPPORT;
137 case EAFNOSUPPORT: return WSAEAFNOSUPPORT;
138 case EADDRINUSE: return WSAEADDRINUSE;
139 case EADDRNOTAVAIL: return WSAEADDRNOTAVAIL;
140 case ENETDOWN: return WSAENETDOWN;
141 case ENETUNREACH: return WSAENETUNREACH;
142 case ENETRESET: return WSAENETRESET;
143 case ECONNABORTED: return WSAECONNABORTED;
144 case EPIPE:
145 case ECONNRESET: return WSAECONNRESET;
146 case ENOBUFS: return WSAENOBUFS;
147 case EISCONN: return WSAEISCONN;
148 case ENOTCONN: return WSAENOTCONN;
149 case ESHUTDOWN: return WSAESHUTDOWN;
150 case ETOOMANYREFS: return WSAETOOMANYREFS;
151 case ETIMEDOUT: return WSAETIMEDOUT;
152 case ECONNREFUSED: return WSAECONNREFUSED;
153 case ELOOP: return WSAELOOP;
154 case ENAMETOOLONG: return WSAENAMETOOLONG;
155 case EHOSTDOWN: return WSAEHOSTDOWN;
156 case EHOSTUNREACH: return WSAEHOSTUNREACH;
157 case ENOTEMPTY: return WSAENOTEMPTY;
158 #ifdef EPROCLIM
159 case EPROCLIM: return WSAEPROCLIM;
160 #endif
161 #ifdef EUSERS
162 case EUSERS: return WSAEUSERS;
163 #endif
164 #ifdef EDQUOT
165 case EDQUOT: return WSAEDQUOT;
166 #endif
167 #ifdef ESTALE
168 case ESTALE: return WSAESTALE;
169 #endif
170 #ifdef EREMOTE
171 case EREMOTE: return WSAEREMOTE;
172 #endif
173 default: errno = err; perror( "sock_set_error" ); return WSAEFAULT;
175 return err;
178 BOOL netconn_init( netconn_t *conn, BOOL secure )
180 conn->socket = -1;
181 if (!secure) return TRUE;
183 #if defined(SONAME_LIBSSL) && defined(SONAME_LIBCRYPTO)
184 if (libssl_handle) return TRUE;
185 if (!(libssl_handle = wine_dlopen( SONAME_LIBSSL, RTLD_NOW, NULL, 0 )))
187 ERR("Trying to use SSL but couldn't load %s. Expect trouble.\n", SONAME_LIBSSL);
188 set_last_error( ERROR_WINHTTP_SECURE_CHANNEL_ERROR );
189 return FALSE;
191 if (!(libcrypto_handle = wine_dlopen( SONAME_LIBCRYPTO, RTLD_NOW, NULL, 0 )))
193 ERR("Trying to use SSL but couldn't load %s. Expect trouble.\n", SONAME_LIBCRYPTO);
194 set_last_error( ERROR_WINHTTP_SECURE_CHANNEL_ERROR );
195 return FALSE;
197 #define LOAD_FUNCPTR(x) \
198 if (!(p##x = wine_dlsym( libssl_handle, #x, NULL, 0 ))) \
200 ERR("Failed to load symbol %s\n", #x); \
201 set_last_error( ERROR_WINHTTP_SECURE_CHANNEL_ERROR ); \
202 return FALSE; \
204 LOAD_FUNCPTR( SSL_library_init );
205 LOAD_FUNCPTR( SSL_load_error_strings );
206 LOAD_FUNCPTR( SSLv23_method );
207 LOAD_FUNCPTR( SSL_CTX_new );
208 LOAD_FUNCPTR( SSL_CTX_free );
209 LOAD_FUNCPTR( SSL_new );
210 LOAD_FUNCPTR( SSL_free );
211 LOAD_FUNCPTR( SSL_set_fd );
212 LOAD_FUNCPTR( SSL_connect );
213 LOAD_FUNCPTR( SSL_shutdown );
214 LOAD_FUNCPTR( SSL_write );
215 LOAD_FUNCPTR( SSL_read );
216 LOAD_FUNCPTR( SSL_get_verify_result );
217 LOAD_FUNCPTR( SSL_get_peer_certificate );
218 LOAD_FUNCPTR( SSL_CTX_get_timeout );
219 LOAD_FUNCPTR( SSL_CTX_set_timeout );
220 LOAD_FUNCPTR( SSL_CTX_set_default_verify_paths );
221 #undef LOAD_FUNCPTR
223 #define LOAD_FUNCPTR(x) \
224 if (!(p##x = wine_dlsym( libcrypto_handle, #x, NULL, 0 ))) \
226 ERR("Failed to load symbol %s\n", #x); \
227 set_last_error( ERROR_WINHTTP_SECURE_CHANNEL_ERROR ); \
228 return FALSE; \
230 LOAD_FUNCPTR( BIO_new_fp );
231 LOAD_FUNCPTR( ERR_get_error );
232 LOAD_FUNCPTR( ERR_error_string );
233 #undef LOAD_FUNCPTR
235 pSSL_library_init();
236 pSSL_load_error_strings();
237 pBIO_new_fp( stderr, BIO_NOCLOSE );
239 method = pSSLv23_method();
240 conn->ssl_ctx = pSSL_CTX_new( method );
242 #else
243 WARN("SSL support not compiled in.\n");
244 set_last_error( ERROR_WINHTTP_SECURE_CHANNEL_ERROR );
245 return FALSE;
246 #endif
247 return TRUE;
250 BOOL netconn_connected( netconn_t *conn )
252 return (conn->socket != -1);
255 BOOL netconn_create( netconn_t *conn, int domain, int type, int protocol )
257 if ((conn->socket = socket( domain, type, protocol )) == -1)
259 WARN("unable to create socket (%s)\n", strerror(errno));
260 set_last_error( sock_get_error( errno ) );
261 return FALSE;
263 return TRUE;
266 BOOL netconn_close( netconn_t *conn )
268 int res;
270 #ifdef SONAME_LIBSSL
271 if (conn->secure)
273 heap_free( conn->peek_msg_mem );
274 conn->peek_msg_mem = NULL;
275 conn->peek_msg = NULL;
276 conn->peek_len = 0;
278 pSSL_shutdown( conn->ssl_conn );
279 pSSL_free( conn->ssl_conn );
280 pSSL_CTX_free( conn->ssl_ctx );
282 conn->ssl_conn = NULL;
283 conn->ssl_ctx = NULL;
284 conn->secure = FALSE;
286 #endif
287 res = close( conn->socket );
288 conn->socket = -1;
289 if (res == -1)
291 set_last_error( sock_get_error( errno ) );
292 return FALSE;
294 return TRUE;
297 BOOL netconn_connect( netconn_t *conn, const struct sockaddr *sockaddr, unsigned int addr_len )
299 if (connect( conn->socket, sockaddr, addr_len ) == -1)
301 WARN("unable to connect to host (%s)\n", strerror(errno));
302 set_last_error( sock_get_error( errno ) );
303 return FALSE;
305 return TRUE;
308 BOOL netconn_secure_connect( netconn_t *conn )
310 #ifdef SONAME_LIBSSL
311 X509 *cert;
312 long res;
314 if (!pSSL_CTX_set_default_verify_paths( conn->ssl_ctx ))
316 ERR("SSL_CTX_set_default_verify_paths failed: %s\n", pERR_error_string( pERR_get_error(), 0 ));
317 set_last_error( ERROR_OUTOFMEMORY );
318 return FALSE;
320 if (!(conn->ssl_conn = pSSL_new( conn->ssl_ctx )))
322 ERR("SSL_new failed: %s\n", pERR_error_string( pERR_get_error(), 0 ));
323 set_last_error( ERROR_OUTOFMEMORY );
324 goto fail;
326 if (!pSSL_set_fd( conn->ssl_conn, conn->socket ))
328 ERR("SSL_set_fd failed: %s\n", pERR_error_string( pERR_get_error(), 0 ));
329 set_last_error( ERROR_WINHTTP_SECURE_CHANNEL_ERROR );
330 goto fail;
332 if (pSSL_connect( conn->ssl_conn ) <= 0)
334 ERR("SSL_connect failed: %s\n", pERR_error_string( pERR_get_error(), 0 ));
335 set_last_error( ERROR_WINHTTP_SECURE_CHANNEL_ERROR );
336 goto fail;
338 if (!(cert = pSSL_get_peer_certificate( conn->ssl_conn )))
340 ERR("No certificate for server: %s\n", pERR_error_string( pERR_get_error(), 0 ));
341 set_last_error( ERROR_WINHTTP_SECURE_CHANNEL_ERROR );
342 goto fail;
344 if ((res = pSSL_get_verify_result( conn->ssl_conn )) != X509_V_OK)
346 /* FIXME: we should set an error and return, but we only print an error at the moment */
347 ERR("couldn't verify server certificate (%ld)\n", res);
349 TRACE("established SSL connection\n");
350 conn->secure = TRUE;
351 return TRUE;
353 fail:
354 if (conn->ssl_conn)
356 pSSL_shutdown( conn->ssl_conn );
357 pSSL_free( conn->ssl_conn );
358 conn->ssl_conn = NULL;
360 #endif
361 return FALSE;
364 BOOL netconn_send( netconn_t *conn, const void *msg, size_t len, int flags, int *sent )
366 if (!netconn_connected( conn )) return FALSE;
367 if (conn->secure)
369 #ifdef SONAME_LIBSSL
370 if (flags) FIXME("SSL_write doesn't support any flags (%08x)\n", flags);
371 *sent = pSSL_write( conn->ssl_conn, msg, len );
372 if (*sent < 1 && len) return FALSE;
373 return TRUE;
374 #else
375 return FALSE;
376 #endif
378 if ((*sent = send( conn->socket, msg, len, flags )) == -1)
380 set_last_error( sock_get_error( errno ) );
381 return FALSE;
383 return TRUE;
386 BOOL netconn_recv( netconn_t *conn, void *buf, size_t len, int flags, int *recvd )
388 *recvd = 0;
389 if (!netconn_connected( conn )) return FALSE;
390 if (!len) return TRUE;
392 if (conn->secure)
394 #ifdef SONAME_LIBSSL
395 if (flags & ~(MSG_PEEK | MSG_WAITALL))
396 FIXME("SSL_read does not support the following flags: %08x\n", flags);
398 /* this ugly hack is all for MSG_PEEK */
399 if (flags & MSG_PEEK && !conn->peek_msg)
401 if (!(conn->peek_msg = conn->peek_msg_mem = heap_alloc( len + 1 ))) return FALSE;
403 else if (flags & MSG_PEEK && conn->peek_msg)
405 if (len < conn->peek_len) FIXME("buffer isn't big enough, should we wrap?\n");
406 *recvd = min( len, conn->peek_len );
407 memcpy( buf, conn->peek_msg, *recvd );
408 return TRUE;
410 else if (conn->peek_msg)
412 *recvd = min( len, conn->peek_len );
413 memcpy( buf, conn->peek_msg, *recvd );
414 conn->peek_len -= *recvd;
415 conn->peek_msg += *recvd;
417 if (conn->peek_len == 0)
419 heap_free( conn->peek_msg_mem );
420 conn->peek_msg_mem = NULL;
421 conn->peek_msg = NULL;
423 /* check if we have enough data from the peek buffer */
424 if (!(flags & MSG_WAITALL) || (*recvd == len)) return TRUE;
426 *recvd += pSSL_read( conn->ssl_conn, (char *)buf + *recvd, len - *recvd );
427 if (flags & MSG_PEEK) /* must copy into buffer */
429 conn->peek_len = *recvd;
430 if (!*recvd)
432 heap_free( conn->peek_msg_mem );
433 conn->peek_msg_mem = NULL;
434 conn->peek_msg = NULL;
436 else memcpy( conn->peek_msg, buf, *recvd );
438 if (*recvd < 1 && len) return FALSE;
439 return TRUE;
440 #else
441 return FALSE;
442 #endif
444 if ((*recvd = recv( conn->socket, buf, len, flags )) == -1)
446 set_last_error( sock_get_error( errno ) );
447 return FALSE;
449 return TRUE;
452 BOOL netconn_query_data_available( netconn_t *conn, DWORD *available )
454 #ifdef FIONREAD
455 int ret, unread;
456 #endif
457 *available = 0;
458 if (!netconn_connected( conn )) return FALSE;
460 if (conn->secure)
462 #ifdef SONAME_LIBSSL
463 if (conn->peek_msg) *available = conn->peek_len;
464 #endif
465 return TRUE;
467 #ifdef FIONREAD
468 if (!(ret = ioctl( conn->socket, FIONREAD, &unread )))
470 TRACE("%d bytes of queued, but unread data\n", unread);
471 *available += unread;
473 #endif
474 return TRUE;
477 BOOL netconn_get_next_line( netconn_t *conn, char *buffer, DWORD *buflen )
479 struct pollfd pfd;
480 BOOL ret = FALSE;
481 DWORD recvd = 0;
483 if (!netconn_connected( conn )) return FALSE;
485 if (conn->secure)
487 #ifdef SONAME_LIBSSL
488 long timeout;
490 timeout = pSSL_CTX_get_timeout( conn->ssl_ctx );
491 pSSL_CTX_set_timeout( conn->ssl_ctx, DEFAULT_RECEIVE_TIMEOUT );
493 while (recvd < *buflen)
495 int dummy;
496 if (!netconn_recv( conn, &buffer[recvd], 1, 0, &dummy ))
498 set_last_error( ERROR_CONNECTION_ABORTED );
499 break;
501 if (buffer[recvd] == '\n')
503 ret = TRUE;
504 break;
506 if (buffer[recvd] != '\r') recvd++;
508 pSSL_CTX_set_timeout( conn->ssl_ctx, timeout );
509 if (ret)
511 buffer[recvd++] = 0;
512 *buflen = recvd;
513 TRACE("received line %s\n", debugstr_a(buffer));
515 return ret;
516 #else
517 return FALSE;
518 #endif
521 pfd.fd = conn->socket;
522 pfd.events = POLLIN;
523 while (recvd < *buflen)
525 if (poll( &pfd, 1, DEFAULT_RECEIVE_TIMEOUT * 1000 ) > 0)
527 int res;
528 if ((res = recv( conn->socket, &buffer[recvd], 1, 0 )) <= 0)
530 if (res == -1) set_last_error( sock_get_error( errno ) );
531 break;
533 if (buffer[recvd] == '\n')
535 ret = TRUE;
536 break;
538 if (buffer[recvd] != '\r') recvd++;
540 else
542 set_last_error( ERROR_WINHTTP_TIMEOUT );
543 break;
546 if (ret)
548 buffer[recvd++] = 0;
549 *buflen = recvd;
550 TRACE("received line %s\n", debugstr_a(buffer));
552 return ret;
555 DWORD netconn_set_timeout( netconn_t *netconn, BOOL send, int value )
557 int res;
558 struct timeval tv;
560 /* value is in milliseconds, convert to struct timeval */
561 tv.tv_sec = value / 1000;
562 tv.tv_usec = (value % 1000) * 1000;
564 if ((res = setsockopt( netconn->socket, SOL_SOCKET, send ? SO_SNDTIMEO : SO_RCVTIMEO, &tv, sizeof(tv) ) == -1))
566 WARN("setsockopt failed (%s)\n", strerror( errno ));
567 return sock_get_error( errno );
569 return ERROR_SUCCESS;
572 BOOL netconn_resolve( WCHAR *hostnameW, INTERNET_PORT port, struct sockaddr_in *sa )
574 char *hostname;
575 #ifdef HAVE_GETADDRINFO
576 struct addrinfo *res, hints;
577 int ret;
578 #else
579 struct hostent *he;
580 #endif
582 if (!(hostname = strdupWA( hostnameW ))) return FALSE;
584 #ifdef HAVE_GETADDRINFO
585 memset( &hints, 0, sizeof(struct addrinfo) );
586 hints.ai_family = AF_INET;
588 ret = getaddrinfo( hostname, NULL, &hints, &res );
589 heap_free( hostname );
590 if (ret != 0)
592 TRACE("failed to get address of %s (%s)\n", debugstr_a(hostname), gai_strerror(ret));
593 return FALSE;
595 memset( sa, 0, sizeof(struct sockaddr_in) );
596 memcpy( &sa->sin_addr, &((struct sockaddr_in *)res->ai_addr)->sin_addr, sizeof(struct in_addr) );
597 sa->sin_family = res->ai_family;
598 sa->sin_port = htons( port );
600 freeaddrinfo( res );
601 #else
602 EnterCriticalSection( &cs_gethostbyname );
604 he = gethostbyname( hostname );
605 heap_free( hostname );
606 if (!he)
608 TRACE("failed to get address of %s (%d)\n", debugstr_a(hostname), h_errno);
609 LeaveCriticalSection( &cs_gethostbyname );
610 return FALSE;
612 memset( sa, 0, sizeof(struct sockaddr_in) );
613 memcpy( (char *)&sa->sin_addr, he->h_addr, he->h_length );
614 sa->sin_family = he->h_addrtype;
615 sa->sin_port = htons( port );
617 LeaveCriticalSection( &cs_gethostbyname );
618 #endif
619 return TRUE;