?  search:
summary | log | graphiclog1 | graphiclog2 | commit | commitdiff | tree | refs | edit | fork
blame | history | raw | HEAD
Fixed wownt32.h to make it usable from inside Wine, and use it to
[wine/gsoc_dplay.git] / dlls / winsock / socket.c
blobb98d6304c0f5555935c31d6185a789f17ebb9815
1 /*
2 * based on Windows Sockets 1.1 specs
3 * (ftp.microsoft.com:/Advsys/winsock/spec11/WINSOCK.TXT)
4 *
5 * Copyright (C) 1993,1994,1996,1997 John Brezak, Erik Bos, Alex Korobka.
6 *
7 * This library is free software; you can redistribute it and/or
8 * modify it under the terms of the GNU Lesser General Public
9 * License as published by the Free Software Foundation; either
10 * version 2.1 of the License, or (at your option) any later version.
11 *
12 * This library is distributed in the hope that it will be useful,
13 * but WITHOUT ANY WARRANTY; without even the implied warranty of
14 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
15 * Lesser General Public License for more details.
16 *
17 * You should have received a copy of the GNU Lesser General Public
18 * License along with this library; if not, write to the Free Software
19 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
20 *
21 * NOTE: If you make any changes to fix a particular app, make sure
22 * they don't break something else like Netscape or telnet and ftp
23 * clients and servers (www.winsite.com got a lot of those).
24 */
25
26 #include "config.h"
27 #include "wine/port.h"
28
29 #include <stdio.h>
30 #include <string.h>
31 #include <sys/types.h>
32 #ifdef HAVE_SYS_IPC_H
33 # include <sys/ipc.h>
34 #endif
35 #ifdef HAVE_SYS_IOCTL_H
36 # include <sys/ioctl.h>
37 #endif
38 #ifdef HAVE_SYS_FILIO_H
39 # include <sys/filio.h>
40 #endif
41 #ifdef HAVE_SYS_SOCKIO_H
42 # include <sys/sockio.h>
43 #endif
44
45 #if defined(__EMX__)
46 # include <sys/so_ioctl.h>
47 #endif
48
49 #ifdef HAVE_SYS_PARAM_H
50 # include <sys/param.h>
51 #endif
52
53 #ifdef HAVE_SYS_MSG_H
54 # include <sys/msg.h>
55 #endif
56 #ifdef HAVE_SYS_WAIT_H
57 # include <sys/wait.h>
58 #endif
59 #include <sys/uio.h>
60 #ifdef HAVE_SYS_SOCKET_H
61 #include <sys/socket.h>
62 #endif
63 #ifdef HAVE_NETINET_IN_H
64 # include <netinet/in.h>
65 #endif
66 #ifdef HAVE_NETINET_TCP_H
67 # include <netinet/tcp.h>
68 #endif
69 #ifdef HAVE_ARPA_INET_H
70 # include <arpa/inet.h>
71 #endif
72 #include <ctype.h>
73 #include <fcntl.h>
74 #include <errno.h>
75 #ifdef HAVE_SYS_ERRNO_H
76 #include <sys/errno.h>
77 #endif
78 #ifdef HAVE_NETDB_H
79 #include <netdb.h>
80 #endif
81 #ifdef HAVE_UNISTD_H
82 # include <unistd.h>
83 #endif
84 #include <stdlib.h>
85 #ifdef HAVE_ARPA_NAMESER_H
86 # include <arpa/nameser.h>
87 #endif
88 #ifdef HAVE_RESOLV_H
89 # include <resolv.h>
90 #endif
91 #ifdef HAVE_NET_IF_H
92 # include <net/if.h>
93 #endif
94 #ifdef HAVE_IPX_GNU
95 # include <netipx/ipx.h>
96 # define HAVE_IPX
97 #endif
98 #ifdef HAVE_IPX_LINUX
99 # include <asm/types.h>
100 # include <linux/ipx.h>
101 # define HAVE_IPX
102 #endif
103
104 #ifdef HAVE_SYS_TIME_H
105 # include <sys/time.h>
106 #endif
107
108 #include "wine/winbase16.h"
109 #include "wingdi.h"
110 #include "winuser.h"
111 #include "winerror.h"
112 #include "winsock2.h"
113 #include "ws2tcpip.h"
114 #include "wsipx.h"
115 #include "wine/winsock16.h"
116 #include "winnt.h"
117 #include "wownt32.h"
118 #include "wine/server.h"
119 #include "wine/debug.h"
120
121
122 WINE_DEFAULT_DEBUG_CHANNEL(winsock);
123
124 /* critical section to protect some non-rentrant net function */
125 extern CRITICAL_SECTION csWSgetXXXbyYYY;
126
127 #define DEBUG_SOCKADDR 0
128 #define dump_sockaddr(a) \
129 DPRINTF("sockaddr_in: family %d, address %s, port %d\n", \
130 ((struct sockaddr_in *)a)->sin_family, \
131 inet_ntoa(((struct sockaddr_in *)a)->sin_addr), \
132 ntohs(((struct sockaddr_in *)a)->sin_port))
133
134 /****************************************************************
135 * Async IO declarations
136 ****************************************************************/
137 #include "async.h"
138
139 static DWORD ws2_async_get_status (const struct async_private *ovp);
140 static DWORD ws2_async_get_count (const struct async_private *ovp);
141 static void ws2_async_set_status (struct async_private *ovp, const DWORD status);
142 static void CALLBACK ws2_async_call_completion (ULONG_PTR data);
143 static void ws2_async_cleanup ( struct async_private *ovp );
144
145 static struct async_ops ws2_async_ops =
146 {
147 ws2_async_get_status,
148 ws2_async_set_status,
149 ws2_async_get_count,
150 ws2_async_call_completion,
151 ws2_async_cleanup
152 };
153
154 static struct async_ops ws2_nocomp_async_ops =
155 {
156 ws2_async_get_status,
157 ws2_async_set_status,
158 ws2_async_get_count,
159 NULL, /* call_completion */
160 ws2_async_cleanup
161 };
162
163 typedef struct ws2_async
164 {
165 async_private async;
166 LPWSAOVERLAPPED overlapped;
167 LPWSAOVERLAPPED user_overlapped;
168 LPWSAOVERLAPPED_COMPLETION_ROUTINE completion_func;
169 struct iovec *iovec;
170 int n_iovecs;
171 struct WS_sockaddr *addr;
172 union {
173 int val; /* for send operations */
174 int *ptr; /* for recv operations */
175 } addrlen;
176 DWORD flags;
177 } ws2_async;
178
179 /****************************************************************/
180
181 /* ----------------------------------- internal data */
182
183 /* ws_... struct conversion flags */
184
185 #define WS_DUP_LINEAR 0x0001
186 #define WS_DUP_SEGPTR 0x0002 /* internal pointers are SEGPTRs */
187 /* by default, internal pointers are linear */
188 typedef struct /* WSAAsyncSelect() control struct */
189 {
190 HANDLE service, event, sock;
191 HWND hWnd;
192 UINT uMsg;
193 LONG lEvent;
194 } ws_select_info;
195
196 #define WS_MAX_SOCKETS_PER_PROCESS 128 /* reasonable guess */
197 #define WS_MAX_UDP_DATAGRAM 1024
198
199 #define PROCFS_NETDEV_FILE "/proc/net/dev" /* Points to the file in the /proc fs
200 that lists the network devices.
201 Do we need an #ifdef LINUX for this? */
202
203 static void *he_buffer; /* typecast for Win16/32 ws_hostent */
204 static SEGPTR he_buffer_seg;
205 static void *se_buffer; /* typecast for Win16/32 ws_servent */
206 static SEGPTR se_buffer_seg;
207 static void *pe_buffer; /* typecast for Win16/32 ws_protoent */
208 static SEGPTR pe_buffer_seg;
209 static char* local_buffer;
210 static SEGPTR dbuffer_seg;
211 static INT num_startup; /* reference counter */
212 static FARPROC blocking_hook;
213
214 /* function prototypes */
215 static int WS_dup_he(struct hostent* p_he, int flag);
216 static int WS_dup_pe(struct protoent* p_pe, int flag);
217 static int WS_dup_se(struct servent* p_se, int flag);
218
219 typedef void WIN_hostent;
220 typedef void WIN_protoent;
221 typedef void WIN_servent;
222
223 int WSAIOCTL_GetInterfaceCount(void);
224 int WSAIOCTL_GetInterfaceName(int intNumber, char *intName);
225
226 UINT16 wsaErrno(void);
227 UINT16 wsaHerrno(int errnr);
228
229 static HANDLE _WSHeap = 0;
230
231 #define WS_ALLOC(size) \
232 HeapAlloc(_WSHeap, HEAP_ZERO_MEMORY, (size) )
233 #define WS_FREE(ptr) \
234 HeapFree(_WSHeap, 0, (ptr) )
235
236 static INT _ws_sock_ops[] =
237 { WS_SO_DEBUG, WS_SO_REUSEADDR, WS_SO_KEEPALIVE, WS_SO_DONTROUTE,
238 WS_SO_BROADCAST, WS_SO_LINGER, WS_SO_OOBINLINE, WS_SO_SNDBUF,
239 WS_SO_RCVBUF, WS_SO_ERROR, WS_SO_TYPE,
240 #ifdef SO_RCVTIMEO
241 WS_SO_RCVTIMEO,
242 #endif
243 #ifdef SO_SNDTIMEO
244 WS_SO_SNDTIMEO,
245 #endif
246 0 };
247 static int _px_sock_ops[] =
248 { SO_DEBUG, SO_REUSEADDR, SO_KEEPALIVE, SO_DONTROUTE, SO_BROADCAST,
249 SO_LINGER, SO_OOBINLINE, SO_SNDBUF, SO_RCVBUF, SO_ERROR, SO_TYPE,
250 #ifdef SO_RCVTIMEO
251 SO_RCVTIMEO,
252 #endif
253 #ifdef SO_SNDTIMEO
254 SO_SNDTIMEO,
255 #endif
256 };
257
258 static INT _ws_tcp_ops[] = {
259 #ifdef TCP_NODELAY
260 WS_TCP_NODELAY,
261 #endif
262 0
263 };
264 static int _px_tcp_ops[] = {
265 #ifdef TCP_NODELAY
266 TCP_NODELAY,
267 #endif
268 0
269 };
270
271 static DWORD opentype_tls_index = -1; /* TLS index for SO_OPENTYPE flag */
272
273 inline static DWORD NtStatusToWSAError ( const DWORD status )
274 {
275 /* We only need to cover the status codes set by server async request handling */
276 DWORD wserr;
277 switch ( status )
278 {
279 case STATUS_SUCCESS: wserr = 0; break;
280 case STATUS_PENDING: wserr = WSA_IO_PENDING; break;
281 case STATUS_INVALID_HANDLE: wserr = WSAENOTSOCK; break; /* WSAEBADF ? */
282 case STATUS_INVALID_PARAMETER: wserr = WSAEINVAL; break;
283 case STATUS_PIPE_DISCONNECTED: wserr = WSAESHUTDOWN; break;
284 case STATUS_CANCELLED: wserr = WSA_OPERATION_ABORTED; break;
285 case STATUS_TIMEOUT: wserr = WSAETIMEDOUT; break;
286 case STATUS_NO_MEMORY: wserr = WSAEFAULT; break;
287 default:
288 if ( status >= WSABASEERR && status <= WSABASEERR+1004 )
289 /* It is not a NT status code but a winsock error */
290 wserr = status;
291 else
292 {
293 wserr = RtlNtStatusToDosError( status );
294 FIXME ( "Status code %08lx converted to DOS error code %lx\n", status, wserr );
295 }
296 }
297 return wserr;
298 }
299
300 /* set last error code from NT status without mapping WSA errors */
301 inline static unsigned int set_error( unsigned int err )
302 {
303 if (err)
304 {
305 err = NtStatusToWSAError ( err );
306 SetLastError( err );
307 }
308 return err;
309 }
310
311 static char* check_buffer(int size);
312
313 inline static int _get_sock_fd(SOCKET s)
314 {
315 int fd;
316
317 if (set_error( wine_server_handle_to_fd( s, GENERIC_READ, &fd, NULL, NULL ) )) return -1;
318 return fd;
319 }
320
321 inline static int _get_sock_fd_type( SOCKET s, DWORD access, enum fd_type *type, int *flags )
322 {
323 int fd;
324 if (set_error( wine_server_handle_to_fd( s, access, &fd, type, flags ) )) return -1;
325 if ( ( (access & GENERIC_READ) && (*flags & FD_FLAG_RECV_SHUTDOWN ) ) ||
326 ( (access & GENERIC_WRITE) && (*flags & FD_FLAG_SEND_SHUTDOWN ) ) )
327 {
328 close (fd);
329 WSASetLastError ( WSAESHUTDOWN );
330 return -1;
331 }
332 return fd;
333 }
334
335 static void _enable_event(SOCKET s, unsigned int event,
336 unsigned int sstate, unsigned int cstate)
337 {
338 SERVER_START_REQ( enable_socket_event )
339 {
340 req->handle = s;
341 req->mask = event;
342 req->sstate = sstate;
343 req->cstate = cstate;
344 wine_server_call( req );
345 }
346 SERVER_END_REQ;
347 }
348
349 static int _is_blocking(SOCKET s)
350 {
351 int ret;
352 SERVER_START_REQ( get_socket_event )
353 {
354 req->handle = s;
355 req->service = FALSE;
356 req->c_event = 0;
357 wine_server_call( req );
358 ret = (reply->state & FD_WINE_NONBLOCKING) == 0;
359 }
360 SERVER_END_REQ;
361 return ret;
362 }
363
364 static unsigned int _get_sock_mask(SOCKET s)
365 {
366 unsigned int ret;
367 SERVER_START_REQ( get_socket_event )
368 {
369 req->handle = s;
370 req->service = FALSE;
371 req->c_event = 0;
372 wine_server_call( req );
373 ret = reply->mask;
374 }
375 SERVER_END_REQ;
376 return ret;
377 }
378
379 static void _sync_sock_state(SOCKET s)
380 {
381 /* do a dummy wineserver request in order to let
382 the wineserver run through its select loop once */
383 (void)_is_blocking(s);
384 }
385
386 static int _get_sock_error(SOCKET s, unsigned int bit)
387 {
388 int events[FD_MAX_EVENTS];
389
390 SERVER_START_REQ( get_socket_event )
391 {
392 req->handle = s;
393 req->service = FALSE;
394 req->c_event = 0;
395 wine_server_set_reply( req, events, sizeof(events) );
396 wine_server_call( req );
397 }
398 SERVER_END_REQ;
399 return events[bit];
400 }
401
402 static void WINSOCK_DeleteIData(void)
403 {
404 /* delete scratch buffers */
405
406 UnMapLS( he_buffer_seg );
407 UnMapLS( se_buffer_seg );
408 UnMapLS( pe_buffer_seg );
409 UnMapLS( dbuffer_seg );
410 if (he_buffer) HeapFree( GetProcessHeap(), 0, he_buffer );
411 if (se_buffer) HeapFree( GetProcessHeap(), 0, se_buffer );
412 if (pe_buffer) HeapFree( GetProcessHeap(), 0, pe_buffer );
413 if (local_buffer) HeapFree( GetProcessHeap(), 0, local_buffer );
414 he_buffer = NULL;
415 se_buffer = NULL;
416 pe_buffer = NULL;
417 local_buffer = NULL;
418 he_buffer_seg = 0;
419 se_buffer_seg = 0;
420 pe_buffer_seg = 0;
421 dbuffer_seg = 0;
422 num_startup = 0;
423 }
424
425 /***********************************************************************
426 * WS_LibMain (WS2_32.init)
427 */
428 BOOL WINAPI WS_LibMain(HINSTANCE hInstDLL, DWORD fdwReason, LPVOID fImpLoad)
429 {
430 TRACE("0x%x 0x%lx %p\n", hInstDLL, fdwReason, fImpLoad);
431 switch (fdwReason) {
432 case DLL_PROCESS_ATTACH:
433 opentype_tls_index = TlsAlloc();
434 break;
435 case DLL_PROCESS_DETACH:
436 TlsFree( opentype_tls_index );
437 WINSOCK_DeleteIData();
438 break;
439 }
440 return TRUE;
441 }
442
443 /***********************************************************************
444 * convert_sockopt()
445 *
446 * Converts socket flags from Windows format.
447 * Return 1 if converted, 0 if not (error).
448 */
449 static int convert_sockopt(INT *level, INT *optname)
450 {
451 int i;
452 switch (*level)
453 {
454 case WS_SOL_SOCKET:
455 *level = SOL_SOCKET;
456 for(i=0; _ws_sock_ops[i]; i++)
457 if( _ws_sock_ops[i] == *optname ) break;
458 if( _ws_sock_ops[i] ) {
459 *optname = _px_sock_ops[i];
460 return 1;
461 }
462 FIXME("Unknown SOL_SOCKET optname 0x%x\n", *optname);
463 break;
464 case WS_IPPROTO_TCP:
465 *level = IPPROTO_TCP;
466 for(i=0; _ws_tcp_ops[i]; i++)
467 if ( _ws_tcp_ops[i] == *optname ) break;
468 if( _ws_tcp_ops[i] ) {
469 *optname = _px_tcp_ops[i];
470 return 1;
471 }
472 FIXME("Unknown IPPROTO_TCP optname 0x%x\n", *optname);
473 break;
474 }
475 return 0;
476 }
477
478 /* ----------------------------------- Per-thread info (or per-process?) */
479
480 static int wsi_strtolo(const char* name, const char* opt)
481 {
482 /* Stuff a lowercase copy of the string into the local buffer */
483
484 int i = strlen(name) + 2;
485 char* p = check_buffer(i + ((opt)?strlen(opt):0));
486
487 if( p )
488 {
489 do *p++ = tolower(*name); while(*name++);
490 i = (p - local_buffer);
491 if( opt ) do *p++ = tolower(*opt); while(*opt++);
492 return i;
493 }
494 return 0;
495 }
496
497 static fd_set* fd_set_import( fd_set* fds, void* wsfds, int* highfd, int lfd[], BOOL b32 )
498 {
499 /* translate Winsock fd set into local fd set */
500
501 if( wsfds )
502 {
503 #define wsfds16 ((ws_fd_set16*)wsfds)
504 #define wsfds32 ((WS_fd_set*)wsfds)
505 int i, count;
506
507 FD_ZERO(fds);
508 count = b32 ? wsfds32->fd_count : wsfds16->fd_count;
509
510 for( i = 0; i < count; i++ )
511 {
512 int s = (b32) ? wsfds32->fd_array[i]
513 : wsfds16->fd_array[i];
514 int fd = _get_sock_fd(s);
515 if (fd != -1)
516 {
517 lfd[ i ] = fd;
518 if( fd > *highfd ) *highfd = fd;
519 FD_SET(fd, fds);
520 }
521 else lfd[ i ] = -1;
522 }
523 #undef wsfds32
524 #undef wsfds16
525 return fds;
526 }
527 return NULL;
528 }
529
530 inline static int sock_error_p(int s)
531 {
532 unsigned int optval, optlen;
533
534 optlen = sizeof(optval);
535 getsockopt(s, SOL_SOCKET, SO_ERROR, (void *) &optval, &optlen);
536 if (optval) WARN("\t[%i] error: %d\n", s, optval);
537 return optval != 0;
538 }
539
540 static int fd_set_export( fd_set* fds, fd_set* exceptfds, void* wsfds, int lfd[], BOOL b32 )
541 {
542 int num_err = 0;
543
544 /* translate local fd set into Winsock fd set, adding
545 * errors to exceptfds (only if app requested it) */
546
547 if( wsfds )
548 {
549 #define wsfds16 ((ws_fd_set16*)wsfds)
550 #define wsfds32 ((WS_fd_set*)wsfds)
551 int i, j, count = (b32) ? wsfds32->fd_count : wsfds16->fd_count;
552
553 for( i = 0, j = 0; i < count; i++ )
554 {
555 if( lfd[i] >= 0 )
556 {
557 int fd = lfd[i];
558 if( FD_ISSET(fd, fds) )
559 {
560 if ( exceptfds && sock_error_p(fd) )
561 {
562 FD_SET(fd, exceptfds);
563 num_err++;
564 }
565 else if( b32 )
566 wsfds32->fd_array[j++] = wsfds32->fd_array[i];
567 else
568 wsfds16->fd_array[j++] = wsfds16->fd_array[i];
569 }
570 close(fd);
571 lfd[i] = -1;
572 }
573 }
574
575 if( b32 ) wsfds32->fd_count = j;
576 else wsfds16->fd_count = j;
577
578 TRACE("\n");
579 #undef wsfds32
580 #undef wsfds16
581 }
582 return num_err;
583 }
584
585 static void fd_set_unimport( void* wsfds, int lfd[], BOOL b32 )
586 {
587 if ( wsfds )
588 {
589 #define wsfds16 ((ws_fd_set16*)wsfds)
590 #define wsfds32 ((WS_fd_set*)wsfds)
591 int i, count = (b32) ? wsfds32->fd_count : wsfds16->fd_count;
592
593 for( i = 0; i < count; i++ )
594 if ( lfd[i] >= 0 )
595 close(lfd[i]);
596
597 TRACE("\n");
598 #undef wsfds32
599 #undef wsfds16
600 }
601 }
602
603 static int do_block( int fd, int mask )
604 {
605 fd_set fds[3];
606 int i, r;
607
608 FD_ZERO(&fds[0]);
609 FD_ZERO(&fds[1]);
610 FD_ZERO(&fds[2]);
611 for (i=0; i<3; i++)
612 if (mask & (1<<i))
613 FD_SET(fd, &fds[i]);
614 i = select( fd+1, &fds[0], &fds[1], &fds[2], NULL );
615 if (i <= 0) return -1;
616 r = 0;
617 for (i=0; i<3; i++)
618 if (FD_ISSET(fd, &fds[i]))
619 r |= 1<<i;
620 return r;
621 }
622
623 void* __ws_memalloc( int size )
624 {
625 return WS_ALLOC(size);
626 }
627
628 void __ws_memfree(void* ptr)
629 {
630 WS_FREE(ptr);
631 }
632
633
634 /* ----------------------------------- API -----
635 *
636 * Init / cleanup / error checking.
637 */
638
639 /***********************************************************************
640 * WSAStartup (WINSOCK.115)
641 *
642 * Create socket control struct, attach it to the global list and
643 * update a pointer in the task struct.
644 */
645 INT16 WINAPI WSAStartup16(UINT16 wVersionRequested, LPWSADATA16 lpWSAData)
646 {
647 static const WSADATA16 data =
648 {
649 0x0101, 0x0101,
650 "WINE Sockets 1.1",
651 #ifdef linux
652 "Linux/i386",
653 #elif defined(__NetBSD__)
654 "NetBSD/i386",
655 #elif defined(sunos)
656 "SunOS",
657 #elif defined(__FreeBSD__)
658 "FreeBSD",
659 #elif defined(__OpenBSD__)
660 "OpenBSD/i386",
661 #else
662 "Unknown",
663 #endif
664 WS_MAX_SOCKETS_PER_PROCESS,
665 WS_MAX_UDP_DATAGRAM,
666 0
667 };
668
669 TRACE("verReq=%x\n", wVersionRequested);
670
671 if (LOBYTE(wVersionRequested) < 1 || (LOBYTE(wVersionRequested) == 1 &&
672 HIBYTE(wVersionRequested) < 1)) return WSAVERNOTSUPPORTED;
673
674 if (!lpWSAData) return WSAEINVAL;
675
676 /* initialize socket heap */
677
678 if( !_WSHeap )
679 {
680 _WSHeap = HeapCreate(HEAP_ZERO_MEMORY, 8120, 32768);
681 if( !_WSHeap )
682 {
683 ERR("Fatal: failed to create WinSock heap\n");
684 return 0;
685 }
686 }
687 if( _WSHeap == 0 ) return WSASYSNOTREADY;
688
689 num_startup++;
690
691 /* return winsock information */
692
693 memcpy(lpWSAData, &data, sizeof(data));
694
695 TRACE("succeeded\n");
696 return 0;
697 }
698
699 /***********************************************************************
700 * WSAStartup (WS2_32.115)
701 */
702 int WINAPI WSAStartup(WORD wVersionRequested, LPWSADATA lpWSAData)
703 {
704 TRACE("verReq=%x\n", wVersionRequested);
705
706 if (LOBYTE(wVersionRequested) < 1)
707 return WSAVERNOTSUPPORTED;
708
709 if (!lpWSAData) return WSAEINVAL;
710
711 /* initialize socket heap */
712
713 if( !_WSHeap )
714 {
715 _WSHeap = HeapCreate(HEAP_ZERO_MEMORY, 8120, 32768);
716 if( !_WSHeap )
717 {
718 ERR("Fatal: failed to create WinSock heap\n");
719 return 0;
720 }
721 }
722 if( _WSHeap == 0 ) return WSASYSNOTREADY;
723
724 num_startup++;
725
726 /* that's the whole of the negotiation for now */
727 lpWSAData->wVersion = wVersionRequested;
728 /* return winsock information */
729 lpWSAData->wHighVersion = 0x0202;
730 strcpy(lpWSAData->szDescription, "WinSock 2.0" );
731 strcpy(lpWSAData->szSystemStatus, "Running" );
732 lpWSAData->iMaxSockets = WS_MAX_SOCKETS_PER_PROCESS;
733 lpWSAData->iMaxUdpDg = WS_MAX_UDP_DATAGRAM;
734 /* don't do anything with lpWSAData->lpVendorInfo */
735 /* (some apps don't allocate the space for this field) */
736
737 TRACE("succeeded\n");
738 return 0;
739 }
740
741
742 /***********************************************************************
743 * WSACleanup (WINSOCK.116)
744 * WSACleanup (WS2_32.116)
745 */
746 INT WINAPI WSACleanup(void)
747 {
748 if (num_startup)
749 {
750 if (--num_startup > 0) return 0;
751 WINSOCK_DeleteIData();
752 return 0;
753 }
754 SetLastError(WSANOTINITIALISED);
755 return SOCKET_ERROR;
756 }
757
758
759 /***********************************************************************
760 * WSAGetLastError (WINSOCK.111)
761 * WSAGetLastError (WS2_32.111)
762 */
763 INT WINAPI WSAGetLastError(void)
764 {
765 return GetLastError();
766 }
767
768 /***********************************************************************
769 * WSASetLastError (WS2_32.112)
770 */
771 void WINAPI WSASetLastError(INT iError) {
772 SetLastError(iError);
773 }
774
775 /***********************************************************************
776 * WSASetLastError (WINSOCK.112)
777 */
778 void WINAPI WSASetLastError16(INT16 iError)
779 {
780 WSASetLastError(iError);
781 }
782
783 static char* check_buffer(int size)
784 {
785 static int local_buflen;
786
787 if (local_buffer)
788 {
789 if (local_buflen >= size ) return local_buffer;
790 HeapFree( GetProcessHeap(), 0, local_buffer );
791 }
792 local_buffer = HeapAlloc( GetProcessHeap(), 0, (local_buflen = size) );
793 return local_buffer;
794 }
795
796 static struct ws_hostent* check_buffer_he(int size)
797 {
798 static int he_len;
799 if (he_buffer)
800 {
801 if (he_len >= size ) return he_buffer;
802 UnMapLS( he_buffer_seg );
803 HeapFree( GetProcessHeap(), 0, he_buffer );
804 }
805 he_buffer = HeapAlloc( GetProcessHeap(), 0, (he_len = size) );
806 he_buffer_seg = MapLS( he_buffer );
807 return he_buffer;
808 }
809
810 static void* check_buffer_se(int size)
811 {
812 static int se_len;
813 if (se_buffer)
814 {
815 if (se_len >= size ) return se_buffer;
816 UnMapLS( se_buffer_seg );
817 HeapFree( GetProcessHeap(), 0, se_buffer );
818 }
819 se_buffer = HeapAlloc( GetProcessHeap(), 0, (se_len = size) );
820 se_buffer_seg = MapLS( se_buffer );
821 return se_buffer;
822 }
823
824 static struct ws_protoent* check_buffer_pe(int size)
825 {
826 static int pe_len;
827 if (pe_buffer)
828 {
829 if (pe_len >= size ) return pe_buffer;
830 UnMapLS( pe_buffer_seg );
831 HeapFree( GetProcessHeap(), 0, pe_buffer );
832 }
833 pe_buffer = HeapAlloc( GetProcessHeap(), 0, (pe_len = size) );
834 pe_buffer_seg = MapLS( he_buffer );
835 return pe_buffer;
836 }
837
838 /* ----------------------------------- i/o APIs */
839
840 #ifdef HAVE_IPX
841 #define SUPPORTED_PF(pf) ((pf)==WS_AF_INET || (pf)== WS_AF_IPX)
842 #else
843 #define SUPPORTED_PF(pf) ((pf)==WS_AF_INET)
844 #endif
845
846
847 /**********************************************************************/
848
849 /* Returns the converted address if successful, NULL if it was too small to
850 * start with. Note that the returned pointer may be the original pointer
851 * if no conversion is necessary.
852 */
853 static const struct sockaddr* ws_sockaddr_ws2u(const struct WS_sockaddr* wsaddr, int wsaddrlen, int *uaddrlen)
854 {
855 switch (wsaddr->sa_family)
856 {
857 #ifdef HAVE_IPX
858 case WS_AF_IPX:
859 {
860 struct WS_sockaddr_ipx* wsipx=(struct WS_sockaddr_ipx*)wsaddr;
861 struct sockaddr_ipx* uipx;
862
863 if (wsaddrlen<sizeof(struct WS_sockaddr_ipx))
864 return NULL;
865
866 *uaddrlen=sizeof(struct sockaddr_ipx);
867 uipx=malloc(*uaddrlen);
868 uipx->sipx_family=AF_IPX;
869 uipx->sipx_port=wsipx->sa_socket;
870 /* copy sa_netnum and sa_nodenum to sipx_network and sipx_node
871 * in one go
872 */
873 memcpy(&uipx->sipx_network,wsipx->sa_netnum,sizeof(uipx->sipx_network)+sizeof(uipx->sipx_node));
874 uipx->sipx_type=IPX_FRAME_NONE;
875 uipx->sipx_zero=0;
876 return (const struct sockaddr*)uipx;
877 }
878 #endif
879
880 default:
881 if (wsaddrlen<sizeof(struct WS_sockaddr))
882 return NULL;
883
884 /* No conversion needed, just return the original address */
885 *uaddrlen=wsaddrlen;
886 return (const struct sockaddr*)wsaddr;
887 }
888 return NULL;
889 }
890
891 /* Allocates a Unix sockaddr structure to receive the data */
892 inline struct sockaddr* ws_sockaddr_alloc(const struct WS_sockaddr* wsaddr, int* wsaddrlen, int* uaddrlen)
893 {
894 if (wsaddr==NULL)
895 {
896 ERR( "WINE shouldn't pass a NULL wsaddr! Attempting to continue\n" );
897
898 /* This is not strictly the right thing to do. Hope it works however */
899 *uaddrlen=0;
900
901 return NULL;
902 }
903
904 if (*wsaddrlen==0)
905 *uaddrlen=0;
906 else
907 *uaddrlen=max(sizeof(struct sockaddr),*wsaddrlen);
908
909 return malloc(*uaddrlen);
910 }
911
912 /* Returns 0 if successful, -1 if the buffer is too small */
913 static int ws_sockaddr_u2ws(const struct sockaddr* uaddr, int uaddrlen, struct WS_sockaddr* wsaddr, int* wsaddrlen)
914 {
915 int res;
916
917 switch(uaddr->sa_family)
918 {
919 #ifdef HAVE_IPX
920 case AF_IPX:
921 {
922 struct sockaddr_ipx* uipx=(struct sockaddr_ipx*)uaddr;
923 struct WS_sockaddr_ipx* wsipx=(struct WS_sockaddr_ipx*)wsaddr;
924
925 res=-1;
926 switch (*wsaddrlen) /* how much can we copy? */
927 {
928 default:
929 res=0; /* enough */
930 *wsaddrlen=uaddrlen;
931 wsipx->sa_socket=uipx->sipx_port;
932 /* fall through */
933 case 13:
934 case 12:
935 memcpy(wsipx->sa_nodenum,uipx->sipx_node,sizeof(wsipx->sa_nodenum));
936 /* fall through */
937 case 11:
938 case 10:
939 case 9:
940 case 8:
941 case 7:
942 case 6:
943 memcpy(wsipx->sa_netnum,&uipx->sipx_network,sizeof(wsipx->sa_netnum));
944 /* fall through */
945 case 5:
946 case 4:
947 case 3:
948 case 2:
949 wsipx->sa_family=WS_AF_IPX;
950 /* fall through */
951 case 1:
952 case 0:
953 /* way too small */
954 break;
955 }
956 }
957 break;
958 #endif
959
960 default:
961 /* No conversion needed */
962 memcpy(wsaddr,uaddr,*wsaddrlen);
963 if (*wsaddrlen<uaddrlen) {
964 res=-1;
965 } else {
966 *wsaddrlen=uaddrlen;
967 res=0;
968 }
969 }
970 return res;
971 }
972
973 /* to be called to free the memory allocated by ws_sockaddr_ws2u or
974 * ws_sockaddr_alloc
975 */
976 inline void ws_sockaddr_free(const struct sockaddr* uaddr, const struct WS_sockaddr* wsaddr)
977 {
978 if (uaddr!=NULL && uaddr!=(const struct sockaddr*)wsaddr)
979 free((void*)uaddr);
980 }
981
982 /**************************************************************************
983 * Functions for handling overlapped I/O
984 **************************************************************************/
985
986 static DWORD ws2_async_get_status (const struct async_private *ovp)
987 {
988 return ((ws2_async*) ovp)->overlapped->Internal;
989 }
990
991 static VOID ws2_async_set_status (struct async_private *ovp, const DWORD status)
992 {
993 ((ws2_async*) ovp)->overlapped->Internal = status;
994 }
995
996 static DWORD ws2_async_get_count (const struct async_private *ovp)
997 {
998 return ((ws2_async*) ovp)->overlapped->InternalHigh;
999 }
1000
1001 static void ws2_async_cleanup ( struct async_private *ap )
1002 {
1003 struct ws2_async *as = (struct ws2_async*) ap;
1004
1005 TRACE ( "as: %p uovl %p ovl %p\n", as, as->user_overlapped, as->overlapped );
1006 if ( !as->user_overlapped )
1007 {
1008 if ( as->overlapped->hEvent != INVALID_HANDLE_VALUE )
1009 WSACloseEvent ( as->overlapped->hEvent );
1010 HeapFree ( GetProcessHeap(), 0, as->overlapped );
1011 }
1012
1013 if ( as->iovec )
1014 HeapFree ( GetProcessHeap(), 0, as->iovec );
1015
1016 HeapFree ( GetProcessHeap(), 0, as );
1017 }
1018
1019 static void CALLBACK ws2_async_call_completion (ULONG_PTR data)
1020 {
1021 ws2_async* as = (ws2_async*) data;
1022
1023 TRACE ("data: %p\n", as);
1024
1025 as->completion_func ( NtStatusToWSAError (as->overlapped->Internal),
1026 as->overlapped->InternalHigh,
1027 as->user_overlapped,
1028 as->flags );
1029 ws2_async_cleanup ( &as->async );
1030 }
1031
1032 /***********************************************************************
1033 * WS2_make_async (INTERNAL)
1034 */
1035
1036 static void WS2_async_recv (async_private *as);
1037 static void WS2_async_send (async_private *as);
1038
1039 inline static struct ws2_async*
1040 WS2_make_async (SOCKET s, int fd, int type, struct iovec *iovec, DWORD dwBufferCount,
1041 LPDWORD lpFlags, struct WS_sockaddr *addr,
1042 LPINT addrlen, LPWSAOVERLAPPED lpOverlapped,
1043 LPWSAOVERLAPPED_COMPLETION_ROUTINE lpCompletionRoutine)
1044 {
1045 struct ws2_async *wsa = HeapAlloc ( GetProcessHeap(), 0, sizeof ( ws2_async ) );
1046
1047 TRACE ( "wsa %p\n", wsa );
1048
1049 if (!wsa)
1050 return NULL;
1051
1052 wsa->async.ops = ( lpCompletionRoutine ? &ws2_async_ops : &ws2_nocomp_async_ops );
1053 wsa->async.handle = (HANDLE) s;
1054 wsa->async.fd = fd;
1055 wsa->async.type = type;
1056 switch (type)
1057 {
1058 case ASYNC_TYPE_READ:
1059 wsa->flags = *lpFlags;
1060 wsa->async.func = WS2_async_recv;
1061 wsa->addrlen.ptr = addrlen;
1062 break;
1063 case ASYNC_TYPE_WRITE:
1064 wsa->flags = 0;
1065 wsa->async.func = WS2_async_send;
1066 wsa->addrlen.val = *addrlen;
1067 break;
1068 default:
1069 ERR ("Invalid async type: %d\n", type);
1070 }
1071 wsa->user_overlapped = lpOverlapped;
1072 wsa->completion_func = lpCompletionRoutine;
1073 wsa->iovec = iovec;
1074 wsa->n_iovecs = dwBufferCount;
1075 wsa->addr = addr;
1076
1077 if ( lpOverlapped )
1078 {
1079 wsa->overlapped = lpOverlapped;
1080 wsa->async.event = ( lpCompletionRoutine ? INVALID_HANDLE_VALUE : lpOverlapped->hEvent );
1081 }
1082 else
1083 {
1084 wsa->overlapped = HeapAlloc ( GetProcessHeap(), 0,
1085 sizeof (WSAOVERLAPPED) );
1086 if ( !wsa->overlapped )
1087 goto error;
1088 wsa->async.event = wsa->overlapped->hEvent = INVALID_HANDLE_VALUE;
1089 }
1090
1091 wsa->overlapped->InternalHigh = 0;
1092 TRACE ( "wsa %p, ops %p, h %d, ev %d, fd %d, func %p, ov %p, uov %p, cfunc %p\n",
1093 wsa, wsa->async.ops, wsa->async.handle, wsa->async.event, wsa->async.fd, wsa->async.func,
1094 wsa->overlapped, wsa->user_overlapped, wsa->completion_func );
1095
1096 return wsa;
1097
1098 error:
1099 TRACE ("Error\n");
1100 HeapFree ( GetProcessHeap(), 0, wsa );
1101 return NULL;
1102 }
1103
1104 /***********************************************************************
1105 * WS2_recv (INTERNAL)
1106 *
1107 * Work horse for both synchronous and asynchronous recv() operations.
1108 */
1109 static int WS2_recv ( int fd, struct iovec* iov, int count,
1110 struct WS_sockaddr *lpFrom, LPINT lpFromlen,
1111 LPDWORD lpFlags )
1112 {
1113 struct msghdr hdr;
1114 int n;
1115 TRACE ( "fd %d, iovec %p, count %d addr %p, len %p, flags %lx\n",
1116 fd, iov, count, lpFrom, lpFromlen, *lpFlags);
1117
1118 hdr.msg_name = NULL;
1119
1120 if ( lpFrom )
1121 {
1122 #if DEBUG_SOCKADDR
1123 dump_sockaddr (lpFrom);
1124 #endif
1125
1126 hdr.msg_namelen = *lpFromlen;
1127 hdr.msg_name = ws_sockaddr_alloc ( lpFrom, lpFromlen, &hdr.msg_namelen );
1128 if ( !hdr.msg_name )
1129 {
1130 WSASetLastError ( WSAEFAULT );
1131 n = -1;
1132 goto out;
1133 }
1134 }
1135 else
1136 hdr.msg_namelen = 0;
1137
1138 hdr.msg_iov = iov;
1139 hdr.msg_iovlen = count;
1140 #ifdef HAVE_MSGHDR_ACCRIGHTS
1141 hdr.msg_accrights = NULL;
1142 hdr.msg_accrightslen = 0;
1143 #else
1144 hdr.msg_control = NULL;
1145 hdr.msg_controllen = 0;
1146 hdr.msg_flags = 0;
1147 #endif
1148
1149 if ( (n = recvmsg (fd, &hdr, *lpFlags)) == -1 )
1150 {
1151 TRACE ( "recvmsg error %d\n", errno);
1152 goto out;
1153 }
1154
1155 if ( lpFrom &&
1156 ws_sockaddr_u2ws ( hdr.msg_name, hdr.msg_namelen,
1157 lpFrom, lpFromlen ) != 0 )
1158 {
1159 /* The from buffer was too small, but we read the data
1160 * anyway. Is that really bad?
1161 */
1162 WSASetLastError ( WSAEFAULT );
1163 WARN ( "Address buffer too small\n" );
1164 }
1165
1166 out:
1167
1168 ws_sockaddr_free ( hdr.msg_name, lpFrom );
1169 TRACE ("-> %d\n", n);
1170 return n;
1171 }
1172
1173 /***********************************************************************
1174 * WS2_async_recv (INTERNAL)
1175 *
1176 * Handler for overlapped recv() operations.
1177 */
1178 static void WS2_async_recv ( async_private *as )
1179 {
1180 ws2_async* wsa = (ws2_async*) as;
1181 int result, err;
1182
1183 TRACE ( "async %p\n", wsa );
1184
1185 if ( wsa->overlapped->Internal != STATUS_PENDING )
1186 {
1187 TRACE ( "status: %ld\n", wsa->overlapped->Internal );
1188 return;
1189 }
1190
1191 result = WS2_recv ( wsa->async.fd, wsa->iovec, wsa->n_iovecs,
1192 wsa->addr, wsa->addrlen.ptr, &wsa->flags );
1193
1194 if (result >= 0)
1195 {
1196 wsa->overlapped->Internal = STATUS_SUCCESS;
1197 wsa->overlapped->InternalHigh = result;
1198 TRACE ( "received %d bytes\n", result );
1199 _enable_event ( (SOCKET) wsa->async.handle, FD_READ, 0, 0 );
1200 return;
1201 }
1202
1203 err = wsaErrno ();
1204 if ( err == WSAEINTR || err == WSAEWOULDBLOCK ) /* errno: EINTR / EAGAIN */
1205 {
1206 wsa->overlapped->Internal = STATUS_PENDING;
1207 _enable_event ( (SOCKET) wsa->async.handle, FD_READ, 0, 0 );
1208 TRACE ( "still pending\n" );
1209 }
1210 else
1211 {
1212 wsa->overlapped->Internal = err;
1213 TRACE ( "Error: %x\n", err );
1214 }
1215 }
1216
1217 /***********************************************************************
1218 * WS2_send (INTERNAL)
1219 *
1220 * Work horse for both synchronous and asynchronous send() operations.
1221 */
1222 static int WS2_send ( int fd, struct iovec* iov, int count,
1223 const struct WS_sockaddr *to, INT tolen, DWORD dwFlags )
1224 {
1225 struct msghdr hdr;
1226 int n = -1;
1227 TRACE ( "fd %d, iovec %p, count %d addr %p, len %d, flags %lx\n",
1228 fd, iov, count, to, tolen, dwFlags);
1229
1230 hdr.msg_name = NULL;
1231
1232 if ( to )
1233 {
1234 #if DEBUG_SOCKADDR
1235 dump_sockaddr (to);
1236 #endif
1237 hdr.msg_name = (struct sockaddr*) ws_sockaddr_ws2u ( to, tolen, &hdr.msg_namelen );
1238 if ( !hdr.msg_name )
1239 {
1240 WSASetLastError ( WSAEFAULT );
1241 goto out;
1242 }
1243 }
1244 else
1245 hdr.msg_namelen = 0;
1246
1247 hdr.msg_iov = iov;
1248 hdr.msg_iovlen = count;
1249 #ifdef HAVE_MSGHDR_ACCRIGHTS
1250 hdr.msg_accrights = NULL;
1251 hdr.msg_accrightslen = 0;
1252 #else
1253 hdr.msg_control = NULL;
1254 hdr.msg_controllen = 0;
1255 hdr.msg_flags = 0;
1256 #endif
1257
1258 n = sendmsg (fd, &hdr, dwFlags);
1259
1260 out:
1261 ws_sockaddr_free ( hdr.msg_name, to );
1262 return n;
1263 }
1264
1265 /***********************************************************************
1266 * WS2_async_send (INTERNAL)
1267 *
1268 * Handler for overlapped send() operations.
1269 */
1270 static void WS2_async_send ( async_private *as )
1271 {
1272 ws2_async* wsa = (ws2_async*) as;
1273 int result, err;
1274
1275 TRACE ( "async %p\n", wsa );
1276
1277 if ( wsa->overlapped->Internal != STATUS_PENDING )
1278 {
1279 TRACE ( "status: %ld\n", wsa->overlapped->Internal );
1280 return;
1281 }
1282
1283 result = WS2_send ( wsa->async.fd, wsa->iovec, wsa->n_iovecs,
1284 wsa->addr, wsa->addrlen.val, wsa->flags );
1285
1286 if (result >= 0)
1287 {
1288 wsa->overlapped->Internal = STATUS_SUCCESS;
1289 wsa->overlapped->InternalHigh = result;
1290 TRACE ( "sent %d bytes\n", result );
1291 _enable_event ( (SOCKET) wsa->async.handle, FD_WRITE, 0, 0 );
1292 return;
1293 }
1294
1295 err = wsaErrno ();
1296 if ( err == WSAEINTR )
1297 {
1298 wsa->overlapped->Internal = STATUS_PENDING;
1299 _enable_event ( (SOCKET) wsa->async.handle, FD_WRITE, 0, 0 );
1300 TRACE ( "still pending\n" );
1301 }
1302 else
1303 {
1304 /* We set the status to a winsock error code and check for that
1305 later in NtStatusToWSAError () */
1306 wsa->overlapped->Internal = err;
1307 TRACE ( "Error: %x\n", err );
1308 }
1309 }
1310
1311 /***********************************************************************
1312 * WS2_async_shutdown (INTERNAL)
1313 *
1314 * Handler for shutdown() operations on overlapped sockets.
1315 */
1316 static void WS2_async_shutdown ( async_private *as )
1317 {
1318 ws2_async* wsa = (ws2_async*) as;
1319 int err = 1;
1320
1321 TRACE ( "async %p %d\n", wsa, wsa->async.type );
1322 switch ( wsa->async.type )
1323 {
1324 case ASYNC_TYPE_READ:
1325 err = shutdown ( wsa->async.fd, 0 );
1326 break;
1327 case ASYNC_TYPE_WRITE:
1328 err = shutdown ( wsa->async.fd, 1 );
1329 break;
1330 default:
1331 ERR ("invalid type: %d\n", wsa->async.type );
1332 }
1333
1334 if ( err )
1335 wsa->overlapped->Internal = wsaErrno ();
1336 else
1337 wsa->overlapped->Internal = STATUS_SUCCESS;
1338 }
1339
1340 /***********************************************************************
1341 * WS2_register_async_shutdown (INTERNAL)
1342 *
1343 * Helper function for WS_shutdown() on overlapped sockets.
1344 */
1345 static int WS2_register_async_shutdown ( SOCKET s, int fd, int type )
1346 {
1347 struct ws2_async *wsa;
1348 int ret, err = WSAEFAULT;
1349 DWORD dwflags = 0;
1350 int len = 0;
1351 LPWSAOVERLAPPED ovl = HeapAlloc (GetProcessHeap(), 0, sizeof ( WSAOVERLAPPED ));
1352
1353 TRACE ("s %d fd %d type %d\n", s, fd, type);
1354 if (!ovl)
1355 goto out;
1356
1357 ovl->hEvent = WSACreateEvent ();
1358 if ( ovl->hEvent == WSA_INVALID_EVENT )
1359 goto out_free;
1360
1361 wsa = WS2_make_async ( s, fd, type, NULL, 0,
1362 &dwflags, NULL, &len, ovl, NULL );
1363 if ( !wsa )
1364 goto out_close;
1365
1366 /* Hack: this will cause ws2_async_cleanup() to free the overlapped structure */
1367 wsa->user_overlapped = NULL;
1368 wsa->async.func = WS2_async_shutdown;
1369 if ( (ret = register_new_async ( &wsa->async )) )
1370 {
1371 err = NtStatusToWSAError ( ret );
1372 ws2_async_cleanup ( &wsa->async );
1373 goto out;
1374 }
1375 /* Try immediate completion */
1376 if ( WSAGetOverlappedResult ( (HANDLE) s, ovl, NULL, FALSE, NULL ) )
1377 return 0;
1378 if ( (err = WSAGetLastError ()) == WSA_IO_INCOMPLETE )
1379 return 0;
1380 return WSAEINVAL;
1381
1382 out_close:
1383 WSACloseEvent ( ovl->hEvent );
1384 out_free:
1385 HeapFree ( GetProcessHeap(), 0, ovl );
1386 out:
1387 return err;
1388 }
1389
1390 /***********************************************************************
1391 * accept (WS2_32.1)
1392 */
1393 SOCKET WINAPI WS_accept(SOCKET s, struct WS_sockaddr *addr,
1394 int *addrlen32)
1395 {
1396 int fd = _get_sock_fd(s);
1397
1398 TRACE("socket %04x\n", (UINT16)s );
1399 if (fd != -1)
1400 {
1401 SOCKET as;
1402 if (_is_blocking(s))
1403 {
1404 /* block here */
1405 do_block(fd, 5);
1406 _sync_sock_state(s); /* let wineserver notice connection */
1407 /* retrieve any error codes from it */
1408 SetLastError(_get_sock_error(s, FD_ACCEPT_BIT));
1409 /* FIXME: care about the error? */
1410 }
1411 close(fd);
1412 SERVER_START_REQ( accept_socket )
1413 {
1414 req->lhandle = s;
1415 req->access = GENERIC_READ|GENERIC_WRITE|SYNCHRONIZE;
1416 req->inherit = TRUE;
1417 set_error( wine_server_call( req ) );
1418 as = (SOCKET)reply->handle;
1419 }
1420 SERVER_END_REQ;
1421 if (as)
1422 {
1423 if (addr)
1424 WS_getpeername(as, addr, addrlen32);
1425 return as;
1426 }
1427 }
1428 else
1429 {
1430 SetLastError(WSAENOTSOCK);
1431 }
1432 return INVALID_SOCKET;
1433 }
1434
1435 /***********************************************************************
1436 * accept (WINSOCK.1)
1437 */
1438 SOCKET16 WINAPI WINSOCK_accept16(SOCKET16 s, struct WS_sockaddr* addr,
1439 INT16* addrlen16 )
1440 {
1441 INT addrlen32 = addrlen16 ? *addrlen16 : 0;
1442 SOCKET retSocket = WS_accept( s, addr, &addrlen32 );
1443 if( addrlen16 ) *addrlen16 = (INT16)addrlen32;
1444 return (SOCKET16)retSocket;
1445 }
1446
1447 /***********************************************************************
1448 * bind (WS2_32.2)
1449 */
1450 int WINAPI WS_bind(SOCKET s, const struct WS_sockaddr* name, int namelen)
1451 {
1452 int fd = _get_sock_fd(s);
1453 int res;
1454
1455 TRACE("socket %04x, ptr %p, length %d\n", s, name, namelen);
1456 #if DEBUG_SOCKADDR
1457 dump_sockaddr(name);
1458 #endif
1459
1460 res=SOCKET_ERROR;
1461 if (fd != -1)
1462 {
1463 if (!name || !SUPPORTED_PF(name->sa_family))
1464 {
1465 SetLastError(WSAEAFNOSUPPORT);
1466 }
1467 else
1468 {
1469 const struct sockaddr* uaddr;
1470 int uaddrlen;
1471
1472 uaddr=ws_sockaddr_ws2u(name,namelen,&uaddrlen);
1473 if (uaddr == NULL)
1474 {
1475 SetLastError(WSAEFAULT);
1476 }
1477 else
1478 {
1479 if (bind(fd, uaddr, uaddrlen) < 0)
1480 {
1481 int loc_errno = errno;
1482 WARN("\tfailure - errno = %i\n", errno);
1483 errno = loc_errno;
1484 switch (errno)
1485 {
1486 case EBADF:
1487 SetLastError(WSAENOTSOCK);
1488 break;
1489 case EADDRNOTAVAIL:
1490 SetLastError(WSAEINVAL);
1491 break;
1492 default:
1493 SetLastError(wsaErrno());
1494 break;
1495 }
1496 }
1497 else
1498 {
1499 res=0; /* success */
1500 }
1501 ws_sockaddr_free(uaddr,name);
1502 }
1503 }
1504 close(fd);
1505 }
1506 else
1507 {
1508 SetLastError(WSAENOTSOCK);
1509 }
1510 return res;
1511 }
1512
1513 /***********************************************************************
1514 * bind (WINSOCK.2)
1515 */
1516 INT16 WINAPI WINSOCK_bind16(SOCKET16 s, struct WS_sockaddr *name, INT16 namelen)
1517 {
1518 return (INT16)WS_bind( s, name, namelen );
1519 }
1520
1521 /***********************************************************************
1522 * closesocket (WS2_32.3)
1523 */
1524 int WINAPI WS_closesocket(SOCKET s)
1525 {
1526 TRACE("socket %08x\n", s);
1527 if (CloseHandle(s)) return 0;
1528 return SOCKET_ERROR;
1529 }
1530
1531 /***********************************************************************
1532 * closesocket (WINSOCK.3)
1533 */
1534 INT16 WINAPI WINSOCK_closesocket16(SOCKET16 s)
1535 {
1536 return (INT16)WS_closesocket(s);
1537 }
1538
1539 /***********************************************************************
1540 * connect (WS2_32.4)
1541 */
1542 int WINAPI WS_connect(SOCKET s, const struct WS_sockaddr* name, int namelen)
1543 {
1544 int fd = _get_sock_fd(s);
1545
1546 TRACE("socket %04x, ptr %p, length %d\n", s, name, namelen);
1547 #if DEBUG_SOCKADDR
1548 dump_sockaddr(name);
1549 #endif
1550
1551 if (fd != -1)
1552 {
1553 const struct sockaddr* uaddr;
1554 int uaddrlen;
1555
1556 uaddr=ws_sockaddr_ws2u(name,namelen,&uaddrlen);
1557 if (uaddr == NULL)
1558 {
1559 SetLastError(WSAEFAULT);
1560 }
1561 else
1562 {
1563 int rc;
1564
1565 rc=connect(fd, uaddr, uaddrlen);
1566 ws_sockaddr_free(uaddr,name);
1567 if (rc == 0)
1568 goto connect_success;
1569 }
1570
1571 if (errno == EINPROGRESS)
1572 {
1573 /* tell wineserver that a connection is in progress */
1574 _enable_event(s, FD_CONNECT|FD_READ|FD_WRITE,
1575 FD_CONNECT|FD_READ|FD_WRITE,
1576 FD_WINE_CONNECTED|FD_WINE_LISTENING);
1577 if (_is_blocking(s))
1578 {
1579 int result;
1580 /* block here */
1581 do_block(fd, 7);
1582 _sync_sock_state(s); /* let wineserver notice connection */
1583 /* retrieve any error codes from it */
1584 result = _get_sock_error(s, FD_CONNECT_BIT);
1585 if (result)
1586 SetLastError(result);
1587 else
1588 {
1589 goto connect_success;
1590 }
1591 }
1592 else
1593 {
1594 SetLastError(WSAEWOULDBLOCK);
1595 }
1596 }
1597 else
1598 {
1599 SetLastError(wsaErrno());
1600 }
1601 close(fd);
1602 }
1603 else
1604 {
1605 SetLastError(WSAENOTSOCK);
1606 }
1607 return SOCKET_ERROR;
1608
1609 connect_success:
1610 close(fd);
1611 _enable_event(s, FD_CONNECT|FD_READ|FD_WRITE,
1612 FD_WINE_CONNECTED|FD_READ|FD_WRITE,
1613 FD_CONNECT|FD_WINE_LISTENING);
1614 return 0;
1615 }
1616
1617 /***********************************************************************
1618 * connect (WINSOCK.4)
1619 */
1620 INT16 WINAPI WINSOCK_connect16(SOCKET16 s, struct WS_sockaddr *name, INT16 namelen)
1621 {
1622 return (INT16)WS_connect( s, name, namelen );
1623 }
1624
1625 /***********************************************************************
1626 * WSAConnect (WS2_32.30)
1627 */
1628 int WINAPI WSAConnect ( SOCKET s, const struct WS_sockaddr* name, int namelen,
1629 LPWSABUF lpCallerData, LPWSABUF lpCalleeData,
1630 LPQOS lpSQOS, LPQOS lpGQOS )
1631 {
1632 if ( lpCallerData || lpCalleeData || lpSQOS || lpGQOS )
1633 FIXME ("unsupported parameters!\n");
1634 return WS_connect ( s, name, namelen );
1635 }
1636
1637
1638 /***********************************************************************
1639 * getpeername (WS2_32.5)
1640 */
1641 int WINAPI WS_getpeername(SOCKET s, struct WS_sockaddr *name, int *namelen)
1642 {
1643 int fd;
1644 int res;
1645
1646 TRACE("socket: %04x, ptr %p, len %8x\n", s, name, *namelen);
1647
1648 /* Check if what we've received is valid. Should we use IsBadReadPtr? */
1649 if( (name == NULL) || (namelen == NULL) )
1650 {
1651 SetLastError( WSAEFAULT );
1652 return SOCKET_ERROR;
1653 }
1654
1655 fd = _get_sock_fd(s);
1656 res = SOCKET_ERROR;
1657
1658 if (fd != -1)
1659 {
1660 struct sockaddr* uaddr;
1661 int uaddrlen;
1662
1663 uaddr=ws_sockaddr_alloc(name,namelen,&uaddrlen);
1664 if (getpeername(fd, uaddr, &uaddrlen) != 0)
1665 {
1666 SetLastError(wsaErrno());
1667 }
1668 else if (ws_sockaddr_u2ws(uaddr,uaddrlen,name,namelen) != 0)
1669 {
1670 /* The buffer was too small */
1671 SetLastError(WSAEFAULT);
1672 }
1673 else
1674 {
1675 res=0;
1676 }
1677 ws_sockaddr_free(uaddr,name);
1678 close(fd);
1679 }
1680 else
1681 {
1682 SetLastError(WSAENOTSOCK);
1683 }
1684 return res;
1685 }
1686
1687 /***********************************************************************
1688 * getpeername (WINSOCK.5)
1689 */
1690 INT16 WINAPI WINSOCK_getpeername16(SOCKET16 s, struct WS_sockaddr *name,
1691 INT16 *namelen16)
1692 {
1693 INT namelen32 = *namelen16;
1694 INT retVal = WS_getpeername( s, name, &namelen32 );
1695
1696 #if DEBUG_SOCKADDR
1697 dump_sockaddr(name);
1698 #endif
1699
1700 *namelen16 = namelen32;
1701 return (INT16)retVal;
1702 }
1703
1704 /***********************************************************************
1705 * getsockname (WS2_32.6)
1706 */
1707 int WINAPI WS_getsockname(SOCKET s, struct WS_sockaddr *name, int *namelen)
1708 {
1709 int fd;
1710 int res;
1711
1712 TRACE("socket: %04x, ptr %p, len %8x\n", s, name, *namelen);
1713
1714 /* Check if what we've received is valid. Should we use IsBadReadPtr? */
1715 if( (name == NULL) || (namelen == NULL) )
1716 {
1717 SetLastError( WSAEFAULT );
1718 return SOCKET_ERROR;
1719 }
1720
1721 fd = _get_sock_fd(s);
1722 res = SOCKET_ERROR;
1723
1724 if (fd != -1)
1725 {
1726 struct sockaddr* uaddr;
1727 int uaddrlen;
1728
1729 uaddr=ws_sockaddr_alloc(name,namelen,&uaddrlen);
1730 if (getsockname(fd, uaddr, &uaddrlen) != 0)
1731 {
1732 SetLastError(wsaErrno());
1733 }
1734 else if (ws_sockaddr_u2ws(uaddr,uaddrlen,name,namelen) != 0)
1735 {
1736 /* The buffer was too small */
1737 SetLastError(WSAEFAULT);
1738 }
1739 else
1740 {
1741 res=0;
1742 }
1743 close(fd);
1744 }
1745 else
1746 {
1747 SetLastError(WSAENOTSOCK);
1748 }
1749 return res;
1750 }
1751
1752 /***********************************************************************
1753 * getsockname (WINSOCK.6)
1754 */
1755 INT16 WINAPI WINSOCK_getsockname16(SOCKET16 s, struct WS_sockaddr *name,
1756 INT16 *namelen16)
1757 {
1758 INT retVal;
1759
1760 if( namelen16 )
1761 {
1762 INT namelen32 = *namelen16;
1763 retVal = WS_getsockname( s, name, &namelen32 );
1764 *namelen16 = namelen32;
1765
1766 #if DEBUG_SOCKADDR
1767 dump_sockaddr(name);
1768 #endif
1769
1770 }
1771 else retVal = SOCKET_ERROR;
1772 return (INT16)retVal;
1773 }
1774
1775
1776 /***********************************************************************
1777 * getsockopt (WS2_32.7)
1778 */
1779 INT WINAPI WS_getsockopt(SOCKET s, INT level,
1780 INT optname, char *optval, INT *optlen)
1781 {
1782 int fd;
1783
1784 TRACE("socket: %04x, level 0x%x, name 0x%x, ptr %8x, len %d\n", s, level,
1785 (int) optname, (int) optval, (int) *optlen);
1786 /* SO_OPENTYPE does not require a valid socket handle. */
1787 if (level == WS_SOL_SOCKET && optname == WS_SO_OPENTYPE)
1788 {
1789 if (!optlen || *optlen < sizeof(int) || !optval)
1790 {
1791 SetLastError(WSAEFAULT);
1792 return SOCKET_ERROR;
1793 }
1794 *(int *)optval = (int)TlsGetValue( opentype_tls_index );
1795 *optlen = sizeof(int);
1796 TRACE("getting global SO_OPENTYPE = 0x%x\n", *((int*)optval) );
1797 return 0;
1798 }
1799
1800 fd = _get_sock_fd(s);
1801 if (fd != -1)
1802 {
1803 if (!convert_sockopt(&level, &optname)) {
1804 SetLastError(WSAENOPROTOOPT); /* Unknown option */
1805 } else {
1806 if (getsockopt(fd, (int) level, optname, optval, optlen) == 0 )
1807 {
1808 close(fd);
1809 return 0;
1810 }
1811 SetLastError((errno == EBADF) ? WSAENOTSOCK : wsaErrno());
1812 }
1813 close(fd);
1814 }
1815 return SOCKET_ERROR;
1816 }
1817
1818
1819 /***********************************************************************
1820 * getsockopt (WINSOCK.7)
1821 */
1822 INT16 WINAPI WINSOCK_getsockopt16(SOCKET16 s, INT16 level,
1823 INT16 optname, char *optval, INT16 *optlen)
1824 {
1825 INT optlen32;
1826 INT *p = &optlen32;
1827 INT retVal;
1828 if( optlen ) optlen32 = *optlen; else p = NULL;
1829 retVal = WS_getsockopt( s, (UINT16)level, optname, optval, p );
1830 if( optlen ) *optlen = optlen32;
1831 return (INT16)retVal;
1832 }
1833
1834
1835 /***********************************************************************
1836 * htonl (WINSOCK.8)
1837 * htonl (WS2_32.8)
1838 */
1839 u_long WINAPI WS_htonl(u_long hostlong)
1840 {
1841 return htonl(hostlong);
1842 }
1843
1844
1845 /***********************************************************************
1846 * htons (WINSOCK.9)
1847 * htons (WS2_32.9)
1848 */
1849 u_short WINAPI WS_htons(u_short hostshort)
1850 {
1851 return htons(hostshort);
1852 }
1853
1854
1855 /***********************************************************************
1856 * inet_addr (WINSOCK.10)
1857 * inet_addr (WS2_32.11)
1858 */
1859 u_long WINAPI WS_inet_addr(const char *cp)
1860 {
1861 return inet_addr(cp);
1862 }
1863
1864
1865 /***********************************************************************
1866 * ntohl (WINSOCK.14)
1867 * ntohl (WS2_32.14)
1868 */
1869 u_long WINAPI WS_ntohl(u_long netlong)
1870 {
1871 return ntohl(netlong);
1872 }
1873
1874
1875 /***********************************************************************
1876 * ntohs (WINSOCK.15)
1877 * ntohs (WS2_32.15)
1878 */
1879 u_short WINAPI WS_ntohs(u_short netshort)
1880 {
1881 return ntohs(netshort);
1882 }
1883
1884
1885 /***********************************************************************
1886 * inet_ntoa (WS2_32.12)
1887 */
1888 char* WINAPI WS_inet_ntoa(struct WS_in_addr in)
1889 {
1890 /* use "buffer for dummies" here because some applications have
1891 * propensity to decode addresses in ws_hostent structure without
1892 * saving them first...
1893 */
1894 static char dbuffer[16]; /* Yes, 16: 4*3 digits + 3 '.' + 1 '\0' */
1895
1896 char* s = inet_ntoa(*((struct in_addr*)&in));
1897 if( s )
1898 {
1899 strcpy(dbuffer, s);
1900 return dbuffer;
1901 }
1902 SetLastError(wsaErrno());
1903 return NULL;
1904 }
1905
1906 /***********************************************************************
1907 * inet_ntoa (WINSOCK.11)
1908 */
1909 SEGPTR WINAPI WINSOCK_inet_ntoa16(struct in_addr in)
1910 {
1911 char* retVal;
1912 if (!(retVal = WS_inet_ntoa(*((struct WS_in_addr*)&in)))) return 0;
1913 if (!dbuffer_seg) dbuffer_seg = MapLS( retVal );
1914 return dbuffer_seg;
1915 }
1916
1917
1918 /**********************************************************************
1919 * WSAIoctl (WS2_32.50)
1920 *
1921 *
1922 * FIXME: Only SIO_GET_INTERFACE_LIST option implemented.
1923 */
1924 INT WINAPI WSAIoctl (SOCKET s,
1925 DWORD dwIoControlCode,
1926 LPVOID lpvInBuffer,
1927 DWORD cbInBuffer,
1928 LPVOID lpbOutBuffer,
1929 DWORD cbOutBuffer,
1930 LPDWORD lpcbBytesReturned,
1931 LPWSAOVERLAPPED lpOverlapped,
1932 LPWSAOVERLAPPED_COMPLETION_ROUTINE lpCompletionRoutine)
1933 {
1934 int fd = _get_sock_fd(s);
1935
1936 if (fd != -1)
1937 {
1938 switch( dwIoControlCode )
1939 {
1940 case SIO_GET_INTERFACE_LIST:
1941 {
1942 INTERFACE_INFO* intArray = (INTERFACE_INFO*)lpbOutBuffer;
1943 int i, numInt;
1944 struct ifreq ifInfo;
1945 char ifName[512];
1946
1947
1948 TRACE ("-> SIO_GET_INTERFACE_LIST request\n");
1949
1950 numInt = WSAIOCTL_GetInterfaceCount();
1951 if (numInt < 0)
1952 {
1953 ERR ("Unable to open /proc filesystem to determine number of network interfaces!\n");
1954 close(fd);
1955 WSASetLastError(WSAEINVAL);
1956 return (SOCKET_ERROR);
1957 }
1958
1959 for (i=0; i<numInt; i++)
1960 {
1961 if (!WSAIOCTL_GetInterfaceName(i, ifName))
1962 {
1963 ERR ("Error parsing /proc filesystem!\n");
1964 close(fd);
1965 WSASetLastError(WSAEINVAL);
1966 return (SOCKET_ERROR);
1967 }
1968
1969 ifInfo.ifr_addr.sa_family = AF_INET;
1970
1971 /* IP Address */
1972 strcpy (ifInfo.ifr_name, ifName);
1973 if (ioctl(fd, SIOCGIFADDR, &ifInfo) < 0)
1974 {
1975 ERR ("Error obtaining IP address\n");
1976 close(fd);
1977 WSASetLastError(WSAEINVAL);
1978 return (SOCKET_ERROR);
1979 }
1980 else
1981 {
1982 struct WS_sockaddr_in *ipTemp = (struct WS_sockaddr_in *)&ifInfo.ifr_addr;
1983
1984 intArray->iiAddress.AddressIn.sin_family = AF_INET;
1985 intArray->iiAddress.AddressIn.sin_port = ipTemp->sin_port;
1986 intArray->iiAddress.AddressIn.sin_addr.WS_s_addr = ipTemp->sin_addr.S_un.S_addr;
1987 }
1988
1989 /* Broadcast Address */
1990 strcpy (ifInfo.ifr_name, ifName);
1991 if (ioctl(fd, SIOCGIFBRDADDR, &ifInfo) < 0)
1992 {
1993 ERR ("Error obtaining Broadcast IP address\n");
1994 close(fd);
1995 WSASetLastError(WSAEINVAL);
1996 return (SOCKET_ERROR);
1997 }
1998 else
1999 {
2000 struct WS_sockaddr_in *ipTemp = (struct WS_sockaddr_in *)&ifInfo.ifr_broadaddr;
2001
2002 intArray->iiBroadcastAddress.AddressIn.sin_family = AF_INET;
2003 intArray->iiBroadcastAddress.AddressIn.sin_port = ipTemp->sin_port;
2004 intArray->iiBroadcastAddress.AddressIn.sin_addr.WS_s_addr = ipTemp->sin_addr.S_un.S_addr;
2005 }
2006
2007 /* Subnet Mask */
2008 strcpy (ifInfo.ifr_name, ifName);
2009 if (ioctl(fd, SIOCGIFNETMASK, &ifInfo) < 0)
2010 {
2011 ERR ("Error obtaining Subnet IP address\n");
2012 close(fd);
2013 WSASetLastError(WSAEINVAL);
2014 return (SOCKET_ERROR);
2015 }
2016 else
2017 {
2018 /* Trying to avoid some compile problems across platforms.
2019 (Linux, FreeBSD, Solaris...) */
2020 #ifndef ifr_netmask
2021 #ifndef ifr_addr
2022 intArray->iiNetmask.AddressIn.sin_family = AF_INET;
2023 intArray->iiNetmask.AddressIn.sin_port = 0;
2024 intArray->iiNetmask.AddressIn.sin_addr.WS_s_addr = 0;
2025 ERR ("Unable to determine Netmask on your platform!\n");
2026 #else
2027 struct WS_sockaddr_in *ipTemp = (struct WS_sockaddr_in *)&ifInfo.ifr_addr;
2028
2029 intArray->iiNetmask.AddressIn.sin_family = AF_INET;
2030 intArray->iiNetmask.AddressIn.sin_port = ipTemp->sin_port;
2031 intArray->iiNetmask.AddressIn.sin_addr.WS_s_addr = ipTemp->sin_addr.S_un.S_addr;
2032 #endif
2033 #else
2034 struct WS_sockaddr_in *ipTemp = (struct WS_sockaddr_in *)&ifInfo.ifr_netmask;
2035
2036 intArray->iiNetmask.AddressIn.sin_family = AF_INET;
2037 intArray->iiNetmask.AddressIn.sin_port = ipTemp->sin_port;
2038 intArray->iiNetmask.AddressIn.sin_addr.WS_s_addr = ipTemp->sin_addr.S_un.S_addr;
2039 #endif
2040 }
2041
2042 /* Socket Status Flags */
2043 strcpy(ifInfo.ifr_name, ifName);
2044 if (ioctl(fd, SIOCGIFFLAGS, &ifInfo) < 0)
2045 {
2046 ERR ("Error obtaining status flags for socket!\n");
2047 close(fd);
2048 WSASetLastError(WSAEINVAL);
2049 return (SOCKET_ERROR);
2050 }
2051 else
2052 {
2053 /* FIXME - Is this the right flag to use? */
2054 intArray->iiFlags = ifInfo.ifr_flags;
2055 }
2056 intArray++; /* Prepare for another interface */
2057 }
2058
2059 /* Calculate the size of the array being returned */
2060 *lpcbBytesReturned = sizeof(INTERFACE_INFO) * numInt;
2061 break;
2062 }
2063
2064 default:
2065 {
2066 WARN("\tunsupported WS_IOCTL cmd (%08lx)\n", dwIoControlCode);
2067 close(fd);
2068 WSASetLastError(WSAEOPNOTSUPP);
2069 return (SOCKET_ERROR);
2070 }
2071 }
2072
2073 /* Function executed with no errors */
2074 close(fd);
2075 return (0);
2076 }
2077 else
2078 {
2079 WSASetLastError(WSAENOTSOCK);
2080 return (SOCKET_ERROR);
2081 }
2082 }
2083
2084
2085 /*
2086 Helper function for WSAIoctl - Get count of the number of interfaces
2087 by parsing /proc filesystem.
2088 */
2089 int WSAIOCTL_GetInterfaceCount(void)
2090 {
2091 FILE *procfs;
2092 char buf[512]; /* Size doesn't matter, something big */
2093 int intcnt=0;
2094
2095
2096 /* Open /proc filesystem file for network devices */
2097 procfs = fopen(PROCFS_NETDEV_FILE, "r");
2098 if (!procfs)
2099 {
2100 /* If we can't open the file, return an error */
2101 return (-1);
2102 }
2103
2104 /* Omit first two lines, they are only headers */
2105 fgets(buf, sizeof buf, procfs);
2106 fgets(buf, sizeof buf, procfs);
2107
2108 while (fgets(buf, sizeof buf, procfs))
2109 {
2110 /* Each line in the file represents a network interface */
2111 intcnt++;
2112 }
2113
2114 fclose(procfs);
2115 return(intcnt);
2116 }
2117
2118
2119 /*
2120 Helper function for WSAIoctl - Get name of device from interface number
2121 by parsing /proc filesystem.
2122 */
2123 int WSAIOCTL_GetInterfaceName(int intNumber, char *intName)
2124 {
2125 FILE *procfs;
2126 char buf[512]; /* Size doesn't matter, something big */
2127 int i;
2128
2129 /* Open /proc filesystem file for network devices */
2130 procfs = fopen(PROCFS_NETDEV_FILE, "r");
2131 if (!procfs)
2132 {
2133 /* If we can't open the file, return an error */
2134 return (-1);
2135 }
2136
2137 /* Omit first two lines, they are only headers */
2138 fgets(buf, sizeof(buf), procfs);
2139 fgets(buf, sizeof(buf), procfs);
2140
2141 for (i=0; i<intNumber; i++)
2142 {
2143 /* Skip the lines that don't interest us. */
2144 fgets(buf, sizeof(buf), procfs);
2145 }
2146 fgets(buf, sizeof(buf), procfs); /* This is the line we want */
2147
2148
2149 /* Parse out the line, grabbing only the name of the device
2150 to the intName variable
2151
2152 The Line comes in like this: (we only care about the device name)
2153 lo: 21970 377 0 0 0 0 0 0 21970 377 0 0 0 0 0 0
2154 */
2155 i=0;
2156 while (isspace(buf[i])) /* Skip initial space(s) */
2157 {
2158 i++;
2159 }
2160
2161 while (buf[i])
2162 {
2163 if (isspace(buf[i]))
2164 {
2165 break;
2166 }
2167
2168 if (buf[i] == ':') /* FIXME: Not sure if this block (alias detection) works properly */
2169 {
2170 /* This interface could be an alias... */
2171 int hold = i;
2172 char *dotname = intName;
2173 *intName++ = buf[i++];
2174
2175 while (isdigit(buf[i]))
2176 {
2177 *intName++ = buf[i++];
2178 }
2179
2180 if (buf[i] != ':')
2181 {
2182 /* ... It wasn't, so back up */
2183 i = hold;
2184 intName = dotname;
2185 }
2186
2187 if (buf[i] == '\0')
2188 {
2189 fclose(procfs);
2190 return(FALSE);
2191 }
2192
2193 i++;
2194 break;
2195 }
2196
2197 *intName++ = buf[i++];
2198 }
2199 *intName++ = '\0';
2200
2201 fclose(procfs);
2202 return(TRUE);
2203 }
2204
2205
2206 /***********************************************************************
2207 * ioctlsocket (WS2_32.10)
2208 */
2209 int WINAPI WS_ioctlsocket(SOCKET s, long cmd, u_long *argp)
2210 {
2211 int fd = _get_sock_fd(s);
2212
2213 TRACE("socket %04x, cmd %08lx, ptr %8x\n", s, cmd, (unsigned) argp);
2214 if (fd != -1)
2215 {
2216 long newcmd = cmd;
2217
2218 switch( cmd )
2219 {
2220 case WS_FIONREAD:
2221 newcmd=FIONREAD;
2222 break;
2223
2224 case WS_FIONBIO:
2225 newcmd=FIONBIO;
2226 if( _get_sock_mask(s) )
2227 {
2228 /* AsyncSelect()'ed sockets are always nonblocking */
2229 if (*argp) {
2230 close(fd);
2231 return 0;
2232 }
2233 SetLastError(WSAEINVAL);
2234 close(fd);
2235 return SOCKET_ERROR;
2236 }
2237 close(fd);
2238 if (*argp)
2239 _enable_event(s, 0, FD_WINE_NONBLOCKING, 0);
2240 else
2241 _enable_event(s, 0, 0, FD_WINE_NONBLOCKING);
2242 return 0;
2243
2244 case WS_SIOCATMARK:
2245 newcmd=SIOCATMARK;
2246 break;
2247
2248 case WS__IOW('f',125,u_long):
2249 WARN("Warning: WS1.1 shouldn't be using async I/O\n");
2250 SetLastError(WSAEINVAL);
2251 return SOCKET_ERROR;
2252
2253 case SIOCGIFBRDADDR:
2254 case SIOCGIFNETMASK:
2255 case SIOCGIFADDR:
2256 /* These don't need any special handling. They are used by
2257 WsControl, and are here to suppress an unecessary warning. */
2258 break;
2259
2260
2261 default:
2262 /* Netscape tries hard to use bogus ioctl 0x667e */
2263 WARN("\tunknown WS_IOCTL cmd (%08lx)\n", cmd);
2264 }
2265 if( ioctl(fd, newcmd, (char*)argp ) == 0 )
2266 {
2267 close(fd);
2268 return 0;
2269 }
2270 SetLastError((errno == EBADF) ? WSAENOTSOCK : wsaErrno());
2271 close(fd);
2272 }
2273 return SOCKET_ERROR;
2274 }
2275
2276 /***********************************************************************
2277 * ioctlsocket (WINSOCK.12)
2278 */
2279 INT16 WINAPI WINSOCK_ioctlsocket16(SOCKET16 s, LONG cmd, ULONG *argp)
2280 {
2281 return (INT16)WS_ioctlsocket( s, cmd, argp );
2282 }
2283
2284
2285 /***********************************************************************
2286 * listen (WS2_32.13)
2287 */
2288 int WINAPI WS_listen(SOCKET s, int backlog)
2289 {
2290 int fd = _get_sock_fd(s);
2291
2292 TRACE("socket %04x, backlog %d\n", s, backlog);
2293 if (fd != -1)
2294 {
2295 if (listen(fd, backlog) == 0)
2296 {
2297 close(fd);
2298 _enable_event(s, FD_ACCEPT,
2299 FD_WINE_LISTENING,
2300 FD_CONNECT|FD_WINE_CONNECTED);
2301 return 0;
2302 }
2303 SetLastError(wsaErrno());
2304 }
2305 else SetLastError(WSAENOTSOCK);
2306 return SOCKET_ERROR;
2307 }
2308
2309 /***********************************************************************
2310 * listen (WINSOCK.13)
2311 */
2312 INT16 WINAPI WINSOCK_listen16(SOCKET16 s, INT16 backlog)
2313 {
2314 return (INT16)WS_listen( s, backlog );
2315 }
2316
2317
2318 /***********************************************************************
2319 * recv (WS2_32.16)
2320 */
2321 int WINAPI WS_recv(SOCKET s, char *buf, int len, int flags)
2322 {
2323 DWORD n, dwFlags = flags;
2324 WSABUF wsabuf;
2325
2326 wsabuf.len = len;
2327 wsabuf.buf = buf;
2328
2329 if ( WSARecvFrom (s, &wsabuf, 1, &n, &dwFlags, NULL, NULL, NULL, NULL) == SOCKET_ERROR )
2330 return SOCKET_ERROR;
2331 else
2332 return n;
2333 }
2334
2335 /***********************************************************************
2336 * recv (WINSOCK.16)
2337 */
2338 INT16 WINAPI WINSOCK_recv16(SOCKET16 s, char *buf, INT16 len, INT16 flags)
2339 {
2340 return (INT16)WS_recv( s, buf, len, flags );
2341 }
2342
2343
2344 /***********************************************************************
2345 * recvfrom (WS2_32.17)
2346 */
2347 int WINAPI WS_recvfrom(SOCKET s, char *buf, INT len, int flags,
2348 struct WS_sockaddr *from, int *fromlen)
2349 {
2350 DWORD n, dwFlags = flags;
2351 WSABUF wsabuf;
2352
2353 wsabuf.len = len;
2354 wsabuf.buf = buf;
2355
2356 if ( WSARecvFrom (s, &wsabuf, 1, &n, &dwFlags, from, fromlen, NULL, NULL) == SOCKET_ERROR )
2357 return SOCKET_ERROR;
2358 else
2359 return n;
2360 }
2361
2362 /***********************************************************************
2363 * recvfrom (WINSOCK.17)
2364 */
2365 INT16 WINAPI WINSOCK_recvfrom16(SOCKET16 s, char *buf, INT16 len, INT16 flags,
2366 struct WS_sockaddr *from, INT16 *fromlen16)
2367 {
2368 INT fromlen32;
2369 INT *p = &fromlen32;
2370 INT retVal;
2371
2372 if( fromlen16 ) fromlen32 = *fromlen16; else p = NULL;
2373 retVal = WS_recvfrom( s, buf, len, flags, from, p );
2374 if( fromlen16 ) *fromlen16 = fromlen32;
2375 return (INT16)retVal;
2376 }
2377
2378 /***********************************************************************
2379 * __ws_select
2380 */
2381 static int __ws_select(BOOL b32,
2382 void *ws_readfds, void *ws_writefds, void *ws_exceptfds,
2383 const struct WS_timeval *ws_timeout)
2384 {
2385 int highfd = 0;
2386 fd_set readfds, writefds, exceptfds;
2387 fd_set *p_read, *p_write, *p_except;
2388 int readfd[FD_SETSIZE], writefd[FD_SETSIZE], exceptfd[FD_SETSIZE];
2389 struct timeval timeout, *timeoutaddr = NULL;
2390
2391 TRACE("read %p, write %p, excp %p timeout %p\n",
2392 ws_readfds, ws_writefds, ws_exceptfds, ws_timeout);
2393
2394 p_read = fd_set_import(&readfds, ws_readfds, &highfd, readfd, b32);
2395 p_write = fd_set_import(&writefds, ws_writefds, &highfd, writefd, b32);
2396 p_except = fd_set_import(&exceptfds, ws_exceptfds, &highfd, exceptfd, b32);
2397 if (ws_timeout)
2398 {
2399 timeoutaddr = &timeout;
2400 timeout.tv_sec=ws_timeout->tv_sec;
2401 timeout.tv_usec=ws_timeout->tv_usec;
2402 }
2403
2404 if( (highfd = select(highfd + 1, p_read, p_write, p_except, timeoutaddr)) > 0 )
2405 {
2406 fd_set_export(&readfds, p_except, ws_readfds, readfd, b32);
2407 fd_set_export(&writefds, p_except, ws_writefds, writefd, b32);
2408
2409 if (p_except && ws_exceptfds)
2410 {
2411 #define wsfds16 ((ws_fd_set16*)ws_exceptfds)
2412 #define wsfds32 ((WS_fd_set*)ws_exceptfds)
2413 int i, j, count = (b32) ? wsfds32->fd_count : wsfds16->fd_count;
2414
2415 for (i = j = 0; i < count; i++)
2416 {
2417 int fd = exceptfd[i];
2418 if( fd >= 0 && FD_ISSET(fd, &exceptfds) )
2419 {
2420 if( b32 )
2421 wsfds32->fd_array[j++] = wsfds32->fd_array[i];
2422 else
2423 wsfds16->fd_array[j++] = wsfds16->fd_array[i];
2424 }
2425 if( fd >= 0 ) close(fd);
2426 exceptfd[i] = -1;
2427 }
2428 if( b32 )
2429 wsfds32->fd_count = j;
2430 else
2431 wsfds16->fd_count = j;
2432 #undef wsfds32
2433 #undef wsfds16
2434 }
2435 return highfd;
2436 }
2437 fd_set_unimport(ws_readfds, readfd, b32);
2438 fd_set_unimport(ws_writefds, writefd, b32);
2439 fd_set_unimport(ws_exceptfds, exceptfd, b32);
2440 if( ws_readfds ) ((WS_fd_set*)ws_readfds)->fd_count = 0;
2441 if( ws_writefds ) ((WS_fd_set*)ws_writefds)->fd_count = 0;
2442 if( ws_exceptfds ) ((WS_fd_set*)ws_exceptfds)->fd_count = 0;
2443
2444 if( highfd == 0 ) return 0;
2445 SetLastError(wsaErrno());
2446 return SOCKET_ERROR;
2447 }
2448
2449 /***********************************************************************
2450 * select (WINSOCK.18)
2451 */
2452 INT16 WINAPI WINSOCK_select16(INT16 nfds, ws_fd_set16 *ws_readfds,
2453 ws_fd_set16 *ws_writefds, ws_fd_set16 *ws_exceptfds,
2454 struct WS_timeval* timeout)
2455 {
2456 return (INT16)__ws_select( FALSE, ws_readfds, ws_writefds, ws_exceptfds, timeout );
2457 }
2458
2459 /***********************************************************************
2460 * select (WS2_32.18)
2461 */
2462 int WINAPI WS_select(int nfds, WS_fd_set *ws_readfds,
2463 WS_fd_set *ws_writefds, WS_fd_set *ws_exceptfds,
2464 const struct WS_timeval* timeout)
2465 {
2466 /* struct timeval is the same for both 32- and 16-bit code */
2467 return (INT)__ws_select( TRUE, ws_readfds, ws_writefds, ws_exceptfds, timeout );
2468 }
2469
2470
2471 /***********************************************************************
2472 * send (WS2_32.19)
2473 */
2474 int WINAPI WS_send(SOCKET s, const char *buf, int len, int flags)
2475 {
2476 DWORD n;
2477 WSABUF wsabuf;
2478
2479 wsabuf.len = len;
2480 wsabuf.buf = (char*) buf;
2481
2482 if ( WSASendTo ( s, &wsabuf, 1, &n, flags, NULL, 0, NULL, NULL) == SOCKET_ERROR )
2483 return SOCKET_ERROR;
2484 else
2485 return n;
2486 }
2487
2488 /***********************************************************************
2489 * WSASend (WS2_32.72)
2490 */
2491 INT WINAPI WSASend( SOCKET s, LPWSABUF lpBuffers, DWORD dwBufferCount,
2492 LPDWORD lpNumberOfBytesSent, DWORD dwFlags,
2493 LPWSAOVERLAPPED lpOverlapped,
2494 LPWSAOVERLAPPED_COMPLETION_ROUTINE lpCompletionRoutine )
2495 {
2496 return WSASendTo ( s, lpBuffers, dwBufferCount, lpNumberOfBytesSent, dwFlags,
2497 NULL, 0, lpOverlapped, lpCompletionRoutine );
2498 }
2499
2500 /***********************************************************************
2501 * WSASendTo (WS2_32.74)
2502 */
2503 INT WINAPI WSASendTo( SOCKET s, LPWSABUF lpBuffers, DWORD dwBufferCount,
2504 LPDWORD lpNumberOfBytesSent, DWORD dwFlags,
2505 const struct WS_sockaddr *to, int tolen,
2506 LPWSAOVERLAPPED lpOverlapped,
2507 LPWSAOVERLAPPED_COMPLETION_ROUTINE lpCompletionRoutine )
2508 {
2509 int i, n, fd, err = WSAENOTSOCK, flags, ret;
2510 struct iovec* iovec;
2511 struct ws2_async *wsa;
2512 enum fd_type type;
2513
2514 TRACE ("socket %04x, wsabuf %p, nbufs %ld, flags %ld, to %p, tolen %d, ovl %p, func %p\n",
2515 s, lpBuffers, dwBufferCount, dwFlags,
2516 to, tolen, lpOverlapped, lpCompletionRoutine);
2517
2518 fd = _get_sock_fd_type( s, GENERIC_WRITE, &type, &flags );
2519 TRACE ( "fd=%d, type=%d, flags=%x\n", fd, type, flags );
2520
2521 if ( fd == -1 )
2522 {
2523 err = WSAGetLastError ();
2524 goto error;
2525 }
2526
2527 iovec = HeapAlloc (GetProcessHeap(), 0, dwBufferCount * sizeof (struct iovec) );
2528
2529 if ( !iovec )
2530 {
2531 err = WSAEFAULT;
2532 goto err_close;
2533 }
2534
2535 for ( i = 0; i < dwBufferCount; i++ )
2536 {
2537 iovec[i].iov_base = lpBuffers[i].buf;
2538 iovec[i].iov_len = lpBuffers[i].len;
2539 }
2540
2541 if ( (lpOverlapped || lpCompletionRoutine) && flags & FD_FLAG_OVERLAPPED )
2542 {
2543 wsa = WS2_make_async ( s, fd, ASYNC_TYPE_WRITE, iovec, dwBufferCount,
2544 &dwFlags, (struct WS_sockaddr*) to, &tolen,
2545 lpOverlapped, lpCompletionRoutine );
2546 if ( !wsa )
2547 {
2548 err = WSAEFAULT;
2549 goto err_free;
2550 }
2551
2552 if ( ( ret = register_new_async ( &wsa->async )) )
2553 {
2554 err = NtStatusToWSAError ( ret );
2555
2556 if ( !lpOverlapped )
2557 HeapFree ( GetProcessHeap(), 0, wsa->overlapped );
2558 HeapFree ( GetProcessHeap(), 0, wsa );
2559 goto err_free;
2560 }
2561
2562 /* Try immediate completion */
2563 if ( lpOverlapped && !NtResetEvent( lpOverlapped->hEvent, NULL ) )
2564 {
2565 if ( WSAGetOverlappedResult ( (HANDLE) s, lpOverlapped,
2566 lpNumberOfBytesSent, FALSE, &dwFlags) )
2567 return 0;
2568
2569 if ( (err = WSAGetLastError ()) != WSA_IO_INCOMPLETE )
2570 goto error;
2571 }
2572
2573 WSASetLastError ( WSA_IO_PENDING );
2574 return SOCKET_ERROR;
2575 }
2576
2577 if (_is_blocking(s))
2578 {
2579 /* FIXME: exceptfds? */
2580 do_block(fd, 2);
2581 }
2582
2583 n = WS2_send ( fd, iovec, dwBufferCount, to, tolen, dwFlags );
2584 if ( n == -1 )
2585 {
2586 err = wsaErrno();
2587 if ( err == WSAEWOULDBLOCK )
2588 _enable_event (s, FD_WRITE, 0, 0);
2589 goto err_free;
2590 }
2591
2592 TRACE(" -> %i bytes\n", n);
2593 *lpNumberOfBytesSent = n;
2594
2595 HeapFree ( GetProcessHeap(), 0, iovec );
2596 close ( fd );
2597 return 0;
2598
2599 err_free:
2600 HeapFree ( GetProcessHeap(), 0, iovec );
2601
2602 err_close:
2603 close ( fd );
2604
2605 error:
2606 WARN (" -> ERROR %d\n", err);
2607 WSASetLastError (err);
2608 return SOCKET_ERROR;
2609 }
2610
2611 /***********************************************************************
2612 * send (WINSOCK.19)
2613 */
2614 INT16 WINAPI WINSOCK_send16(SOCKET16 s, char *buf, INT16 len, INT16 flags)
2615 {
2616 return WS_send( s, buf, len, flags );
2617 }
2618
2619 /***********************************************************************
2620 * sendto (WS2_32.20)
2621 */
2622 int WINAPI WS_sendto(SOCKET s, const char *buf, int len, int flags,
2623 const struct WS_sockaddr *to, int tolen)
2624 {
2625 DWORD n;
2626 WSABUF wsabuf;
2627
2628 wsabuf.len = len;
2629 wsabuf.buf = (char*) buf;
2630
2631 if ( WSASendTo (s, &wsabuf, 1, &n, flags, to, tolen, NULL, NULL) == SOCKET_ERROR )
2632 return SOCKET_ERROR;
2633 else
2634 return n;
2635 }
2636
2637 /***********************************************************************
2638 * sendto (WINSOCK.20)
2639 */
2640 INT16 WINAPI WINSOCK_sendto16(SOCKET16 s, char *buf, INT16 len, INT16 flags,
2641 struct WS_sockaddr *to, INT16 tolen)
2642 {
2643 return (INT16)WS_sendto( s, buf, len, flags, to, tolen );
2644 }
2645
2646 /***********************************************************************
2647 * setsockopt (WS2_32.21)
2648 */
2649 int WINAPI WS_setsockopt(SOCKET s, int level, int optname,
2650 const char *optval, int optlen)
2651 {
2652 int fd;
2653
2654 TRACE("socket: %04x, level 0x%x, name 0x%x, ptr %8x, len %d\n", s, level,
2655 (int) optname, (int) optval, optlen);
2656 /* SO_OPENTYPE does not require a valid socket handle. */
2657 if (level == WS_SOL_SOCKET && optname == WS_SO_OPENTYPE)
2658 {
2659 if (optlen < sizeof(int) || !optval)
2660 {
2661 SetLastError(WSAEFAULT);
2662 return SOCKET_ERROR;
2663 }
2664 TlsSetValue( opentype_tls_index, (LPVOID)*(int *)optval );
2665 TRACE("setting global SO_OPENTYPE to 0x%x\n", *(int *)optval );
2666 return 0;
2667 }
2668
2669 fd = _get_sock_fd(s);
2670 if (fd != -1)
2671 {
2672 struct linger linger;
2673 int woptval;
2674 struct timeval tval;
2675
2676 /* Is a privileged and useless operation, so we don't. */
2677 if ((optname == WS_SO_DEBUG) && (level == WS_SOL_SOCKET)) {
2678 FIXME("(%d,SOL_SOCKET,SO_DEBUG,%p(%ld)) attempted (is privileged). Ignoring.\n",s,optval,*(DWORD*)optval);
2679 return 0;
2680 }
2681
2682 if(optname == WS_SO_DONTLINGER && level == WS_SOL_SOCKET) {
2683 /* This is unique to WinSock and takes special conversion */
2684 linger.l_onoff = *((int*)optval) ? 0: 1;
2685 linger.l_linger = 0;
2686 optname=SO_LINGER;
2687 optval = (char*)&linger;
2688 optlen = sizeof(struct linger);
2689 level = SOL_SOCKET;
2690 }else{
2691 if (!convert_sockopt(&level, &optname)) {
2692 SetLastError(WSAENOPROTOOPT);
2693 close(fd);
2694 return SOCKET_ERROR;
2695 }
2696 if (optname == SO_LINGER && optval) {
2697 /* yes, uses unsigned short in both win16/win32 */
2698 linger.l_onoff = ((UINT16*)optval)[0];
2699 linger.l_linger = ((UINT16*)optval)[1];
2700 /* FIXME: what is documented behavior if SO_LINGER optval
2701 is null?? */
2702 optval = (char*)&linger;
2703 optlen = sizeof(struct linger);
2704 } else if (optlen < sizeof(int)){
2705 woptval= *((INT16 *) optval);
2706 optval= (char*) &woptval;
2707 optlen=sizeof(int);
2708 }
2709 #ifdef SO_RCVTIMEO
2710 if (level == SOL_SOCKET && optname == SO_RCVTIMEO) {
2711 if (optlen == sizeof(UINT32)) {
2712 /* WinSock passes miliseconds instead of struct timeval */
2713 tval.tv_usec = *(PUINT32)optval % 1000;
2714 tval.tv_sec = *(PUINT32)optval / 1000;
2715 /* min of 500 milisec */
2716 if (tval.tv_sec == 0 && tval.tv_usec < 500) tval.tv_usec = 500;
2717 optlen = sizeof(struct timeval);
2718 optval = (char*)&tval;
2719 } else if (optlen == sizeof(struct timeval)) {
2720 WARN("SO_RCVTIMEO for %d bytes: assuming unixism\n", optlen);
2721 } else {
2722 WARN("SO_RCVTIMEO for %d bytes is weird: ignored\n", optlen);
2723 close(fd);
2724 return 0;
2725 }
2726 }
2727 #endif
2728 #ifdef SO_SNDTIMEO
2729 if (level == SOL_SOCKET && optname == SO_SNDTIMEO) {
2730 if (optlen == sizeof(UINT32)) {
2731 /* WinSock passes miliseconds instead of struct timeval */
2732 tval.tv_usec = *(PUINT32)optval % 1000;
2733 tval.tv_sec = *(PUINT32)optval / 1000;
2734 /* min of 500 milisec */
2735 if (tval.tv_sec == 0 && tval.tv_usec < 500) tval.tv_usec = 500;
2736 optlen = sizeof(struct timeval);
2737 optval = (char*)&tval;
2738 } else if (optlen == sizeof(struct timeval)) {
2739 WARN("SO_SNDTIMEO for %d bytes: assuming unixism\n", optlen);
2740 } else {
2741 WARN("SO_SNDTIMEO for %d bytes is weird: ignored\n", optlen);
2742 close(fd);
2743 return 0;
2744 }
2745 }
2746 #endif
2747 }
2748 if(optname == SO_RCVBUF && *(int*)optval < 2048) {
2749 WARN("SO_RCVBF for %d bytes is too small: ignored\n", *(int*)optval );
2750 close( fd);
2751 return 0;
2752 }
2753
2754 if (setsockopt(fd, level, optname, optval, optlen) == 0)
2755 {
2756 close(fd);
2757 return 0;
2758 }
2759 SetLastError(wsaErrno());
2760 close(fd);
2761 }
2762 else SetLastError(WSAENOTSOCK);
2763 return SOCKET_ERROR;
2764 }
2765
2766 /***********************************************************************
2767 * setsockopt (WINSOCK.21)
2768 */
2769 INT16 WINAPI WINSOCK_setsockopt16(SOCKET16 s, INT16 level, INT16 optname,
2770 char *optval, INT16 optlen)
2771 {
2772 if( !optval ) return SOCKET_ERROR;
2773 return (INT16)WS_setsockopt( s, (UINT16)level, optname, optval, optlen );
2774 }
2775
2776
2777 /***********************************************************************
2778 * shutdown (WS2_32.22)
2779 */
2780 int WINAPI WS_shutdown(SOCKET s, int how)
2781 {
2782 int fd, fd0 = -1, fd1 = -1, flags, err = WSAENOTSOCK;
2783 enum fd_type type;
2784 unsigned int clear_flags = 0;
2785
2786 fd = _get_sock_fd_type ( s, 0, &type, &flags );
2787 TRACE("socket %04x, how %i %d %d \n", s, how, type, flags );
2788
2789 if (fd == -1)
2790 return SOCKET_ERROR;
2791
2792 switch( how )
2793 {
2794 case 0: /* drop receives */
2795 clear_flags |= FD_READ;
2796 break;
2797 case 1: /* drop sends */
2798 clear_flags |= FD_WRITE;
2799 break;
2800 case 2: /* drop all */
2801 clear_flags |= FD_READ|FD_WRITE;
2802 default:
2803 clear_flags |= FD_WINE_CONNECTED|FD_WINE_LISTENING;
2804 }
2805
2806 if ( flags & FD_FLAG_OVERLAPPED ) {
2807
2808 switch ( how )
2809 {
2810 case SD_RECEIVE:
2811 fd0 = fd;
2812 break;
2813 case SD_SEND:
2814 fd1 = fd;
2815 break;
2816 case SD_BOTH:
2817 default:
2818 fd0 = fd;
2819 fd1 = _get_sock_fd ( s );
2820 }
2821
2822 if ( fd0 != -1 )
2823 {
2824 err = WS2_register_async_shutdown ( s, fd0, ASYNC_TYPE_READ );
2825 if ( err )
2826 {
2827 close ( fd0 );
2828 goto error;
2829 }
2830 }
2831 if ( fd1 != -1 )
2832 {
2833 err = WS2_register_async_shutdown ( s, fd1, ASYNC_TYPE_WRITE );
2834 if ( err )
2835 {
2836 close ( fd1 );
2837 goto error;
2838 }
2839 }
2840 }
2841 else /* non-overlapped mode */
2842 {
2843 if ( shutdown( fd, how ) )
2844 {
2845 err = wsaErrno ();
2846 close ( fd );
2847 goto error;
2848 }
2849 close(fd);
2850 }
2851
2852 _enable_event( s, 0, 0, clear_flags );
2853 if ( how > 1) WSAAsyncSelect( s, 0, 0, 0 );
2854 return 0;
2855
2856 error:
2857 _enable_event( s, 0, 0, clear_flags );
2858 WSASetLastError ( err );
2859 return SOCKET_ERROR;
2860 }
2861
2862 /***********************************************************************
2863 * shutdown (WINSOCK.22)
2864 */
2865 INT16 WINAPI WINSOCK_shutdown16(SOCKET16 s, INT16 how)
2866 {
2867 return (INT16)WS_shutdown( s, how );
2868 }
2869
2870
2871 /***********************************************************************
2872 * socket (WS2_32.23)
2873 */
2874 SOCKET WINAPI WS_socket(int af, int type, int protocol)
2875 {
2876 TRACE("af=%d type=%d protocol=%d\n", af, type, protocol);
2877
2878 return WSASocketA ( af, type, protocol, NULL, 0,
2879 (TlsGetValue(opentype_tls_index) ? 0 : WSA_FLAG_OVERLAPPED) );
2880 }
2881
2882 /***********************************************************************
2883 * socket (WINSOCK.23)
2884 */
2885 SOCKET16 WINAPI WINSOCK_socket16(INT16 af, INT16 type, INT16 protocol)
2886 {
2887 return (SOCKET16)WS_socket( af, type, protocol );
2888 }
2889
2890
2891 /* ----------------------------------- DNS services
2892 *
2893 * IMPORTANT: 16-bit API structures have SEGPTR pointers inside them.
2894 * Also, we have to use wsock32 stubs to convert structures and
2895 * error codes from Unix to WSA, hence there is no direct mapping in
2896 * the relay32/wsock32.spec.
2897 */
2898
2899
2900 /***********************************************************************
2901 * __ws_gethostbyaddr
2902 */
2903 static WIN_hostent* __ws_gethostbyaddr(const char *addr, int len, int type, int dup_flag)
2904 {
2905 WIN_hostent *retval = NULL;
2906
2907 struct hostent* host;
2908 #if HAVE_LINUX_GETHOSTBYNAME_R_6
2909 char *extrabuf;
2910 int ebufsize=1024;
2911 struct hostent hostentry;
2912 int locerr=ENOBUFS;
2913 host = NULL;
2914 extrabuf=HeapAlloc(GetProcessHeap(),0,ebufsize) ;
2915 while(extrabuf) {
2916 int res = gethostbyaddr_r(addr, len, type,
2917 &hostentry, extrabuf, ebufsize, &host, &locerr);
2918 if( res != ERANGE) break;
2919 ebufsize *=2;
2920 extrabuf=HeapReAlloc(GetProcessHeap(),0,extrabuf,ebufsize) ;
2921 }
2922 if (!host) SetLastError((locerr < 0) ? wsaErrno() : wsaHerrno(locerr));
2923 #else
2924 EnterCriticalSection( &csWSgetXXXbyYYY );
2925 host = gethostbyaddr(addr, len, type);
2926 if (!host) SetLastError((h_errno < 0) ? wsaErrno() : wsaHerrno(h_errno));
2927 #endif
2928 if( host != NULL )
2929 {
2930 if( WS_dup_he(host, dup_flag) )
2931 retval = he_buffer;
2932 else
2933 SetLastError(WSAENOBUFS);
2934 }
2935 #ifdef HAVE_LINUX_GETHOSTBYNAME_R_6
2936 HeapFree(GetProcessHeap(),0,extrabuf);
2937 #else
2938 LeaveCriticalSection( &csWSgetXXXbyYYY );
2939 #endif
2940 return retval;
2941 }
2942
2943 /***********************************************************************
2944 * gethostbyaddr (WINSOCK.51)
2945 */
2946 SEGPTR WINAPI WINSOCK_gethostbyaddr16(const char *addr, INT16 len, INT16 type)
2947 {
2948 TRACE("ptr %p, len %d, type %d\n", addr, len, type);
2949 if (!__ws_gethostbyaddr( addr, len, type, WS_DUP_SEGPTR )) return 0;
2950 return he_buffer_seg;
2951 }
2952
2953 /***********************************************************************
2954 * gethostbyaddr (WS2_32.51)
2955 */
2956 struct WS_hostent* WINAPI WS_gethostbyaddr(const char *addr, int len,
2957 int type)
2958 {
2959 TRACE("ptr %08x, len %d, type %d\n",
2960 (unsigned) addr, len, type);
2961 return __ws_gethostbyaddr(addr, len, type, WS_DUP_LINEAR);
2962 }
2963
2964 /***********************************************************************
2965 * __ws_gethostbyname
2966 */
2967 static WIN_hostent * __ws_gethostbyname(const char *name, int dup_flag)
2968 {
2969 WIN_hostent *retval = NULL;
2970 struct hostent* host;
2971 #ifdef HAVE_LINUX_GETHOSTBYNAME_R_6
2972 char *extrabuf;
2973 int ebufsize=1024;
2974 struct hostent hostentry;
2975 int locerr = ENOBUFS;
2976 host = NULL;
2977 extrabuf=HeapAlloc(GetProcessHeap(),0,ebufsize) ;
2978 while(extrabuf) {
2979 int res = gethostbyname_r(name, &hostentry, extrabuf, ebufsize, &host, &locerr);
2980 if( res != ERANGE) break;
2981 ebufsize *=2;
2982 extrabuf=HeapReAlloc(GetProcessHeap(),0,extrabuf,ebufsize) ;
2983 }
2984 if (!host) SetLastError((locerr < 0) ? wsaErrno() : wsaHerrno(locerr));
2985 #else
2986 EnterCriticalSection( &csWSgetXXXbyYYY );
2987 host = gethostbyname(name);
2988 if (!host) SetLastError((h_errno < 0) ? wsaErrno() : wsaHerrno(h_errno));
2989 #endif
2990 if( host != NULL )
2991 {
2992 if( WS_dup_he(host, dup_flag) )
2993 retval = he_buffer;
2994 else SetLastError(WSAENOBUFS);
2995 }
2996 #ifdef HAVE_LINUX_GETHOSTBYNAME_R_6
2997 HeapFree(GetProcessHeap(),0,extrabuf);
2998 #else
2999 LeaveCriticalSection( &csWSgetXXXbyYYY );
3000 #endif
3001 return retval;
3002 }
3003
3004 /***********************************************************************
3005 * gethostbyname (WINSOCK.52)
3006 */
3007 SEGPTR WINAPI WINSOCK_gethostbyname16(const char *name)
3008 {
3009 TRACE( "%s\n", debugstr_a(name) );
3010 if (!__ws_gethostbyname( name, WS_DUP_SEGPTR )) return 0;
3011 return he_buffer_seg;
3012 }
3013
3014 /***********************************************************************
3015 * gethostbyname (WS2_32.52)
3016 */
3017 struct WS_hostent* WINAPI WS_gethostbyname(const char* name)
3018 {
3019 TRACE( "%s\n", debugstr_a(name) );
3020 return __ws_gethostbyname( name, WS_DUP_LINEAR );
3021 }
3022
3023
3024 /***********************************************************************
3025 * __ws_getprotobyname
3026 */
3027 static WIN_protoent* __ws_getprotobyname(const char *name, int dup_flag)
3028 {
3029 WIN_protoent* retval = NULL;
3030 #ifdef HAVE_GETPROTOBYNAME
3031 struct protoent* proto;
3032 EnterCriticalSection( &csWSgetXXXbyYYY );
3033 if( (proto = getprotobyname(name)) != NULL )
3034 {
3035 if( WS_dup_pe(proto, dup_flag) )
3036 retval = pe_buffer;
3037 else SetLastError(WSAENOBUFS);
3038 }
3039 else {
3040 MESSAGE("protocol %s not found; You might want to add "
3041 "this to /etc/protocols\n", debugstr_a(name) );
3042 SetLastError(WSANO_DATA);
3043 }
3044 LeaveCriticalSection( &csWSgetXXXbyYYY );
3045 #endif
3046 return retval;
3047 }
3048
3049 /***********************************************************************
3050 * getprotobyname (WINSOCK.53)
3051 */
3052 SEGPTR WINAPI WINSOCK_getprotobyname16(const char *name)
3053 {
3054 TRACE( "%s\n", debugstr_a(name) );
3055 if (!__ws_getprotobyname(name, WS_DUP_SEGPTR)) return 0;
3056 return pe_buffer_seg;
3057 }
3058
3059 /***********************************************************************
3060 * getprotobyname (WS2_32.53)
3061 */
3062 struct WS_protoent* WINAPI WS_getprotobyname(const char* name)
3063 {
3064 TRACE( "%s\n", debugstr_a(name) );
3065 return __ws_getprotobyname(name, WS_DUP_LINEAR);
3066 }
3067
3068
3069 /***********************************************************************
3070 * __ws_getprotobynumber
3071 */
3072 static WIN_protoent* __ws_getprotobynumber(int number, int dup_flag)
3073 {
3074 WIN_protoent* retval = NULL;
3075 #ifdef HAVE_GETPROTOBYNUMBER
3076 struct protoent* proto;
3077 EnterCriticalSection( &csWSgetXXXbyYYY );
3078 if( (proto = getprotobynumber(number)) != NULL )
3079 {
3080 if( WS_dup_pe(proto, dup_flag) )
3081 retval = pe_buffer;
3082 else SetLastError(WSAENOBUFS);
3083 }
3084 else {
3085 MESSAGE("protocol number %d not found; You might want to add "
3086 "this to /etc/protocols\n", number );
3087 SetLastError(WSANO_DATA);
3088 }
3089 LeaveCriticalSection( &csWSgetXXXbyYYY );
3090 #endif
3091 return retval;
3092 }
3093
3094 /***********************************************************************
3095 * getprotobynumber (WINSOCK.54)
3096 */
3097 SEGPTR WINAPI WINSOCK_getprotobynumber16(INT16 number)
3098 {
3099 TRACE("%i\n", number);
3100 if (!__ws_getprotobynumber(number, WS_DUP_SEGPTR)) return 0;
3101 return pe_buffer_seg;
3102 }
3103
3104 /***********************************************************************
3105 * getprotobynumber (WS2_32.54)
3106 */
3107 struct WS_protoent* WINAPI WS_getprotobynumber(int number)
3108 {
3109 TRACE("%i\n", number);
3110 return __ws_getprotobynumber(number, WS_DUP_LINEAR);
3111 }
3112
3113
3114 /***********************************************************************
3115 * __ws_getservbyname
3116 */
3117 static WIN_servent* __ws_getservbyname(const char *name, const char *proto, int dup_flag)
3118 {
3119 WIN_servent* retval = NULL;
3120 struct servent* serv;
3121 int i = wsi_strtolo( name, proto );
3122
3123 if( i ) {
3124 EnterCriticalSection( &csWSgetXXXbyYYY );
3125 serv = getservbyname(local_buffer,
3126 proto ? (local_buffer + i) : NULL);
3127 if( serv != NULL )
3128 {
3129 if( WS_dup_se(serv, dup_flag) )
3130 retval = se_buffer;
3131 else SetLastError(WSAENOBUFS);
3132 }
3133 else {
3134 MESSAGE("service %s protocol %s not found; You might want to add "
3135 "this to /etc/services\n", debugstr_a(local_buffer),
3136 proto ? debugstr_a(local_buffer+i):"*");
3137 SetLastError(WSANO_DATA);
3138 }
3139 LeaveCriticalSection( &csWSgetXXXbyYYY );
3140 }
3141 else SetLastError(WSAENOBUFS);
3142 return retval;
3143 }
3144
3145 /***********************************************************************
3146 * getservbyname (WINSOCK.55)
3147 */
3148 SEGPTR WINAPI WINSOCK_getservbyname16(const char *name, const char *proto)
3149 {
3150 TRACE( "%s, %s\n", debugstr_a(name), debugstr_a(proto) );
3151 if (!__ws_getservbyname(name, proto, WS_DUP_SEGPTR)) return 0;
3152 return se_buffer_seg;
3153 }
3154
3155 /***********************************************************************
3156 * getservbyname (WS2_32.55)
3157 */
3158 struct WS_servent* WINAPI WS_getservbyname(const char *name, const char *proto)
3159 {
3160 TRACE( "%s, %s\n", debugstr_a(name), debugstr_a(proto) );
3161 return __ws_getservbyname(name, proto, WS_DUP_LINEAR);
3162 }
3163
3164
3165 /***********************************************************************
3166 * __ws_getservbyport
3167 */
3168 static WIN_servent* __ws_getservbyport(int port, const char* proto, int dup_flag)
3169 {
3170 WIN_servent* retval = NULL;
3171 #ifdef HAVE_GETSERVBYPORT
3172 struct servent* serv;
3173 if (!proto || wsi_strtolo( proto, NULL )) {
3174 EnterCriticalSection( &csWSgetXXXbyYYY );
3175 if( (serv = getservbyport(port, (proto) ? local_buffer : NULL)) != NULL ) {
3176 if( WS_dup_se(serv, dup_flag) )
3177 retval = se_buffer;
3178 else SetLastError(WSAENOBUFS);
3179 }
3180 else {
3181 MESSAGE("service on port %lu protocol %s not found; You might want to add "
3182 "this to /etc/services\n", (unsigned long)ntohl(port),
3183 proto ? debugstr_a(local_buffer) : "*");
3184 SetLastError(WSANO_DATA);
3185 }
3186 LeaveCriticalSection( &csWSgetXXXbyYYY );
3187 }
3188 else SetLastError(WSAENOBUFS);
3189 #endif
3190 return retval;
3191 }
3192
3193 /***********************************************************************
3194 * getservbyport (WINSOCK.56)
3195 */
3196 SEGPTR WINAPI WINSOCK_getservbyport16(INT16 port, const char *proto)
3197 {
3198 TRACE("%d (i.e. port %d), %s\n", (int)port, (int)ntohl(port), debugstr_a(proto));
3199 if (!__ws_getservbyport(port, proto, WS_DUP_SEGPTR)) return 0;
3200 return se_buffer_seg;
3201 }
3202
3203 /***********************************************************************
3204 * getservbyport (WS2_32.56)
3205 */
3206 struct WS_servent* WINAPI WS_getservbyport(int port, const char *proto)
3207 {
3208 TRACE("%d (i.e. port %d), %s\n", (int)port, (int)ntohl(port), debugstr_a(proto));
3209 return __ws_getservbyport(port, proto, WS_DUP_LINEAR);
3210 }
3211
3212
3213 /***********************************************************************
3214 * gethostname (WS2_32.57)
3215 */
3216 int WINAPI WS_gethostname(char *name, int namelen)
3217 {
3218 TRACE("name %p, len %d\n", name, namelen);
3219
3220 if (gethostname(name, namelen) == 0)
3221 {
3222 TRACE("<- '%s'\n", name);
3223 return 0;
3224 }
3225 SetLastError((errno == EINVAL) ? WSAEFAULT : wsaErrno());
3226 TRACE("<- ERROR !\n");
3227 return SOCKET_ERROR;
3228 }
3229
3230 /***********************************************************************
3231 * gethostname (WINSOCK.57)
3232 */
3233 INT16 WINAPI WINSOCK_gethostname16(char *name, INT16 namelen)
3234 {
3235 return (INT16)WS_gethostname(name, namelen);
3236 }
3237
3238
3239 /* ------------------------------------- Windows sockets extensions -- *
3240 * *
3241 * ------------------------------------------------------------------- */
3242
3243 /***********************************************************************
3244 * WSAEnumNetworkEvents (WS2_32.36)
3245 */
3246 int WINAPI WSAEnumNetworkEvents(SOCKET s, WSAEVENT hEvent, LPWSANETWORKEVENTS lpEvent)
3247 {
3248 int ret;
3249
3250 TRACE("%08x, hEvent %08x, lpEvent %08x\n", s, hEvent, (unsigned)lpEvent );
3251
3252 SERVER_START_REQ( get_socket_event )
3253 {
3254 req->handle = s;
3255 req->service = TRUE;
3256 req->c_event = hEvent;
3257 wine_server_set_reply( req, lpEvent->iErrorCode, sizeof(lpEvent->iErrorCode) );
3258 if (!(ret = wine_server_call(req))) lpEvent->lNetworkEvents = reply->pmask & reply->mask;
3259 }
3260 SERVER_END_REQ;
3261 if (!ret) return 0;
3262 SetLastError(WSAEINVAL);
3263 return SOCKET_ERROR;
3264 }
3265
3266 /***********************************************************************
3267 * WSAEventSelect (WS2_32.39)
3268 */
3269 int WINAPI WSAEventSelect(SOCKET s, WSAEVENT hEvent, LONG lEvent)
3270 {
3271 int ret;
3272
3273 TRACE("%08x, hEvent %08x, event %08x\n", s, hEvent, (unsigned)lEvent );
3274
3275 SERVER_START_REQ( set_socket_event )
3276 {
3277 req->handle = s;
3278 req->mask = lEvent;
3279 req->event = hEvent;
3280 req->window = 0;
3281 req->msg = 0;
3282 ret = wine_server_call( req );
3283 }
3284 SERVER_END_REQ;
3285 if (!ret) return 0;
3286 SetLastError(WSAEINVAL);
3287 return SOCKET_ERROR;
3288 }
3289
3290 /**********************************************************************
3291 * WSAGetOverlappedResult (WS2_32.40)
3292 */
3293 BOOL WINAPI WSAGetOverlappedResult ( SOCKET s, LPWSAOVERLAPPED lpOverlapped,
3294 LPDWORD lpcbTransfer, BOOL fWait,
3295 LPDWORD lpdwFlags )
3296 {
3297 DWORD r;
3298
3299 TRACE ( "socket %d ovl %p trans %p, wait %d flags %p\n",
3300 s, lpOverlapped, lpcbTransfer, fWait, lpdwFlags );
3301
3302 if ( !(lpOverlapped && lpOverlapped->hEvent) )
3303 {
3304 ERR ( "Invalid pointer\n" );
3305 WSASetLastError (WSA_INVALID_PARAMETER);
3306 return FALSE;
3307 }
3308
3309 if ( fWait )
3310 {
3311 while ( WaitForSingleObjectEx (lpOverlapped->hEvent, INFINITE, TRUE) == STATUS_USER_APC );
3312 }
3313 else if ( lpOverlapped->Internal == STATUS_PENDING )
3314 {
3315 /* Wait in order to give APCs a chance to run. */
3316 /* This is cheating, so we must set the event again in case of success -
3317 it may be a non-manual reset event. */
3318 while ( (r = WaitForSingleObjectEx (lpOverlapped->hEvent, 0, TRUE)) == STATUS_USER_APC );
3319 if ( r == WAIT_OBJECT_0 )
3320 NtSetEvent ( lpOverlapped->hEvent, NULL );
3321 }
3322
3323 if ( lpcbTransfer )
3324 *lpcbTransfer = lpOverlapped->InternalHigh;
3325
3326 if ( lpdwFlags )
3327 *lpdwFlags = lpOverlapped->Offset;
3328
3329 switch ( lpOverlapped->Internal )
3330 {
3331 case STATUS_SUCCESS:
3332 return TRUE;
3333 case STATUS_PENDING:
3334 WSASetLastError ( WSA_IO_INCOMPLETE );
3335 if (fWait) ERR ("PENDING status after waiting!\n");
3336 return FALSE;
3337 default:
3338 WSASetLastError ( NtStatusToWSAError ( lpOverlapped->Internal ));
3339 return FALSE;
3340 }
3341 }
3342
3343
3344 /***********************************************************************
3345 * WSAAsyncSelect (WS2_32.101)
3346 */
3347 INT WINAPI WSAAsyncSelect(SOCKET s, HWND hWnd, UINT uMsg, LONG lEvent)
3348 {
3349 int ret;
3350
3351 TRACE("%x, hWnd %x, uMsg %08x, event %08lx\n", s, hWnd, uMsg, lEvent );
3352
3353 SERVER_START_REQ( set_socket_event )
3354 {
3355 req->handle = s;
3356 req->mask = lEvent;
3357 req->event = 0;
3358 req->window = hWnd;
3359 req->msg = uMsg;
3360 ret = wine_server_call( req );
3361 }
3362 SERVER_END_REQ;
3363 if (!ret) return 0;
3364 SetLastError(WSAEINVAL);
3365 return SOCKET_ERROR;
3366 }
3367
3368 /***********************************************************************
3369 * WSAAsyncSelect (WINSOCK.101)
3370 */
3371 INT16 WINAPI WSAAsyncSelect16(SOCKET16 s, HWND16 hWnd, UINT16 wMsg, LONG lEvent)
3372 {
3373 return (INT16)WSAAsyncSelect( s, HWND_32(hWnd), wMsg, lEvent );
3374 }
3375
3376 /***********************************************************************
3377 * WSARecvEx (WINSOCK.1107)
3378 *
3379 * See description for WSARecvEx()
3380 */
3381 INT16 WINAPI WSARecvEx16(SOCKET16 s, char *buf, INT16 len, INT16 *flags)
3382 {
3383 FIXME("(WSARecvEx16) partial packet return value not set \n");
3384
3385 return WINSOCK_recv16(s, buf, len, *flags);
3386 }
3387
3388
3389 /***********************************************************************
3390 * WSACreateEvent (WS2_32.31)
3391 *
3392 */
3393 WSAEVENT WINAPI WSACreateEvent(void)
3394 {
3395 /* Create a manual-reset event, with initial state: unsignealed */
3396 TRACE("\n");
3397
3398 return CreateEventA(NULL, TRUE, FALSE, NULL);
3399 }
3400
3401 /***********************************************************************
3402 * WSACloseEvent (WS2_32.29)
3403 *
3404 */
3405 BOOL WINAPI WSACloseEvent(WSAEVENT event)
3406 {
3407 TRACE ("event=0x%x\n", event);
3408
3409 return CloseHandle(event);
3410 }
3411
3412 /***********************************************************************
3413 * WSASocketA (WS2_32.78)
3414 *
3415 */
3416 SOCKET WINAPI WSASocketA(int af, int type, int protocol,
3417 LPWSAPROTOCOL_INFOA lpProtocolInfo,
3418 GROUP g, DWORD dwFlags)
3419 {
3420 SOCKET ret;
3421
3422 /*
3423 FIXME: The "advanced" parameters of WSASocketA (lpProtocolInfo,
3424 g, dwFlags except WSA_FLAG_OVERLAPPED) are ignored.
3425 */
3426
3427 TRACE("af=%d type=%d protocol=%d protocol_info=%p group=%d flags=0x%lx\n",
3428 af, type, protocol, lpProtocolInfo, g, dwFlags );
3429
3430 /* hack for WSADuplicateSocket */
3431 if (lpProtocolInfo && lpProtocolInfo->dwServiceFlags4 == 0xff00ff00) {
3432 ret = lpProtocolInfo->dwCatalogEntryId;
3433 TRACE("\tgot duplicate %04x\n", ret);
3434 return ret;
3435 }
3436
3437 /* check the socket family */
3438 switch(af)
3439 {
3440 #ifdef HAVE_IPX
3441 case WS_AF_IPX: af = AF_IPX;
3442 #endif
3443 case AF_INET:
3444 case AF_UNSPEC:
3445 break;
3446 default:
3447 SetLastError(WSAEAFNOSUPPORT);
3448 return INVALID_SOCKET;
3449 }
3450
3451 /* check the socket type */
3452 switch(type)
3453 {
3454 case WS_SOCK_STREAM:
3455 type=SOCK_STREAM;
3456 break;
3457 case WS_SOCK_DGRAM:
3458 type=SOCK_DGRAM;
3459 break;
3460 case WS_SOCK_RAW:
3461 type=SOCK_RAW;
3462 break;
3463 default:
3464 SetLastError(WSAESOCKTNOSUPPORT);
3465 return INVALID_SOCKET;
3466 }
3467
3468 /* check the protocol type */
3469 if ( protocol < 0 ) /* don't support negative values */
3470 {
3471 SetLastError(WSAEPROTONOSUPPORT);
3472 return INVALID_SOCKET;
3473 }
3474
3475 if ( af == AF_UNSPEC) /* did they not specify the address family? */
3476 switch(protocol)
3477 {
3478 case IPPROTO_TCP:
3479 if (type == SOCK_STREAM) { af = AF_INET; break; }
3480 case IPPROTO_UDP:
3481 if (type == SOCK_DGRAM) { af = AF_INET; break; }
3482 default: SetLastError(WSAEPROTOTYPE); return INVALID_SOCKET;
3483 }
3484
3485 SERVER_START_REQ( create_socket )
3486 {
3487 req->family = af;
3488 req->type = type;
3489 req->protocol = protocol;
3490 req->access = GENERIC_READ|GENERIC_WRITE|SYNCHRONIZE;
3491 req->flags = dwFlags;
3492 req->inherit = TRUE;
3493 set_error( wine_server_call( req ) );
3494 ret = (SOCKET)reply->handle;
3495 }
3496 SERVER_END_REQ;
3497 if (ret)
3498 {
3499 TRACE("\tcreated %04x\n", ret );
3500 return ret;
3501 }
3502
3503 if (GetLastError() == WSAEACCES) /* raw socket denied */
3504 {
3505 if (type == SOCK_RAW)
3506 MESSAGE("WARNING: Trying to create a socket of type SOCK_RAW, will fail unless running as root\n");
3507 else
3508 MESSAGE("WS_SOCKET: not enough privileges to create socket, try running as root\n");
3509 SetLastError(WSAESOCKTNOSUPPORT);
3510 }
3511
3512 WARN("\t\tfailed!\n");
3513 return INVALID_SOCKET;
3514 }
3515
3516
3517 /***********************************************************************
3518 * __WSAFDIsSet (WINSOCK.151)
3519 */
3520 INT16 WINAPI __WSAFDIsSet16(SOCKET16 s, ws_fd_set16 *set)
3521 {
3522 int i = set->fd_count;
3523
3524 TRACE("(%d,%8lx(%i))\n", s,(unsigned long)set, i);
3525
3526 while (i--)
3527 if (set->fd_array[i] == s) return 1;
3528 return 0;
3529 }
3530
3531 /***********************************************************************
3532 * __WSAFDIsSet (WS2_32.151)
3533 */
3534 int WINAPI __WSAFDIsSet(SOCKET s, WS_fd_set *set)
3535 {
3536 int i = set->fd_count;
3537
3538 TRACE("(%d,%8lx(%i))\n", s,(unsigned long)set, i);
3539
3540 while (i--)
3541 if (set->fd_array[i] == s) return 1;
3542 return 0;
3543 }
3544
3545 /***********************************************************************
3546 * WSAIsBlocking (WINSOCK.114)
3547 * WSAIsBlocking (WS2_32.114)
3548 */
3549 BOOL WINAPI WSAIsBlocking(void)
3550 {
3551 /* By default WinSock should set all its sockets to non-blocking mode
3552 * and poll in PeekMessage loop when processing "blocking" ones. This
3553 * function is supposed to tell if the program is in this loop. Our
3554 * blocking calls are truly blocking so we always return FALSE.
3555 *
3556 * Note: It is allowed to call this function without prior WSAStartup().
3557 */
3558
3559 TRACE("\n");
3560 return FALSE;
3561 }
3562
3563 /***********************************************************************
3564 * WSACancelBlockingCall (WINSOCK.113)
3565 * WSACancelBlockingCall (WS2_32.113)
3566 */
3567 INT WINAPI WSACancelBlockingCall(void)
3568 {
3569 TRACE("\n");
3570 return 0;
3571 }
3572
3573
3574 /***********************************************************************
3575 * WSASetBlockingHook (WINSOCK.109)
3576 */
3577 FARPROC16 WINAPI WSASetBlockingHook16(FARPROC16 lpBlockFunc)
3578 {
3579 FARPROC16 prev = (FARPROC16)blocking_hook;
3580 blocking_hook = (FARPROC)lpBlockFunc;
3581 TRACE("hook %p\n", lpBlockFunc);
3582 return prev;
3583 }
3584
3585
3586 /***********************************************************************
3587 * WSASetBlockingHook (WS2_32.109)
3588 */
3589 FARPROC WINAPI WSASetBlockingHook(FARPROC lpBlockFunc)
3590 {
3591 FARPROC prev = blocking_hook;
3592 blocking_hook = lpBlockFunc;
3593 TRACE("hook %p\n", lpBlockFunc);
3594 return prev;
3595 }
3596
3597
3598 /***********************************************************************
3599 * WSAUnhookBlockingHook (WINSOCK.110)
3600 */
3601 INT16 WINAPI WSAUnhookBlockingHook16(void)
3602 {
3603 blocking_hook = NULL;
3604 return 0;
3605 }
3606
3607
3608 /***********************************************************************
3609 * WSAUnhookBlockingHook (WS2_32.110)
3610 */
3611 INT WINAPI WSAUnhookBlockingHook(void)
3612 {
3613 blocking_hook = NULL;
3614 return 0;
3615 }
3616
3617
3618 /* ----------------------------------- end of API stuff */
3619
3620 /* ----------------------------------- helper functions -
3621 *
3622 * TODO: Merge WS_dup_..() stuff into one function that
3623 * would operate with a generic structure containing internal
3624 * pointers (via a template of some kind).
3625 */
3626
3627 static int list_size(char** l, int item_size)
3628 {
3629 int i,j = 0;
3630 if(l)
3631 { for(i=0;l[i];i++)
3632 j += (item_size) ? item_size : strlen(l[i]) + 1;
3633 j += (i + 1) * sizeof(char*); }
3634 return j;
3635 }
3636
3637 static int list_dup(char** l_src, char* ref, char* base, int item_size)
3638 {
3639 /* base is either either equal to ref or 0 or SEGPTR */
3640
3641 char* p = ref;
3642 char** l_to = (char**)ref;
3643 int i,j,k;
3644
3645 for(j=0;l_src[j];j++) ;
3646 p += (j + 1) * sizeof(char*);
3647 for(i=0;i<j;i++)
3648 { l_to[i] = base + (p - ref);
3649 k = ( item_size ) ? item_size : strlen(l_src[i]) + 1;
3650 memcpy(p, l_src[i], k); p += k; }
3651 l_to[i] = NULL;
3652 return (p - ref);
3653 }
3654
3655 /* ----- hostent */
3656
3657 static int hostent_size(struct hostent* p_he)
3658 {
3659 int size = 0;
3660 if( p_he )
3661 { size = sizeof(struct hostent);
3662 size += strlen(p_he->h_name) + 1;
3663 size += list_size(p_he->h_aliases, 0);
3664 size += list_size(p_he->h_addr_list, p_he->h_length ); }
3665 return size;
3666 }
3667
3668 /* duplicate hostent entry
3669 * and handle all Win16/Win32 dependent things (struct size, ...) *correctly*.
3670 * Dito for protoent and servent.
3671 */
3672 static int WS_dup_he(struct hostent* p_he, int flag)
3673 {
3674 /* Convert hostent structure into ws_hostent so that the data fits
3675 * into local_buffer. Internal pointers can be linear, SEGPTR, or
3676 * relative to local_buffer depending on "flag" value. Returns size
3677 * of the data copied.
3678 */
3679
3680 int size = hostent_size(p_he);
3681 if( size )
3682 {
3683 char *p_name,*p_aliases,*p_addr,*p_base,*p;
3684 char *p_to;
3685 struct ws_hostent16 *p_to16;
3686 struct WS_hostent *p_to32;
3687
3688 check_buffer_he(size);
3689 p_to = he_buffer;
3690 p_to16 = he_buffer;
3691 p_to32 = he_buffer;
3692
3693 p = p_to;
3694 p_base = (flag & WS_DUP_SEGPTR) ? (char*)he_buffer_seg : he_buffer;
3695 p += (flag & WS_DUP_SEGPTR) ?
3696 sizeof(struct ws_hostent16) : sizeof(struct WS_hostent);
3697 p_name = p;
3698 strcpy(p, p_he->h_name); p += strlen(p) + 1;
3699 p_aliases = p;
3700 p += list_dup(p_he->h_aliases, p, p_base + (p - p_to), 0);
3701 p_addr = p;
3702 list_dup(p_he->h_addr_list, p, p_base + (p - p_to), p_he->h_length);
3703
3704 if (flag & WS_DUP_SEGPTR) /* Win16 */
3705 {
3706 p_to16->h_addrtype = (INT16)p_he->h_addrtype;
3707 p_to16->h_length = (INT16)p_he->h_length;
3708 p_to16->h_name = (SEGPTR)(p_base + (p_name - p_to));
3709 p_to16->h_aliases = (SEGPTR)(p_base + (p_aliases - p_to));
3710 p_to16->h_addr_list = (SEGPTR)(p_base + (p_addr - p_to));
3711 size += (sizeof(struct ws_hostent16) - sizeof(struct hostent));
3712 }
3713 else /* Win32 */
3714 {
3715 p_to32->h_addrtype = p_he->h_addrtype;
3716 p_to32->h_length = p_he->h_length;
3717 p_to32->h_name = (p_base + (p_name - p_to));
3718 p_to32->h_aliases = (char **)(p_base + (p_aliases - p_to));
3719 p_to32->h_addr_list = (char **)(p_base + (p_addr - p_to));
3720 size += (sizeof(struct WS_hostent) - sizeof(struct hostent));
3721 }
3722 }
3723 return size;
3724 }
3725
3726 /* ----- protoent */
3727
3728 static int protoent_size(struct protoent* p_pe)
3729 {
3730 int size = 0;
3731 if( p_pe )
3732 { size = sizeof(struct protoent);
3733 size += strlen(p_pe->p_name) + 1;
3734 size += list_size(p_pe->p_aliases, 0); }
3735 return size;
3736 }
3737
3738 static int WS_dup_pe(struct protoent* p_pe, int flag)
3739 {
3740 int size = protoent_size(p_pe);
3741 if( size )
3742 {
3743 char *p_to;
3744 struct ws_protoent16 *p_to16;
3745 struct WS_protoent *p_to32;
3746 char *p_name,*p_aliases,*p_base,*p;
3747
3748 check_buffer_pe(size);
3749 p_to = pe_buffer;
3750 p_to16 = pe_buffer;
3751 p_to32 = pe_buffer;
3752 p = p_to;
3753 p_base = (flag & WS_DUP_SEGPTR) ? (char*)pe_buffer_seg : pe_buffer;
3754 p += (flag & WS_DUP_SEGPTR) ?
3755 sizeof(struct ws_protoent16) : sizeof(struct WS_protoent);
3756 p_name = p;
3757 strcpy(p, p_pe->p_name); p += strlen(p) + 1;
3758 p_aliases = p;
3759 list_dup(p_pe->p_aliases, p, p_base + (p - p_to), 0);
3760
3761 if (flag & WS_DUP_SEGPTR) /* Win16 */
3762 {
3763 p_to16->p_proto = (INT16)p_pe->p_proto;
3764 p_to16->p_name = (SEGPTR)(p_base) + (p_name - p_to);
3765 p_to16->p_aliases = (SEGPTR)((p_base) + (p_aliases - p_to));
3766 size += (sizeof(struct ws_protoent16) - sizeof(struct protoent));
3767 }
3768 else /* Win32 */
3769 {
3770 p_to32->p_proto = p_pe->p_proto;
3771 p_to32->p_name = (p_base) + (p_name - p_to);
3772 p_to32->p_aliases = (char **)((p_base) + (p_aliases - p_to));
3773 size += (sizeof(struct WS_protoent) - sizeof(struct protoent));
3774 }
3775 }
3776 return size;
3777 }
3778
3779 /* ----- servent */
3780
3781 static int servent_size(struct servent* p_se)
3782 {
3783 int size = 0;
3784 if( p_se )
3785 { size += sizeof(struct servent);
3786 size += strlen(p_se->s_proto) + strlen(p_se->s_name) + 2;
3787 size += list_size(p_se->s_aliases, 0); }
3788 return size;
3789 }
3790
3791 static int WS_dup_se(struct servent* p_se, int flag)
3792 {
3793 int size = servent_size(p_se);
3794 if( size )
3795 {
3796 char *p_name,*p_aliases,*p_proto,*p_base,*p;
3797 char *p_to;
3798 struct ws_servent16 *p_to16;
3799 struct WS_servent *p_to32;
3800
3801 check_buffer_se(size);
3802 p_to = se_buffer;
3803 p_to16 = se_buffer;
3804 p_to32 = se_buffer;
3805 p = p_to;
3806 p_base = (flag & WS_DUP_SEGPTR) ? (char*)se_buffer_seg : se_buffer;
3807 p += (flag & WS_DUP_SEGPTR) ?
3808 sizeof(struct ws_servent16) : sizeof(struct WS_servent);
3809 p_name = p;
3810 strcpy(p, p_se->s_name); p += strlen(p) + 1;
3811 p_proto = p;
3812 strcpy(p, p_se->s_proto); p += strlen(p) + 1;
3813 p_aliases = p;
3814 list_dup(p_se->s_aliases, p, p_base + (p - p_to), 0);
3815
3816 if (flag & WS_DUP_SEGPTR) /* Win16 */
3817 {
3818 p_to16->s_port = (INT16)p_se->s_port;
3819 p_to16->s_name = (SEGPTR)(p_base + (p_name - p_to));
3820 p_to16->s_proto = (SEGPTR)(p_base + (p_proto - p_to));
3821 p_to16->s_aliases = (SEGPTR)(p_base + (p_aliases - p_to));
3822 size += (sizeof(struct ws_servent16) - sizeof(struct servent));
3823 }
3824 else /* Win32 */
3825 {
3826 p_to32->s_port = p_se->s_port;
3827 p_to32->s_name = (p_base + (p_name - p_to));
3828 p_to32->s_proto = (p_base + (p_proto - p_to));
3829 p_to32->s_aliases = (char **)(p_base + (p_aliases - p_to));
3830 size += (sizeof(struct WS_servent) - sizeof(struct servent));
3831 }
3832 }
3833 return size;
3834 }
3835
3836 /* ----------------------------------- error handling */
3837
3838 UINT16 wsaErrno(void)
3839 {
3840 int loc_errno = errno;
3841 WARN("errno %d, (%s).\n", loc_errno, strerror(loc_errno));
3842
3843 switch(loc_errno)
3844 {
3845 case EINTR: return WSAEINTR;
3846 case EBADF: return WSAEBADF;
3847 case EPERM:
3848 case EACCES: return WSAEACCES;
3849 case EFAULT: return WSAEFAULT;
3850 case EINVAL: return WSAEINVAL;
3851 case EMFILE: return WSAEMFILE;
3852 case EWOULDBLOCK: return WSAEWOULDBLOCK;
3853 case EINPROGRESS: return WSAEINPROGRESS;
3854 case EALREADY: return WSAEALREADY;
3855 case ENOTSOCK: return WSAENOTSOCK;
3856 case EDESTADDRREQ: return WSAEDESTADDRREQ;
3857 case EMSGSIZE: return WSAEMSGSIZE;
3858 case EPROTOTYPE: return WSAEPROTOTYPE;
3859 case ENOPROTOOPT: return WSAENOPROTOOPT;
3860 case EPROTONOSUPPORT: return WSAEPROTONOSUPPORT;
3861 case ESOCKTNOSUPPORT: return WSAESOCKTNOSUPPORT;
3862 case EOPNOTSUPP: return WSAEOPNOTSUPP;
3863 case EPFNOSUPPORT: return WSAEPFNOSUPPORT;
3864 case EAFNOSUPPORT: return WSAEAFNOSUPPORT;
3865 case EADDRINUSE: return WSAEADDRINUSE;
3866 case EADDRNOTAVAIL: return WSAEADDRNOTAVAIL;
3867 case ENETDOWN: return WSAENETDOWN;
3868 case ENETUNREACH: return WSAENETUNREACH;
3869 case ENETRESET: return WSAENETRESET;
3870 case ECONNABORTED: return WSAECONNABORTED;
3871 case EPIPE:
3872 case ECONNRESET: return WSAECONNRESET;
3873 case ENOBUFS: return WSAENOBUFS;
3874 case EISCONN: return WSAEISCONN;
3875 case ENOTCONN: return WSAENOTCONN;
3876 case ESHUTDOWN: return WSAESHUTDOWN;
3877 case ETOOMANYREFS: return WSAETOOMANYREFS;
3878 case ETIMEDOUT: return WSAETIMEDOUT;
3879 case ECONNREFUSED: return WSAECONNREFUSED;
3880 case ELOOP: return WSAELOOP;
3881 case ENAMETOOLONG: return WSAENAMETOOLONG;
3882 case EHOSTDOWN: return WSAEHOSTDOWN;
3883 case EHOSTUNREACH: return WSAEHOSTUNREACH;
3884 case ENOTEMPTY: return WSAENOTEMPTY;
3885 #ifdef EPROCLIM
3886 case EPROCLIM: return WSAEPROCLIM;
3887 #endif
3888 #ifdef EUSERS
3889 case EUSERS: return WSAEUSERS;
3890 #endif
3891 #ifdef EDQUOT
3892 case EDQUOT: return WSAEDQUOT;
3893 #endif
3894 #ifdef ESTALE
3895 case ESTALE: return WSAESTALE;
3896 #endif
3897 #ifdef EREMOTE
3898 case EREMOTE: return WSAEREMOTE;
3899 #endif
3900
3901 /* just in case we ever get here and there are no problems */
3902 case 0: return 0;
3903 default:
3904 WARN("Unknown errno %d!\n", loc_errno);
3905 return WSAEOPNOTSUPP;
3906 }
3907 }
3908
3909 UINT16 wsaHerrno(int loc_errno)
3910 {
3911
3912 WARN("h_errno %d.\n", loc_errno);
3913
3914 switch(loc_errno)
3915 {
3916 case HOST_NOT_FOUND: return WSAHOST_NOT_FOUND;
3917 case TRY_AGAIN: return WSATRY_AGAIN;
3918 case NO_RECOVERY: return WSANO_RECOVERY;
3919 case NO_DATA: return WSANO_DATA;
3920 case ENOBUFS: return WSAENOBUFS;
3921
3922 case 0: return 0;
3923 default:
3924 WARN("Unknown h_errno %d!\n", loc_errno);
3925 return WSAEOPNOTSUPP;
3926 }
3927 }
3928
3929
3930 /***********************************************************************
3931 * WSARecv (WS2_32.67)
3932 */
3933 int WINAPI WSARecv (SOCKET s, LPWSABUF lpBuffers, DWORD dwBufferCount,
3934 LPDWORD NumberOfBytesReceived, LPDWORD lpFlags,
3935 LPWSAOVERLAPPED lpOverlapped,
3936 LPWSAOVERLAPPED_COMPLETION_ROUTINE lpCompletionRoutine)
3937 {
3938 return WSARecvFrom (s, lpBuffers, dwBufferCount, NumberOfBytesReceived, lpFlags,
3939 NULL, NULL, lpOverlapped, lpCompletionRoutine);
3940 }
3941
3942 /***********************************************************************
3943 * WSARecvFrom (WS2_32.69)
3944 */
3945 INT WINAPI WSARecvFrom( SOCKET s, LPWSABUF lpBuffers, DWORD dwBufferCount,
3946 LPDWORD lpNumberOfBytesRecvd, LPDWORD lpFlags, struct WS_sockaddr *lpFrom,
3947 LPINT lpFromlen, LPWSAOVERLAPPED lpOverlapped,
3948 LPWSAOVERLAPPED_COMPLETION_ROUTINE lpCompletionRoutine )
3949
3950 {
3951 int i, n, fd, err = WSAENOTSOCK, flags, ret;
3952 struct iovec* iovec;
3953 struct ws2_async *wsa;
3954 enum fd_type type;
3955
3956 TRACE("socket %04x, wsabuf %p, nbufs %ld, flags %ld, from %p, fromlen %ld, ovl %p, func %p\n",
3957 s, lpBuffers, dwBufferCount, *lpFlags, lpFrom,
3958 (lpFromlen ? *lpFromlen : -1L),
3959 lpOverlapped, lpCompletionRoutine);
3960
3961 fd = _get_sock_fd_type( s, GENERIC_READ, &type, &flags );
3962 TRACE ( "fd=%d, type=%d, flags=%x\n", fd, type, flags );
3963
3964 if (fd == -1)
3965 {
3966 err = WSAGetLastError ();
3967 goto error;
3968 }
3969
3970 iovec = HeapAlloc ( GetProcessHeap(), 0, dwBufferCount * sizeof (struct iovec) );
3971 if ( !iovec )
3972 {
3973 err = WSAEFAULT;
3974 goto err_close;
3975 }
3976
3977 for (i = 0; i < dwBufferCount; i++)
3978 {
3979 iovec[i].iov_base = lpBuffers[i].buf;
3980 iovec[i].iov_len = lpBuffers[i].len;
3981 }
3982
3983 if ( (lpOverlapped || lpCompletionRoutine) && flags & FD_FLAG_OVERLAPPED )
3984 {
3985 wsa = WS2_make_async ( s, fd, ASYNC_TYPE_READ, iovec, dwBufferCount,
3986 lpFlags, lpFrom, lpFromlen,
3987 lpOverlapped, lpCompletionRoutine );
3988
3989 if ( !wsa )
3990 {
3991 err = WSAEFAULT;
3992 goto err_free;
3993 }
3994
3995 if ( ( ret = register_new_async ( &wsa->async )) )
3996 {
3997 err = NtStatusToWSAError ( ret );
3998
3999 if ( !lpOverlapped )
4000 HeapFree ( GetProcessHeap(), 0, wsa->overlapped );
4001 HeapFree ( GetProcessHeap(), 0, wsa );
4002 goto err_free;
4003 }
4004
4005 /* Try immediate completion */
4006 if ( lpOverlapped && !NtResetEvent( lpOverlapped->hEvent, NULL ) )
4007 {
4008 if ( WSAGetOverlappedResult ( (HANDLE) s, lpOverlapped,
4009 lpNumberOfBytesRecvd, FALSE, lpFlags) )
4010 return 0;
4011
4012 if ( (err = WSAGetLastError ()) != WSA_IO_INCOMPLETE )
4013 goto error;
4014 }
4015
4016 WSASetLastError ( WSA_IO_PENDING );
4017 return SOCKET_ERROR;
4018 }
4019
4020 if ( _is_blocking(s) )
4021 {
4022 /* block here */
4023 /* FIXME: OOB and exceptfds? */
4024 do_block(fd, 1);
4025 }
4026
4027 n = WS2_recv ( fd, iovec, dwBufferCount, lpFrom, lpFromlen, lpFlags );
4028 if ( n == -1 )
4029 {
4030 err = wsaErrno();
4031 goto err_free;
4032 }
4033
4034 TRACE(" -> %i bytes\n", n);
4035 *lpNumberOfBytesRecvd = n;
4036
4037 HeapFree (GetProcessHeap(), 0, iovec);
4038 close(fd);
4039 _enable_event(s, FD_READ, 0, 0);
4040
4041 return 0;
4042
4043 err_free:
4044 HeapFree (GetProcessHeap(), 0, iovec);
4045
4046 err_close:
4047 close (fd);
4048
4049 error:
4050 WARN(" -> ERROR %d\n", err);
4051 WSASetLastError ( err );
4052 return SOCKET_ERROR;
4053 }
4054
4055 /***********************************************************************
4056 * WSCInstallProvider (WS2_32.88)
4057 */
4058 INT WINAPI WSCInstallProvider( const LPGUID lpProviderId,
4059 LPCWSTR lpszProviderDllPath,
4060 const LPWSAPROTOCOL_INFOW lpProtocolInfoList,
4061 DWORD dwNumberOfEntries,
4062 LPINT lpErrno )
4063 {
4064 FIXME("(%s, %s, %p, %ld, %p): stub !\n", debugstr_guid(lpProviderId),
4065 debugstr_w(lpszProviderDllPath), lpProtocolInfoList,
4066 dwNumberOfEntries, lpErrno);
4067 *lpErrno = 0;
4068 return 0;
4069 }
4070
4071
4072 /***********************************************************************
4073 * WSCDeinstallProvider (WS2_32.83)
4074 */
4075 INT WINAPI WSCDeinstallProvider(LPGUID lpProviderId, LPINT lpErrno)
4076 {
4077 FIXME("(%s, %p): stub !\n", debugstr_guid(lpProviderId), lpErrno);
4078 *lpErrno = 0;
4079 return 0;
4080 }
4081
4082
4083 /***********************************************************************
4084 * WSAAccept (WS2_32.26)
4085 */
4086 SOCKET WINAPI WSAAccept( SOCKET s, struct WS_sockaddr *addr, LPINT addrlen,
4087 LPCONDITIONPROC lpfnCondition, DWORD dwCallbackData)
4088 {
4089
4090 int ret = 0, size = 0;
4091 WSABUF CallerId, CallerData, CalleeId, CalleeData;
4092 /* QOS SQOS, GQOS; */
4093 GROUP g;
4094 SOCKET cs;
4095 SOCKADDR src_addr, dst_addr;
4096
4097 TRACE("Socket %u, sockaddr %p, addrlen %p, fnCondition %p, dwCallbackData %ld\n",
4098 s, addr, addrlen, lpfnCondition, dwCallbackData);
4099
4100
4101 size = sizeof(src_addr);
4102 cs = WS_accept(s, &src_addr, &size);
4103
4104 if (cs == SOCKET_ERROR) return SOCKET_ERROR;
4105
4106 CallerId.buf = (char *)&src_addr;
4107 CallerId.len = sizeof(src_addr);
4108
4109 CallerData.buf = NULL;
4110 CallerData.len = (ULONG)NULL;
4111
4112 WS_getsockname(cs, &dst_addr, &size);
4113
4114 CalleeId.buf = (char *)&dst_addr;
4115 CalleeId.len = sizeof(dst_addr);
4116
4117
4118 ret = (*lpfnCondition)(&CallerId, &CallerData, NULL, NULL,
4119 &CalleeId, &CalleeData, &g, dwCallbackData);
4120
4121 switch (ret)
4122 {
4123 case CF_ACCEPT:
4124 if (addr && addrlen)
4125 addr = memcpy(addr, &src_addr, (*addrlen > size) ? size : *addrlen );
4126 return cs;
4127 case CF_DEFER:
4128 SERVER_START_REQ ( set_socket_deferred )
4129 {
4130 req->handle = s;
4131 req->deferred = cs;
4132 if ( !wine_server_call_err ( req ) )
4133 {
4134 SetLastError ( WSATRY_AGAIN );
4135 CloseHandle ( cs );
4136 }
4137 }
4138 SERVER_END_REQ;
4139 return SOCKET_ERROR;
4140 case CF_REJECT:
4141 WS_closesocket(cs);
4142 SetLastError(WSAECONNREFUSED);
4143 return SOCKET_ERROR;
4144 default:
4145 FIXME("Unknown return type from Condition function\n");
4146 SetLastError(WSAENOTSOCK);
4147 return SOCKET_ERROR;
4148 }
4149
4150 SetLastError(WSAENOTSOCK);
4151 return SOCKET_ERROR;
4152 }
4153
4154 /***********************************************************************
4155 * WSAEnumProtocolsA (WS2_32.37)
4156 */
4157 int WINAPI WSAEnumProtocolsA(LPINT lpiProtocols, LPWSAPROTOCOL_INFOA lpProtocolBuffer, LPDWORD lpdwBufferLength)
4158 {
4159 FIXME("(%p,%p,%p): stub\n", lpiProtocols,lpProtocolBuffer, lpdwBufferLength);
4160 return 0;
4161 }
4162
4163 /***********************************************************************
4164 * WSAEnumProtocolsW (WS2_32.38)
4165 */
4166 int WINAPI WSAEnumProtocolsW(LPINT lpiProtocols, LPWSAPROTOCOL_INFOW lpProtocolBuffer, LPDWORD lpdwBufferLength)
4167 {
4168 FIXME("(%p,%p,%p): stub\n", lpiProtocols,lpProtocolBuffer, lpdwBufferLength);
4169 return 0;
4170 }
4171
4172 /***********************************************************************
4173 * WSADuplicateSocketA (WS2_32.32)
4174 */
4175 int WINAPI WSADuplicateSocketA( SOCKET s, DWORD dwProcessId, LPWSAPROTOCOL_INFOA lpProtocolInfo )
4176 {
4177 HANDLE hProcess;
4178
4179 TRACE("(%d,%lx,%p)\n", s, dwProcessId, lpProtocolInfo);
4180 memset(lpProtocolInfo, 0, sizeof(*lpProtocolInfo));
4181 /* FIXME: WS_getsockopt(s, WS_SOL_SOCKET, SO_PROTOCOL_INFO, lpProtocolInfo, sizeof(*lpProtocolInfo)); */
4182 /* I don't know what the real Windoze does next, this is a hack */
4183 /* ...we could duplicate and then use ConvertToGlobalHandle on the duplicate, then let
4184 * the target use the global duplicate, or we could copy a reference to us to the structure
4185 * and let the target duplicate it from us, but let's do it as simple as possible */
4186 hProcess = OpenProcess(PROCESS_DUP_HANDLE, FALSE, dwProcessId);
4187 DuplicateHandle(GetCurrentProcess(), s,
4188 hProcess, (LPHANDLE)&lpProtocolInfo->dwCatalogEntryId,
4189 0, FALSE, DUPLICATE_SAME_ACCESS);
4190 CloseHandle(hProcess);
4191 lpProtocolInfo->dwServiceFlags4 = 0xff00ff00; /* magic */
4192 return 0;
4193 }
DirectPlay implementation for GSoC