git.oblomov.eu Git - wine/blob - dlls/ws2_32/socket.c

   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  * Copyright (C) 2005 Marcus Meissner
   7  *
   8  * This library is free software; you can redistribute it and/or
   9  * modify it under the terms of the GNU Lesser General Public
  10  * License as published by the Free Software Foundation; either
  11  * version 2.1 of the License, or (at your option) any later version.
  12  *
  13  * This library is distributed in the hope that it will be useful,
  14  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  15  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  16  * Lesser General Public License for more details.
  17  *
  18  * You should have received a copy of the GNU Lesser General Public
  19  * License along with this library; if not, write to the Free Software
  20  * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301, USA
  21  *
  22  * NOTE: If you make any changes to fix a particular app, make sure
  23  * they don't break something else like Netscape or telnet and ftp
  24  * clients and servers (www.winsite.com got a lot of those).
  25  */
  26
  27 #include "config.h"
  28 #include "wine/port.h"
  29
  30 #include <stdarg.h>
  31 #include <stdio.h>
  32 #include <string.h>
  33 #include <sys/types.h>
  34 #ifdef HAVE_SYS_IPC_H
  35 # include <sys/ipc.h>
  36 #endif
  37 #ifdef HAVE_SYS_IOCTL_H
  38 # include <sys/ioctl.h>
  39 #endif
  40 #ifdef HAVE_SYS_FILIO_H
  41 # include <sys/filio.h>
  42 #endif
  43 #ifdef HAVE_SYS_SOCKIO_H
  44 # include <sys/sockio.h>
  45 #endif
  46
  47 #if defined(__EMX__)
  48 # include <sys/so_ioctl.h>
  49 #endif
  50
  51 #ifdef HAVE_SYS_PARAM_H
  52 # include <sys/param.h>
  53 #endif
  54
  55 #ifdef HAVE_SYS_MSG_H
  56 # include <sys/msg.h>
  57 #endif
  58 #ifdef HAVE_SYS_WAIT_H
  59 # include <sys/wait.h>
  60 #endif
  61 #ifdef HAVE_SYS_UIO_H
  62 # include <sys/uio.h>
  63 #endif
  64 #ifdef HAVE_SYS_SOCKET_H
  65 #include <sys/socket.h>
  66 #endif
  67 #ifdef HAVE_NETINET_IN_H
  68 # include <netinet/in.h>
  69 #endif
  70 #ifdef HAVE_NETINET_TCP_H
  71 # include <netinet/tcp.h>
  72 #endif
  73 #ifdef HAVE_ARPA_INET_H
  74 # include <arpa/inet.h>
  75 #endif
  76 #include <ctype.h>
  77 #include <fcntl.h>
  78 #include <errno.h>
  79 #ifdef HAVE_SYS_ERRNO_H
  80 #include <sys/errno.h>
  81 #endif
  82 #ifdef HAVE_NETDB_H
  83 #include <netdb.h>
  84 #endif
  85 #ifdef HAVE_UNISTD_H
  86 # include <unistd.h>
  87 #endif
  88 #include <stdlib.h>
  89 #ifdef HAVE_ARPA_NAMESER_H
  90 # include <arpa/nameser.h>
  91 #endif
  92 #ifdef HAVE_RESOLV_H
  93 # include <resolv.h>
  94 #endif
  95 #ifdef HAVE_NET_IF_H
  96 # include <net/if.h>
  97 #endif
  98
  99 #ifdef HAVE_NETIPX_IPX_H
 100 # include <netipx/ipx.h>
 101 # define HAVE_IPX
 102 #elif defined(HAVE_LINUX_IPX_H)
 103 # ifdef HAVE_ASM_TYPES_H
 104 #  include <asm/types.h>
 105 # endif
 106 # include <linux/ipx.h>
 107 # define HAVE_IPX
 108 #endif
 109
 110 #ifdef HAVE_POLL_H
 111 #include <poll.h>
 112 #endif
 113 #ifdef HAVE_SYS_POLL_H
 114 # include <sys/poll.h>
 115 #endif
 116 #ifdef HAVE_SYS_TIME_H
 117 # include <sys/time.h>
 118 #endif
 119
 120 #define NONAMELESSUNION
 121 #define NONAMELESSSTRUCT
 122 #include "ntstatus.h"
 123 #define WIN32_NO_STATUS
 124 #include "windef.h"
 125 #include "winbase.h"
 126 #include "wingdi.h"
 127 #include "winuser.h"
 128 #include "winerror.h"
 129 #include "winnls.h"
 130 #include "winsock2.h"
 131 #include "mswsock.h"
 132 #include "ws2tcpip.h"
 133 #include "ws2spi.h"
 134 #include "wsipx.h"
 135 #include "winnt.h"
 136 #include "iphlpapi.h"
 137 #include "thread.h"
 138 #include "wine/server.h"
 139 #include "wine/debug.h"
 140 #include "wine/unicode.h"
 141
 142 #ifdef HAVE_IPX
 143 # include "wsnwlink.h"
 144 #endif
 145
 146
 147 #if defined(__FreeBSD__) || defined(__FreeBSD_kernel__)
 148 # define sipx_network    sipx_addr.x_net
 149 # define sipx_node       sipx_addr.x_host.c_host
 150 #endif  /* __FreeBSD__ */
 151
 152 #ifndef INADDR_NONE
 153 #define INADDR_NONE ~0UL
 154 #endif
 155
 156 WINE_DEFAULT_DEBUG_CHANNEL(winsock);
 157
 158 /* critical section to protect some non-rentrant net function */
 159 extern CRITICAL_SECTION csWSgetXXXbyYYY;
 160
 161 inline static const char *debugstr_sockaddr( const struct WS_sockaddr *a )
 162 {
 163     if (!a) return "(nil)";
 164     return wine_dbg_sprintf("{ family %d, address %s, port %d }",
 165                             ((const struct sockaddr_in *)a)->sin_family,
 166                             inet_ntoa(((const struct sockaddr_in *)a)->sin_addr),
 167                             ntohs(((const struct sockaddr_in *)a)->sin_port));
 168 }
 169
 170 /* HANDLE<->SOCKET conversion (SOCKET is UINT_PTR). */
 171 #define SOCKET2HANDLE(s) ((HANDLE)(s))
 172 #define HANDLE2SOCKET(h) ((SOCKET)(h))
 173
 174 /****************************************************************
 175  * Async IO declarations
 176  ****************************************************************/
 177
 178 typedef struct ws2_async
 179 {
 180     HANDLE                              hSocket;
 181     enum ws2_mode {ws2m_read, ws2m_write, ws2m_sd_read, ws2m_sd_write} mode;
 182     LPWSAOVERLAPPED                     user_overlapped;
 183     LPWSAOVERLAPPED_COMPLETION_ROUTINE  completion_func;
 184     struct iovec                        *iovec;
 185     int                                 n_iovecs;
 186     struct WS_sockaddr                  *addr;
 187     union
 188     {
 189         int val;     /* for send operations */
 190         int *ptr;    /* for recv operations */
 191     }                                   addrlen;
 192     DWORD                               flags;
 193     int                                 fd;
 194     HANDLE                              event;
 195 } ws2_async;
 196
 197 /****************************************************************/
 198
 199 /* ----------------------------------- internal data */
 200
 201 /* ws_... struct conversion flags */
 202
 203 typedef struct          /* WSAAsyncSelect() control struct */
 204 {
 205   HANDLE      service, event, sock;
 206   HWND        hWnd;
 207   UINT        uMsg;
 208   LONG        lEvent;
 209 } ws_select_info;
 210
 211 #define WS_MAX_SOCKETS_PER_PROCESS      128     /* reasonable guess */
 212 #define WS_MAX_UDP_DATAGRAM             1024
 213 static INT WINAPI WSA_DefaultBlockingHook( FARPROC x );
 214
 215 /* hostent's, servent's and protent's are stored in one buffer per thread,
 216  * as documented on MSDN for the functions that return any of the buffers */
 217 struct per_thread_data
 218 {
 219     int opentype;
 220     struct WS_hostent *he_buffer;
 221     struct WS_servent *se_buffer;
 222     struct WS_protoent *pe_buffer;
 223     int he_len;
 224     int se_len;
 225     int pe_len;
 226 };
 227
 228 static INT num_startup;          /* reference counter */
 229 static FARPROC blocking_hook = WSA_DefaultBlockingHook;
 230
 231 /* function prototypes */
 232 static struct WS_hostent *WS_dup_he(const struct hostent* p_he);
 233 static struct WS_protoent *WS_dup_pe(const struct protoent* p_pe);
 234 static struct WS_servent *WS_dup_se(const struct servent* p_se);
 235
 236 int WSAIOCTL_GetInterfaceCount(void);
 237 int WSAIOCTL_GetInterfaceName(int intNumber, char *intName);
 238
 239 UINT wsaErrno(void);
 240 UINT wsaHerrno(int errnr);
 241
 242 #define MAP_OPTION(opt) { WS_##opt, opt }
 243
 244 static const int ws_sock_map[][2] =
 245 {
 246     MAP_OPTION( SO_DEBUG ),
 247     MAP_OPTION( SO_ACCEPTCONN ),
 248     MAP_OPTION( SO_REUSEADDR ),
 249     MAP_OPTION( SO_KEEPALIVE ),
 250     MAP_OPTION( SO_DONTROUTE ),
 251     MAP_OPTION( SO_BROADCAST ),
 252     MAP_OPTION( SO_LINGER ),
 253     MAP_OPTION( SO_OOBINLINE ),
 254     MAP_OPTION( SO_SNDBUF ),
 255     MAP_OPTION( SO_RCVBUF ),
 256     MAP_OPTION( SO_ERROR ),
 257     MAP_OPTION( SO_TYPE ),
 258 #ifdef SO_RCVTIMEO
 259     MAP_OPTION( SO_RCVTIMEO ),
 260 #endif
 261 #ifdef SO_SNDTIMEO
 262     MAP_OPTION( SO_SNDTIMEO ),
 263 #endif
 264 };
 265
 266 static const int ws_tcp_map[][2] =
 267 {
 268 #ifdef TCP_NODELAY
 269     MAP_OPTION( TCP_NODELAY ),
 270 #endif
 271 };
 272
 273 static const int ws_ip_map[][2] =
 274 {
 275     MAP_OPTION( IP_MULTICAST_IF ),
 276     MAP_OPTION( IP_MULTICAST_TTL ),
 277     MAP_OPTION( IP_MULTICAST_LOOP ),
 278     MAP_OPTION( IP_ADD_MEMBERSHIP ),
 279     MAP_OPTION( IP_DROP_MEMBERSHIP ),
 280     MAP_OPTION( IP_OPTIONS ),
 281 #ifdef IP_HDRINCL
 282     MAP_OPTION( IP_HDRINCL ),
 283 #endif
 284     MAP_OPTION( IP_TOS ),
 285     MAP_OPTION( IP_TTL ),
 286 };
 287
 288 static const int ws_af_map[][2] =
 289 {
 290     MAP_OPTION( AF_UNSPEC ),
 291     MAP_OPTION( AF_INET ),
 292     MAP_OPTION( AF_INET6 ),
 293 #ifdef HAVE_IPX
 294     MAP_OPTION( AF_IPX ),
 295 #endif
 296 };
 297
 298 static const int ws_socktype_map[][2] =
 299 {
 300     MAP_OPTION( SOCK_DGRAM ),
 301     MAP_OPTION( SOCK_STREAM ),
 302     MAP_OPTION( SOCK_RAW ),
 303 };
 304
 305 static const int ws_proto_map[][2] =
 306 {
 307     MAP_OPTION( IPPROTO_IP ),
 308     MAP_OPTION( IPPROTO_TCP ),
 309     MAP_OPTION( IPPROTO_UDP ),
 310     MAP_OPTION( IPPROTO_ICMP ),
 311     MAP_OPTION( IPPROTO_IGMP ),
 312     MAP_OPTION( IPPROTO_RAW ),
 313 };
 314
 315 static const int ws_aiflag_map[][2] =
 316 {
 317     MAP_OPTION( AI_PASSIVE ),
 318     MAP_OPTION( AI_CANONNAME ),
 319     MAP_OPTION( AI_NUMERICHOST ),
 320     /* Linux/UNIX knows a lot more. But Windows only
 321      * has 3 as far as I could see. -Marcus
 322      */
 323 };
 324
 325 static const int ws_eai_map[][2] =
 326 {
 327     MAP_OPTION( EAI_AGAIN ),
 328     MAP_OPTION( EAI_BADFLAGS ),
 329     MAP_OPTION( EAI_FAIL ),
 330     MAP_OPTION( EAI_FAMILY ),
 331     MAP_OPTION( EAI_MEMORY ),
 332 /* Note: EAI_NODATA is deprecated, but still
 333  * used by Windows and Linux... We map the newer
 334  * EAI_NONAME to EAI_NODATA for now until Windows
 335  * changes too.
 336  */
 337 #ifdef EAI_NODATA
 338     MAP_OPTION( EAI_NODATA ),
 339 #endif
 340 #ifdef EAI_NONAME
 341     { WS_EAI_NODATA, EAI_NONAME },
 342 #endif
 343
 344     MAP_OPTION( EAI_SERVICE ),
 345     MAP_OPTION( EAI_SOCKTYPE ),
 346     { 0, 0 }
 347 };
 348
 349 inline static DWORD NtStatusToWSAError( const DWORD status )
 350 {
 351     /* We only need to cover the status codes set by server async request handling */
 352     DWORD wserr;
 353     switch ( status )
 354     {
 355     case STATUS_SUCCESS:              wserr = 0;                     break;
 356     case STATUS_PENDING:              wserr = WSA_IO_PENDING;        break;
 357     case STATUS_INVALID_HANDLE:       wserr = WSAENOTSOCK;           break;  /* WSAEBADF ? */
 358     case STATUS_INVALID_PARAMETER:    wserr = WSAEINVAL;             break;
 359     case STATUS_PIPE_DISCONNECTED:    wserr = WSAESHUTDOWN;          break;
 360     case STATUS_CANCELLED:            wserr = WSA_OPERATION_ABORTED; break;
 361     case STATUS_TIMEOUT:              wserr = WSAETIMEDOUT;          break;
 362     case STATUS_NO_MEMORY:            wserr = WSAEFAULT;             break;
 363     default:
 364         if ( status >= WSABASEERR && status <= WSABASEERR+1004 )
 365             /* It is not a NT status code but a winsock error */
 366             wserr = status;
 367         else
 368         {
 369             wserr = RtlNtStatusToDosError( status );
 370             FIXME( "Status code %08x converted to DOS error code %x\n", status, wserr );
 371         }
 372     }
 373     return wserr;
 374 }
 375
 376 /* set last error code from NT status without mapping WSA errors */
 377 inline static unsigned int set_error( unsigned int err )
 378 {
 379     if (err)
 380     {
 381         err = NtStatusToWSAError( err );
 382         SetLastError( err );
 383     }
 384     return err;
 385 }
 386
 387 inline static int get_sock_fd( SOCKET s, DWORD access, int *flags )
 388 {
 389     int fd;
 390     if (set_error( wine_server_handle_to_fd( SOCKET2HANDLE(s), access, &fd, flags ) ))
 391         return -1;
 392     return fd;
 393 }
 394
 395 inline static void release_sock_fd( SOCKET s, int fd )
 396 {
 397     wine_server_release_fd( SOCKET2HANDLE(s), fd );
 398 }
 399
 400 static void _enable_event( HANDLE s, unsigned int event,
 401                            unsigned int sstate, unsigned int cstate )
 402 {
 403     SERVER_START_REQ( enable_socket_event )
 404     {
 405         req->handle = s;
 406         req->mask   = event;
 407         req->sstate = sstate;
 408         req->cstate = cstate;
 409         wine_server_call( req );
 410     }
 411     SERVER_END_REQ;
 412 }
 413
 414 static int _is_blocking(SOCKET s)
 415 {
 416     int ret;
 417     SERVER_START_REQ( get_socket_event )
 418     {
 419         req->handle  = SOCKET2HANDLE(s);
 420         req->service = FALSE;
 421         req->c_event = 0;
 422         wine_server_call( req );
 423         ret = (reply->state & FD_WINE_NONBLOCKING) == 0;
 424     }
 425     SERVER_END_REQ;
 426     return ret;
 427 }
 428
 429 static unsigned int _get_sock_mask(SOCKET s)
 430 {
 431     unsigned int ret;
 432     SERVER_START_REQ( get_socket_event )
 433     {
 434         req->handle  = SOCKET2HANDLE(s);
 435         req->service = FALSE;
 436         req->c_event = 0;
 437         wine_server_call( req );
 438         ret = reply->mask;
 439     }
 440     SERVER_END_REQ;
 441     return ret;
 442 }
 443
 444 static void _sync_sock_state(SOCKET s)
 445 {
 446     /* do a dummy wineserver request in order to let
 447        the wineserver run through its select loop once */
 448     (void)_is_blocking(s);
 449 }
 450
 451 static int _get_sock_error(SOCKET s, unsigned int bit)
 452 {
 453     int events[FD_MAX_EVENTS];
 454
 455     SERVER_START_REQ( get_socket_event )
 456     {
 457         req->handle  = SOCKET2HANDLE(s);
 458         req->service = FALSE;
 459         req->c_event = 0;
 460         wine_server_set_reply( req, events, sizeof(events) );
 461         wine_server_call( req );
 462     }
 463     SERVER_END_REQ;
 464     return events[bit];
 465 }
 466
 467 static struct per_thread_data *get_per_thread_data(void)
 468 {
 469     struct per_thread_data * ptb = NtCurrentTeb()->WinSockData;
 470     /* lazy initialization */
 471     if (!ptb)
 472     {
 473         ptb = HeapAlloc( GetProcessHeap(), HEAP_ZERO_MEMORY, sizeof(*ptb) );
 474         NtCurrentTeb()->WinSockData = ptb;
 475     }
 476     return ptb;
 477 }
 478
 479 static void free_per_thread_data(void)
 480 {
 481     struct per_thread_data * ptb = NtCurrentTeb()->WinSockData;
 482
 483     if (!ptb) return;
 484
 485     /* delete scratch buffers */
 486     HeapFree( GetProcessHeap(), 0, ptb->he_buffer );
 487     HeapFree( GetProcessHeap(), 0, ptb->se_buffer );
 488     HeapFree( GetProcessHeap(), 0, ptb->pe_buffer );
 489     ptb->he_buffer = NULL;
 490     ptb->se_buffer = NULL;
 491     ptb->pe_buffer = NULL;
 492
 493     HeapFree( GetProcessHeap(), 0, ptb );
 494     NtCurrentTeb()->WinSockData = NULL;
 495 }
 496
 497 /***********************************************************************
 498  *              DllMain (WS2_32.init)
 499  */
 500 BOOL WINAPI DllMain(HINSTANCE hInstDLL, DWORD fdwReason, LPVOID fImpLoad)
 501 {
 502     TRACE("%p 0x%x %p\n", hInstDLL, fdwReason, fImpLoad);
 503     switch (fdwReason) {
 504     case DLL_PROCESS_ATTACH:
 505         break;
 506     case DLL_PROCESS_DETACH:
 507         free_per_thread_data();
 508         num_startup = 0;
 509         break;
 510     case DLL_THREAD_DETACH:
 511         free_per_thread_data();
 512         break;
 513     }
 514     return TRUE;
 515 }
 516
 517 /***********************************************************************
 518  *          convert_sockopt()
 519  *
 520  * Converts socket flags from Windows format.
 521  * Return 1 if converted, 0 if not (error).
 522  */
 523 static int convert_sockopt(INT *level, INT *optname)
 524 {
 525   int i;
 526   switch (*level)
 527   {
 528      case WS_SOL_SOCKET:
 529         *level = SOL_SOCKET;
 530         for(i=0; i<sizeof(ws_sock_map)/sizeof(ws_sock_map[0]); i++) {
 531             if( ws_sock_map[i][0] == *optname )
 532             {
 533                 *optname = ws_sock_map[i][1];
 534                 return 1;
 535             }
 536         }
 537         FIXME("Unknown SOL_SOCKET optname 0x%x\n", *optname);
 538         break;
 539      case WS_IPPROTO_TCP:
 540         *level = IPPROTO_TCP;
 541         for(i=0; i<sizeof(ws_tcp_map)/sizeof(ws_tcp_map[0]); i++) {
 542             if ( ws_tcp_map[i][0] == *optname )
 543             {
 544                 *optname = ws_tcp_map[i][1];
 545                 return 1;
 546             }
 547         }
 548         FIXME("Unknown IPPROTO_TCP optname 0x%x\n", *optname);
 549         break;
 550      case WS_IPPROTO_IP:
 551         *level = IPPROTO_IP;
 552         for(i=0; i<sizeof(ws_ip_map)/sizeof(ws_ip_map[0]); i++) {
 553             if (ws_ip_map[i][0] == *optname )
 554             {
 555                 *optname = ws_ip_map[i][1];
 556                 return 1;
 557             }
 558         }
 559         FIXME("Unknown IPPROTO_IP optname 0x%x\n", *optname);
 560         break;
 561      default: FIXME("Unimplemented or unknown socket level\n");
 562   }
 563   return 0;
 564 }
 565
 566 static inline BOOL is_timeout_option( int optname )
 567 {
 568 #ifdef SO_RCVTIMEO
 569     if (optname == SO_RCVTIMEO) return TRUE;
 570 #endif
 571 #ifdef SO_SNDTIMEO
 572     if (optname == SO_SNDTIMEO) return TRUE;
 573 #endif
 574     return FALSE;
 575 }
 576
 577 /* ----------------------------------- Per-thread info (or per-process?) */
 578
 579 static char *strdup_lower(const char *str)
 580 {
 581     int i;
 582     char *ret = HeapAlloc( GetProcessHeap(), 0, strlen(str) + 1 );
 583
 584     if (ret)
 585     {
 586         for (i = 0; str[i]; i++) ret[i] = tolower(str[i]);
 587         ret[i] = 0;
 588     }
 589     else SetLastError(WSAENOBUFS);
 590     return ret;
 591 }
 592
 593 static fd_set* fd_set_import( fd_set* fds, const WS_fd_set* wsfds, int access, int* highfd, int lfd[] )
 594 {
 595     /* translate Winsock fd set into local fd set */
 596     if( wsfds )
 597     {
 598         unsigned int i;
 599
 600         FD_ZERO(fds);
 601         for( i = 0; i < wsfds->fd_count; i++ )
 602         {
 603             int s = wsfds->fd_array[i];
 604             int fd = get_sock_fd( s, access, NULL );
 605             if (fd != -1)
 606             {
 607                 lfd[ i ] = fd;
 608                 if( fd > *highfd ) *highfd = fd;
 609                 FD_SET(fd, fds);
 610             }
 611             else lfd[ i ] = -1;
 612         }
 613         return fds;
 614     }
 615     return NULL;
 616 }
 617
 618 inline static int sock_error_p(int s)
 619 {
 620     unsigned int optval, optlen;
 621
 622     optlen = sizeof(optval);
 623     getsockopt(s, SOL_SOCKET, SO_ERROR, (void *) &optval, &optlen);
 624     if (optval) WARN("\t[%i] error: %d\n", s, optval);
 625     return optval != 0;
 626 }
 627
 628 static int fd_set_export( const fd_set* fds, fd_set* exceptfds, WS_fd_set* wsfds, int lfd[] )
 629 {
 630     int num_err = 0;
 631
 632     /* translate local fd set into Winsock fd set, adding
 633      * errors to exceptfds (only if app requested it) */
 634
 635     if( wsfds )
 636     {
 637         int i, j, count = wsfds->fd_count;
 638
 639         for( i = 0, j = 0; i < count; i++ )
 640         {
 641             int fd = lfd[i];
 642             SOCKET s = wsfds->fd_array[i];
 643             if (fd == -1) continue;
 644             if( FD_ISSET(fd, fds) )
 645             {
 646                 if ( exceptfds && sock_error_p(fd) )
 647                 {
 648                     FD_SET(fd, exceptfds);
 649                     num_err++;
 650                 }
 651                 else wsfds->fd_array[j++] = s;
 652             }
 653             release_sock_fd( s, fd );
 654         }
 655         wsfds->fd_count = j;
 656     }
 657     return num_err;
 658 }
 659
 660 static void fd_set_unimport( WS_fd_set* wsfds, int lfd[] )
 661 {
 662     if ( wsfds )
 663     {
 664         unsigned int i;
 665
 666         for ( i = 0; i < wsfds->fd_count; i++ )
 667             if ( lfd[i] >= 0 ) release_sock_fd( wsfds->fd_array[i], lfd[i] );
 668         wsfds->fd_count = 0;
 669     }
 670 }
 671
 672 /* Utility: get the SO_RCVTIMEO or SO_SNDTIMEO socket option
 673  * from an fd and return the value converted to milli seconds
 674  * or -1 if there is an infinite time out */
 675 static inline int get_rcvsnd_timeo( int fd, int optname)
 676 {
 677   struct timeval tv;
 678   unsigned int len = sizeof(tv);
 679   int ret = getsockopt(fd, SOL_SOCKET, optname, &tv, &len);
 680   if( ret >= 0)
 681       ret = tv.tv_sec * 1000 + tv.tv_usec / 1000;
 682   if( ret <= 0 ) /* tv == {0,0} means infinite time out */
 683       return -1;
 684   return ret;
 685 }
 686
 687 /* macro wrappers for portability */
 688 #ifdef SO_RCVTIMEO
 689 #define GET_RCVTIMEO(fd) get_rcvsnd_timeo( (fd), SO_RCVTIMEO)
 690 #else
 691 #define GET_RCVTIMEO(fd) (-1)
 692 #endif
 693
 694 #ifdef SO_SNDTIMEO
 695 #define GET_SNDTIMEO(fd) get_rcvsnd_timeo( (fd), SO_SNDTIMEO)
 696 #else
 697 #define GET_SNDTIMEO(fd) (-1)
 698 #endif
 699
 700 /* utility: given an fd, will block until one of the events occurs */
 701 static inline int do_block( int fd, int events, int timeout )
 702 {
 703   struct pollfd pfd;
 704   int ret;
 705
 706   pfd.fd = fd;
 707   pfd.events = events;
 708
 709   while ((ret = poll(&pfd, 1, timeout)) < 0)
 710   {
 711       if (errno != EINTR)
 712           return -1;
 713   }
 714   if( ret == 0 )
 715       return 0;
 716   return pfd.revents;
 717 }
 718
 719 static int
 720 convert_af_w2u(int windowsaf) {
 721     int i;
 722
 723     for (i=0;i<sizeof(ws_af_map)/sizeof(ws_af_map[0]);i++)
 724         if (ws_af_map[i][0] == windowsaf)
 725             return ws_af_map[i][1];
 726     FIXME("unhandled Windows address family %d\n", windowsaf);
 727     return -1;
 728 }
 729
 730 static int
 731 convert_af_u2w(int unixaf) {
 732     int i;
 733
 734     for (i=0;i<sizeof(ws_af_map)/sizeof(ws_af_map[0]);i++)
 735         if (ws_af_map[i][1] == unixaf)
 736             return ws_af_map[i][0];
 737     FIXME("unhandled UNIX address family %d\n", unixaf);
 738     return -1;
 739 }
 740
 741 static int
 742 convert_proto_w2u(int windowsproto) {
 743     int i;
 744
 745     for (i=0;i<sizeof(ws_proto_map)/sizeof(ws_proto_map[0]);i++)
 746         if (ws_proto_map[i][0] == windowsproto)
 747             return ws_proto_map[i][1];
 748     FIXME("unhandled Windows socket protocol %d\n", windowsproto);
 749     return -1;
 750 }
 751
 752 static int
 753 convert_proto_u2w(int unixproto) {
 754     int i;
 755
 756     for (i=0;i<sizeof(ws_proto_map)/sizeof(ws_proto_map[0]);i++)
 757         if (ws_proto_map[i][1] == unixproto)
 758             return ws_proto_map[i][0];
 759     FIXME("unhandled UNIX socket protocol %d\n", unixproto);
 760     return -1;
 761 }
 762
 763 static int
 764 convert_socktype_w2u(int windowssocktype) {
 765     int i;
 766
 767     for (i=0;i<sizeof(ws_socktype_map)/sizeof(ws_socktype_map[0]);i++)
 768         if (ws_socktype_map[i][0] == windowssocktype)
 769             return ws_socktype_map[i][1];
 770     FIXME("unhandled Windows socket type %d\n", windowssocktype);
 771     return -1;
 772 }
 773
 774 static int
 775 convert_socktype_u2w(int unixsocktype) {
 776     int i;
 777
 778     for (i=0;i<sizeof(ws_socktype_map)/sizeof(ws_socktype_map[0]);i++)
 779         if (ws_socktype_map[i][1] == unixsocktype)
 780             return ws_socktype_map[i][0];
 781     FIXME("unhandled UNIX socket type %d\n", unixsocktype);
 782     return -1;
 783 }
 784
 785 /* ----------------------------------- API -----
 786  *
 787  * Init / cleanup / error checking.
 788  */
 789
 790 /***********************************************************************
 791  *      WSAStartup              (WS2_32.115)
 792  */
 793 int WINAPI WSAStartup(WORD wVersionRequested, LPWSADATA lpWSAData)
 794 {
 795     TRACE("verReq=%x\n", wVersionRequested);
 796
 797     if (LOBYTE(wVersionRequested) < 1)
 798         return WSAVERNOTSUPPORTED;
 799
 800     if (!lpWSAData) return WSAEINVAL;
 801
 802     num_startup++;
 803
 804     /* that's the whole of the negotiation for now */
 805     lpWSAData->wVersion = wVersionRequested;
 806     /* return winsock information */
 807     lpWSAData->wHighVersion = 0x0202;
 808     strcpy(lpWSAData->szDescription, "WinSock 2.0" );
 809     strcpy(lpWSAData->szSystemStatus, "Running" );
 810     lpWSAData->iMaxSockets = WS_MAX_SOCKETS_PER_PROCESS;
 811     lpWSAData->iMaxUdpDg = WS_MAX_UDP_DATAGRAM;
 812     /* don't do anything with lpWSAData->lpVendorInfo */
 813     /* (some apps don't allocate the space for this field) */
 814
 815     TRACE("succeeded\n");
 816     return 0;
 817 }
 818
 819
 820 /***********************************************************************
 821  *      WSACleanup                      (WS2_32.116)
 822  */
 823 INT WINAPI WSACleanup(void)
 824 {
 825     if (num_startup) {
 826         num_startup--;
 827         return 0;
 828     }
 829     SetLastError(WSANOTINITIALISED);
 830     return SOCKET_ERROR;
 831 }
 832
 833
 834 /***********************************************************************
 835  *      WSAGetLastError         (WINSOCK.111)
 836  *      WSAGetLastError         (WS2_32.111)
 837  */
 838 INT WINAPI WSAGetLastError(void)
 839 {
 840         return GetLastError();
 841 }
 842
 843 /***********************************************************************
 844  *      WSASetLastError         (WS2_32.112)
 845  */
 846 void WINAPI WSASetLastError(INT iError) {
 847     SetLastError(iError);
 848 }
 849
 850 static struct WS_hostent *check_buffer_he(int size)
 851 {
 852     struct per_thread_data * ptb = get_per_thread_data();
 853     if (ptb->he_buffer)
 854     {
 855         if (ptb->he_len >= size ) return ptb->he_buffer;
 856         HeapFree( GetProcessHeap(), 0, ptb->he_buffer );
 857     }
 858     ptb->he_buffer = HeapAlloc( GetProcessHeap(), 0, (ptb->he_len = size) );
 859     if (!ptb->he_buffer) SetLastError(WSAENOBUFS);
 860     return ptb->he_buffer;
 861 }
 862
 863 static struct WS_servent *check_buffer_se(int size)
 864 {
 865     struct per_thread_data * ptb = get_per_thread_data();
 866     if (ptb->se_buffer)
 867     {
 868         if (ptb->se_len >= size ) return ptb->se_buffer;
 869         HeapFree( GetProcessHeap(), 0, ptb->se_buffer );
 870     }
 871     ptb->se_buffer = HeapAlloc( GetProcessHeap(), 0, (ptb->se_len = size) );
 872     if (!ptb->se_buffer) SetLastError(WSAENOBUFS);
 873     return ptb->se_buffer;
 874 }
 875
 876 static struct WS_protoent *check_buffer_pe(int size)
 877 {
 878     struct per_thread_data * ptb = get_per_thread_data();
 879     if (ptb->pe_buffer)
 880     {
 881         if (ptb->pe_len >= size ) return ptb->pe_buffer;
 882         HeapFree( GetProcessHeap(), 0, ptb->pe_buffer );
 883     }
 884     ptb->pe_buffer = HeapAlloc( GetProcessHeap(), 0, (ptb->pe_len = size) );
 885     if (!ptb->pe_buffer) SetLastError(WSAENOBUFS);
 886     return ptb->pe_buffer;
 887 }
 888
 889 /* ----------------------------------- i/o APIs */
 890
 891 #ifdef HAVE_IPX
 892 #define SUPPORTED_PF(pf) ((pf)==WS_AF_INET || (pf)== WS_AF_IPX || (pf) == WS_AF_INET6)
 893 #else
 894 #define SUPPORTED_PF(pf) ((pf)==WS_AF_INET || (pf) == WS_AF_INET6)
 895 #endif
 896
 897
 898 /**********************************************************************/
 899
 900 /* Returns the converted address if successful, NULL if it was too small to
 901  * start with. Note that the returned pointer may be the original pointer
 902  * if no conversion is necessary.
 903  */
 904 static struct sockaddr* ws_sockaddr_ws2u(const struct WS_sockaddr* wsaddr, int wsaddrlen, unsigned int *uaddrlen)
 905 {
 906     switch (wsaddr->sa_family)
 907     {
 908 #ifdef HAVE_IPX
 909     case WS_AF_IPX:
 910         {
 911             const struct WS_sockaddr_ipx* wsipx=(const struct WS_sockaddr_ipx*)wsaddr;
 912             struct sockaddr_ipx* uipx;
 913
 914             if (wsaddrlen<sizeof(struct WS_sockaddr_ipx))
 915                 return NULL;
 916
 917             *uaddrlen=sizeof(struct sockaddr_ipx);
 918             uipx=HeapAlloc(GetProcessHeap(), HEAP_ZERO_MEMORY, *uaddrlen);
 919             uipx->sipx_family=AF_IPX;
 920             uipx->sipx_port=wsipx->sa_socket;
 921             /* copy sa_netnum and sa_nodenum to sipx_network and sipx_node
 922              * in one go
 923              */
 924             memcpy(&uipx->sipx_network,wsipx->sa_netnum,sizeof(uipx->sipx_network)+sizeof(uipx->sipx_node));
 925 #ifdef IPX_FRAME_NONE
 926             uipx->sipx_type=IPX_FRAME_NONE;
 927 #endif
 928             return (struct sockaddr*)uipx;
 929         }
 930 #endif
 931     case WS_AF_INET6: {
 932         struct sockaddr_in6* uin6;
 933         const struct WS_sockaddr_in6* win6 = (struct WS_sockaddr_in6*)wsaddr;
 934
 935         /* Note: Windows has 2 versions of the sockaddr_in6 struct, one with
 936          * scope_id, one without. Check:
 937          * http://msdn.microsoft.com/library/en-us/winsock/winsock/sockaddr_2.asp
 938          */
 939         if (wsaddrlen >= sizeof(struct WS_sockaddr_in6_old)) {
 940             *uaddrlen=sizeof(struct sockaddr_in6);
 941             uin6=HeapAlloc(GetProcessHeap(), HEAP_ZERO_MEMORY, *uaddrlen);
 942             uin6->sin6_family   = AF_INET6;
 943             uin6->sin6_port     = win6->sin6_port;
 944             uin6->sin6_flowinfo = win6->sin6_flowinfo;
 945 #ifdef HAVE_STRUCT_SOCKADDR_IN6_SIN6_SCOPE_ID
 946             if (wsaddrlen >= sizeof(struct WS_sockaddr_in6)) uin6->sin6_scope_id = win6->sin6_scope_id;
 947 #endif
 948             memcpy(&uin6->sin6_addr,&win6->sin6_addr,16); /* 16 bytes = 128 address bits */
 949             return (struct sockaddr*)uin6;
 950         }
 951         FIXME("bad size %d for WS_sockaddr_in6\n",wsaddrlen);
 952         return NULL;
 953     }
 954     case WS_AF_INET: {
 955         struct sockaddr_in* uin;
 956         const struct WS_sockaddr_in* win = (struct WS_sockaddr_in*)wsaddr;
 957
 958         if (wsaddrlen<sizeof(struct WS_sockaddr_in))
 959             return NULL;
 960         *uaddrlen=sizeof(struct sockaddr_in);
 961         uin = HeapAlloc(GetProcessHeap(), HEAP_ZERO_MEMORY, *uaddrlen);
 962         uin->sin_family = AF_INET;
 963         uin->sin_port   = win->sin_port;
 964         memcpy(&uin->sin_addr,&win->sin_addr,4); /* 4 bytes = 32 address bits */
 965         return (struct sockaddr*)uin;
 966     }
 967     case WS_AF_UNSPEC: {
 968         /* Try to determine the needed space by the passed windows sockaddr space */
 969         switch (wsaddrlen) {
 970         default: /* likely a ipv4 address */
 971         case sizeof(struct WS_sockaddr_in):
 972             *uaddrlen = sizeof(struct sockaddr_in);
 973             break;
 974 #ifdef HAVE_IPX
 975         case sizeof(struct WS_sockaddr_ipx):
 976             *uaddrlen = sizeof(struct sockaddr_ipx);
 977             break;
 978 #endif
 979         case sizeof(struct WS_sockaddr_in6):
 980         case sizeof(struct WS_sockaddr_in6_old):
 981             *uaddrlen = sizeof(struct sockaddr_in6);
 982             break;
 983         }
 984         return HeapAlloc(GetProcessHeap(),HEAP_ZERO_MEMORY,*uaddrlen);
 985     }
 986     default:
 987         FIXME("Unknown address family %d, return NULL.\n", wsaddr->sa_family);
 988         return NULL;
 989     }
 990 }
 991
 992 /* Allocates a Unix sockaddr structure to receive the data */
 993 static inline struct sockaddr* ws_sockaddr_alloc(const struct WS_sockaddr* wsaddr, int* wsaddrlen, unsigned int* uaddrlen)
 994 {
 995     if (wsaddr==NULL)
 996     {
 997       ERR( "WINE shouldn't pass a NULL wsaddr! Attempting to continue\n" );
 998
 999       /* This is not strictly the right thing to do. Hope it works however */
1000       *uaddrlen=0;
1001
1002       return NULL;
1003     }
1004
1005     if (*wsaddrlen==0)
1006         *uaddrlen=0;
1007     else
1008         *uaddrlen=max(sizeof(struct sockaddr),*wsaddrlen);
1009
1010     return HeapAlloc(GetProcessHeap(), HEAP_ZERO_MEMORY, *uaddrlen);
1011 }
1012
1013 /* Returns 0 if successful, -1 if the buffer is too small */
1014 static int ws_sockaddr_u2ws(const struct sockaddr* uaddr, int uaddrlen, struct WS_sockaddr* wsaddr, int* wsaddrlen)
1015 {
1016     int res;
1017
1018     switch(uaddr->sa_family)
1019     {
1020 #ifdef HAVE_IPX
1021     case AF_IPX:
1022         {
1023             const struct sockaddr_ipx* uipx=(const struct sockaddr_ipx*)uaddr;
1024             struct WS_sockaddr_ipx* wsipx=(struct WS_sockaddr_ipx*)wsaddr;
1025
1026             res=-1;
1027             switch (*wsaddrlen) /* how much can we copy? */
1028             {
1029             default:
1030                 res=0; /* enough */
1031                 *wsaddrlen=uaddrlen;
1032                 wsipx->sa_socket=uipx->sipx_port;
1033                 /* fall through */
1034             case 13:
1035             case 12:
1036                 memcpy(wsipx->sa_nodenum,uipx->sipx_node,sizeof(wsipx->sa_nodenum));
1037                 /* fall through */
1038             case 11:
1039             case 10:
1040             case 9:
1041             case 8:
1042             case 7:
1043             case 6:
1044                 memcpy(wsipx->sa_netnum,&uipx->sipx_network,sizeof(wsipx->sa_netnum));
1045                 /* fall through */
1046             case 5:
1047             case 4:
1048             case 3:
1049             case 2:
1050                 wsipx->sa_family=WS_AF_IPX;
1051                 /* fall through */
1052             case 1:
1053             case 0:
1054                 /* way too small */
1055                 break;
1056             }
1057         }
1058         break;
1059 #endif
1060     case AF_INET6: {
1061         const struct sockaddr_in6* uin6 = (struct sockaddr_in6*)uaddr;
1062         struct WS_sockaddr_in6_old* win6old = (struct WS_sockaddr_in6_old*)wsaddr;
1063
1064         if (*wsaddrlen < sizeof(struct WS_sockaddr_in6_old))
1065             return -1;
1066         win6old->sin6_family   = WS_AF_INET6;
1067         win6old->sin6_port     = uin6->sin6_port;
1068         win6old->sin6_flowinfo = uin6->sin6_flowinfo;
1069         memcpy(&win6old->sin6_addr,&uin6->sin6_addr,16); /* 16 bytes = 128 address bits */
1070         *wsaddrlen = sizeof(struct WS_sockaddr_in6_old);
1071 #ifdef HAVE_STRUCT_SOCKADDR_IN6_SIN6_SCOPE_ID
1072         if (*wsaddrlen >= sizeof(struct WS_sockaddr_in6)) {
1073             struct WS_sockaddr_in6* win6 = (struct WS_sockaddr_in6*)wsaddr;
1074             win6->sin6_scope_id = uin6->sin6_scope_id;
1075             *wsaddrlen = sizeof(struct WS_sockaddr_in6);
1076         }
1077 #endif
1078         return 0;
1079     }
1080     case AF_INET: {
1081         struct sockaddr_in* uin = (struct sockaddr_in*)uaddr;
1082         struct WS_sockaddr_in* win = (struct WS_sockaddr_in*)wsaddr;
1083
1084         if (*wsaddrlen < sizeof(struct WS_sockaddr_in))
1085             return -1;
1086         win->sin_family = WS_AF_INET;
1087         win->sin_port   = uin->sin_port;
1088         memcpy(&win->sin_addr,&uin->sin_addr,4); /* 4 bytes = 32 address bits */
1089         *wsaddrlen = sizeof(struct WS_sockaddr_in);
1090         return 0;
1091     }
1092     case AF_UNSPEC: {
1093         memset(wsaddr,0,*wsaddrlen);
1094         return 0;
1095     }
1096     default:
1097         FIXME("Unknown address family %d\n", uaddr->sa_family);
1098         return -1;
1099     }
1100     return res;
1101 }
1102
1103 /* to be called to free the memory allocated by ws_sockaddr_ws2u or
1104  * ws_sockaddr_alloc
1105  */
1106 static inline void ws_sockaddr_free(const struct sockaddr* uaddr, const struct WS_sockaddr* wsaddr)
1107 {
1108     if (uaddr!=(const struct sockaddr*)wsaddr)
1109         HeapFree(GetProcessHeap(), 0, (void *)uaddr);
1110 }
1111
1112 /**************************************************************************
1113  * Functions for handling overlapped I/O
1114  **************************************************************************/
1115
1116 static void CALLBACK ws2_async_terminate(ws2_async* as, IO_STATUS_BLOCK* iosb)
1117 {
1118     TRACE( "as: %p uovl %p ovl %p\n", as, as->user_overlapped, iosb );
1119
1120     wine_server_release_fd( as->hSocket, as->fd );
1121     if ( as->event != INVALID_HANDLE_VALUE )
1122         NtSetEvent( as->event, NULL );
1123
1124     if (as->completion_func)
1125         as->completion_func( NtStatusToWSAError (iosb->u.Status),
1126                              iosb->Information, as->user_overlapped, as->flags );
1127     if ( !as->user_overlapped )
1128     {
1129 #if 0
1130         /* FIXME: I don't think this is really used */
1131         if ( as->overlapped->hEvent != INVALID_HANDLE_VALUE )
1132             WSACloseEvent( as->overlapped->hEvent  );
1133 #endif
1134         HeapFree( GetProcessHeap(), 0, iosb );
1135     }
1136
1137     HeapFree( GetProcessHeap(), 0, as->iovec );
1138     HeapFree( GetProcessHeap(), 0, as );
1139 }
1140
1141 /***********************************************************************
1142  *              WS2_make_async          (INTERNAL)
1143  */
1144
1145 static void WINAPI WS2_async_recv(void*, IO_STATUS_BLOCK*, ULONG);
1146 static void WINAPI WS2_async_send(void*, IO_STATUS_BLOCK*, ULONG);
1147 static void WINAPI WS2_async_shutdown( void*, IO_STATUS_BLOCK*, ULONG);
1148
1149 inline static struct ws2_async*
1150 WS2_make_async(SOCKET s, int fd, enum ws2_mode mode, struct iovec *iovec, DWORD dwBufferCount,
1151                LPDWORD lpFlags, struct WS_sockaddr *addr,
1152                LPINT addrlen, LPWSAOVERLAPPED lpOverlapped,
1153                LPWSAOVERLAPPED_COMPLETION_ROUTINE lpCompletionRoutine,
1154                IO_STATUS_BLOCK **piosb)
1155 {
1156     struct ws2_async *wsa = HeapAlloc( GetProcessHeap(), 0, sizeof( ws2_async ) );
1157
1158     TRACE( "wsa %p\n", wsa );
1159
1160     if (!wsa)
1161         return NULL;
1162
1163     wsa->hSocket = (HANDLE) s;
1164     wsa->mode = mode;
1165     switch (mode)
1166     {
1167     case ws2m_read:
1168     case ws2m_sd_read:
1169         wsa->flags = *lpFlags;
1170         wsa->addrlen.ptr = addrlen;
1171         break;
1172     case ws2m_write:
1173     case ws2m_sd_write:
1174         wsa->flags = 0;
1175         wsa->addrlen.val = *addrlen;
1176         break;
1177     default:
1178         ERR("Invalid async mode: %d\n", mode);
1179     }
1180     wsa->user_overlapped = lpOverlapped;
1181     wsa->completion_func = lpCompletionRoutine;
1182     wsa->iovec = iovec;
1183     wsa->n_iovecs = dwBufferCount;
1184     wsa->addr = addr;
1185     wsa->fd = fd;
1186     wsa->event = INVALID_HANDLE_VALUE;
1187
1188     if ( lpOverlapped )
1189     {
1190         *piosb = (IO_STATUS_BLOCK*)lpOverlapped;
1191         if (!lpCompletionRoutine)
1192         {
1193             wsa->event = lpOverlapped->hEvent;
1194             NtResetEvent(wsa->event, NULL);
1195         }
1196     }
1197     else if (!(*piosb = HeapAlloc( GetProcessHeap(), 0, sizeof(IO_STATUS_BLOCK))))
1198         goto error;
1199
1200     (*piosb)->Information = 0;
1201     (*piosb)->u.Status = STATUS_PENDING;
1202     TRACE( "wsa %p, h %p, ev %p, fd %d, iosb %p, uov %p, cfunc %p\n",
1203            wsa, wsa->hSocket, wsa->event, wsa->fd,
1204            *piosb, wsa->user_overlapped, wsa->completion_func );
1205
1206     return wsa;
1207
1208 error:
1209     TRACE("Error\n");
1210     HeapFree( GetProcessHeap(), 0, wsa );
1211     return NULL;
1212 }
1213
1214 static ULONG ws2_queue_async(struct ws2_async* wsa, IO_STATUS_BLOCK* iosb)
1215 {
1216     PIO_APC_ROUTINE     apc;
1217     int                 type;
1218     NTSTATUS            status;
1219
1220     switch (wsa->mode)
1221     {
1222     case ws2m_read:     apc = WS2_async_recv;     type = ASYNC_TYPE_READ;  break;
1223     case ws2m_write:    apc = WS2_async_send;     type = ASYNC_TYPE_WRITE; break;
1224     case ws2m_sd_read:  apc = WS2_async_shutdown; type = ASYNC_TYPE_READ;  break;
1225     case ws2m_sd_write: apc = WS2_async_shutdown; type = ASYNC_TYPE_WRITE; break;
1226     default: FIXME("Unknown internal mode (%d)\n", wsa->mode); return STATUS_INVALID_PARAMETER;
1227     }
1228
1229     SERVER_START_REQ( register_async )
1230     {
1231         req->handle = wsa->hSocket;
1232         req->io_apc = apc;
1233         req->io_sb = iosb;
1234         req->io_user = wsa;
1235         req->type = type;
1236         req->count = iosb->Information;
1237         status = wine_server_call( req );
1238     }
1239     SERVER_END_REQ;
1240
1241     if ( status ) iosb->u.Status = status;
1242     if ( iosb->u.Status != STATUS_PENDING )
1243     {
1244         /* Note: we get here a non zero status when we couldn't queue the async
1245          * in the server. Therefore, we simply terminate the async.
1246          */
1247         status = iosb->u.Status;
1248         ws2_async_terminate(wsa, iosb);
1249         return status;
1250     }
1251     NtCurrentTeb()->num_async_io++;
1252     return STATUS_SUCCESS;
1253 }
1254
1255 /***********************************************************************
1256  *              WS2_recv                (INTERNAL)
1257  *
1258  * Workhorse for both synchronous and asynchronous recv() operations.
1259  */
1260 static int WS2_recv( int fd, struct iovec* iov, int count,
1261                      struct WS_sockaddr *lpFrom, LPINT lpFromlen,
1262                       LPDWORD lpFlags )
1263 {
1264     struct msghdr hdr;
1265     int n;
1266     TRACE( "fd %d, iovec %p, count %d addr %s, len %p, flags %x\n",
1267            fd, iov, count, debugstr_sockaddr(lpFrom), lpFromlen, *lpFlags);
1268
1269     hdr.msg_name = NULL;
1270
1271     if ( lpFrom )
1272     {
1273         hdr.msg_namelen = *lpFromlen;
1274         hdr.msg_name = ws_sockaddr_alloc( lpFrom, lpFromlen, &hdr.msg_namelen );
1275         if ( !hdr.msg_name )
1276         {
1277             WSASetLastError( WSAEFAULT );
1278             n = -1;
1279             goto out;
1280         }
1281     }
1282     else
1283         hdr.msg_namelen = 0;
1284
1285     hdr.msg_iov = iov;
1286     hdr.msg_iovlen = count;
1287 #ifdef HAVE_STRUCT_MSGHDR_MSG_ACCRIGHTS
1288     hdr.msg_accrights = NULL;
1289     hdr.msg_accrightslen = 0;
1290 #else
1291     hdr.msg_control = NULL;
1292     hdr.msg_controllen = 0;
1293     hdr.msg_flags = 0;
1294 #endif
1295
1296     if ( (n = recvmsg(fd, &hdr, *lpFlags)) == -1 )
1297     {
1298         TRACE( "recvmsg error %d\n", errno);
1299         goto out;
1300     }
1301
1302     if ( lpFrom &&
1303          ws_sockaddr_u2ws( hdr.msg_name, hdr.msg_namelen,
1304                            lpFrom, lpFromlen ) != 0 )
1305     {
1306         /* The from buffer was too small, but we read the data
1307          * anyway. Is that really bad?
1308          */
1309         WSASetLastError( WSAEFAULT );
1310         WARN( "Address buffer too small\n" );
1311     }
1312
1313 out:
1314
1315     ws_sockaddr_free( hdr.msg_name, lpFrom );
1316     TRACE("-> %d\n", n);
1317     return n;
1318 }
1319
1320 /***********************************************************************
1321  *              WS2_async_recv          (INTERNAL)
1322  *
1323  * Handler for overlapped recv() operations.
1324  */
1325 static void WINAPI WS2_async_recv( void* ovp, IO_STATUS_BLOCK* iosb, ULONG status)
1326 {
1327     ws2_async* wsa = (ws2_async*) ovp;
1328     int result, err;
1329
1330     TRACE( "(%p %p %x)\n", wsa, iosb, status );
1331
1332     switch (status)
1333     {
1334     case STATUS_ALERTED:
1335         result = WS2_recv( wsa->fd, wsa->iovec, wsa->n_iovecs,
1336                            wsa->addr, wsa->addrlen.ptr, &wsa->flags );
1337         if (result >= 0)
1338         {
1339             iosb->u.Status = STATUS_SUCCESS;
1340             iosb->Information = result;
1341             TRACE( "received %d bytes\n", result );
1342             _enable_event( wsa->hSocket, FD_READ, 0, 0 );
1343         }
1344         else
1345         {
1346             err = wsaErrno();
1347             if ( err == WSAEINTR || err == WSAEWOULDBLOCK )  /* errno: EINTR / EAGAIN */
1348             {
1349                 iosb->u.Status = STATUS_PENDING;
1350                 _enable_event( wsa->hSocket, FD_READ, 0, 0 );
1351                 TRACE( "still pending\n" );
1352             }
1353             else
1354             {
1355                 iosb->u.Status = err; /* FIXME: is this correct ???? */
1356                 TRACE( "Error: %x\n", err );
1357             }
1358         }
1359         if (iosb->u.Status == STATUS_PENDING)
1360             ws2_queue_async(wsa, iosb);
1361         else
1362             ws2_async_terminate(wsa, iosb);
1363         break;
1364     default:
1365         FIXME( "status: %d\n", status );
1366         iosb->u.Status = status;
1367         ws2_async_terminate(wsa, iosb);
1368         return;
1369     }
1370 }
1371
1372 /***********************************************************************
1373  *              WS2_send                (INTERNAL)
1374  *
1375  * Workhorse for both synchronous and asynchronous send() operations.
1376  */
1377 static int WS2_send( int fd, struct iovec* iov, int count,
1378                      const struct WS_sockaddr *to, INT tolen, DWORD dwFlags )
1379 {
1380     struct msghdr hdr;
1381     int n = -1;
1382     TRACE( "fd %d, iovec %p, count %d addr %s, len %d, flags %x\n",
1383            fd, iov, count, debugstr_sockaddr(to), tolen, dwFlags);
1384
1385     hdr.msg_name = NULL;
1386
1387     if ( to )
1388     {
1389         hdr.msg_name = (struct sockaddr*) ws_sockaddr_ws2u( to, tolen, &hdr.msg_namelen );
1390         if ( !hdr.msg_name )
1391         {
1392             WSASetLastError( WSAEFAULT );
1393             goto out;
1394         }
1395
1396 #ifdef HAVE_IPX
1397         if(to->sa_family == WS_AF_IPX)
1398         {
1399 #ifdef SOL_IPX
1400             struct sockaddr_ipx* uipx = (struct sockaddr_ipx*)hdr.msg_name;
1401             int val=0;
1402             unsigned int len=sizeof(int);
1403
1404             /* The packet type is stored at the ipx socket level; At least the linux kernel seems
1405              *  to do something with it in case hdr.msg_name is NULL. Nonetheless can we use it to store
1406              *  the packet type and then we can retrieve it using getsockopt. After that we can set the
1407              *  ipx type in the sockaddr_opx structure with the stored value.
1408              */
1409             if(getsockopt(fd, SOL_IPX, IPX_TYPE, &val, &len) != -1)
1410             {
1411                 TRACE("ptype: %d (fd:%d)\n", val, fd);
1412                 uipx->sipx_type = val;
1413             }
1414 #endif
1415         }
1416 #endif
1417
1418     }
1419     else
1420         hdr.msg_namelen = 0;
1421
1422     hdr.msg_iov = iov;
1423     hdr.msg_iovlen = count;
1424 #ifdef HAVE_STRUCT_MSGHDR_MSG_ACCRIGHTS
1425     hdr.msg_accrights = NULL;
1426     hdr.msg_accrightslen = 0;
1427 #else
1428     hdr.msg_control = NULL;
1429     hdr.msg_controllen = 0;
1430     hdr.msg_flags = 0;
1431 #endif
1432
1433     n = sendmsg(fd, &hdr, dwFlags);
1434
1435 out:
1436     ws_sockaddr_free( hdr.msg_name, to );
1437     return n;
1438 }
1439
1440 /***********************************************************************
1441  *              WS2_async_send          (INTERNAL)
1442  *
1443  * Handler for overlapped send() operations.
1444  */
1445 static void WINAPI WS2_async_send(void* as, IO_STATUS_BLOCK* iosb, ULONG status)
1446 {
1447     ws2_async* wsa = (ws2_async*) as;
1448     int result;
1449
1450     TRACE( "(%p %p %x)\n", wsa, iosb, status );
1451
1452     switch (status)
1453     {
1454     case STATUS_ALERTED:
1455         if (iosb->u.Status != STATUS_PENDING) FIXME("wrong %08x\n", iosb->u.Status);
1456         /* check to see if the data is ready (non-blocking) */
1457         result = WS2_send( wsa->fd, wsa->iovec, wsa->n_iovecs,
1458                            wsa->addr, wsa->addrlen.val, wsa->flags );
1459
1460         if (result >= 0)
1461         {
1462             iosb->u.Status = STATUS_SUCCESS;
1463             iosb->Information = result;
1464             TRACE( "sent %d bytes\n", result );
1465             _enable_event( wsa->hSocket, FD_WRITE, 0, 0 );
1466         }
1467         else
1468         {
1469             int err = wsaErrno();
1470             if ( err == WSAEINTR )
1471             {
1472                 iosb->u.Status = STATUS_PENDING;
1473                 _enable_event( wsa->hSocket, FD_WRITE, 0, 0 );
1474                 TRACE( "still pending\n" );
1475             }
1476             else
1477             {
1478                 /* We set the status to a winsock error code and check for that
1479                    later in NtStatusToWSAError () */
1480                 iosb->u.Status = err;
1481                 TRACE( "Error: %x\n", err );
1482             }
1483         }
1484         if (iosb->u.Status == STATUS_PENDING)
1485             ws2_queue_async(wsa, iosb);
1486         else
1487             ws2_async_terminate(wsa, iosb);
1488         break;
1489     default:
1490         FIXME( "status: %d\n", status );
1491         iosb->u.Status = status;
1492         ws2_async_terminate(wsa, iosb);
1493         return;
1494     }
1495
1496 }
1497
1498 /***********************************************************************
1499  *              WS2_async_shutdown      (INTERNAL)
1500  *
1501  * Handler for shutdown() operations on overlapped sockets.
1502  */
1503 static void WINAPI WS2_async_shutdown( void* as, PIO_STATUS_BLOCK iosb, ULONG status )
1504 {
1505     ws2_async* wsa = (ws2_async*) as;
1506     int err = 1;
1507
1508     TRACE( "async %p %d\n", wsa, wsa->mode );
1509     switch (status)
1510     {
1511     case STATUS_ALERTED:
1512         switch ( wsa->mode )
1513         {
1514         case ws2m_sd_read:   err = shutdown( wsa->fd, 0 );  break;
1515         case ws2m_sd_write:  err = shutdown( wsa->fd, 1 );  break;
1516         default: ERR("invalid mode: %d\n", wsa->mode );
1517         }
1518         iosb->u.Status = err ? wsaErrno() : STATUS_SUCCESS;
1519         if (iosb->u.Status == STATUS_PENDING)
1520             ws2_queue_async(wsa, iosb);
1521         else
1522             ws2_async_terminate(wsa, iosb);
1523         break;
1524     default:
1525         iosb->u.Status = status;
1526         ws2_async_terminate(wsa, iosb);
1527         break;
1528     }
1529
1530 }
1531
1532 /***********************************************************************
1533  *  WS2_register_async_shutdown         (INTERNAL)
1534  *
1535  * Helper function for WS_shutdown() on overlapped sockets.
1536  */
1537 static int WS2_register_async_shutdown( SOCKET s, int fd, enum ws2_mode mode )
1538 {
1539     struct ws2_async *wsa;
1540     int ret, err = WSAEFAULT;
1541     DWORD dwflags = 0;
1542     int len = 0;
1543     LPWSAOVERLAPPED ovl = HeapAlloc(GetProcessHeap(), 0, sizeof( WSAOVERLAPPED ));
1544     IO_STATUS_BLOCK *iosb = NULL;
1545
1546     TRACE("s %d fd %d mode %d\n", s, fd, mode);
1547     if (!ovl)
1548         goto out;
1549
1550     ovl->hEvent = WSACreateEvent();
1551     if ( ovl->hEvent == WSA_INVALID_EVENT )
1552         goto out_free;
1553
1554     wsa = WS2_make_async( s, fd, mode, NULL, 0,
1555                           &dwflags, NULL, &len, ovl, NULL, &iosb );
1556     if ( !wsa )
1557         goto out_close;
1558
1559     /* Hack: this will cause ws2_async_terminate() to free the overlapped structure */
1560     wsa->user_overlapped = NULL;
1561     if ( (ret = ws2_queue_async( wsa, iosb )) )
1562     {
1563         err = NtStatusToWSAError( ret );
1564         goto out;
1565     }
1566     /* Try immediate completion */
1567     while ( WaitForSingleObjectEx( ovl->hEvent, 0, TRUE ) == STATUS_USER_APC );
1568     return 0;
1569
1570 out_close:
1571     WSACloseEvent( ovl->hEvent );
1572 out_free:
1573     HeapFree( GetProcessHeap(), 0, ovl );
1574 out:
1575     return err;
1576 }
1577
1578 /***********************************************************************
1579  *              accept          (WS2_32.1)
1580  */
1581 SOCKET WINAPI WS_accept(SOCKET s, struct WS_sockaddr *addr,
1582                                  int *addrlen32)
1583 {
1584     SOCKET as;
1585     BOOL is_blocking;
1586
1587     TRACE("socket %04x\n", s );
1588     is_blocking = _is_blocking(s);
1589
1590     do {
1591         if (is_blocking)
1592         {
1593             int fd = get_sock_fd( s, FILE_READ_DATA, NULL );
1594             if (fd == -1) return INVALID_SOCKET;
1595             /* block here */
1596             do_block(fd, POLLIN, -1);
1597             _sync_sock_state(s); /* let wineserver notice connection */
1598             release_sock_fd( s, fd );
1599             /* retrieve any error codes from it */
1600             SetLastError(_get_sock_error(s, FD_ACCEPT_BIT));
1601             /* FIXME: care about the error? */
1602         }
1603         SERVER_START_REQ( accept_socket )
1604         {
1605             req->lhandle    = SOCKET2HANDLE(s);
1606             req->access     = GENERIC_READ|GENERIC_WRITE|SYNCHRONIZE;
1607             req->attributes = OBJ_INHERIT;
1608             set_error( wine_server_call( req ) );
1609             as = HANDLE2SOCKET( reply->handle );
1610         }
1611         SERVER_END_REQ;
1612         if (as)
1613         {
1614             if (addr) WS_getpeername(as, addr, addrlen32);
1615             return as;
1616         }
1617     } while (is_blocking);
1618     return INVALID_SOCKET;
1619 }
1620
1621 /***********************************************************************
1622  *              bind                    (WS2_32.2)
1623  */
1624 int WINAPI WS_bind(SOCKET s, const struct WS_sockaddr* name, int namelen)
1625 {
1626     int fd = get_sock_fd( s, 0, NULL );
1627     int res = SOCKET_ERROR;
1628
1629     TRACE("socket %04x, ptr %p %s, length %d\n", s, name, debugstr_sockaddr(name), namelen);
1630
1631     if (fd != -1)
1632     {
1633         if (!name || (name->sa_family && !SUPPORTED_PF(name->sa_family)))
1634         {
1635             SetLastError(WSAEAFNOSUPPORT);
1636         }
1637         else
1638         {
1639             const struct sockaddr* uaddr;
1640             unsigned int uaddrlen;
1641
1642             uaddr=ws_sockaddr_ws2u(name,namelen,&uaddrlen);
1643             if (uaddr == NULL)
1644             {
1645                 SetLastError(WSAEFAULT);
1646             }
1647             else
1648             {
1649                 if (bind(fd, uaddr, uaddrlen) < 0)
1650                 {
1651                     int loc_errno = errno;
1652                     WARN("\tfailure - errno = %i\n", errno);
1653                     errno = loc_errno;
1654                     switch (errno)
1655                     {
1656                     case EBADF:
1657                         SetLastError(WSAENOTSOCK);
1658                         break;
1659                     case EADDRNOTAVAIL:
1660                         SetLastError(WSAEINVAL);
1661                         break;
1662                     default:
1663                         SetLastError(wsaErrno());
1664                         break;
1665                     }
1666                 }
1667                 else
1668                 {
1669                     res=0; /* success */
1670                 }
1671                 ws_sockaddr_free(uaddr,name);
1672             }
1673         }
1674         release_sock_fd( s, fd );
1675     }
1676     return res;
1677 }
1678
1679 /***********************************************************************
1680  *              closesocket             (WS2_32.3)
1681  */
1682 int WINAPI WS_closesocket(SOCKET s)
1683 {
1684     TRACE("socket %04x\n", s);
1685     if (CloseHandle(SOCKET2HANDLE(s))) return 0;
1686     return SOCKET_ERROR;
1687 }
1688
1689 /***********************************************************************
1690  *              connect         (WS2_32.4)
1691  */
1692 int WINAPI WS_connect(SOCKET s, const struct WS_sockaddr* name, int namelen)
1693 {
1694     int fd = get_sock_fd( s, FILE_READ_DATA, NULL );
1695
1696     TRACE("socket %04x, ptr %p %s, length %d\n", s, name, debugstr_sockaddr(name), namelen);
1697
1698     if (fd != -1)
1699     {
1700         const struct sockaddr* uaddr;
1701         unsigned int uaddrlen;
1702
1703         uaddr=ws_sockaddr_ws2u(name,namelen,&uaddrlen);
1704         if (uaddr == NULL)
1705         {
1706             SetLastError(WSAEFAULT);
1707         }
1708         else
1709         {
1710             int rc;
1711
1712             rc=connect(fd, uaddr, uaddrlen);
1713             ws_sockaddr_free(uaddr,name);
1714             if (rc == 0)
1715                 goto connect_success;
1716         }
1717
1718         if (errno == EINPROGRESS)
1719         {
1720             /* tell wineserver that a connection is in progress */
1721             _enable_event(SOCKET2HANDLE(s), FD_CONNECT|FD_READ|FD_WRITE,
1722                           FD_CONNECT|FD_READ|FD_WRITE,
1723                           FD_WINE_CONNECTED|FD_WINE_LISTENING);
1724             if (_is_blocking(s))
1725             {
1726                 int result;
1727                 /* block here */
1728                 do_block(fd, POLLIN | POLLOUT, -1);
1729                 _sync_sock_state(s); /* let wineserver notice connection */
1730                 /* retrieve any error codes from it */
1731                 result = _get_sock_error(s, FD_CONNECT_BIT);
1732                 if (result)
1733                     SetLastError(result);
1734                 else
1735                 {
1736                     goto connect_success;
1737                 }
1738             }
1739             else
1740             {
1741                 SetLastError(WSAEWOULDBLOCK);
1742             }
1743         }
1744         else
1745         {
1746             SetLastError(wsaErrno());
1747         }
1748         release_sock_fd( s, fd );
1749     }
1750     return SOCKET_ERROR;
1751
1752 connect_success:
1753     release_sock_fd( s, fd );
1754     _enable_event(SOCKET2HANDLE(s), FD_CONNECT|FD_READ|FD_WRITE,
1755                   FD_WINE_CONNECTED|FD_READ|FD_WRITE,
1756                   FD_CONNECT|FD_WINE_LISTENING);
1757     return 0;
1758 }
1759
1760 /***********************************************************************
1761  *              WSAConnect             (WS2_32.30)
1762  */
1763 int WINAPI WSAConnect( SOCKET s, const struct WS_sockaddr* name, int namelen,
1764                        LPWSABUF lpCallerData, LPWSABUF lpCalleeData,
1765                        LPQOS lpSQOS, LPQOS lpGQOS )
1766 {
1767     if ( lpCallerData || lpCalleeData || lpSQOS || lpGQOS )
1768         FIXME("unsupported parameters!\n");
1769     return WS_connect( s, name, namelen );
1770 }
1771
1772
1773 /***********************************************************************
1774  *              getpeername             (WS2_32.5)
1775  */
1776 int WINAPI WS_getpeername(SOCKET s, struct WS_sockaddr *name, int *namelen)
1777 {
1778     int fd;
1779     int res;
1780
1781     TRACE("socket: %04x, ptr %p, len %08x\n", s, name, *namelen);
1782
1783     /* Check if what we've received is valid. Should we use IsBadReadPtr? */
1784     if( (name == NULL) || (namelen == NULL) )
1785     {
1786         SetLastError( WSAEFAULT );
1787         return SOCKET_ERROR;
1788     }
1789
1790     fd = get_sock_fd( s, 0, NULL );
1791     res = SOCKET_ERROR;
1792
1793     if (fd != -1)
1794     {
1795         struct sockaddr* uaddr;
1796         unsigned int uaddrlen;
1797
1798         uaddr=ws_sockaddr_alloc(name,namelen,&uaddrlen);
1799         if (getpeername(fd, uaddr, &uaddrlen) != 0)
1800         {
1801             SetLastError(wsaErrno());
1802         }
1803         else if (ws_sockaddr_u2ws(uaddr,uaddrlen,name,namelen) != 0)
1804         {
1805             /* The buffer was too small */
1806             SetLastError(WSAEFAULT);
1807         }
1808         else
1809         {
1810             res=0;
1811         }
1812         ws_sockaddr_free(uaddr,name);
1813         release_sock_fd( s, fd );
1814     }
1815     return res;
1816 }
1817
1818 /***********************************************************************
1819  *              getsockname             (WS2_32.6)
1820  */
1821 int WINAPI WS_getsockname(SOCKET s, struct WS_sockaddr *name, int *namelen)
1822 {
1823     int fd;
1824     int res;
1825
1826     TRACE("socket: %04x, ptr %p, len %8x\n", s, name, *namelen);
1827
1828     /* Check if what we've received is valid. Should we use IsBadReadPtr? */
1829     if( (name == NULL) || (namelen == NULL) )
1830     {
1831         SetLastError( WSAEFAULT );
1832         return SOCKET_ERROR;
1833     }
1834
1835     fd = get_sock_fd( s, 0, NULL );
1836     res = SOCKET_ERROR;
1837
1838     if (fd != -1)
1839     {
1840         struct sockaddr* uaddr;
1841         unsigned int uaddrlen;
1842
1843         uaddr=ws_sockaddr_alloc(name,namelen,&uaddrlen);
1844         if (getsockname(fd, uaddr, &uaddrlen) != 0)
1845         {
1846             SetLastError(wsaErrno());
1847         }
1848         else if (ws_sockaddr_u2ws(uaddr,uaddrlen,name,namelen) != 0)
1849         {
1850             /* The buffer was too small */
1851             SetLastError(WSAEFAULT);
1852         }
1853         else
1854         {
1855             res=0;
1856         }
1857         ws_sockaddr_free(uaddr,name);
1858         release_sock_fd( s, fd );
1859     }
1860     return res;
1861 }
1862
1863 /***********************************************************************
1864  *              getsockopt              (WS2_32.7)
1865  */
1866 INT WINAPI WS_getsockopt(SOCKET s, INT level,
1867                                   INT optname, char *optval, INT *optlen)
1868 {
1869     int fd;
1870     INT ret = 0;
1871
1872     TRACE("socket: %04x, level 0x%x, name 0x%x, ptr %p, len %d\n",
1873           s, level, optname, optval, *optlen);
1874     /* SO_OPENTYPE does not require a valid socket handle. */
1875     if (level == WS_SOL_SOCKET && optname == WS_SO_OPENTYPE)
1876     {
1877         if (!optlen || *optlen < sizeof(int) || !optval)
1878         {
1879             SetLastError(WSAEFAULT);
1880             return SOCKET_ERROR;
1881         }
1882         *(int *)optval = get_per_thread_data()->opentype;
1883         *optlen = sizeof(int);
1884         TRACE("getting global SO_OPENTYPE = 0x%x\n", *((int*)optval) );
1885         return 0;
1886     }
1887
1888 #ifdef HAVE_IPX
1889     if(level == NSPROTO_IPX)
1890     {
1891         struct WS_sockaddr_ipx addr;
1892         IPX_ADDRESS_DATA *data;
1893         int namelen;
1894         switch(optname)
1895         {
1896             case IPX_PTYPE:
1897                 fd = get_sock_fd( s, 0, NULL );
1898 #ifdef SOL_IPX
1899                 if(getsockopt(fd, SOL_IPX, IPX_TYPE, optval, (unsigned int*)optlen) == -1)
1900                 {
1901                     return SOCKET_ERROR;
1902                 }
1903 #else
1904                 {
1905                     struct ipx val;
1906                     socklen_t len=sizeof(struct ipx);
1907
1908                     if(getsockopt(fd, 0, SO_DEFAULT_HEADERS, &val, &len) == -1 )
1909                         return SOCKET_ERROR;
1910                     *optval = (int)val.ipx_pt;
1911                 }
1912 #endif
1913                 TRACE("ptype: %d (fd: %d)\n", *(int*)optval, fd);
1914                 release_sock_fd( s, fd );
1915
1916                 return 0;
1917             case IPX_ADDRESS:
1918                 /*
1919                 *  On a Win2000 system with one network card there are usually three ipx devices one with a speed of 28.8kbps, 10Mbps and 100Mbps.
1920                 *  Using this call you can then retrieve info about this all. In case of Linux it is a bit different. Usually you have
1921                 *  only "one" device active and further it is not possible to query things like the linkspeed.
1922                 */
1923                 FIXME("IPX_ADDRESS\n");
1924                 namelen = sizeof(struct WS_sockaddr_ipx);
1925                 memset(&addr, 0, sizeof(struct WS_sockaddr_ipx));
1926                 WS_getsockname(s, (struct WS_sockaddr*)&addr, &namelen);
1927
1928                 data = (IPX_ADDRESS_DATA*)optval;
1929                 memcpy(data->nodenum,&addr.sa_nodenum,sizeof(data->nodenum));
1930                 memcpy(data->netnum,&addr.sa_netnum,sizeof(data->netnum));
1931                 data->adapternum = 0;
1932                 data->wan = FALSE; /* We are not on a wan for now .. */
1933                 data->status = FALSE; /* Since we are not on a wan, the wan link isn't up */
1934                 data->maxpkt = 1467; /* This value is the default one, at least on Win2k/WinXP */
1935                 data->linkspeed = 100000; /* Set the line speed in 100bit/s to 10 Mbit; note 1MB = 1000kB in this case */
1936                 return 0;
1937             case IPX_MAX_ADAPTER_NUM:
1938                 FIXME("IPX_MAX_ADAPTER_NUM\n");
1939                 *(int*)optval = 1; /* As noted under IPX_ADDRESS we have just one card. */
1940
1941                 return 0;
1942             default:
1943                 FIXME("IPX optname:%x\n", optname);
1944                 return SOCKET_ERROR;
1945         }
1946     }
1947 #endif
1948
1949     if( (fd = get_sock_fd( s, 0, NULL )) == -1)
1950         return SOCKET_ERROR;
1951
1952     if (!convert_sockopt(&level, &optname)) {
1953         SetLastError(WSAENOPROTOOPT);   /* Unknown option */
1954         ret = SOCKET_ERROR;
1955     } else {
1956         struct timeval tv;
1957         struct linger lingval;
1958         unsigned int len, *plen = (unsigned int*)optlen;
1959         char *pval = optval;
1960         if(level == SOL_SOCKET && is_timeout_option(optname)) {
1961             len = sizeof(tv);
1962             plen = &len;
1963             pval = (char *) &tv;
1964         } else if( level == SOL_SOCKET && optname == SO_LINGER) {
1965             len = sizeof(lingval);
1966             plen = &len;
1967             pval = (char *) &lingval;
1968         }
1969         if (getsockopt(fd, (int) level, optname, pval, plen) != 0 ) {
1970             SetLastError((errno == EBADF) ? WSAENOTSOCK : wsaErrno());
1971             ret = SOCKET_ERROR;
1972         } else if(level == SOL_SOCKET && is_timeout_option(optname)) {
1973             if( *optlen >= sizeof(INT) ) {
1974                 *optlen = sizeof(INT);
1975                 *(INT*)optval = tv.tv_sec * 1000 + tv.tv_usec / 1000;
1976             } else {
1977                 SetLastError(WSAEFAULT);
1978                 ret = SOCKET_ERROR;
1979             }
1980         } else if( level == SOL_SOCKET && optname == SO_LINGER) {
1981             if( *optlen >=  sizeof( LINGER) ) {
1982                 (( LINGER *) optval)->l_onoff = lingval.l_onoff;
1983                 (( LINGER *) optval)->l_linger = lingval.l_linger;
1984             } else {
1985                 SetLastError(WSAEFAULT);
1986                 ret = SOCKET_ERROR;
1987             }
1988         }
1989     }
1990     release_sock_fd( s, fd );
1991     return ret;
1992 }
1993
1994
1995 /***********************************************************************
1996  *              htonl                   (WINSOCK.8)
1997  *              htonl                   (WS2_32.8)
1998  */
1999 WS_u_long WINAPI WS_htonl(WS_u_long hostlong)
2000 {
2001     return htonl(hostlong);
2002 }
2003
2004
2005 /***********************************************************************
2006  *              htons                   (WINSOCK.9)
2007  *              htons                   (WS2_32.9)
2008  */
2009 WS_u_short WINAPI WS_htons(WS_u_short hostshort)
2010 {
2011     return htons(hostshort);
2012 }
2013
2014 /***********************************************************************
2015  *              WSAHtonl                (WS2_32.46)
2016  *  From MSDN decription of error codes, this function should also
2017  *  check if WinSock has been initialized and the socket is a valid
2018  *  socket. But why? This function only translates a host byte order
2019  *  u_long into a network byte order u_long...
2020  */
2021 int WINAPI WSAHtonl(SOCKET s, WS_u_long hostlong, WS_u_long *lpnetlong)
2022 {
2023     if (lpnetlong)
2024     {
2025         *lpnetlong = htonl(hostlong);
2026         return 0;
2027     }
2028     WSASetLastError(WSAEFAULT);
2029     return SOCKET_ERROR;
2030 }
2031
2032 /***********************************************************************
2033  *              WSAHtons                (WS2_32.47)
2034  *  From MSDN decription of error codes, this function should also
2035  *  check if WinSock has been initialized and the socket is a valid
2036  *  socket. But why? This function only translates a host byte order
2037  *  u_short into a network byte order u_short...
2038  */
2039 int WINAPI WSAHtons(SOCKET s, WS_u_short hostshort, WS_u_short *lpnetshort)
2040 {
2041
2042     if (lpnetshort)
2043     {
2044         *lpnetshort = htons(hostshort);
2045         return 0;
2046     }
2047     WSASetLastError(WSAEFAULT);
2048     return SOCKET_ERROR;
2049 }
2050
2051
2052 /***********************************************************************
2053  *              inet_addr               (WINSOCK.10)
2054  *              inet_addr               (WS2_32.11)
2055  */
2056 WS_u_long WINAPI WS_inet_addr(const char *cp)
2057 {
2058     return inet_addr(cp);
2059 }
2060
2061
2062 /***********************************************************************
2063  *              ntohl                   (WINSOCK.14)
2064  *              ntohl                   (WS2_32.14)
2065  */
2066 WS_u_long WINAPI WS_ntohl(WS_u_long netlong)
2067 {
2068     return ntohl(netlong);
2069 }
2070
2071
2072 /***********************************************************************
2073  *              ntohs                   (WINSOCK.15)
2074  *              ntohs                   (WS2_32.15)
2075  */
2076 WS_u_short WINAPI WS_ntohs(WS_u_short netshort)
2077 {
2078     return ntohs(netshort);
2079 }
2080
2081
2082 /***********************************************************************
2083  *              inet_ntoa               (WS2_32.12)
2084  */
2085 char* WINAPI WS_inet_ntoa(struct WS_in_addr in)
2086 {
2087   /* use "buffer for dummies" here because some applications have a
2088    * propensity to decode addresses in ws_hostent structure without
2089    * saving them first...
2090    */
2091     static char dbuffer[16]; /* Yes, 16: 4*3 digits + 3 '.' + 1 '\0' */
2092
2093     char* s = inet_ntoa(*((struct in_addr*)&in));
2094     if( s )
2095     {
2096         strcpy(dbuffer, s);
2097         return dbuffer;
2098     }
2099     SetLastError(wsaErrno());
2100     return NULL;
2101 }
2102
2103 /**********************************************************************
2104  *              WSAIoctl                (WS2_32.50)
2105  *
2106  */
2107 INT WINAPI WSAIoctl(SOCKET s,
2108                     DWORD   dwIoControlCode,
2109                     LPVOID  lpvInBuffer,
2110                     DWORD   cbInBuffer,
2111                     LPVOID  lpbOutBuffer,
2112                     DWORD   cbOutBuffer,
2113                     LPDWORD lpcbBytesReturned,
2114                     LPWSAOVERLAPPED lpOverlapped,
2115                     LPWSAOVERLAPPED_COMPLETION_ROUTINE lpCompletionRoutine)
2116 {
2117    TRACE("%d, 0x%08x, %p, %d, %p, %d, %p, %p, %p\n",
2118        s, dwIoControlCode, lpvInBuffer, cbInBuffer, lpbOutBuffer,
2119        cbOutBuffer, lpcbBytesReturned, lpOverlapped, lpCompletionRoutine);
2120
2121    switch( dwIoControlCode )
2122    {
2123    case WS_FIONBIO:
2124         if (cbInBuffer != sizeof(WS_u_long)) {
2125             WSASetLastError(WSAEFAULT);
2126             return SOCKET_ERROR;
2127         }
2128         return WS_ioctlsocket( s, WS_FIONBIO, lpvInBuffer);
2129
2130    case WS_FIONREAD:
2131         if (cbOutBuffer != sizeof(WS_u_long)) {
2132             WSASetLastError(WSAEFAULT);
2133             return SOCKET_ERROR;
2134         }
2135         return WS_ioctlsocket( s, WS_FIONREAD, lpbOutBuffer);
2136
2137    case SIO_GET_INTERFACE_LIST:
2138        {
2139            INTERFACE_INFO* intArray = (INTERFACE_INFO*)lpbOutBuffer;
2140            DWORD size, numInt, apiReturn;
2141            int fd;
2142
2143            TRACE("-> SIO_GET_INTERFACE_LIST request\n");
2144
2145            if (!lpbOutBuffer)
2146            {
2147                WSASetLastError(WSAEFAULT);
2148                return SOCKET_ERROR;
2149            }
2150            if (!lpcbBytesReturned)
2151            {
2152                WSASetLastError(WSAEFAULT);
2153                return SOCKET_ERROR;
2154            }
2155
2156            fd = get_sock_fd( s, 0, NULL );
2157            if (fd == -1) return SOCKET_ERROR;
2158
2159            apiReturn = GetAdaptersInfo(NULL, &size);
2160            if (apiReturn == ERROR_NO_DATA)
2161            {
2162                numInt = 0;
2163            }
2164            else if (apiReturn == ERROR_BUFFER_OVERFLOW)
2165            {
2166                PIP_ADAPTER_INFO table = HeapAlloc(GetProcessHeap(),0,size);
2167
2168                if (table)
2169                {
2170                   if (GetAdaptersInfo(table, &size) == NO_ERROR)
2171                   {
2172                      PIP_ADAPTER_INFO ptr;
2173
2174                      if (size*sizeof(INTERFACE_INFO)/sizeof(IP_ADAPTER_INFO) > cbOutBuffer)
2175                      {
2176                         WARN("Buffer too small = %u, cbOutBuffer = %u\n", size, cbOutBuffer);
2177                         HeapFree(GetProcessHeap(),0,table);
2178                         release_sock_fd( s, fd );
2179                         WSASetLastError(WSAEFAULT);
2180                         return SOCKET_ERROR;
2181                      }
2182                      for (ptr = table, numInt = 0; ptr;
2183                       ptr = ptr->Next, intArray++, numInt++)
2184                      {
2185                         unsigned int addr, mask, bcast;
2186                         struct ifreq ifInfo;
2187
2188                         /* Socket Status Flags */
2189                         lstrcpynA(ifInfo.ifr_name, ptr->AdapterName, IFNAMSIZ);
2190                         if (ioctl(fd, SIOCGIFFLAGS, &ifInfo) < 0)
2191                         {
2192                            ERR("Error obtaining status flags for socket!\n");
2193                            HeapFree(GetProcessHeap(),0,table);
2194                            release_sock_fd( s, fd );
2195                            WSASetLastError(WSAEINVAL);
2196                            return SOCKET_ERROR;
2197                         }
2198                         else
2199                         {
2200                            /* set flags; the values of IFF_* are not the same
2201                               under Linux and Windows, therefore must generate
2202                               new flags */
2203                            intArray->iiFlags = 0;
2204                            if (ifInfo.ifr_flags & IFF_BROADCAST)
2205                               intArray->iiFlags |= WS_IFF_BROADCAST;
2206 #ifdef IFF_POINTOPOINT
2207                            if (ifInfo.ifr_flags & IFF_POINTOPOINT)
2208                               intArray->iiFlags |= WS_IFF_POINTTOPOINT;
2209 #endif
2210                            if (ifInfo.ifr_flags & IFF_LOOPBACK)
2211                               intArray->iiFlags |= WS_IFF_LOOPBACK;
2212                            if (ifInfo.ifr_flags & IFF_UP)
2213                               intArray->iiFlags |= WS_IFF_UP;
2214                            if (ifInfo.ifr_flags & IFF_MULTICAST)
2215                               intArray->iiFlags |= WS_IFF_MULTICAST;
2216                         }
2217
2218                         addr = inet_addr(ptr->IpAddressList.IpAddress.String);
2219                         mask = inet_addr(ptr->IpAddressList.IpMask.String);
2220                         bcast = addr | (addr & !mask);
2221                         intArray->iiAddress.AddressIn.sin_family = AF_INET;
2222                         intArray->iiAddress.AddressIn.sin_port = 0;
2223                         intArray->iiAddress.AddressIn.sin_addr.WS_s_addr =
2224                          addr;
2225                         intArray->iiNetmask.AddressIn.sin_family = AF_INET;
2226                         intArray->iiNetmask.AddressIn.sin_port = 0;
2227                         intArray->iiNetmask.AddressIn.sin_addr.WS_s_addr =
2228                          mask;
2229                         intArray->iiBroadcastAddress.AddressIn.sin_family =
2230                          AF_INET;
2231                         intArray->iiBroadcastAddress.AddressIn.sin_port = 0;
2232                         intArray->iiBroadcastAddress.AddressIn.sin_addr.
2233                          WS_s_addr = bcast;
2234                      }
2235                   }
2236                   else
2237                   {
2238                      ERR("Unable to get interface table!\n");
2239                      release_sock_fd( s, fd );
2240                      HeapFree(GetProcessHeap(),0,table);
2241                      WSASetLastError(WSAEINVAL);
2242                      return SOCKET_ERROR;
2243                   }
2244                   HeapFree(GetProcessHeap(),0,table);
2245                }
2246                else
2247                {
2248                   release_sock_fd( s, fd );
2249                   WSASetLastError(WSAEINVAL);
2250                   return SOCKET_ERROR;
2251                }
2252            }
2253            else
2254            {
2255                ERR("Unable to get interface table!\n");
2256                release_sock_fd( s, fd );
2257                WSASetLastError(WSAEINVAL);
2258                return SOCKET_ERROR;
2259            }
2260            /* Calculate the size of the array being returned */
2261            *lpcbBytesReturned = sizeof(INTERFACE_INFO) * numInt;
2262            release_sock_fd( s, fd );
2263            break;
2264        }
2265
2266    case SIO_ADDRESS_LIST_CHANGE:
2267        FIXME("-> SIO_ADDRESS_LIST_CHANGE request: stub\n");
2268        /* FIXME: error and return code depend on whether socket was created
2269         * with WSA_FLAG_OVERLAPPED, but there is no easy way to get this */
2270        break;
2271
2272    case SIO_FLUSH:
2273         FIXME("SIO_FLUSH: stub.\n");
2274         break;
2275
2276    default:
2277        FIXME("unsupported WS_IOCTL cmd (%08x)\n", dwIoControlCode);
2278        WSASetLastError(WSAEOPNOTSUPP);
2279        return SOCKET_ERROR;
2280    }
2281
2282    return 0;
2283 }
2284
2285
2286 /***********************************************************************
2287  *              ioctlsocket             (WS2_32.10)
2288  */
2289 int WINAPI WS_ioctlsocket(SOCKET s, long cmd, WS_u_long *argp)
2290 {
2291     int fd;
2292     long newcmd  = cmd;
2293
2294     TRACE("socket %04x, cmd %08lx, ptr %p\n", s, cmd, argp);
2295
2296     switch( cmd )
2297     {
2298     case WS_FIONREAD:
2299         newcmd=FIONREAD;
2300         break;
2301
2302     case WS_FIONBIO:
2303         if( _get_sock_mask(s) )
2304         {
2305             /* AsyncSelect()'ed sockets are always nonblocking */
2306             if (*argp) return 0;
2307             SetLastError(WSAEINVAL);
2308             return SOCKET_ERROR;
2309         }
2310         fd = get_sock_fd( s, 0, NULL );
2311         if (fd != -1)
2312         {
2313             int ret;
2314             if (*argp)
2315             {
2316                 _enable_event(SOCKET2HANDLE(s), 0, FD_WINE_NONBLOCKING, 0);
2317                 ret = fcntl( fd, F_SETFL, O_NONBLOCK );
2318             }
2319             else
2320             {
2321                 _enable_event(SOCKET2HANDLE(s), 0, 0, FD_WINE_NONBLOCKING);
2322                 ret = fcntl( fd, F_SETFL, 0 );
2323             }
2324             release_sock_fd( s, fd );
2325             if (!ret) return 0;
2326             SetLastError((errno == EBADF) ? WSAENOTSOCK : wsaErrno());
2327         }
2328         return SOCKET_ERROR;
2329
2330     case WS_SIOCATMARK:
2331         newcmd=SIOCATMARK;
2332         break;
2333
2334     case WS_FIOASYNC:
2335         WARN("Warning: WS1.1 shouldn't be using async I/O\n");
2336         SetLastError(WSAEINVAL);
2337         return SOCKET_ERROR;
2338
2339     case SIOCGIFBRDADDR:
2340     case SIOCGIFNETMASK:
2341     case SIOCGIFADDR:
2342         /* These don't need any special handling.  They are used by
2343            WsControl, and are here to suppress an unnecessary warning. */
2344         break;
2345
2346     default:
2347         /* Netscape tries hard to use bogus ioctl 0x667e */
2348         /* FIXME: 0x667e above is ('f' << 8) | 126, and is a low word of
2349          * FIONBIO (_IOW('f', 126, u_long)), how that should be handled?
2350          */
2351         WARN("\tunknown WS_IOCTL cmd (%08lx)\n", cmd);
2352         break;
2353     }
2354
2355     fd = get_sock_fd( s, 0, NULL );
2356     if (fd != -1)
2357     {
2358         if( ioctl(fd, newcmd, (char*)argp ) == 0 )
2359         {
2360             release_sock_fd( s, fd );
2361             return 0;
2362         }
2363         SetLastError((errno == EBADF) ? WSAENOTSOCK : wsaErrno());
2364         release_sock_fd( s, fd );
2365     }
2366     return SOCKET_ERROR;
2367 }
2368
2369 /***********************************************************************
2370  *              listen          (WS2_32.13)
2371  */
2372 int WINAPI WS_listen(SOCKET s, int backlog)
2373 {
2374     int fd = get_sock_fd( s, FILE_READ_DATA, NULL );
2375
2376     TRACE("socket %04x, backlog %d\n", s, backlog);
2377     if (fd != -1)
2378     {
2379         if (listen(fd, backlog) == 0)
2380         {
2381             release_sock_fd( s, fd );
2382             _enable_event(SOCKET2HANDLE(s), FD_ACCEPT,
2383                           FD_WINE_LISTENING,
2384                           FD_CONNECT|FD_WINE_CONNECTED);
2385             return 0;
2386         }
2387         SetLastError(wsaErrno());
2388         release_sock_fd( s, fd );
2389     }
2390     return SOCKET_ERROR;
2391 }
2392
2393 /***********************************************************************
2394  *              recv                    (WS2_32.16)
2395  */
2396 int WINAPI WS_recv(SOCKET s, char *buf, int len, int flags)
2397 {
2398     DWORD n, dwFlags = flags;
2399     WSABUF wsabuf;
2400
2401     wsabuf.len = len;
2402     wsabuf.buf = buf;
2403
2404     if ( WSARecvFrom(s, &wsabuf, 1, &n, &dwFlags, NULL, NULL, NULL, NULL) == SOCKET_ERROR )
2405         return SOCKET_ERROR;
2406     else
2407         return n;
2408 }
2409
2410 /***********************************************************************
2411  *              recvfrom                (WS2_32.17)
2412  */
2413 int WINAPI WS_recvfrom(SOCKET s, char *buf, INT len, int flags,
2414                        struct WS_sockaddr *from, int *fromlen)
2415 {
2416     DWORD n, dwFlags = flags;
2417     WSABUF wsabuf;
2418
2419     wsabuf.len = len;
2420     wsabuf.buf = buf;
2421
2422     if ( WSARecvFrom(s, &wsabuf, 1, &n, &dwFlags, from, fromlen, NULL, NULL) == SOCKET_ERROR )
2423         return SOCKET_ERROR;
2424     else
2425         return n;
2426 }
2427
2428 /***********************************************************************
2429  *              select                  (WS2_32.18)
2430  */
2431 int WINAPI WS_select(int nfds, WS_fd_set *ws_readfds,
2432                      WS_fd_set *ws_writefds, WS_fd_set *ws_exceptfds,
2433                      const struct WS_timeval* ws_timeout)
2434 {
2435     int         highfd = 0;
2436     fd_set      readfds, writefds, exceptfds;
2437     fd_set     *p_read, *p_write, *p_except;
2438     int         readfd[FD_SETSIZE], writefd[FD_SETSIZE], exceptfd[FD_SETSIZE];
2439     struct timeval timeout, *timeoutaddr = NULL;
2440
2441     TRACE("read %p, write %p, excp %p timeout %p\n",
2442           ws_readfds, ws_writefds, ws_exceptfds, ws_timeout);
2443
2444     p_read = fd_set_import(&readfds, ws_readfds, FILE_READ_DATA, &highfd, readfd);
2445     p_write = fd_set_import(&writefds, ws_writefds, FILE_WRITE_DATA, &highfd, writefd);
2446     p_except = fd_set_import(&exceptfds, ws_exceptfds, 0, &highfd, exceptfd);
2447     if (ws_timeout)
2448     {
2449         timeoutaddr = &timeout;
2450         timeout.tv_sec=ws_timeout->tv_sec;
2451         timeout.tv_usec=ws_timeout->tv_usec;
2452     }
2453
2454     if( (highfd = select(highfd + 1, p_read, p_write, p_except, timeoutaddr)) > 0 )
2455     {
2456         fd_set_export(&readfds, p_except, ws_readfds, readfd);
2457         fd_set_export(&writefds, p_except, ws_writefds, writefd);
2458
2459         if (p_except && ws_exceptfds)
2460         {
2461             unsigned int i, j;
2462
2463             for (i = j = 0; i < ws_exceptfds->fd_count; i++)
2464             {
2465                 int fd = exceptfd[i];
2466                 SOCKET s = ws_exceptfds->fd_array[i];
2467                 if (fd == -1) continue;
2468                 if (FD_ISSET(fd, &exceptfds)) ws_exceptfds->fd_array[j++] = s;
2469                 release_sock_fd( s, fd );
2470             }
2471             ws_exceptfds->fd_count = j;
2472         }
2473         return highfd;
2474     }
2475     fd_set_unimport(ws_readfds, readfd);
2476     fd_set_unimport(ws_writefds, writefd);
2477     fd_set_unimport(ws_exceptfds, exceptfd);
2478
2479     if( highfd == 0 ) return 0;
2480     SetLastError(wsaErrno());
2481     return SOCKET_ERROR;
2482 }
2483
2484
2485 /***********************************************************************
2486  *              send                    (WS2_32.19)
2487  */
2488 int WINAPI WS_send(SOCKET s, const char *buf, int len, int flags)
2489 {
2490     DWORD n;
2491     WSABUF wsabuf;
2492
2493     wsabuf.len = len;
2494     wsabuf.buf = (char*) buf;
2495
2496     if ( WSASendTo( s, &wsabuf, 1, &n, flags, NULL, 0, NULL, NULL) == SOCKET_ERROR )
2497         return SOCKET_ERROR;
2498     else
2499         return n;
2500 }
2501
2502 /***********************************************************************
2503  *              WSASend                 (WS2_32.72)
2504  */
2505 INT WINAPI WSASend( SOCKET s, LPWSABUF lpBuffers, DWORD dwBufferCount,
2506                     LPDWORD lpNumberOfBytesSent, DWORD dwFlags,
2507                     LPWSAOVERLAPPED lpOverlapped,
2508                     LPWSAOVERLAPPED_COMPLETION_ROUTINE lpCompletionRoutine )
2509 {
2510     return WSASendTo( s, lpBuffers, dwBufferCount, lpNumberOfBytesSent, dwFlags,
2511                       NULL, 0, lpOverlapped, lpCompletionRoutine );
2512 }
2513
2514 /***********************************************************************
2515  *              WSASendDisconnect       (WS2_32.73)
2516  */
2517 INT WINAPI WSASendDisconnect( SOCKET s, LPWSABUF lpBuffers )
2518 {
2519     return WS_shutdown( s, SD_SEND );
2520 }
2521
2522
2523 /***********************************************************************
2524  *              WSASendTo               (WS2_32.74)
2525  */
2526 INT WINAPI WSASendTo( SOCKET s, LPWSABUF lpBuffers, DWORD dwBufferCount,
2527                       LPDWORD lpNumberOfBytesSent, DWORD dwFlags,
2528                       const struct WS_sockaddr *to, int tolen,
2529                       LPWSAOVERLAPPED lpOverlapped,
2530                       LPWSAOVERLAPPED_COMPLETION_ROUTINE lpCompletionRoutine )
2531 {
2532     unsigned int i;
2533     int n, fd, err = WSAENOTSOCK, flags, ret;
2534     struct iovec* iovec;
2535     struct ws2_async *wsa;
2536     IO_STATUS_BLOCK* iosb;
2537
2538     TRACE("socket %04x, wsabuf %p, nbufs %d, flags %d, to %p, tolen %d, ovl %p, func %p\n",
2539           s, lpBuffers, dwBufferCount, dwFlags,
2540           to, tolen, lpOverlapped, lpCompletionRoutine);
2541
2542     fd = get_sock_fd( s, FILE_WRITE_DATA, &flags );
2543     TRACE( "fd=%d, flags=%x\n", fd, flags );
2544
2545     if ( fd == -1 ) return SOCKET_ERROR;
2546
2547     if (flags & FD_FLAG_SEND_SHUTDOWN)
2548     {
2549         WSASetLastError( WSAESHUTDOWN );
2550         goto err_close;
2551     }
2552
2553     if ( !lpNumberOfBytesSent )
2554     {
2555         err = WSAEFAULT;
2556         goto err_close;
2557     }
2558
2559     iovec = HeapAlloc(GetProcessHeap(), 0, dwBufferCount * sizeof(struct iovec) );
2560
2561     if ( !iovec )
2562     {
2563         err = WSAEFAULT;
2564         goto err_close;
2565     }
2566
2567     for ( i = 0; i < dwBufferCount; i++ )
2568     {
2569         iovec[i].iov_base = lpBuffers[i].buf;
2570         iovec[i].iov_len  = lpBuffers[i].len;
2571     }
2572
2573     if ( (lpOverlapped || lpCompletionRoutine) && flags & FD_FLAG_OVERLAPPED )
2574     {
2575         wsa = WS2_make_async( s, fd, ws2m_write, iovec, dwBufferCount,
2576                               &dwFlags, (struct WS_sockaddr*) to, &tolen,
2577                               lpOverlapped, lpCompletionRoutine, &iosb );
2578         if ( !wsa )
2579         {
2580             err = WSAEFAULT;
2581             goto err_free;
2582         }
2583
2584         if ( ( ret = ws2_queue_async( wsa, iosb ) ) )
2585         {
2586             err = NtStatusToWSAError( ret );
2587
2588             if ( !lpOverlapped )
2589                 HeapFree( GetProcessHeap(), 0, iosb );
2590             HeapFree( GetProcessHeap(), 0, wsa );
2591             goto err_free;
2592         }
2593
2594         /* Try immediate completion */
2595         if ( lpOverlapped )
2596         {
2597             if  ( WSAGetOverlappedResult( s, lpOverlapped,
2598                                           lpNumberOfBytesSent, FALSE, &dwFlags) )
2599                 return 0;
2600
2601             if ( (err = WSAGetLastError()) != WSA_IO_INCOMPLETE )
2602                 goto error;
2603         }
2604
2605         WSASetLastError( WSA_IO_PENDING );
2606         return SOCKET_ERROR;
2607     }
2608
2609     if (_is_blocking(s))
2610     {
2611         /* FIXME: exceptfds? */
2612         int timeout = GET_SNDTIMEO(fd);
2613         if( !do_block(fd, POLLOUT, timeout)) {
2614             err = WSAETIMEDOUT;
2615             goto err_free; /* msdn says a timeout in send is fatal */
2616         }
2617     }
2618
2619     n = WS2_send( fd, iovec, dwBufferCount, to, tolen, dwFlags );
2620     if ( n == -1 )
2621     {
2622         err = wsaErrno();
2623         if ( err == WSAEWOULDBLOCK )
2624             _enable_event(SOCKET2HANDLE(s), FD_WRITE, 0, 0);
2625         goto err_free;
2626     }
2627
2628     TRACE(" -> %i bytes\n", n);
2629     *lpNumberOfBytesSent = n;
2630
2631     HeapFree( GetProcessHeap(), 0, iovec );
2632     release_sock_fd( s, fd );
2633     return 0;
2634
2635 err_free:
2636     HeapFree( GetProcessHeap(), 0, iovec );
2637
2638 err_close:
2639     release_sock_fd( s, fd );
2640
2641 error:
2642     WARN(" -> ERROR %d\n", err);
2643     WSASetLastError(err);
2644     return SOCKET_ERROR;
2645 }
2646
2647 /***********************************************************************
2648  *              sendto          (WS2_32.20)
2649  */
2650 int WINAPI WS_sendto(SOCKET s, const char *buf, int len, int flags,
2651                               const struct WS_sockaddr *to, int tolen)
2652 {
2653     DWORD n;
2654     WSABUF wsabuf;
2655
2656     wsabuf.len = len;
2657     wsabuf.buf = (char*) buf;
2658
2659     if ( WSASendTo(s, &wsabuf, 1, &n, flags, to, tolen, NULL, NULL) == SOCKET_ERROR )
2660         return SOCKET_ERROR;
2661     else
2662         return n;
2663 }
2664
2665 /***********************************************************************
2666  *              setsockopt              (WS2_32.21)
2667  */
2668 int WINAPI WS_setsockopt(SOCKET s, int level, int optname,
2669                                   const char *optval, int optlen)
2670 {
2671     int fd;
2672     int woptval;
2673     struct linger linger;
2674     struct timeval tval;
2675
2676     TRACE("socket: %04x, level %d, name %d, ptr %p, len %d\n",
2677           s, level, optname, optval, optlen);
2678
2679     /* SO_OPENTYPE does not require a valid socket handle. */
2680     if (level == WS_SOL_SOCKET && optname == WS_SO_OPENTYPE)
2681     {
2682         if (optlen < sizeof(int) || !optval)
2683         {
2684             SetLastError(WSAEFAULT);
2685             return SOCKET_ERROR;
2686         }
2687         get_per_thread_data()->opentype = *(int *)optval;
2688         TRACE("setting global SO_OPENTYPE to 0x%x\n", *(int *)optval );
2689         return 0;
2690     }
2691
2692     /* For some reason the game GrandPrixLegends does set SO_DONTROUTE on its
2693      * socket. This will either not happen under windows or it is ignored in
2694      * windows (but it works in linux and therefore prevents the game from
2695      * finding games outside the current network) */
2696     if ( level==WS_SOL_SOCKET && optname==WS_SO_DONTROUTE )
2697     {
2698         FIXME("Does windows ignore SO_DONTROUTE?\n");
2699         return 0;
2700     }
2701
2702 #ifdef HAVE_IPX
2703     if(level == NSPROTO_IPX)
2704     {
2705         switch(optname)
2706         {
2707             case IPX_PTYPE:
2708                 fd = get_sock_fd( s, 0, NULL );
2709                 TRACE("trying to set IPX_PTYPE: %d (fd: %d)\n", *(int*)optval, fd);
2710
2711                 /* We try to set the ipx type on ipx socket level. */
2712 #ifdef SOL_IPX
2713                 if(setsockopt(fd, SOL_IPX, IPX_TYPE, optval, optlen) == -1)
2714                 {
2715                     ERR("IPX: could not set ipx option type; expect weird behaviour\n");
2716                     return SOCKET_ERROR;
2717                 }
2718 #else
2719                 {
2720                     struct ipx val;
2721                     /* Should we retrieve val using a getsockopt call and then
2722                      * set the modified one? */
2723                     val.ipx_pt = *optval;
2724                     setsockopt(fd, 0, SO_DEFAULT_HEADERS, &val, sizeof(struct ipx));
2725                 }
2726 #endif
2727                 release_sock_fd( s, fd );
2728                 return 0;
2729             case IPX_FILTERPTYPE:
2730                 /* Sets the receive filter packet type, at the moment we don't support it */
2731                 FIXME("IPX_FILTERPTYPE: %x\n", *optval);
2732
2733                 /* Returning 0 is better for now than returning a SOCKET_ERROR */
2734                 return 0;
2735             default:
2736                 FIXME("opt_name:%x\n", optname);
2737                 return SOCKET_ERROR;
2738         }
2739         return 0;
2740     }
2741 #endif
2742
2743     /* Is a privileged and useless operation, so we don't. */
2744     if ((optname == WS_SO_DEBUG) && (level == WS_SOL_SOCKET))
2745     {
2746         FIXME("(%d,SOL_SOCKET,SO_DEBUG,%p(%d)) attempted (is privileged). Ignoring.\n",s,optval,*(DWORD*)optval);
2747         return 0;
2748     }
2749
2750     if(optname == WS_SO_DONTLINGER && level == WS_SOL_SOCKET) {
2751         /* This is unique to WinSock and takes special conversion */
2752         linger.l_onoff  = *((int*)optval) ? 0: 1;
2753         linger.l_linger = 0;
2754         optname=SO_LINGER;
2755         optval = (char*)&linger;
2756         optlen = sizeof(struct linger);
2757         level = SOL_SOCKET;
2758     }
2759     else
2760     {
2761         if (!convert_sockopt(&level, &optname)) {
2762             ERR("Invalid level (%d) or optname (%d)\n", level, optname);
2763             SetLastError(WSAENOPROTOOPT);
2764             return SOCKET_ERROR;
2765         }
2766         if (optname == SO_LINGER && optval) {
2767             linger.l_onoff  = ((LINGER*)optval)->l_onoff;
2768             linger.l_linger  = ((LINGER*)optval)->l_linger;
2769             /* FIXME: what is documented behavior if SO_LINGER optval
2770                is null?? */
2771             optval = (char*)&linger;
2772             optlen = sizeof(struct linger);
2773         }
2774         else if (optval && optlen < sizeof(int))
2775         {
2776             woptval= *((INT16 *) optval);
2777             optval= (char*) &woptval;
2778             optlen=sizeof(int);
2779         }
2780         if (level == SOL_SOCKET && is_timeout_option(optname))
2781         {
2782             if (optlen == sizeof(UINT32)) {
2783                 /* WinSock passes miliseconds instead of struct timeval */
2784                 tval.tv_usec = (*(PUINT32)optval % 1000) * 1000;
2785                 tval.tv_sec = *(PUINT32)optval / 1000;
2786                 /* min of 500 milisec */
2787                 if (tval.tv_sec == 0 && tval.tv_usec < 500000)
2788                     tval.tv_usec = 500000;
2789                 optlen = sizeof(struct timeval);
2790                 optval = (char*)&tval;
2791             } else if (optlen == sizeof(struct timeval)) {
2792                 WARN("SO_SND/RCVTIMEO for %d bytes: assuming unixism\n", optlen);
2793             } else {
2794                 WARN("SO_SND/RCVTIMEO for %d bytes is weird: ignored\n", optlen);
2795                 return 0;
2796             }
2797         }
2798         if (level == SOL_SOCKET && optname == SO_RCVBUF && *(int*)optval < 2048)
2799         {
2800             WARN("SO_RCVBF for %d bytes is too small: ignored\n", *(int*)optval );
2801             return 0;
2802         }
2803     }
2804
2805
2806     fd = get_sock_fd( s, 0, NULL );
2807     if (fd == -1) return SOCKET_ERROR;
2808
2809     if (setsockopt(fd, level, optname, optval, optlen) == 0)
2810     {
2811         release_sock_fd( s, fd );
2812         return 0;
2813     }
2814     TRACE("Setting socket error, %d\n", wsaErrno());
2815     SetLastError(wsaErrno());
2816     release_sock_fd( s, fd );
2817     return SOCKET_ERROR;
2818 }
2819
2820 /***********************************************************************
2821  *              shutdown                (WS2_32.22)
2822  */
2823 int WINAPI WS_shutdown(SOCKET s, int how)
2824 {
2825     int fd, fd0 = -1, fd1 = -1, flags, err = WSAENOTSOCK;
2826     unsigned int clear_flags = 0;
2827
2828     fd = get_sock_fd( s, 0, &flags );
2829     TRACE("socket %04x, how %i %x\n", s, how, flags );
2830
2831     if (fd == -1)
2832         return SOCKET_ERROR;
2833
2834     switch( how )
2835     {
2836     case 0: /* drop receives */
2837         clear_flags |= FD_READ;
2838         break;
2839     case 1: /* drop sends */
2840         clear_flags |= FD_WRITE;
2841         break;
2842     case 2: /* drop all */
2843         clear_flags |= FD_READ|FD_WRITE;
2844     default:
2845         clear_flags |= FD_WINE_LISTENING;
2846     }
2847
2848     if ( flags & FD_FLAG_OVERLAPPED ) {
2849
2850         switch ( how )
2851         {
2852         case SD_RECEIVE:
2853             fd0 = fd;
2854             break;
2855         case SD_SEND:
2856             fd1 = fd;
2857             break;
2858         case SD_BOTH:
2859         default:
2860             fd0 = fd;
2861             fd1 = get_sock_fd( s, 0, NULL );
2862             break;
2863         }
2864
2865         if ( fd0 != -1 )
2866         {
2867             err = WS2_register_async_shutdown( s, fd0, ws2m_sd_read );
2868             if ( err )
2869             {
2870                 release_sock_fd( s, fd0 );
2871                 goto error;
2872             }
2873         }
2874         if ( fd1 != -1 )
2875         {
2876             err = WS2_register_async_shutdown( s, fd1, ws2m_sd_write );
2877             if ( err )
2878             {
2879                 release_sock_fd( s, fd1 );
2880                 goto error;
2881             }
2882         }
2883     }
2884     else /* non-overlapped mode */
2885     {
2886         if ( shutdown( fd, how ) )
2887         {
2888             err = wsaErrno();
2889             release_sock_fd( s, fd );
2890             goto error;
2891         }
2892         release_sock_fd( s, fd );
2893     }
2894
2895     _enable_event( SOCKET2HANDLE(s), 0, 0, clear_flags );
2896     if ( how > 1) WSAAsyncSelect( s, 0, 0, 0 );
2897     return 0;
2898
2899 error:
2900     _enable_event( SOCKET2HANDLE(s), 0, 0, clear_flags );
2901     WSASetLastError( err );
2902     return SOCKET_ERROR;
2903 }
2904
2905 /***********************************************************************
2906  *              socket          (WS2_32.23)
2907  */
2908 SOCKET WINAPI WS_socket(int af, int type, int protocol)
2909 {
2910     TRACE("af=%d type=%d protocol=%d\n", af, type, protocol);
2911
2912     return WSASocketA( af, type, protocol, NULL, 0,
2913                        get_per_thread_data()->opentype ? 0 : WSA_FLAG_OVERLAPPED );
2914 }
2915
2916
2917 /***********************************************************************
2918  *              gethostbyaddr           (WS2_32.51)
2919  */
2920 struct WS_hostent* WINAPI WS_gethostbyaddr(const char *addr, int len, int type)
2921 {
2922     struct WS_hostent *retval = NULL;
2923     struct hostent* host;
2924
2925 #ifdef HAVE_LINUX_GETHOSTBYNAME_R_6
2926     char *extrabuf;
2927     int ebufsize=1024;
2928     struct hostent hostentry;
2929     int locerr=ENOBUFS;
2930     host = NULL;
2931     extrabuf=HeapAlloc(GetProcessHeap(),0,ebufsize) ;
2932     while(extrabuf) {
2933         int res = gethostbyaddr_r(addr, len, type,
2934                                   &hostentry, extrabuf, ebufsize, &host, &locerr);
2935         if( res != ERANGE) break;
2936         ebufsize *=2;
2937         extrabuf=HeapReAlloc(GetProcessHeap(),0,extrabuf,ebufsize) ;
2938     }
2939     if (!host) SetLastError((locerr < 0) ? wsaErrno() : wsaHerrno(locerr));
2940 #else
2941     EnterCriticalSection( &csWSgetXXXbyYYY );
2942     host = gethostbyaddr(addr, len, type);
2943     if (!host) SetLastError((h_errno < 0) ? wsaErrno() : wsaHerrno(h_errno));
2944 #endif
2945     if( host != NULL ) retval = WS_dup_he(host);
2946 #ifdef  HAVE_LINUX_GETHOSTBYNAME_R_6
2947     HeapFree(GetProcessHeap(),0,extrabuf);
2948 #else
2949     LeaveCriticalSection( &csWSgetXXXbyYYY );
2950 #endif
2951     TRACE("ptr %p, len %d, type %d ret %p\n", addr, len, type, retval);
2952     return retval;
2953 }
2954
2955 /***********************************************************************
2956  *              gethostbyname           (WS2_32.52)
2957  */
2958 struct WS_hostent* WINAPI WS_gethostbyname(const char* name)
2959 {
2960     struct WS_hostent *retval = NULL;
2961     struct hostent*     host;
2962 #ifdef  HAVE_LINUX_GETHOSTBYNAME_R_6
2963     char *extrabuf;
2964     int ebufsize=1024;
2965     struct hostent hostentry;
2966     int locerr = ENOBUFS;
2967 #endif
2968     char buf[100];
2969     if( !name) {
2970         name = buf;
2971         if( gethostname( buf, 100) == -1) {
2972             SetLastError( WSAENOBUFS); /* appropriate ? */
2973             return retval;
2974         }
2975     }
2976 #ifdef  HAVE_LINUX_GETHOSTBYNAME_R_6
2977     host = NULL;
2978     extrabuf=HeapAlloc(GetProcessHeap(),0,ebufsize) ;
2979     while(extrabuf) {
2980         int res = gethostbyname_r(name, &hostentry, extrabuf, ebufsize, &host, &locerr);
2981         if( res != ERANGE) break;
2982         ebufsize *=2;
2983         extrabuf=HeapReAlloc(GetProcessHeap(),0,extrabuf,ebufsize) ;
2984     }
2985     if (!host) SetLastError((locerr < 0) ? wsaErrno() : wsaHerrno(locerr));
2986 #else
2987     EnterCriticalSection( &csWSgetXXXbyYYY );
2988     host = gethostbyname(name);
2989     if (!host) SetLastError((h_errno < 0) ? wsaErrno() : wsaHerrno(h_errno));
2990 #endif
2991     if (host) retval = WS_dup_he(host);
2992 #ifdef  HAVE_LINUX_GETHOSTBYNAME_R_6
2993     HeapFree(GetProcessHeap(),0,extrabuf);
2994 #else
2995     LeaveCriticalSection( &csWSgetXXXbyYYY );
2996 #endif
2997     TRACE( "%s ret %p\n", debugstr_a(name), retval );
2998     return retval;
2999 }
3000
3001
3002 /***********************************************************************
3003  *              getprotobyname          (WS2_32.53)
3004  */
3005 struct WS_protoent* WINAPI WS_getprotobyname(const char* name)
3006 {
3007     struct WS_protoent* retval = NULL;
3008 #ifdef HAVE_GETPROTOBYNAME
3009     struct protoent*     proto;
3010     EnterCriticalSection( &csWSgetXXXbyYYY );
3011     if( (proto = getprotobyname(name)) != NULL )
3012     {
3013         retval = WS_dup_pe(proto);
3014     }
3015     else {
3016         MESSAGE("protocol %s not found; You might want to add "
3017                 "this to /etc/protocols\n", debugstr_a(name) );
3018         SetLastError(WSANO_DATA);
3019     }
3020     LeaveCriticalSection( &csWSgetXXXbyYYY );
3021 #endif
3022     TRACE( "%s ret %p\n", debugstr_a(name), retval );
3023     return retval;
3024 }
3025
3026
3027 /***********************************************************************
3028  *              getprotobynumber        (WS2_32.54)
3029  */
3030 struct WS_protoent* WINAPI WS_getprotobynumber(int number)
3031 {
3032     struct WS_protoent* retval = NULL;
3033 #ifdef HAVE_GETPROTOBYNUMBER
3034     struct protoent*     proto;
3035     EnterCriticalSection( &csWSgetXXXbyYYY );
3036     if( (proto = getprotobynumber(number)) != NULL )
3037     {
3038         retval = WS_dup_pe(proto);
3039     }
3040     else {
3041         MESSAGE("protocol number %d not found; You might want to add "
3042                 "this to /etc/protocols\n", number );
3043         SetLastError(WSANO_DATA);
3044     }
3045     LeaveCriticalSection( &csWSgetXXXbyYYY );
3046 #endif
3047     TRACE("%i ret %p\n", number, retval);
3048     return retval;
3049 }
3050
3051
3052 /***********************************************************************
3053  *              getservbyname           (WS2_32.55)
3054  */
3055 struct WS_servent* WINAPI WS_getservbyname(const char *name, const char *proto)
3056 {
3057     struct WS_servent* retval = NULL;
3058     struct servent*     serv;
3059     char *name_str;
3060     char *proto_str = NULL;
3061
3062     if (!(name_str = strdup_lower(name))) return NULL;
3063
3064     if (proto && *proto)
3065     {
3066         if (!(proto_str = strdup_lower(proto)))
3067         {
3068             HeapFree( GetProcessHeap(), 0, name_str );
3069             return NULL;
3070         }
3071     }
3072
3073     EnterCriticalSection( &csWSgetXXXbyYYY );
3074     serv = getservbyname(name_str, proto_str);
3075     if( serv != NULL )
3076     {
3077         retval = WS_dup_se(serv);
3078     }
3079     else SetLastError(WSANO_DATA);
3080     LeaveCriticalSection( &csWSgetXXXbyYYY );
3081     HeapFree( GetProcessHeap(), 0, proto_str );
3082     HeapFree( GetProcessHeap(), 0, name_str );
3083     TRACE( "%s, %s ret %p\n", debugstr_a(name), debugstr_a(proto), retval );
3084     return retval;
3085 }
3086
3087 /***********************************************************************
3088  *              freeaddrinfo            (WS2_32.@)
3089  */
3090 void WINAPI WS_freeaddrinfo(struct WS_addrinfo *res)
3091 {
3092     while (res) {
3093         struct WS_addrinfo *next;
3094
3095         HeapFree(GetProcessHeap(),0,res->ai_canonname);
3096         HeapFree(GetProcessHeap(),0,res->ai_addr);
3097         next = res->ai_next;
3098         HeapFree(GetProcessHeap(),0,res);
3099         res = next;
3100     }
3101 }
3102
3103 /* helper functions for getaddrinfo() */
3104 static int convert_aiflag_w2u(int winflags) {
3105     int i, unixflags = 0;
3106
3107     for (i=0;i<sizeof(ws_aiflag_map)/sizeof(ws_aiflag_map[0]);i++)
3108         if (ws_aiflag_map[i][0] & winflags) {
3109             unixflags |= ws_aiflag_map[i][1];
3110             winflags &= ~ws_aiflag_map[i][0];
3111         }
3112     if (winflags)
3113         FIXME("Unhandled windows AI_xxx flags %x\n", winflags);
3114     return unixflags;
3115 }
3116
3117 static int convert_aiflag_u2w(int unixflags) {
3118     int i, winflags = 0;
3119
3120     for (i=0;i<sizeof(ws_aiflag_map)/sizeof(ws_aiflag_map[0]);i++)
3121         if (ws_aiflag_map[i][1] & unixflags) {
3122             winflags |= ws_aiflag_map[i][0];
3123             unixflags &= ~ws_aiflag_map[i][1];
3124         }
3125     if (unixflags) /* will warn usually */
3126         WARN("Unhandled UNIX AI_xxx flags %x\n", unixflags);
3127     return winflags;
3128 }
3129
3130 static int convert_eai_u2w(int unixret) {
3131     int i;
3132
3133     for (i=0;ws_eai_map[i][0];i++)
3134         if (ws_eai_map[i][1] == unixret)
3135             return ws_eai_map[i][0];
3136     return unixret;
3137 }
3138
3139 /***********************************************************************
3140  *              getaddrinfo             (WS2_32.@)
3141  */
3142 int WINAPI WS_getaddrinfo(LPCSTR nodename, LPCSTR servname, const struct WS_addrinfo *hints, struct WS_addrinfo **res)
3143 {
3144 #if HAVE_GETADDRINFO
3145     struct addrinfo *unixaires = NULL;
3146     int   result;
3147     struct addrinfo unixhints, *punixhints = NULL;
3148     CHAR *node = NULL, *serv = NULL;
3149
3150     if (nodename)
3151         if (!(node = strdup_lower(nodename))) return WSA_NOT_ENOUGH_MEMORY;
3152
3153     if (servname) {
3154         if (!(serv = strdup_lower(servname))) {
3155             HeapFree(GetProcessHeap(), 0, node);
3156             return WSA_NOT_ENOUGH_MEMORY;
3157         }
3158     }
3159
3160     if (hints) {
3161         punixhints = &unixhints;
3162
3163         memset(&unixhints, 0, sizeof(unixhints));
3164         punixhints->ai_flags    = convert_aiflag_w2u(hints->ai_flags);
3165         if (hints->ai_family == 0) /* wildcard, specific to getaddrinfo() */
3166             punixhints->ai_family = 0;
3167         else
3168             punixhints->ai_family = convert_af_w2u(hints->ai_family);
3169         if (hints->ai_socktype == 0) /* wildcard, specific to getaddrinfo() */
3170             punixhints->ai_socktype = 0;
3171         else
3172             punixhints->ai_socktype = convert_socktype_w2u(hints->ai_socktype);
3173         if (hints->ai_protocol == 0) /* wildcard, specific to getaddrinfo() */
3174             punixhints->ai_protocol = 0;
3175         else
3176             punixhints->ai_protocol = convert_proto_w2u(hints->ai_protocol);
3177     }
3178
3179     /* getaddrinfo(3) is thread safe, no need to wrap in CS */
3180     result = getaddrinfo(nodename, servname, punixhints, &unixaires);
3181
3182     TRACE("%s, %s %p -> %p %d\n", nodename, servname, hints, res, result);
3183
3184     HeapFree(GetProcessHeap(), 0, node);
3185     HeapFree(GetProcessHeap(), 0, serv);
3186
3187     if (!result) {
3188         struct addrinfo *xuai = unixaires;
3189         struct WS_addrinfo **xai = res;
3190
3191         *xai = NULL;
3192         while (xuai) {
3193             struct WS_addrinfo *ai = HeapAlloc(GetProcessHeap(),HEAP_ZERO_MEMORY, sizeof(struct WS_addrinfo));
3194             int len;
3195
3196             if (!ai)
3197                 goto outofmem;
3198
3199             *xai = ai;xai = &ai->ai_next;
3200             ai->ai_flags    = convert_aiflag_u2w(xuai->ai_flags);
3201             ai->ai_family   = convert_af_u2w(xuai->ai_family);
3202             ai->ai_socktype = convert_socktype_u2w(xuai->ai_socktype);
3203             ai->ai_protocol = convert_proto_u2w(xuai->ai_protocol);
3204             if (xuai->ai_canonname) {
3205                 TRACE("canon name - %s\n",debugstr_a(xuai->ai_canonname));
3206                 ai->ai_canonname = HeapAlloc(GetProcessHeap(),0,strlen(xuai->ai_canonname)+1);
3207                 if (!ai->ai_canonname)
3208                     goto outofmem;
3209                 strcpy(ai->ai_canonname,xuai->ai_canonname);
3210             }
3211             len = xuai->ai_addrlen;
3212             ai->ai_addr = HeapAlloc(GetProcessHeap(),0,len);
3213             if (!ai->ai_addr)
3214                 goto outofmem;
3215             ai->ai_addrlen = len;
3216             do {
3217                 int winlen = ai->ai_addrlen;
3218
3219                 if (!ws_sockaddr_u2ws(xuai->ai_addr, xuai->ai_addrlen, ai->ai_addr, &winlen)) {
3220                     ai->ai_addrlen = winlen;
3221                     break;
3222                 }
3223                 len = 2*len;
3224                 ai->ai_addr = HeapReAlloc(GetProcessHeap(),0,ai->ai_addr,len);
3225                 if (!ai->ai_addr)
3226                     goto outofmem;
3227                 ai->ai_addrlen = len;
3228             } while (1);
3229             xuai = xuai->ai_next;
3230         }
3231         freeaddrinfo(unixaires);
3232     } else {
3233         result = convert_eai_u2w(result);
3234     }
3235     return result;
3236
3237 outofmem:
3238     if (*res) WS_freeaddrinfo(*res);
3239     if (unixaires) freeaddrinfo(unixaires);
3240     *res = NULL;
3241     return WSA_NOT_ENOUGH_MEMORY;
3242 #else
3243     FIXME("getaddrinfo() failed, not found during buildtime.\n");
3244     return EAI_FAIL;
3245 #endif
3246 }
3247
3248 /***********************************************************************
3249  *              GetAddrInfoW            (WS2_32.@)
3250  */
3251 int WINAPI GetAddrInfoW(LPCWSTR nodename, LPCWSTR servname, const ADDRINFOW *hints, PADDRINFOW *res)
3252 {
3253     FIXME("empty stub!\n");
3254     return EAI_FAIL;
3255 }
3256
3257 int WINAPI WS_getnameinfo(const SOCKADDR *sa, WS_socklen_t salen, PCHAR host,
3258                           DWORD hostlen, PCHAR serv, DWORD servlen, INT flags)
3259 {
3260 #if HAVE_GETNAMEINFO
3261     int ret;
3262     const struct sockaddr* sa_u;
3263     unsigned int size;
3264
3265     TRACE("%s %d %p %d %p %d %d\n", debugstr_sockaddr(sa), salen, host, hostlen,
3266           serv, servlen, flags);
3267
3268     sa_u = ws_sockaddr_ws2u(sa, salen, &size);
3269     if (!sa_u)
3270     {
3271         WSASetLastError(WSAEFAULT);
3272         return WSA_NOT_ENOUGH_MEMORY;
3273     }
3274     ret = getnameinfo(sa_u, size, host, hostlen, serv, servlen, convert_aiflag_w2u(flags));
3275
3276     ws_sockaddr_free(sa_u, sa);
3277     return convert_eai_u2w(ret);
3278 #else
3279     FIXME("getnameinfo() failed, not found during buildtime.\n");
3280     return EAI_FAIL;
3281 #endif
3282 }
3283
3284 /***********************************************************************
3285  *              getservbyport           (WS2_32.56)
3286  */
3287 struct WS_servent* WINAPI WS_getservbyport(int port, const char *proto)
3288 {
3289     struct WS_servent* retval = NULL;
3290 #ifdef HAVE_GETSERVBYPORT
3291     struct servent*     serv;
3292     char *proto_str = NULL;
3293
3294     if (proto && *proto)
3295     {
3296         if (!(proto_str = strdup_lower(proto))) return NULL;
3297     }
3298     EnterCriticalSection( &csWSgetXXXbyYYY );
3299     if( (serv = getservbyport(port, proto_str)) != NULL ) {
3300         retval = WS_dup_se(serv);
3301     }
3302     else SetLastError(WSANO_DATA);
3303     LeaveCriticalSection( &csWSgetXXXbyYYY );
3304     HeapFree( GetProcessHeap(), 0, proto_str );
3305 #endif
3306     TRACE("%d (i.e. port %d), %s ret %p\n", port, (int)ntohl(port), debugstr_a(proto), retval);
3307     return retval;
3308 }
3309
3310
3311 /***********************************************************************
3312  *              gethostname           (WS2_32.57)
3313  */
3314 int WINAPI WS_gethostname(char *name, int namelen)
3315 {
3316     TRACE("name %p, len %d\n", name, namelen);
3317
3318     if (gethostname(name, namelen) == 0)
3319     {
3320         TRACE("<- '%s'\n", name);
3321         return 0;
3322     }
3323     SetLastError((errno == EINVAL) ? WSAEFAULT : wsaErrno());
3324     TRACE("<- ERROR !\n");
3325     return SOCKET_ERROR;
3326 }
3327
3328
3329 /* ------------------------------------- Windows sockets extensions -- *
3330  *                                                                     *
3331  * ------------------------------------------------------------------- */
3332
3333 /***********************************************************************
3334  *              WSAEnumNetworkEvents (WS2_32.36)
3335  */
3336 int WINAPI WSAEnumNetworkEvents(SOCKET s, WSAEVENT hEvent, LPWSANETWORKEVENTS lpEvent)
3337 {
3338     int ret;
3339
3340     TRACE("%08x, hEvent %p, lpEvent %p\n", s, hEvent, lpEvent );
3341
3342     SERVER_START_REQ( get_socket_event )
3343     {
3344         req->handle  = SOCKET2HANDLE(s);
3345         req->service = TRUE;
3346         req->c_event = hEvent;
3347         wine_server_set_reply( req, lpEvent->iErrorCode, sizeof(lpEvent->iErrorCode) );
3348         if (!(ret = wine_server_call(req))) lpEvent->lNetworkEvents = reply->pmask & reply->mask;
3349     }
3350     SERVER_END_REQ;
3351     if (!ret) return 0;
3352     SetLastError(WSAEINVAL);
3353     return SOCKET_ERROR;
3354 }
3355
3356 /***********************************************************************
3357  *              WSAEventSelect (WS2_32.39)
3358  */
3359 int WINAPI WSAEventSelect(SOCKET s, WSAEVENT hEvent, long lEvent)
3360 {
3361     int ret;
3362
3363     TRACE("%08x, hEvent %p, event %08x\n", s, hEvent, (unsigned)lEvent );
3364
3365     SERVER_START_REQ( set_socket_event )
3366     {
3367         req->handle = SOCKET2HANDLE(s);
3368         req->mask   = lEvent;
3369         req->event  = hEvent;
3370         req->window = 0;
3371         req->msg    = 0;
3372         ret = wine_server_call( req );
3373     }
3374     SERVER_END_REQ;
3375     if (!ret) return 0;
3376     SetLastError(WSAEINVAL);
3377     return SOCKET_ERROR;
3378 }
3379
3380 /**********************************************************************
3381  *      WSAGetOverlappedResult (WS2_32.40)
3382  */
3383 BOOL WINAPI WSAGetOverlappedResult( SOCKET s, LPWSAOVERLAPPED lpOverlapped,
3384                                     LPDWORD lpcbTransfer, BOOL fWait,
3385                                     LPDWORD lpdwFlags )
3386 {
3387     DWORD r;
3388
3389     TRACE( "socket %04x ovl %p trans %p, wait %d flags %p\n",
3390            s, lpOverlapped, lpcbTransfer, fWait, lpdwFlags );
3391
3392     if ( lpOverlapped == NULL )
3393     {
3394         ERR( "Invalid pointer\n" );
3395         WSASetLastError(WSA_INVALID_PARAMETER);
3396         return FALSE;
3397     }
3398
3399     if ( fWait )
3400     {
3401         if (lpOverlapped->hEvent)
3402             while ( WaitForSingleObjectEx(lpOverlapped->hEvent,
3403                                           INFINITE, TRUE) == STATUS_USER_APC );
3404         else /* busy loop */
3405             while ( ((volatile OVERLAPPED*)lpOverlapped)->Internal == STATUS_PENDING )
3406                 Sleep( 10 );
3407
3408     }
3409     else if ( lpOverlapped->Internal == STATUS_PENDING )
3410     {
3411         /* Wait in order to give APCs a chance to run. */
3412         /* This is cheating, so we must set the event again in case of success -
3413            it may be a non-manual reset event. */
3414         while ( (r = WaitForSingleObjectEx(lpOverlapped->hEvent, 0, TRUE)) == STATUS_USER_APC );
3415         if ( r == WAIT_OBJECT_0 && lpOverlapped->hEvent )
3416             NtSetEvent( lpOverlapped->hEvent, NULL );
3417     }
3418
3419     if ( lpcbTransfer )
3420         *lpcbTransfer = lpOverlapped->InternalHigh;
3421
3422     if ( lpdwFlags )
3423         *lpdwFlags = lpOverlapped->u.s.Offset;
3424
3425     switch ( lpOverlapped->Internal )
3426     {
3427     case STATUS_SUCCESS:
3428         return TRUE;
3429     case STATUS_PENDING:
3430         WSASetLastError( WSA_IO_INCOMPLETE );
3431         if (fWait) ERR("PENDING status after waiting!\n");
3432         return FALSE;
3433     default:
3434         WSASetLastError( NtStatusToWSAError( lpOverlapped->Internal ));
3435         return FALSE;
3436     }
3437 }
3438
3439
3440 /***********************************************************************
3441  *      WSAAsyncSelect                  (WS2_32.101)
3442  */
3443 INT WINAPI WSAAsyncSelect(SOCKET s, HWND hWnd, UINT uMsg, long lEvent)
3444 {
3445     int ret;
3446
3447     TRACE("%x, hWnd %p, uMsg %08x, event %08lx\n", s, hWnd, uMsg, lEvent );
3448
3449     SERVER_START_REQ( set_socket_event )
3450     {
3451         req->handle = SOCKET2HANDLE(s);
3452         req->mask   = lEvent;
3453         req->event  = 0;
3454         req->window = hWnd;
3455         req->msg    = uMsg;
3456         ret = wine_server_call( req );
3457     }
3458     SERVER_END_REQ;
3459     if (!ret) return 0;
3460     SetLastError(WSAEINVAL);
3461     return SOCKET_ERROR;
3462 }
3463
3464 /***********************************************************************
3465  *      WSACreateEvent          (WS2_32.31)
3466  *
3467  */
3468 WSAEVENT WINAPI WSACreateEvent(void)
3469 {
3470     /* Create a manual-reset event, with initial state: unsignaled */
3471     TRACE("\n");
3472
3473     return CreateEventW(NULL, TRUE, FALSE, NULL);
3474 }
3475
3476 /***********************************************************************
3477  *      WSACloseEvent          (WS2_32.29)
3478  *
3479  */
3480 BOOL WINAPI WSACloseEvent(WSAEVENT event)
3481 {
3482     TRACE ("event=%p\n", event);
3483
3484     return CloseHandle(event);
3485 }
3486
3487 /***********************************************************************
3488  *      WSASocketA          (WS2_32.78)
3489  *
3490  */
3491 SOCKET WINAPI WSASocketA(int af, int type, int protocol,
3492                          LPWSAPROTOCOL_INFOA lpProtocolInfo,
3493                          GROUP g, DWORD dwFlags)
3494 {
3495     INT len;
3496     WSAPROTOCOL_INFOW info;
3497
3498     TRACE("af=%d type=%d protocol=%d protocol_info=%p group=%d flags=0x%x\n",
3499           af, type, protocol, lpProtocolInfo, g, dwFlags);
3500
3501     if (!lpProtocolInfo) return WSASocketW(af, type, protocol, NULL, g, dwFlags);
3502
3503     memcpy(&info, lpProtocolInfo, FIELD_OFFSET(WSAPROTOCOL_INFOW, szProtocol));
3504     len = MultiByteToWideChar(CP_ACP, 0, lpProtocolInfo->szProtocol, -1,
3505                               info.szProtocol, WSAPROTOCOL_LEN + 1);
3506
3507     if (!len)
3508     {
3509         WSASetLastError( WSAEINVAL);
3510         return SOCKET_ERROR;
3511     }
3512
3513     return WSASocketW(af, type, protocol, &info, g, dwFlags);
3514 }
3515
3516 /***********************************************************************
3517  *      WSASocketW          (WS2_32.79)
3518  *
3519  */
3520 SOCKET WINAPI WSASocketW(int af, int type, int protocol,
3521                          LPWSAPROTOCOL_INFOW lpProtocolInfo,
3522                          GROUP g, DWORD dwFlags)
3523 {
3524     SOCKET ret;
3525
3526    /*
3527       FIXME: The "advanced" parameters of WSASocketW (lpProtocolInfo,
3528       g, dwFlags except WSA_FLAG_OVERLAPPED) are ignored.
3529    */
3530
3531    TRACE("af=%d type=%d protocol=%d protocol_info=%p group=%d flags=0x%x\n",
3532          af, type, protocol, lpProtocolInfo, g, dwFlags );
3533
3534     /* hack for WSADuplicateSocket */
3535     if (lpProtocolInfo && lpProtocolInfo->dwServiceFlags4 == 0xff00ff00) {
3536       ret = lpProtocolInfo->dwCatalogEntryId;
3537       TRACE("\tgot duplicate %04x\n", ret);
3538       return ret;
3539     }
3540
3541     /* check and convert the socket family */
3542     af = convert_af_w2u(af);
3543     if (af == -1)
3544     {
3545       FIXME("Unsupported socket family %d!\n", af);
3546       SetLastError(WSAEAFNOSUPPORT);
3547       return INVALID_SOCKET;
3548     }
3549
3550     /* check the socket type */
3551     type = convert_socktype_w2u(type);
3552     if (type == -1)
3553     {
3554       SetLastError(WSAESOCKTNOSUPPORT);
3555       return INVALID_SOCKET;
3556     }
3557
3558     /* check the protocol type */
3559     if ( protocol < 0 )  /* don't support negative values */
3560     {
3561         SetLastError(WSAEPROTONOSUPPORT);
3562         return INVALID_SOCKET;
3563     }
3564
3565     if ( af == AF_UNSPEC)  /* did they not specify the address family? */
3566         switch(protocol)
3567         {
3568           case IPPROTO_TCP:
3569              if (type == SOCK_STREAM) { af = AF_INET; break; }
3570           case IPPROTO_UDP:
3571              if (type == SOCK_DGRAM)  { af = AF_INET; break; }
3572           default: SetLastError(WSAEPROTOTYPE); return INVALID_SOCKET;
3573         }
3574
3575     SERVER_START_REQ( create_socket )
3576     {
3577         req->family     = af;
3578         req->type       = type;
3579         req->protocol   = protocol;
3580         req->access     = GENERIC_READ|GENERIC_WRITE|SYNCHRONIZE;
3581         req->attributes = OBJ_INHERIT;
3582         req->flags      = dwFlags;
3583         set_error( wine_server_call( req ) );
3584         ret = HANDLE2SOCKET( reply->handle );
3585     }
3586     SERVER_END_REQ;
3587     if (ret)
3588     {
3589         TRACE("\tcreated %04x\n", ret );
3590         return ret;
3591     }
3592
3593     if (GetLastError() == WSAEACCES) /* raw socket denied */
3594     {
3595         if (type == SOCK_RAW)
3596             MESSAGE("WARNING: Trying to create a socket of type SOCK_RAW, will fail unless running as root\n");
3597         else
3598             MESSAGE("WS_SOCKET: not enough privileges to create socket, try running as root\n");
3599         SetLastError(WSAESOCKTNOSUPPORT);
3600     }
3601
3602     WARN("\t\tfailed!\n");
3603     return INVALID_SOCKET;
3604 }
3605
3606 /***********************************************************************
3607  *      WSAJoinLeaf          (WS2_32.58)
3608  *
3609  */
3610 SOCKET WINAPI WSAJoinLeaf(
3611         SOCKET s,
3612         const struct WS_sockaddr *addr,
3613         int addrlen,
3614         LPWSABUF lpCallerData,
3615         LPWSABUF lpCalleeData,
3616         LPQOS lpSQOS,
3617         LPQOS lpGQOS,
3618         DWORD dwFlags)
3619 {
3620     FIXME("stub.\n");
3621     return INVALID_SOCKET;
3622 }
3623
3624 /***********************************************************************
3625  *      __WSAFDIsSet                    (WS2_32.151)
3626  */
3627 int WINAPI __WSAFDIsSet(SOCKET s, WS_fd_set *set)
3628 {
3629   int i = set->fd_count;
3630
3631   TRACE("(%d,%p(%i))\n", s, set, i);
3632
3633   while (i--)
3634       if (set->fd_array[i] == s) return 1;
3635   return 0;
3636 }
3637
3638 /***********************************************************************
3639  *      WSAIsBlocking                   (WINSOCK.114)
3640  *      WSAIsBlocking                   (WS2_32.114)
3641  */
3642 BOOL WINAPI WSAIsBlocking(void)
3643 {
3644   /* By default WinSock should set all its sockets to non-blocking mode
3645    * and poll in PeekMessage loop when processing "blocking" ones. This
3646    * function is supposed to tell if the program is in this loop. Our
3647    * blocking calls are truly blocking so we always return FALSE.
3648    *
3649    * Note: It is allowed to call this function without prior WSAStartup().
3650    */
3651
3652   TRACE("\n");
3653   return FALSE;
3654 }
3655
3656 /***********************************************************************
3657  *      WSACancelBlockingCall           (WINSOCK.113)
3658  *      WSACancelBlockingCall           (WS2_32.113)
3659  */
3660 INT WINAPI WSACancelBlockingCall(void)
3661 {
3662     TRACE("\n");
3663     return 0;
3664 }
3665
3666 static INT WINAPI WSA_DefaultBlockingHook( FARPROC x )
3667 {
3668     FIXME("How was this called?\n");
3669     return x();
3670 }
3671
3672
3673 /***********************************************************************
3674  *      WSASetBlockingHook (WS2_32.109)
3675  */
3676 FARPROC WINAPI WSASetBlockingHook(FARPROC lpBlockFunc)
3677 {
3678   FARPROC prev = blocking_hook;
3679   blocking_hook = lpBlockFunc;
3680   TRACE("hook %p\n", lpBlockFunc);
3681   return prev;
3682 }
3683
3684
3685 /***********************************************************************
3686  *      WSAUnhookBlockingHook (WS2_32.110)
3687  */
3688 INT WINAPI WSAUnhookBlockingHook(void)
3689 {
3690     blocking_hook = WSA_DefaultBlockingHook;
3691     return 0;
3692 }
3693
3694
3695 /* ----------------------------------- end of API stuff */
3696
3697 /* ----------------------------------- helper functions -
3698  *
3699  * TODO: Merge WS_dup_..() stuff into one function that
3700  * would operate with a generic structure containing internal
3701  * pointers (via a template of some kind).
3702  */
3703
3704 static int list_size(char** l, int item_size)
3705 {
3706   int i,j = 0;
3707   if(l)
3708   { for(i=0;l[i];i++)
3709         j += (item_size) ? item_size : strlen(l[i]) + 1;
3710     j += (i + 1) * sizeof(char*); }
3711   return j;
3712 }
3713
3714 static int list_dup(char** l_src, char** l_to, int item_size)
3715 {
3716    char *p;
3717    int i;
3718
3719    for (i = 0; l_src[i]; i++) ;
3720    p = (char *)(l_to + i + 1);
3721    for (i = 0; l_src[i]; i++)
3722    {
3723        int count = ( item_size ) ? item_size : strlen(l_src[i]) + 1;
3724        memcpy(p, l_src[i], count);
3725        l_to[i] = p;
3726        p += count;
3727    }
3728    l_to[i] = NULL;
3729    return p - (char *)l_to;
3730 }
3731
3732 /* ----- hostent */
3733
3734 /* duplicate hostent entry
3735  * and handle all Win16/Win32 dependent things (struct size, ...) *correctly*.
3736  * Dito for protoent and servent.
3737  */
3738 static struct WS_hostent *WS_dup_he(const struct hostent* p_he)
3739 {
3740     char *p;
3741     struct WS_hostent *p_to;
3742
3743     int size = (sizeof(*p_he) +
3744                 strlen(p_he->h_name) + 1 +
3745                 list_size(p_he->h_aliases, 0) +
3746                 list_size(p_he->h_addr_list, p_he->h_length));
3747
3748     if (!(p_to = check_buffer_he(size))) return NULL;
3749     p_to->h_addrtype = p_he->h_addrtype;
3750     p_to->h_length = p_he->h_length;
3751
3752     p = (char *)(p_to + 1);
3753     p_to->h_name = p;
3754     strcpy(p, p_he->h_name);
3755     p += strlen(p) + 1;
3756
3757     p_to->h_aliases = (char **)p;
3758     p += list_dup(p_he->h_aliases, p_to->h_aliases, 0);
3759
3760     p_to->h_addr_list = (char **)p;
3761     list_dup(p_he->h_addr_list, p_to->h_addr_list, p_he->h_length);
3762     return p_to;
3763 }
3764
3765 /* ----- protoent */
3766
3767 static struct WS_protoent *WS_dup_pe(const struct protoent* p_pe)
3768 {
3769     char *p;
3770     struct WS_protoent *p_to;
3771
3772     int size = (sizeof(*p_pe) +
3773                 strlen(p_pe->p_name) + 1 +
3774                 list_size(p_pe->p_aliases, 0));
3775
3776     if (!(p_to = check_buffer_pe(size))) return NULL;
3777     p_to->p_proto = p_pe->p_proto;
3778
3779     p = (char *)(p_to + 1);
3780     p_to->p_name = p;
3781     strcpy(p, p_pe->p_name);
3782     p += strlen(p) + 1;
3783
3784     p_to->p_aliases = (char **)p;
3785     list_dup(p_pe->p_aliases, p_to->p_aliases, 0);
3786     return p_to;
3787 }
3788
3789 /* ----- servent */
3790
3791 static struct WS_servent *WS_dup_se(const struct servent* p_se)
3792 {
3793     char *p;
3794     struct WS_servent *p_to;
3795
3796     int size = (sizeof(*p_se) +
3797                 strlen(p_se->s_proto) + 1 +
3798                 strlen(p_se->s_name) + 1 +
3799                 list_size(p_se->s_aliases, 0));
3800
3801     if (!(p_to = check_buffer_se(size))) return NULL;
3802     p_to->s_port = p_se->s_port;
3803
3804     p = (char *)(p_to + 1);
3805     p_to->s_name = p;
3806     strcpy(p, p_se->s_name);
3807     p += strlen(p) + 1;
3808
3809     p_to->s_proto = p;
3810     strcpy(p, p_se->s_proto);
3811     p += strlen(p) + 1;
3812
3813     p_to->s_aliases = (char **)p;
3814     list_dup(p_se->s_aliases, p_to->s_aliases, 0);
3815     return p_to;
3816 }
3817
3818 /* ----------------------------------- error handling */
3819
3820 UINT wsaErrno(void)
3821 {
3822     int loc_errno = errno;
3823     WARN("errno %d, (%s).\n", loc_errno, strerror(loc_errno));
3824
3825     switch(loc_errno)
3826     {
3827         case EINTR:             return WSAEINTR;
3828         case EBADF:             return WSAEBADF;
3829         case EPERM:
3830         case EACCES:            return WSAEACCES;
3831         case EFAULT:            return WSAEFAULT;
3832         case EINVAL:            return WSAEINVAL;
3833         case EMFILE:            return WSAEMFILE;
3834         case EWOULDBLOCK:       return WSAEWOULDBLOCK;
3835         case EINPROGRESS:       return WSAEINPROGRESS;
3836         case EALREADY:          return WSAEALREADY;
3837         case ENOTSOCK:          return WSAENOTSOCK;
3838         case EDESTADDRREQ:      return WSAEDESTADDRREQ;
3839         case EMSGSIZE:          return WSAEMSGSIZE;
3840         case EPROTOTYPE:        return WSAEPROTOTYPE;
3841         case ENOPROTOOPT:       return WSAENOPROTOOPT;
3842         case EPROTONOSUPPORT:   return WSAEPROTONOSUPPORT;
3843         case ESOCKTNOSUPPORT:   return WSAESOCKTNOSUPPORT;
3844         case EOPNOTSUPP:        return WSAEOPNOTSUPP;
3845         case EPFNOSUPPORT:      return WSAEPFNOSUPPORT;
3846         case EAFNOSUPPORT:      return WSAEAFNOSUPPORT;
3847         case EADDRINUSE:        return WSAEADDRINUSE;
3848         case EADDRNOTAVAIL:     return WSAEADDRNOTAVAIL;
3849         case ENETDOWN:          return WSAENETDOWN;
3850         case ENETUNREACH:       return WSAENETUNREACH;
3851         case ENETRESET:         return WSAENETRESET;
3852         case ECONNABORTED:      return WSAECONNABORTED;
3853         case EPIPE:
3854         case ECONNRESET:        return WSAECONNRESET;
3855         case ENOBUFS:           return WSAENOBUFS;
3856         case EISCONN:           return WSAEISCONN;
3857         case ENOTCONN:          return WSAENOTCONN;
3858         case ESHUTDOWN:         return WSAESHUTDOWN;
3859         case ETOOMANYREFS:      return WSAETOOMANYREFS;
3860         case ETIMEDOUT:         return WSAETIMEDOUT;
3861         case ECONNREFUSED:      return WSAECONNREFUSED;
3862         case ELOOP:             return WSAELOOP;
3863         case ENAMETOOLONG:      return WSAENAMETOOLONG;
3864         case EHOSTDOWN:         return WSAEHOSTDOWN;
3865         case EHOSTUNREACH:      return WSAEHOSTUNREACH;
3866         case ENOTEMPTY:         return WSAENOTEMPTY;
3867 #ifdef EPROCLIM
3868         case EPROCLIM:          return WSAEPROCLIM;
3869 #endif
3870 #ifdef EUSERS
3871         case EUSERS:            return WSAEUSERS;
3872 #endif
3873 #ifdef EDQUOT
3874         case EDQUOT:            return WSAEDQUOT;
3875 #endif
3876 #ifdef ESTALE
3877         case ESTALE:            return WSAESTALE;
3878 #endif
3879 #ifdef EREMOTE
3880         case EREMOTE:           return WSAEREMOTE;
3881 #endif
3882
3883        /* just in case we ever get here and there are no problems */
3884         case 0:                 return 0;
3885         default:
3886                 WARN("Unknown errno %d!\n", loc_errno);
3887                 return WSAEOPNOTSUPP;
3888     }
3889 }
3890
3891 UINT wsaHerrno(int loc_errno)
3892 {
3893
3894     WARN("h_errno %d.\n", loc_errno);
3895
3896     switch(loc_errno)
3897     {
3898         case HOST_NOT_FOUND:    return WSAHOST_NOT_FOUND;
3899         case TRY_AGAIN:         return WSATRY_AGAIN;
3900         case NO_RECOVERY:       return WSANO_RECOVERY;
3901         case NO_DATA:           return WSANO_DATA;
3902         case ENOBUFS:           return WSAENOBUFS;
3903
3904         case 0:                 return 0;
3905         default:
3906                 WARN("Unknown h_errno %d!\n", loc_errno);
3907                 return WSAEOPNOTSUPP;
3908     }
3909 }
3910
3911
3912 /***********************************************************************
3913  *              WSARecv                 (WS2_32.67)
3914  */
3915 int WINAPI WSARecv(SOCKET s, LPWSABUF lpBuffers, DWORD dwBufferCount,
3916                    LPDWORD NumberOfBytesReceived, LPDWORD lpFlags,
3917                    LPWSAOVERLAPPED lpOverlapped,
3918                    LPWSAOVERLAPPED_COMPLETION_ROUTINE lpCompletionRoutine)
3919 {
3920     return WSARecvFrom(s, lpBuffers, dwBufferCount, NumberOfBytesReceived, lpFlags,
3921                        NULL, NULL, lpOverlapped, lpCompletionRoutine);
3922 }
3923
3924 /***********************************************************************
3925  *              WSARecvFrom             (WS2_32.69)
3926  */
3927 INT WINAPI WSARecvFrom( SOCKET s, LPWSABUF lpBuffers, DWORD dwBufferCount,
3928                         LPDWORD lpNumberOfBytesRecvd, LPDWORD lpFlags, struct WS_sockaddr *lpFrom,
3929                         LPINT lpFromlen, LPWSAOVERLAPPED lpOverlapped,
3930                         LPWSAOVERLAPPED_COMPLETION_ROUTINE lpCompletionRoutine )
3931
3932 {
3933     unsigned int i;
3934     int n, fd, err = WSAENOTSOCK, flags, ret;
3935     struct iovec* iovec;
3936     struct ws2_async *wsa;
3937     IO_STATUS_BLOCK* iosb;
3938
3939     TRACE("socket %04x, wsabuf %p, nbufs %d, flags %d, from %p, fromlen %ld, ovl %p, func %p\n",
3940           s, lpBuffers, dwBufferCount, *lpFlags, lpFrom,
3941           (lpFromlen ? *lpFromlen : -1L),
3942           lpOverlapped, lpCompletionRoutine);
3943
3944     fd = get_sock_fd( s, FILE_READ_DATA, &flags );
3945     TRACE( "fd=%d, flags=%x\n", fd, flags );
3946
3947     if (fd == -1) return SOCKET_ERROR;
3948
3949     if (flags & FD_FLAG_RECV_SHUTDOWN)
3950     {
3951         WSASetLastError( WSAESHUTDOWN );
3952         goto err_close;
3953     }
3954
3955     iovec = HeapAlloc( GetProcessHeap(), 0, dwBufferCount * sizeof (struct iovec) );
3956     if ( !iovec )
3957     {
3958         err = WSAEFAULT;
3959         goto err_close;
3960     }
3961
3962     for (i = 0; i < dwBufferCount; i++)
3963     {
3964         iovec[i].iov_base = lpBuffers[i].buf;
3965         iovec[i].iov_len  = lpBuffers[i].len;
3966     }
3967
3968     if ( (lpOverlapped || lpCompletionRoutine) && flags & FD_FLAG_OVERLAPPED )
3969     {
3970         wsa = WS2_make_async( s, fd, ws2m_read, iovec, dwBufferCount,
3971                               lpFlags, lpFrom, lpFromlen,
3972                               lpOverlapped, lpCompletionRoutine, &iosb );
3973
3974         if ( !wsa )
3975         {
3976             err = WSAEFAULT;
3977             goto err_free;
3978         }
3979
3980         if ( ( ret = ws2_queue_async( wsa, iosb )) )
3981         {
3982             err = NtStatusToWSAError( ret );
3983
3984             if ( !lpOverlapped )
3985                 HeapFree( GetProcessHeap(), 0, iosb );
3986             HeapFree( GetProcessHeap(), 0, wsa );
3987             goto err_free;
3988         }
3989
3990         /* Try immediate completion */
3991         if ( lpOverlapped )
3992         {
3993             if  ( WSAGetOverlappedResult( s, lpOverlapped,
3994                                            lpNumberOfBytesRecvd, FALSE, lpFlags) )
3995                 return 0;
3996
3997             if ( (err = WSAGetLastError()) != WSA_IO_INCOMPLETE )
3998                 goto error;
3999         }
4000
4001         WSASetLastError( WSA_IO_PENDING );
4002         return SOCKET_ERROR;
4003     }
4004
4005     if ( _is_blocking(s) )
4006     {
4007         /* block here */
4008         /* FIXME: OOB and exceptfds? */
4009         int timeout = GET_RCVTIMEO(fd);
4010         if( !do_block(fd, POLLIN, timeout)) {
4011             err = WSAETIMEDOUT;
4012             /* a timeout is not fatal */
4013             _enable_event(SOCKET2HANDLE(s), FD_READ, 0, 0);
4014             goto err_free;
4015         }
4016     }
4017
4018     n = WS2_recv( fd, iovec, dwBufferCount, lpFrom, lpFromlen, lpFlags );
4019     if ( n == -1 )
4020     {
4021         err = wsaErrno();
4022         goto err_free;
4023     }
4024
4025     TRACE(" -> %i bytes\n", n);
4026     *lpNumberOfBytesRecvd = n;
4027
4028     HeapFree(GetProcessHeap(), 0, iovec);
4029     release_sock_fd( s, fd );
4030     _enable_event(SOCKET2HANDLE(s), FD_READ, 0, 0);
4031
4032     return 0;
4033
4034 err_free:
4035     HeapFree(GetProcessHeap(), 0, iovec);
4036
4037 err_close:
4038     release_sock_fd( s, fd );
4039
4040 error:
4041     WARN(" -> ERROR %d\n", err);
4042     WSASetLastError( err );
4043     return SOCKET_ERROR;
4044 }
4045
4046 /***********************************************************************
4047  *              WSCInstallProvider             (WS2_32.88)
4048  */
4049 INT WINAPI WSCInstallProvider( const LPGUID lpProviderId,
4050                                LPCWSTR lpszProviderDllPath,
4051                                const LPWSAPROTOCOL_INFOW lpProtocolInfoList,
4052                                DWORD dwNumberOfEntries,
4053                                LPINT lpErrno )
4054 {
4055     FIXME("(%s, %s, %p, %d, %p): stub !\n", debugstr_guid(lpProviderId),
4056           debugstr_w(lpszProviderDllPath), lpProtocolInfoList,
4057           dwNumberOfEntries, lpErrno);
4058     *lpErrno = 0;
4059     return 0;
4060 }
4061
4062
4063 /***********************************************************************
4064  *              WSCDeinstallProvider             (WS2_32.83)
4065  */
4066 INT WINAPI WSCDeinstallProvider(LPGUID lpProviderId, LPINT lpErrno)
4067 {
4068     FIXME("(%s, %p): stub !\n", debugstr_guid(lpProviderId), lpErrno);
4069     *lpErrno = 0;
4070     return 0;
4071 }
4072
4073
4074 /***********************************************************************
4075  *              WSAAccept                        (WS2_32.26)
4076  */
4077 SOCKET WINAPI WSAAccept( SOCKET s, struct WS_sockaddr *addr, LPINT addrlen,
4078                LPCONDITIONPROC lpfnCondition, DWORD dwCallbackData)
4079 {
4080
4081        int ret = 0, size = 0;
4082        WSABUF CallerId, CallerData, CalleeId, CalleeData;
4083        /*        QOS SQOS, GQOS; */
4084        GROUP g;
4085        SOCKET cs;
4086        SOCKADDR src_addr, dst_addr;
4087
4088        TRACE("Socket  %04x, sockaddr %p, addrlen %p, fnCondition %p, dwCallbackData %d\n",
4089                s, addr, addrlen, lpfnCondition, dwCallbackData);
4090
4091
4092        size = sizeof(src_addr);
4093        cs = WS_accept(s, &src_addr, &size);
4094
4095        if (cs == SOCKET_ERROR) return SOCKET_ERROR;
4096
4097        CallerId.buf = (char *)&src_addr;
4098        CallerId.len = sizeof(src_addr);
4099
4100        CallerData.buf = NULL;
4101        CallerData.len = (ULONG)NULL;
4102
4103        WS_getsockname(cs, &dst_addr, &size);
4104
4105        CalleeId.buf = (char *)&dst_addr;
4106        CalleeId.len = sizeof(dst_addr);
4107
4108
4109        ret = (*lpfnCondition)(&CallerId, &CallerData, NULL, NULL,
4110                        &CalleeId, &CalleeData, &g, dwCallbackData);
4111
4112        switch (ret)
4113        {
4114                case CF_ACCEPT:
4115                        if (addr && addrlen)
4116                                addr = memcpy(addr, &src_addr, (*addrlen > size) ?  size : *addrlen );
4117                        return cs;
4118                case CF_DEFER:
4119                        SERVER_START_REQ( set_socket_deferred )
4120                        {
4121                            req->handle = SOCKET2HANDLE(s);
4122                            req->deferred = SOCKET2HANDLE(cs);
4123                            if ( !wine_server_call_err ( req ) )
4124                            {
4125                                SetLastError( WSATRY_AGAIN );
4126                                WS_closesocket( cs );
4127                            }
4128                        }
4129                        SERVER_END_REQ;
4130                        return SOCKET_ERROR;
4131                case CF_REJECT:
4132                        WS_closesocket(cs);
4133                        SetLastError(WSAECONNREFUSED);
4134                        return SOCKET_ERROR;
4135                default:
4136                        FIXME("Unknown return type from Condition function\n");
4137                        SetLastError(WSAENOTSOCK);
4138                        return SOCKET_ERROR;
4139                }
4140 }
4141
4142 /***********************************************************************
4143  *              WSADuplicateSocketA                      (WS2_32.32)
4144  */
4145 int WINAPI WSADuplicateSocketA( SOCKET s, DWORD dwProcessId, LPWSAPROTOCOL_INFOA lpProtocolInfo )
4146 {
4147    HANDLE hProcess;
4148
4149    TRACE("(%d,%x,%p)\n", s, dwProcessId, lpProtocolInfo);
4150    memset(lpProtocolInfo, 0, sizeof(*lpProtocolInfo));
4151    /* FIXME: WS_getsockopt(s, WS_SOL_SOCKET, SO_PROTOCOL_INFO, lpProtocolInfo, sizeof(*lpProtocolInfo)); */
4152    /* I don't know what the real Windoze does next, this is a hack */
4153    /* ...we could duplicate and then use ConvertToGlobalHandle on the duplicate, then let
4154     * the target use the global duplicate, or we could copy a reference to us to the structure
4155     * and let the target duplicate it from us, but let's do it as simple as possible */
4156    hProcess = OpenProcess(PROCESS_DUP_HANDLE, FALSE, dwProcessId);
4157    DuplicateHandle(GetCurrentProcess(), SOCKET2HANDLE(s),
4158                    hProcess, (LPHANDLE)&lpProtocolInfo->dwCatalogEntryId,
4159                    0, FALSE, DUPLICATE_SAME_ACCESS);
4160    CloseHandle(hProcess);
4161    lpProtocolInfo->dwServiceFlags4 = 0xff00ff00; /* magic */
4162    return 0;
4163 }
4164
4165 /***********************************************************************
4166  *              WSADuplicateSocketW                      (WS2_32.33)
4167  */
4168 int WINAPI WSADuplicateSocketW( SOCKET s, DWORD dwProcessId, LPWSAPROTOCOL_INFOW lpProtocolInfo )
4169 {
4170    HANDLE hProcess;
4171
4172    TRACE("(%d,%x,%p)\n", s, dwProcessId, lpProtocolInfo);
4173
4174    memset(lpProtocolInfo, 0, sizeof(*lpProtocolInfo));
4175    hProcess = OpenProcess(PROCESS_DUP_HANDLE, FALSE, dwProcessId);
4176    DuplicateHandle(GetCurrentProcess(), SOCKET2HANDLE(s),
4177                    hProcess, (LPHANDLE)&lpProtocolInfo->dwCatalogEntryId,
4178                    0, FALSE, DUPLICATE_SAME_ACCESS);
4179    CloseHandle(hProcess);
4180    lpProtocolInfo->dwServiceFlags4 = 0xff00ff00; /* magic */
4181    return 0;
4182 }
4183
4184 /***********************************************************************
4185  *              WSAInstallServiceClassA                  (WS2_32.48)
4186  */
4187 int WINAPI WSAInstallServiceClassA(LPWSASERVICECLASSINFOA info)
4188 {
4189     FIXME("Request to install service %s\n",debugstr_a(info->lpszServiceClassName));
4190     WSASetLastError(WSAEACCES);
4191     return SOCKET_ERROR;
4192 }
4193
4194 /***********************************************************************
4195  *              WSAInstallServiceClassW                  (WS2_32.49)
4196  */
4197 int WINAPI WSAInstallServiceClassW(LPWSASERVICECLASSINFOW info)
4198 {
4199     FIXME("Request to install service %s\n",debugstr_w(info->lpszServiceClassName));
4200     WSASetLastError(WSAEACCES);
4201     return SOCKET_ERROR;
4202 }
4203
4204 /***********************************************************************
4205  *              WSARemoveServiceClass                    (WS2_32.70)
4206  */
4207 int WINAPI WSARemoveServiceClass(LPGUID info)
4208 {
4209     FIXME("Request to remove service %p\n",info);
4210     WSASetLastError(WSATYPE_NOT_FOUND);
4211     return SOCKET_ERROR;
4212 }
4213
4214 /***********************************************************************
4215  *              WSAStringToAddressA                      (WS2_32.80)
4216  */
4217 INT WINAPI WSAStringToAddressA(LPSTR AddressString,
4218                                INT AddressFamily,
4219                                LPWSAPROTOCOL_INFOA lpProtocolInfo,
4220                                LPSOCKADDR lpAddress,
4221                                LPINT lpAddressLength)
4222 {
4223     INT res=0;
4224     struct in_addr inetaddr;
4225     LPSTR workBuffer=NULL,ptrPort;
4226
4227     TRACE( "(%s, %x, %p, %p, %p)\n", AddressString, AddressFamily, lpProtocolInfo,
4228            lpAddress, lpAddressLength );
4229
4230     if (!lpAddressLength || !lpAddress) return SOCKET_ERROR;
4231
4232     if (AddressString)
4233     {
4234         workBuffer = HeapAlloc( GetProcessHeap(), 0, strlen(AddressString)+1 );
4235         if (workBuffer)
4236         {
4237             strcpy(workBuffer,AddressString);
4238             switch (AddressFamily)
4239             {
4240             case AF_INET:
4241                 /* caller wants to know the size of the socket buffer */
4242                 if (*lpAddressLength < sizeof(SOCKADDR_IN))
4243                 {
4244                     *lpAddressLength = sizeof(SOCKADDR_IN);
4245                     res = WSAEFAULT;
4246                 }
4247                 else
4248                 {
4249                     /* caller wants to translate an AddressString into a SOCKADDR */
4250                     if (lpAddress)
4251                     {
4252                         memset(lpAddress,0,sizeof(SOCKADDR_IN));
4253                         ((LPSOCKADDR_IN)lpAddress)->sin_family = AF_INET;
4254                         ptrPort = strchr(workBuffer,':');
4255                         if (ptrPort)
4256                         {
4257                             ((LPSOCKADDR_IN)lpAddress)->sin_port = (WS_u_short)atoi(ptrPort+1);
4258                             *ptrPort = '\0';
4259                         }
4260                         else
4261                             ((LPSOCKADDR_IN)lpAddress)->sin_port = 0;
4262                         if (inet_aton(workBuffer, &inetaddr) > 0)
4263                         {
4264                             ((LPSOCKADDR_IN)lpAddress)->sin_addr.WS_s_addr = inetaddr.s_addr;
4265                             res = 0;
4266                         }
4267                         else
4268                             res = WSAEINVAL;
4269                     }
4270                 }
4271                 if (lpProtocolInfo)
4272                     FIXME("(%s, %x, %p, %p, %p) - ProtocolInfo not implemented!\n",
4273                         AddressString, AddressFamily,
4274                         lpProtocolInfo, lpAddress, lpAddressLength);
4275
4276                 break;
4277             default:
4278                 FIXME("(%s, %x, %p, %p, %p) - AddressFamiliy not implemented!\n",
4279                     AddressString, AddressFamily,
4280                     lpProtocolInfo, lpAddress, lpAddressLength);
4281             }
4282             HeapFree( GetProcessHeap(), 0, workBuffer );
4283         }
4284         else
4285             res = WSA_NOT_ENOUGH_MEMORY;
4286     }
4287     else
4288         res = WSAEINVAL;
4289
4290     if (!res) return 0;
4291     WSASetLastError(res);
4292     return SOCKET_ERROR;
4293 }
4294
4295 /***********************************************************************
4296  *              WSAStringToAddressW                      (WS2_32.81)
4297  *
4298  * Does anybody know if this functions allows to use hebrew/arabic/chinese... digits?
4299  * If this should be the case, it would be required to map these digits
4300  * to Unicode digits (0-9) using FoldString first.
4301  */
4302 INT WINAPI WSAStringToAddressW(LPWSTR AddressString,
4303                                INT AddressFamily,
4304                                LPWSAPROTOCOL_INFOW lpProtocolInfo,
4305                                LPSOCKADDR lpAddress,
4306                                LPINT lpAddressLength)
4307 {
4308     INT sBuffer,res=0;
4309     LPSTR workBuffer=NULL;
4310     WSAPROTOCOL_INFOA infoA;
4311     LPWSAPROTOCOL_INFOA lpProtoInfoA = NULL;
4312
4313     TRACE( "(%s, %x, %p, %p, %p)\n", debugstr_w(AddressString), AddressFamily, lpProtocolInfo,
4314            lpAddress, lpAddressLength );
4315
4316     if (!lpAddressLength || !lpAddress) return SOCKET_ERROR;
4317
4318     /* if ProtocolInfo is available - convert to ANSI variant */
4319     if (lpProtocolInfo)
4320     {
4321         lpProtoInfoA = &infoA;
4322         memcpy( lpProtoInfoA, lpProtocolInfo, FIELD_OFFSET( WSAPROTOCOL_INFOA, szProtocol ) );
4323
4324         if (!WideCharToMultiByte( CP_ACP, 0, lpProtocolInfo->szProtocol, -1,
4325                                   lpProtoInfoA->szProtocol, WSAPROTOCOL_LEN+1, NULL, NULL ))
4326         {
4327             WSASetLastError( WSAEINVAL);
4328             return SOCKET_ERROR;
4329         }
4330     }
4331
4332     if (AddressString)
4333     {
4334         /* Translate AddressString to ANSI code page - assumes that only
4335            standard digits 0-9 are used with this API call */
4336         sBuffer = WideCharToMultiByte( CP_ACP, 0, AddressString, -1, NULL, 0, NULL, NULL );
4337         workBuffer = HeapAlloc( GetProcessHeap(), 0, sBuffer );
4338
4339         if (workBuffer)
4340         {
4341             WideCharToMultiByte( CP_ACP, 0, AddressString, -1, workBuffer, sBuffer, NULL, NULL );
4342             res = WSAStringToAddressA(workBuffer,AddressFamily,lpProtoInfoA,
4343                                       lpAddress,lpAddressLength);
4344             HeapFree( GetProcessHeap(), 0, workBuffer );
4345             return res;
4346         }
4347         else
4348             res = WSA_NOT_ENOUGH_MEMORY;
4349     }
4350     else
4351         res = WSAEINVAL;
4352
4353     WSASetLastError(res);
4354     return SOCKET_ERROR;
4355 }
4356
4357 /***********************************************************************
4358  *              WSAAddressToStringA                      (WS2_32.27)
4359  *
4360  *  See WSAAddressToStringW
4361  */
4362 INT WINAPI WSAAddressToStringA( LPSOCKADDR sockaddr, DWORD len,
4363                                 LPWSAPROTOCOL_INFOA info, LPSTR string,
4364                                 LPDWORD lenstr )
4365 {
4366     INT size;
4367     CHAR buffer[22]; /* 12 digits + 3 dots + ':' + 5 digits + '\0' */
4368     CHAR *p;
4369
4370     TRACE( "(%p, %d, %p, %p, %p)\n", sockaddr, len, info, string, lenstr );
4371
4372     if (!sockaddr || len < sizeof(SOCKADDR_IN)) return SOCKET_ERROR;
4373     if (!string || !lenstr) return SOCKET_ERROR;
4374
4375     /* sin_family is garanteed to be the first u_short */
4376     if (((SOCKADDR_IN *)sockaddr)->sin_family != AF_INET) return SOCKET_ERROR;
4377
4378     sprintf( buffer, "%u.%u.%u.%u:%u",
4379              (unsigned int)(ntohl( ((SOCKADDR_IN *)sockaddr)->sin_addr.WS_s_addr ) >> 24 & 0xff),
4380              (unsigned int)(ntohl( ((SOCKADDR_IN *)sockaddr)->sin_addr.WS_s_addr ) >> 16 & 0xff),
4381              (unsigned int)(ntohl( ((SOCKADDR_IN *)sockaddr)->sin_addr.WS_s_addr ) >> 8 & 0xff),
4382              (unsigned int)(ntohl( ((SOCKADDR_IN *)sockaddr)->sin_addr.WS_s_addr ) & 0xff),
4383              ntohs( ((SOCKADDR_IN *)sockaddr)->sin_port ) );
4384
4385     p = strchr( buffer, ':' );
4386     if (!((SOCKADDR_IN *)sockaddr)->sin_port) *p = 0;
4387
4388     size = strlen( buffer );
4389
4390     if (*lenstr <  size)
4391     {
4392         *lenstr = size;
4393         WSASetLastError(WSAEFAULT);
4394         return SOCKET_ERROR;
4395     }
4396
4397     strcpy( string, buffer );
4398     return 0;
4399 }
4400
4401 /***********************************************************************
4402  *              WSAAddressToStringW                      (WS2_32.28)
4403  *
4404  * Convert a sockaddr address into a readable address string.
4405  *
4406  * PARAMS
4407  *  sockaddr [I]    Pointer to a sockaddr structure.
4408  *  len      [I]    Size of the sockaddr structure.
4409  *  info     [I]    Pointer to a WSAPROTOCOL_INFOW structure (optional).
4410  *  string   [I/O]  Pointer to a buffer to receive the address string.
4411  *  lenstr   [I/O]  Size of the receive buffer in WCHARs.
4412  *
4413  * RETURNS
4414  *  Success: 0
4415  *  Failure: SOCKET_ERROR
4416  *
4417  * NOTES
4418  *  The 'info' parameter is ignored.
4419  *
4420  * BUGS
4421  *  Only supports AF_INET addresses.
4422  */
4423 INT WINAPI WSAAddressToStringW( LPSOCKADDR sockaddr, DWORD len,
4424                                 LPWSAPROTOCOL_INFOW info, LPWSTR string,
4425                                 LPDWORD lenstr )
4426 {
4427     INT size;
4428     WCHAR buffer[22]; /* 12 digits + 3 dots + ':' + 5 digits + '\0' */
4429     static const WCHAR format[] = { '%','u','.','%','u','.','%','u','.','%','u',':','%','u',0 };
4430     WCHAR *p;
4431
4432     TRACE( "(%p, %x, %p, %p, %p)\n", sockaddr, len, info, string, lenstr );
4433
4434     if (!sockaddr || len < sizeof(SOCKADDR_IN)) return SOCKET_ERROR;
4435     if (!string || !lenstr) return SOCKET_ERROR;
4436
4437     /* sin_family is garanteed to be the first u_short */
4438     if (((SOCKADDR_IN *)sockaddr)->sin_family != AF_INET) return SOCKET_ERROR;
4439
4440     sprintfW( buffer, format,
4441               (unsigned int)(ntohl( ((SOCKADDR_IN *)sockaddr)->sin_addr.WS_s_addr ) >> 24 & 0xff),
4442               (unsigned int)(ntohl( ((SOCKADDR_IN *)sockaddr)->sin_addr.WS_s_addr ) >> 16 & 0xff),
4443               (unsigned int)(ntohl( ((SOCKADDR_IN *)sockaddr)->sin_addr.WS_s_addr ) >> 8 & 0xff),
4444               (unsigned int)(ntohl( ((SOCKADDR_IN *)sockaddr)->sin_addr.WS_s_addr ) & 0xff),
4445               ntohs( ((SOCKADDR_IN *)sockaddr)->sin_port ) );
4446
4447     p = strchrW( buffer, ':' );
4448     if (!((SOCKADDR_IN *)sockaddr)->sin_port) *p = 0;
4449
4450     size = lstrlenW( buffer );
4451
4452     if (*lenstr <  size)
4453     {
4454         *lenstr = size;
4455         return SOCKET_ERROR;
4456     }
4457
4458     lstrcpyW( string, buffer );
4459     return 0;
4460 }
4461
4462 /***********************************************************************
4463  *              WSAEnumNameSpaceProvidersA                  (WS2_32.34)
4464  */
4465 INT WINAPI WSAEnumNameSpaceProvidersA( LPDWORD len, LPWSANAMESPACE_INFOA buffer )
4466 {
4467     FIXME( "(%p %p) Stub!\n", len, buffer );
4468     return 0;
4469 }
4470
4471 /***********************************************************************
4472  *              WSAEnumNameSpaceProvidersW                  (WS2_32.35)
4473  */
4474 INT WINAPI WSAEnumNameSpaceProvidersW( LPDWORD len, LPWSANAMESPACE_INFOW buffer )
4475 {
4476     FIXME( "(%p %p) Stub!\n", len, buffer );
4477     return 0;
4478 }
4479
4480 /***********************************************************************
4481  *              WSAGetQOSByName                             (WS2_32.41)
4482  */
4483 BOOL WINAPI WSAGetQOSByName( SOCKET s, LPWSABUF lpQOSName, LPQOS lpQOS )
4484 {
4485     FIXME( "(0x%04x %p %p) Stub!\n", s, lpQOSName, lpQOS );
4486     return FALSE;
4487 }
4488
4489 /***********************************************************************
4490  *              WSAGetServiceClassInfoA                     (WS2_32.42)
4491  */
4492 INT WINAPI WSAGetServiceClassInfoA( LPGUID provider, LPGUID service, LPDWORD len,
4493                                     LPWSASERVICECLASSINFOA info )
4494 {
4495     FIXME( "(%s %s %p %p) Stub!\n", debugstr_guid(provider), debugstr_guid(service),
4496            len, info );
4497     WSASetLastError(WSA_NOT_ENOUGH_MEMORY);
4498     return SOCKET_ERROR;
4499 }
4500
4501 /***********************************************************************
4502  *              WSAGetServiceClassInfoW                     (WS2_32.43)
4503  */
4504 INT WINAPI WSAGetServiceClassInfoW( LPGUID provider, LPGUID service, LPDWORD len,
4505                                     LPWSASERVICECLASSINFOW info )
4506 {
4507     FIXME( "(%s %s %p %p) Stub!\n", debugstr_guid(provider), debugstr_guid(service),
4508            len, info );
4509     WSASetLastError(WSA_NOT_ENOUGH_MEMORY);
4510     return SOCKET_ERROR;
4511 }
4512
4513 /***********************************************************************
4514  *              WSAGetServiceClassNameByClassIdA            (WS2_32.44)
4515  */
4516 INT WINAPI WSAGetServiceClassNameByClassIdA( LPGUID class, LPSTR service, LPDWORD len )
4517 {
4518     FIXME( "(%s %p %p) Stub!\n", debugstr_guid(class), service, len );
4519     WSASetLastError(WSA_NOT_ENOUGH_MEMORY);
4520     return SOCKET_ERROR;
4521 }
4522
4523 /***********************************************************************
4524  *              WSAGetServiceClassNameByClassIdW            (WS2_32.45)
4525  */
4526 INT WINAPI WSAGetServiceClassNameByClassIdW( LPGUID class, LPWSTR service, LPDWORD len )
4527 {
4528     FIXME( "(%s %p %p) Stub!\n", debugstr_guid(class), service, len );
4529     WSASetLastError(WSA_NOT_ENOUGH_MEMORY);
4530     return SOCKET_ERROR;
4531 }
4532
4533 /***********************************************************************
4534  *              WSALookupServiceBeginA                       (WS2_32.59)
4535  */
4536 INT WINAPI WSALookupServiceBeginA( LPWSAQUERYSETA lpqsRestrictions,
4537                                    DWORD dwControlFlags,
4538                                    LPHANDLE lphLookup)
4539 {
4540     FIXME("(%p 0x%08x %p) Stub!\n", lpqsRestrictions, dwControlFlags,
4541             lphLookup);
4542     WSASetLastError(WSA_NOT_ENOUGH_MEMORY);
4543     return SOCKET_ERROR;
4544 }
4545
4546 /***********************************************************************
4547  *              WSALookupServiceBeginW                       (WS2_32.60)
4548  */
4549 INT WINAPI WSALookupServiceBeginW( LPWSAQUERYSETW lpqsRestrictions,
4550                                    DWORD dwControlFlags,
4551                                    LPHANDLE lphLookup)
4552 {
4553     FIXME("(%p 0x%08x %p) Stub!\n", lpqsRestrictions, dwControlFlags,
4554             lphLookup);
4555     WSASetLastError(WSA_NOT_ENOUGH_MEMORY);
4556     return SOCKET_ERROR;
4557 }
4558
4559 /***********************************************************************
4560  *              WSALookupServiceBeginW                       (WS2_32.61)
4561  */
4562 INT WINAPI WSALookupServiceEnd( HANDLE lookup )
4563 {
4564     FIXME("(%p) Stub!\n", lookup );
4565     return 0;
4566 }
4567
4568 /***********************************************************************
4569  *              WSALookupServiceNextA                       (WS2_32.62)
4570  */
4571 INT WINAPI WSALookupServiceNextA( HANDLE lookup, DWORD flags, LPDWORD len, LPWSAQUERYSETA results )
4572 {
4573     FIXME( "(%p 0x%08x %p %p) Stub!\n", lookup, flags, len, results );
4574     return 0;
4575 }
4576
4577 /***********************************************************************
4578  *              WSALookupServiceNextW                       (WS2_32.63)
4579  */
4580 INT WINAPI WSALookupServiceNextW( HANDLE lookup, DWORD flags, LPDWORD len, LPWSAQUERYSETW results )
4581 {
4582     FIXME( "(%p 0x%08x %p %p) Stub!\n", lookup, flags, len, results );
4583     return 0;
4584 }
4585
4586 /***********************************************************************
4587  *              WSANtohl                                   (WS2_32.64)
4588  */
4589 INT WINAPI WSANtohl( SOCKET s, WS_u_long netlong, WS_u_long* lphostlong )
4590 {
4591     TRACE( "(0x%04x 0x%08x %p)\n", s, netlong, lphostlong );
4592
4593     if (!lphostlong) return WSAEFAULT;
4594
4595     *lphostlong = ntohl( netlong );
4596     return 0;
4597 }
4598
4599 /***********************************************************************
4600  *              WSANtohs                                   (WS2_32.65)
4601  */
4602 INT WINAPI WSANtohs( SOCKET s, WS_u_short netshort, WS_u_short* lphostshort )
4603 {
4604     TRACE( "(0x%04x 0x%08x %p)\n", s, netshort, lphostshort );
4605
4606     if (!lphostshort) return WSAEFAULT;
4607
4608     *lphostshort = ntohs( netshort );
4609     return 0;
4610 }
4611
4612 /***********************************************************************
4613  *              WSAProviderConfigChange                     (WS2_32.66)
4614  */
4615 INT WINAPI WSAProviderConfigChange( LPHANDLE handle, LPWSAOVERLAPPED overlapped,
4616                                     LPWSAOVERLAPPED_COMPLETION_ROUTINE completion )
4617 {
4618     FIXME( "(%p %p %p) Stub!\n", handle, overlapped, completion );
4619     return SOCKET_ERROR;
4620 }
4621
4622 /***********************************************************************
4623  *              WSARecvDisconnect                           (WS2_32.68)
4624  */
4625 INT WINAPI WSARecvDisconnect( SOCKET s, LPWSABUF disconnectdata )
4626 {
4627     TRACE( "(0x%04x %p)\n", s, disconnectdata );
4628
4629     return WS_shutdown( s, 0 );
4630 }
4631
4632 /***********************************************************************
4633  *              WSASetServiceA                              (WS2_32.76)
4634  */
4635 INT WINAPI WSASetServiceA( LPWSAQUERYSETA query, WSAESETSERVICEOP operation, DWORD flags )
4636 {
4637     FIXME( "(%p 0x%08x 0x%08x) Stub!\n", query, operation, flags );
4638     return 0;
4639 }
4640
4641 /***********************************************************************
4642  *              WSASetServiceW                              (WS2_32.77)
4643  */
4644 INT WINAPI WSASetServiceW( LPWSAQUERYSETW query, WSAESETSERVICEOP operation, DWORD flags )
4645 {
4646     FIXME( "(%p 0x%08x 0x%08x) Stub!\n", query, operation, flags );
4647     return 0;
4648 }
4649
4650 /***********************************************************************
4651  *              WSCEnableNSProvider                         (WS2_32.84)
4652  */
4653 INT WINAPI WSCEnableNSProvider( LPGUID provider, BOOL enable )
4654 {
4655     FIXME( "(%s 0x%08x) Stub!\n", debugstr_guid(provider), enable );
4656     return 0;
4657 }
4658
4659 /***********************************************************************
4660  *              WSCGetProviderPath                          (WS2_32.86)
4661  */
4662 INT WINAPI WSCGetProviderPath( LPGUID provider, LPWSTR path, LPINT len, LPINT errcode )
4663 {
4664     FIXME( "(%s %p %p %p) Stub!\n", debugstr_guid(provider), path, len, errcode );
4665
4666     if (!errcode || !provider || !len) return WSAEFAULT;
4667
4668     *errcode = WSAEINVAL;
4669     return SOCKET_ERROR;
4670 }
4671
4672 /***********************************************************************
4673  *              WSCInstallNameSpace                         (WS2_32.87)
4674  */
4675 INT WINAPI WSCInstallNameSpace( LPWSTR identifier, LPWSTR path, DWORD namespace,
4676                                 DWORD version, LPGUID provider )
4677 {
4678     FIXME( "(%s %s 0x%08x 0x%08x %s) Stub!\n", debugstr_w(identifier), debugstr_w(path),
4679            namespace, version, debugstr_guid(provider) );
4680     return 0;
4681 }
4682
4683 /***********************************************************************
4684  *              WSCUnInstallNameSpace                       (WS2_32.89)
4685  */
4686 INT WINAPI WSCUnInstallNameSpace( LPGUID lpProviderId )
4687 {
4688     FIXME("(%p) Stub!\n", lpProviderId);
4689     return NO_ERROR;
4690 }
4691
4692 /***********************************************************************
4693  *              WSCWriteProviderOrder                       (WS2_32.91)
4694  */
4695 INT WINAPI WSCWriteProviderOrder( LPDWORD entry, DWORD number )
4696 {
4697     FIXME("(%p 0x%08x) Stub!\n", entry, number);
4698     return 0;
4699 }