?  search:
summary | log | graphiclog1 | graphiclog2 | commit | commitdiff | tree | refs | edit | fork
blame | history | raw | HEAD
Handle POLLHUP better (delay FD_CLOSE notification until all data has
[wine/gsoc-2012-control.git] / dlls / winsock / socket.c
blobc166cc15a80a7b5ecaebf77f7a53dbd674eb8b85
1 /*
2 * based on Windows Sockets 1.1 specs
3 * (ftp.microsoft.com:/Advsys/winsock/spec11/WINSOCK.TXT)
4 *
5 * (C) 1993,1994,1996,1997 John Brezak, Erik Bos, Alex Korobka.
6 *
7 * NOTE: If you make any changes to fix a particular app, make sure
8 * they don't break something else like Netscape or telnet and ftp
9 * clients and servers (www.winsite.com got a lot of those).
10 *
11 */
12
13 #include "config.h"
14
15 #include <string.h>
16 #include <sys/types.h>
17 #ifdef HAVE_SYS_IPC_H
18 # include <sys/ipc.h>
19 #endif
20 #include <sys/ioctl.h>
21 #ifdef HAVE_SYS_FILIO_H
22 # include <sys/filio.h>
23 #endif
24 #if defined(__svr4__) || defined(__sun)
25 #include <sys/ioccom.h>
26 #ifdef HAVE_SYS_SOCKIO_H
27 # include <sys/sockio.h>
28 #endif
29 #endif
30
31 #if defined(__EMX__)
32 # include <sys/so_ioctl.h>
33 #endif
34
35 #ifdef HAVE_SYS_PARAM_H
36 # include <sys/param.h>
37 #endif
38
39 #ifdef HAVE_SYS_MSG_H
40 # include <sys/msg.h>
41 #endif
42 #ifdef HAVE_SYS_WAIT_H
43 # include <sys/wait.h>
44 #endif
45 #ifdef HAVE_SYS_SOCKET_H
46 #include <sys/socket.h>
47 #endif
48 #ifdef HAVE_NETINET_IN_H
49 # include <netinet/in.h>
50 #endif
51 #ifdef HAVE_NETINET_TCP_H
52 # include <netinet/tcp.h>
53 #endif
54 #ifdef HAVE_ARPA_INET_H
55 # include <arpa/inet.h>
56 #endif
57 #include <ctype.h>
58 #include <fcntl.h>
59 #include <errno.h>
60 #ifdef HAVE_SYS_ERRNO_H
61 #include <sys/errno.h>
62 #endif
63 #include <netdb.h>
64 #include <unistd.h>
65 #include <stdlib.h>
66 #ifdef HAVE_ARPA_NAMESER_H
67 # include <arpa/nameser.h>
68 #endif
69 #ifdef HAVE_RESOLV_H
70 # include <resolv.h>
71 #endif
72
73 #include "wine/winbase16.h"
74 #include "wingdi.h"
75 #include "winuser.h"
76 #include "winsock2.h"
77 #include "winnt.h"
78 #include "heap.h"
79 #include "task.h"
80 #include "message.h"
81 #include "miscemu.h"
82 #include "wine/port.h"
83 #include "services.h"
84 #include "server.h"
85 #include "debugtools.h"
86
87 DEFAULT_DEBUG_CHANNEL(winsock)
88
89 #define DEBUG_SOCKADDR 0
90 #define dump_sockaddr(a) \
91 DPRINTF("sockaddr_in: family %d, address %s, port %d\n", \
92 ((struct sockaddr_in *)a)->sin_family, \
93 inet_ntoa(((struct sockaddr_in *)a)->sin_addr), \
94 ntohs(((struct sockaddr_in *)a)->sin_port))
95
96 /* ----------------------------------- internal data */
97
98 /* ws_... struct conversion flags */
99
100 #define WS_DUP_LINEAR 0x0001
101 #define WS_DUP_NATIVE 0x0000 /* not used anymore */
102 #define WS_DUP_OFFSET 0x0002 /* internal pointers are offsets */
103 #define WS_DUP_SEGPTR 0x0004 /* internal pointers are SEGPTRs */
104 /* by default, internal pointers are linear */
105 typedef struct /* WSAAsyncSelect() control struct */
106 {
107 HANDLE service, event, sock;
108 HWND hWnd;
109 UINT uMsg;
110 LONG lEvent;
111 struct _WSINFO *pwsi;
112 } ws_select_info;
113
114 #define WS_MAX_SOCKETS_PER_PROCESS 128 /* reasonable guess */
115 #define WS_MAX_UDP_DATAGRAM 1024
116
117 #define WS_ACCEPT_QUEUE 6
118
119 #define WSI_BLOCKINGCALL 0x00000001 /* per-thread info flags */
120 #define WSI_BLOCKINGHOOK 0x00000002 /* 32-bit callback */
121
122 typedef struct _WSINFO
123 {
124 DWORD dwThisProcess;
125 struct _WSINFO *lpNextIData;
126
127 unsigned flags;
128 INT16 num_startup; /* reference counter */
129 INT16 num_async_rq;
130 INT16 last_free; /* entry in the socket table */
131 UINT16 buflen;
132 char* buffer; /* allocated from SEGPTR heap */
133 struct ws_hostent *he;
134 int helen;
135 struct ws_servent *se;
136 int selen;
137 struct ws_protoent *pe;
138 int pelen;
139 char* dbuffer; /* buffer for dummies (32 bytes) */
140
141 DWORD blocking_hook;
142
143 volatile HANDLE accept_old[WS_ACCEPT_QUEUE], accept_new[WS_ACCEPT_QUEUE];
144 } WSINFO, *LPWSINFO;
145
146 /* function prototypes */
147 int WS_dup_he(LPWSINFO pwsi, struct hostent* p_he, int flag);
148 int WS_dup_pe(LPWSINFO pwsi, struct protoent* p_pe, int flag);
149 int WS_dup_se(LPWSINFO pwsi, struct servent* p_se, int flag);
150
151 UINT16 wsaErrno(void);
152 UINT16 wsaHerrno(void);
153
154 static HANDLE _WSHeap = 0;
155
156 #define WS_ALLOC(size) \
157 HeapAlloc(_WSHeap, HEAP_ZERO_MEMORY, (size) )
158 #define WS_FREE(ptr) \
159 HeapFree(_WSHeap, 0, (ptr) )
160
161 static INT _ws_sock_ops[] =
162 { WS_SO_DEBUG, WS_SO_REUSEADDR, WS_SO_KEEPALIVE, WS_SO_DONTROUTE,
163 WS_SO_BROADCAST, WS_SO_LINGER, WS_SO_OOBINLINE, WS_SO_SNDBUF,
164 WS_SO_RCVBUF, WS_SO_ERROR, WS_SO_TYPE, WS_SO_DONTLINGER,
165 #ifdef SO_RCVTIMEO
166 WS_SO_RCVTIMEO,
167 #endif
168 0 };
169 static int _px_sock_ops[] =
170 { SO_DEBUG, SO_REUSEADDR, SO_KEEPALIVE, SO_DONTROUTE, SO_BROADCAST,
171 SO_LINGER, SO_OOBINLINE, SO_SNDBUF, SO_RCVBUF, SO_ERROR, SO_TYPE,
172 WS_SO_DONTLINGER, /* no unix equivalent */
173 #ifdef SO_RCVTIMEO
174 SO_RCVTIMEO,
175 #endif
176 };
177
178 static INT _ws_tcp_ops[] = {
179 #ifdef TCP_NODELAY
180 WS_TCP_NODELAY,
181 #endif
182 0
183 };
184 static int _px_tcp_ops[] = {
185 #ifdef TCP_NODELAY
186 TCP_NODELAY,
187 #endif
188 0
189 };
190
191 /* we need a special routine to handle WSA* errors */
192 static inline int sock_server_call( enum request req )
193 {
194 unsigned int res = server_call_noerr( req );
195 if (res)
196 {
197 /* do not map WSA errors */
198 if ((res < WSABASEERR) || (res >= 0x10000000)) res = RtlNtStatusToDosError(res);
199 SetLastError( res );
200 }
201 return res;
202 }
203
204 static int _check_ws(LPWSINFO pwsi, SOCKET s);
205 static char* _check_buffer(LPWSINFO pwsi, int size);
206
207 static int _get_sock_fd(SOCKET s)
208 {
209 struct get_read_fd_request *req = get_req_buffer();
210 int fd;
211
212 req->handle = s;
213 server_call_fd( REQ_GET_READ_FD, -1, &fd );
214 if (fd == -1)
215 FIXME("handle %d is not a socket (GLE %ld)\n",s,GetLastError());
216 return fd;
217 }
218
219 static void _enable_event(SOCKET s, unsigned int event,
220 unsigned int sstate, unsigned int cstate)
221 {
222 struct enable_socket_event_request *req = get_req_buffer();
223
224 req->handle = s;
225 req->mask = event;
226 req->sstate = sstate;
227 req->cstate = cstate;
228 sock_server_call( REQ_ENABLE_SOCKET_EVENT );
229 }
230
231 static int _is_blocking(SOCKET s)
232 {
233 struct get_socket_event_request *req = get_req_buffer();
234
235 req->handle = s;
236 req->service = FALSE;
237 req->s_event = 0;
238 req->c_event = 0;
239 sock_server_call( REQ_GET_SOCKET_EVENT );
240 return (req->state & WS_FD_NONBLOCKING) == 0;
241 }
242
243 static unsigned int _get_sock_mask(SOCKET s)
244 {
245 struct get_socket_event_request *req = get_req_buffer();
246
247 req->handle = s;
248 req->service = FALSE;
249 req->s_event = 0;
250 req->c_event = 0;
251 sock_server_call( REQ_GET_SOCKET_EVENT );
252 return req->mask;
253 }
254
255 static void _sync_sock_state(SOCKET s)
256 {
257 /* do a dummy wineserver request in order to let
258 the wineserver run through its select loop once */
259 (void)_is_blocking(s);
260 }
261
262 static int _get_sock_error(SOCKET s, unsigned int bit)
263 {
264 struct get_socket_event_request *req = get_req_buffer();
265
266 req->handle = s;
267 req->service = FALSE;
268 req->s_event = 0;
269 req->c_event = 0;
270 sock_server_call( REQ_GET_SOCKET_EVENT );
271 return req->errors[bit];
272 }
273
274 static LPWSINFO lpFirstIData = NULL;
275
276 static LPWSINFO WINSOCK_GetIData(void)
277 {
278 DWORD pid = GetCurrentProcessId();
279 LPWSINFO iData;
280
281 for (iData = lpFirstIData; iData; iData = iData->lpNextIData) {
282 if (iData->dwThisProcess == pid)
283 break;
284 }
285 return iData;
286 }
287
288 static BOOL WINSOCK_CreateIData(void)
289 {
290 LPWSINFO iData;
291
292 iData = HeapAlloc(GetProcessHeap(), HEAP_ZERO_MEMORY, sizeof(WSINFO));
293 if (!iData)
294 return FALSE;
295 iData->dwThisProcess = GetCurrentProcessId();
296 iData->lpNextIData = lpFirstIData;
297 lpFirstIData = iData;
298 return TRUE;
299 }
300
301 static void WINSOCK_DeleteIData(void)
302 {
303 LPWSINFO iData = WINSOCK_GetIData();
304 LPWSINFO* ppid;
305 if (iData) {
306 for (ppid = &lpFirstIData; *ppid; ppid = &(*ppid)->lpNextIData) {
307 if (*ppid == iData) {
308 *ppid = iData->lpNextIData;
309 break;
310 }
311 }
312
313 if( iData->flags & WSI_BLOCKINGCALL )
314 TRACE("\tinside blocking call!\n");
315
316 /* delete scratch buffers */
317
318 if( iData->buffer ) SEGPTR_FREE(iData->buffer);
319 if( iData->dbuffer ) SEGPTR_FREE(iData->dbuffer);
320
321 HeapFree(GetProcessHeap(), 0, iData);
322 }
323 }
324
325 BOOL WINAPI WSOCK32_LibMain(HINSTANCE hInstDLL, DWORD fdwReason, LPVOID fImpLoad)
326 {
327 TRACE("0x%x 0x%lx %p\n", hInstDLL, fdwReason, fImpLoad);
328 switch (fdwReason) {
329 case DLL_PROCESS_DETACH:
330 WINSOCK_DeleteIData();
331 break;
332 }
333 return TRUE;
334 }
335
336 BOOL WINAPI WINSOCK_LibMain(DWORD fdwReason, HINSTANCE hInstDLL, WORD ds,
337 WORD wHeapSize, DWORD dwReserved1, WORD wReserved2)
338 {
339 TRACE("0x%x 0x%lx\n", hInstDLL, fdwReason);
340 switch (fdwReason) {
341 case DLL_PROCESS_DETACH:
342 WINSOCK_DeleteIData();
343 break;
344 }
345 return TRUE;
346 }
347
348 /***********************************************************************
349 * convert_sockopt()
350 *
351 * Converts socket flags from Windows format.
352 */
353 static void convert_sockopt(INT *level, INT *optname)
354 {
355 int i;
356 switch (*level)
357 {
358 case WS_SOL_SOCKET:
359 *level = SOL_SOCKET;
360 for(i=0; _ws_sock_ops[i]; i++)
361 if( _ws_sock_ops[i] == *optname ) break;
362 if( _ws_sock_ops[i] ) *optname = _px_sock_ops[i];
363 else FIXME("Unknown SOL_SOCKET optname %d\n", *optname);
364 break;
365 case WS_IPPROTO_TCP:
366 *level = IPPROTO_TCP;
367 for(i=0; _ws_tcp_ops[i]; i++)
368 if ( _ws_tcp_ops[i] == *optname ) break;
369 if( _ws_tcp_ops[i] ) *optname = _px_tcp_ops[i];
370 else FIXME("Unknown IPPROTO_TCP optname %d\n", *optname);
371 break;
372 }
373 }
374
375 /* ----------------------------------- Per-thread info (or per-process?) */
376
377 static int wsi_strtolo(LPWSINFO pwsi, const char* name, const char* opt)
378 {
379 /* Stuff a lowercase copy of the string into the local buffer */
380
381 int i = strlen(name) + 2;
382 char* p = _check_buffer(pwsi, i + ((opt)?strlen(opt):0));
383
384 if( p )
385 {
386 do *p++ = tolower(*name); while(*name++);
387 i = (p - (char*)(pwsi->buffer));
388 if( opt ) do *p++ = tolower(*opt); while(*opt++);
389 return i;
390 }
391 return 0;
392 }
393
394 static fd_set* fd_set_import( fd_set* fds, LPWSINFO pwsi, void* wsfds, int* highfd, int lfd[], BOOL b32 )
395 {
396 /* translate Winsock fd set into local fd set */
397
398 if( wsfds )
399 {
400 #define wsfds16 ((ws_fd_set16*)wsfds)
401 #define wsfds32 ((ws_fd_set32*)wsfds)
402 int i, count;
403
404 FD_ZERO(fds);
405 count = b32 ? wsfds32->fd_count : wsfds16->fd_count;
406
407 for( i = 0; i < count; i++ )
408 {
409 int s = (b32) ? wsfds32->fd_array[i]
410 : wsfds16->fd_array[i];
411 if( _check_ws(pwsi, s) )
412 {
413 int fd = _get_sock_fd(s);
414 lfd[ i ] = fd;
415 if( fd > *highfd ) *highfd = fd;
416 FD_SET(fd, fds);
417 }
418 else lfd[ i ] = -1;
419 }
420 #undef wsfds32
421 #undef wsfds16
422 return fds;
423 }
424 return NULL;
425 }
426
427 inline static int sock_error_p(int s)
428 {
429 unsigned int optval, optlen;
430
431 optlen = sizeof(optval);
432 getsockopt(s, SOL_SOCKET, SO_ERROR, (void *) &optval, &optlen);
433 if (optval) WARN("\t[%i] error: %d\n", s, optval);
434 return optval != 0;
435 }
436
437 static int fd_set_export( LPWSINFO pwsi, fd_set* fds, fd_set* exceptfds, void* wsfds, int lfd[], BOOL b32 )
438 {
439 int num_err = 0;
440
441 /* translate local fd set into Winsock fd set, adding
442 * errors to exceptfds (only if app requested it) */
443
444 if( wsfds )
445 {
446 #define wsfds16 ((ws_fd_set16*)wsfds)
447 #define wsfds32 ((ws_fd_set32*)wsfds)
448 int i, j, count = (b32) ? wsfds32->fd_count : wsfds16->fd_count;
449
450 for( i = 0, j = 0; i < count; i++ )
451 {
452 if( lfd[i] >= 0 )
453 {
454 int fd = lfd[i];
455 if( FD_ISSET(fd, fds) )
456 {
457 if ( exceptfds && sock_error_p(fd) )
458 {
459 FD_SET(fd, exceptfds);
460 num_err++;
461 }
462 else if( b32 )
463 wsfds32->fd_array[j++] = wsfds32->fd_array[i];
464 else
465 wsfds16->fd_array[j++] = wsfds16->fd_array[i];
466 }
467 close(fd);
468 lfd[i] = -1;
469 }
470 }
471
472 if( b32 ) wsfds32->fd_count = j;
473 else wsfds16->fd_count = j;
474
475 TRACE("\n");
476 #undef wsfds32
477 #undef wsfds16
478 }
479 return num_err;
480 }
481
482 static void fd_set_unimport( void* wsfds, int lfd[], BOOL b32 )
483 {
484 if ( wsfds )
485 {
486 #define wsfds16 ((ws_fd_set16*)wsfds)
487 #define wsfds32 ((ws_fd_set32*)wsfds)
488 int i, count = (b32) ? wsfds32->fd_count : wsfds16->fd_count;
489
490 for( i = 0; i < count; i++ )
491 if ( lfd[i] >= 0 )
492 close(lfd[i]);
493
494 TRACE("\n");
495 #undef wsfds32
496 #undef wsfds16
497 }
498 }
499
500 static int do_block( int fd, int mask )
501 {
502 fd_set fds[3];
503 int i, r;
504
505 FD_ZERO(&fds[0]);
506 FD_ZERO(&fds[1]);
507 FD_ZERO(&fds[2]);
508 for (i=0; i<3; i++)
509 if (mask & (1<<i))
510 FD_SET(fd, &fds[i]);
511 i = select( fd+1, &fds[0], &fds[1], &fds[2], NULL );
512 if (i <= 0) return -1;
513 r = 0;
514 for (i=0; i<3; i++)
515 if (FD_ISSET(fd, &fds[i]))
516 r |= 1<<i;
517 return r;
518 }
519
520 void* __ws_memalloc( int size )
521 {
522 return WS_ALLOC(size);
523 }
524
525 void __ws_memfree(void* ptr)
526 {
527 WS_FREE(ptr);
528 }
529
530
531 /* ----------------------------------- API -----
532 *
533 * Init / cleanup / error checking.
534 */
535
536 /***********************************************************************
537 * WSAStartup16() (WINSOCK.115)
538 *
539 * Create socket control struct, attach it to the global list and
540 * update a pointer in the task struct.
541 */
542 INT16 WINAPI WSAStartup16(UINT16 wVersionRequested, LPWSADATA lpWSAData)
543 {
544 WSADATA WINSOCK_data = { 0x0101, 0x0101,
545 "WINE Sockets 1.1",
546 #ifdef linux
547 "Linux/i386",
548 #elif defined(__NetBSD__)
549 "NetBSD/i386",
550 #elif defined(sunos)
551 "SunOS",
552 #elif defined(__FreeBSD__)
553 "FreeBSD",
554 #elif defined(__OpenBSD__)
555 "OpenBSD/i386",
556 #else
557 "Unknown",
558 #endif
559 WS_MAX_SOCKETS_PER_PROCESS,
560 WS_MAX_UDP_DATAGRAM, (SEGPTR)NULL };
561 LPWSINFO pwsi;
562
563 TRACE("verReq=%x\n", wVersionRequested);
564
565 if (LOBYTE(wVersionRequested) < 1 || (LOBYTE(wVersionRequested) == 1 &&
566 HIBYTE(wVersionRequested) < 1)) return WSAVERNOTSUPPORTED;
567
568 if (!lpWSAData) return WSAEINVAL;
569
570 /* initialize socket heap */
571
572 if( !_WSHeap )
573 {
574 _WSHeap = HeapCreate(HEAP_ZERO_MEMORY, 8120, 32768);
575 if( !_WSHeap )
576 {
577 ERR("Fatal: failed to create WinSock heap\n");
578 return 0;
579 }
580 }
581 if( _WSHeap == 0 ) return WSASYSNOTREADY;
582
583 pwsi = WINSOCK_GetIData();
584 if( pwsi == NULL )
585 {
586 WINSOCK_CreateIData();
587 pwsi = WINSOCK_GetIData();
588 if (!pwsi) return WSASYSNOTREADY;
589 }
590 pwsi->num_startup++;
591
592 /* return winsock information */
593
594 memcpy(lpWSAData, &WINSOCK_data, sizeof(WINSOCK_data));
595
596 TRACE("succeeded\n");
597 return 0;
598 }
599
600 /***********************************************************************
601 * WSAStartup32() (WSOCK32.115)
602 */
603 INT WINAPI WSAStartup(UINT wVersionRequested, LPWSADATA lpWSAData)
604 {
605 return WSAStartup16( wVersionRequested, lpWSAData );
606 }
607
608 /***********************************************************************
609 * WSACleanup() (WINSOCK.116)
610 */
611 INT WINAPI WSACleanup(void)
612 {
613 LPWSINFO pwsi = WINSOCK_GetIData();
614 if( pwsi ) {
615 if( --pwsi->num_startup > 0 ) return 0;
616
617 WINSOCK_DeleteIData();
618 return 0;
619 }
620 SetLastError(WSANOTINITIALISED);
621 return SOCKET_ERROR;
622 }
623
624
625 /***********************************************************************
626 * WSAGetLastError() (WSOCK32.111)(WINSOCK.111)
627 */
628 INT WINAPI WSAGetLastError(void)
629 {
630 return GetLastError();
631 }
632
633 /***********************************************************************
634 * WSASetLastError32() (WSOCK32.112)
635 */
636 void WINAPI WSASetLastError(INT iError) {
637 SetLastError(iError);
638 }
639
640 /***********************************************************************
641 * WSASetLastError16() (WINSOCK.112)
642 */
643 void WINAPI WSASetLastError16(INT16 iError)
644 {
645 WSASetLastError(iError);
646 }
647
648 int _check_ws(LPWSINFO pwsi, SOCKET s)
649 {
650 if( pwsi )
651 {
652 int fd;
653 if( pwsi->flags & WSI_BLOCKINGCALL ) SetLastError(WSAEINPROGRESS);
654 if ( (fd = _get_sock_fd(s)) < 0 ) {
655 SetLastError(WSAENOTSOCK);
656 return 0;
657 }
658 /* FIXME: maybe check whether fd is really a socket? */
659 close( fd );
660 return 1;
661 }
662 return 0;
663 }
664
665 char* _check_buffer(LPWSINFO pwsi, int size)
666 {
667 if( pwsi->buffer && pwsi->buflen >= size ) return pwsi->buffer;
668 else SEGPTR_FREE(pwsi->buffer);
669
670 pwsi->buffer = (char*)SEGPTR_ALLOC((pwsi->buflen = size));
671 return pwsi->buffer;
672 }
673
674 struct ws_hostent* _check_buffer_he(LPWSINFO pwsi, int size)
675 {
676 if( pwsi->he && pwsi->helen >= size ) return pwsi->he;
677 else SEGPTR_FREE(pwsi->he);
678
679 pwsi->he = (struct ws_hostent*)SEGPTR_ALLOC((pwsi->helen = size));
680 return pwsi->he;
681 }
682
683 struct ws_servent* _check_buffer_se(LPWSINFO pwsi, int size)
684 {
685 if( pwsi->se && pwsi->selen >= size ) return pwsi->se;
686 else SEGPTR_FREE(pwsi->se);
687
688 pwsi->se = (struct ws_servent*)SEGPTR_ALLOC((pwsi->selen = size));
689 return pwsi->se;
690 }
691
692 struct ws_protoent* _check_buffer_pe(LPWSINFO pwsi, int size)
693 {
694 if( pwsi->pe && pwsi->pelen >= size ) return pwsi->pe;
695 else SEGPTR_FREE(pwsi->pe);
696
697 pwsi->pe = (struct ws_protoent*)SEGPTR_ALLOC((pwsi->pelen = size));
698 return pwsi->pe;
699 }
700
701 /* ----------------------------------- i/o APIs */
702
703 /***********************************************************************
704 * accept() (WSOCK32.1)
705 */
706 static void WSOCK32_async_accept(LPWSINFO pwsi, SOCKET s, SOCKET as)
707 {
708 int q;
709 /* queue socket for WSAAsyncSelect */
710 for (q=0; q<WS_ACCEPT_QUEUE; q++)
711 if (InterlockedCompareExchange((PVOID*)&pwsi->accept_old[q], (PVOID)s, (PVOID)0) == (PVOID)0)
712 break;
713 if (q<WS_ACCEPT_QUEUE)
714 pwsi->accept_new[q] = as;
715 else
716 ERR("accept queue too small\n");
717 /* now signal our AsyncSelect handler */
718 _enable_event(s, WS_FD_SERVEVENT, 0, 0);
719 }
720
721 SOCKET WINAPI WSOCK32_accept(SOCKET s, struct sockaddr *addr,
722 INT *addrlen32)
723 {
724 LPWSINFO pwsi = WINSOCK_GetIData();
725 #ifdef HAVE_IPX
726 struct ws_sockaddr_ipx* addr2 = (struct ws_sockaddr_ipx *)addr;
727 #endif
728 struct accept_socket_request *req = get_req_buffer();
729
730 TRACE("(%08x): socket %04x\n",
731 (unsigned)pwsi, (UINT16)s );
732 if( _check_ws(pwsi, s) )
733 {
734 if (_is_blocking(s))
735 {
736 /* block here */
737 int fd = _get_sock_fd(s);
738 do_block(fd, 5);
739 close(fd);
740 _sync_sock_state(s); /* let wineserver notice connection */
741 /* retrieve any error codes from it */
742 SetLastError(_get_sock_error(s, FD_ACCEPT_BIT));
743 /* FIXME: care about the error? */
744 }
745 req->lhandle = s;
746 req->access = GENERIC_READ|GENERIC_WRITE|SYNCHRONIZE;
747 req->inherit = TRUE;
748 sock_server_call( REQ_ACCEPT_SOCKET );
749 if( req->handle >= 0 )
750 {
751 unsigned omask = _get_sock_mask( s );
752 SOCKET as = req->handle;
753 int fd = _get_sock_fd( as );
754 if( getpeername(fd, addr, addrlen32) != -1 )
755 {
756 #ifdef HAVE_IPX
757 if (addr && ((struct sockaddr_ipx *)addr)->sipx_family == AF_IPX) {
758 addr = (struct sockaddr *)
759 malloc(addrlen32 ? *addrlen32 : sizeof(*addr2));
760 memcpy(addr, addr2,
761 addrlen32 ? *addrlen32 : sizeof(*addr2));
762 addr2->sipx_family = WS_AF_IPX;
763 addr2->sipx_network = ((struct sockaddr_ipx *)addr)->sipx_network;
764 addr2->sipx_port = ((struct sockaddr_ipx *)addr)->sipx_port;
765 memcpy(addr2->sipx_node,
766 ((struct sockaddr_ipx *)addr)->sipx_node, IPX_NODE_LEN);
767 free(addr);
768 }
769 #endif
770 } else SetLastError(wsaErrno());
771 close(fd);
772 if (omask & WS_FD_SERVEVENT)
773 WSOCK32_async_accept(pwsi, s, as);
774 return as;
775 }
776 }
777 return INVALID_SOCKET;
778 }
779
780 /***********************************************************************
781 * accept() (WINSOCK.1)
782 */
783 SOCKET16 WINAPI WINSOCK_accept16(SOCKET16 s, struct sockaddr* addr,
784 INT16* addrlen16 )
785 {
786 INT addrlen32 = addrlen16 ? *addrlen16 : 0;
787 SOCKET retSocket = WSOCK32_accept( s, addr, &addrlen32 );
788 if( addrlen16 ) *addrlen16 = (INT16)addrlen32;
789 return (SOCKET16)retSocket;
790 }
791
792 /***********************************************************************
793 * bind() (WSOCK32.2)
794 */
795 INT WINAPI WSOCK32_bind(SOCKET s, struct sockaddr *name, INT namelen)
796 {
797 LPWSINFO pwsi = WINSOCK_GetIData();
798 #ifdef HAVE_IPX
799 struct ws_sockaddr_ipx* name2 = (struct ws_sockaddr_ipx *)name;
800 #endif
801
802 TRACE("(%08x): socket %04x, ptr %8x, length %d\n",
803 (unsigned)pwsi, s, (int) name, namelen);
804 #if DEBUG_SOCKADDR
805 dump_sockaddr(name);
806 #endif
807
808 if ( _check_ws(pwsi, s) )
809 {
810 int fd = _get_sock_fd(s);
811 /* FIXME: what family does this really map to on the Unix side? */
812 if (name && ((struct ws_sockaddr_ipx *)name)->sipx_family == WS_AF_PUP)
813 ((struct ws_sockaddr_ipx *)name)->sipx_family = AF_UNSPEC;
814 #ifdef HAVE_IPX
815 else if (name &&
816 ((struct ws_sockaddr_ipx *)name)->sipx_family == WS_AF_IPX)
817 {
818 name = (struct sockaddr *) malloc(sizeof(struct sockaddr_ipx));
819 memset(name, '\0', sizeof(struct sockaddr_ipx));
820 ((struct sockaddr_ipx *)name)->sipx_family = AF_IPX;
821 ((struct sockaddr_ipx *)name)->sipx_port = name2->sipx_port;
822 ((struct sockaddr_ipx *)name)->sipx_network = name2->sipx_network;
823 memcpy(((struct sockaddr_ipx *)name)->sipx_node,
824 name2->sipx_node, IPX_NODE_LEN);
825 namelen = sizeof(struct sockaddr_ipx);
826 }
827 #endif
828 if ( namelen >= sizeof(*name) )
829 {
830 if ( name && (((struct ws_sockaddr_in *)name)->sin_family == AF_INET
831 #ifdef HAVE_IPX
832 || ((struct sockaddr_ipx *)name)->sipx_family == AF_IPX
833 #endif
834 ))
835 {
836 if ( bind(fd, name, namelen) < 0 )
837 {
838 int loc_errno = errno;
839 WARN("\tfailure - errno = %i\n", errno);
840 errno = loc_errno;
841 switch(errno)
842 {
843 case EBADF: SetLastError(WSAENOTSOCK); break;
844 case EADDRNOTAVAIL: SetLastError(WSAEINVAL); break;
845 default: SetLastError(wsaErrno());break;
846 }
847 }
848 else {
849 #ifdef HAVE_IPX
850 if (((struct sockaddr_ipx *)name)->sipx_family == AF_IPX)
851 free(name);
852 #endif
853 close(fd);
854 return 0; /* success */
855 }
856 } else SetLastError(WSAEAFNOSUPPORT);
857 } else SetLastError(WSAEFAULT);
858 #ifdef HAVE_IPX
859 if (name && ((struct sockaddr_ipx *)name)->sipx_family == AF_IPX)
860 free(name);
861 #endif
862 close(fd);
863 }
864 return SOCKET_ERROR;
865 }
866
867 /***********************************************************************
868 * bind() (WINSOCK.2)
869 */
870 INT16 WINAPI WINSOCK_bind16(SOCKET16 s, struct sockaddr *name, INT16 namelen)
871 {
872 return (INT16)WSOCK32_bind( s, name, namelen );
873 }
874
875 /***********************************************************************
876 * closesocket() (WSOCK32.3)
877 */
878 INT WINAPI WSOCK32_closesocket(SOCKET s)
879 {
880 LPWSINFO pwsi = WINSOCK_GetIData();
881
882 TRACE("(%08x): socket %08x\n", (unsigned)pwsi, s);
883
884 if( _check_ws(pwsi, s) )
885 {
886 if( CloseHandle(s) )
887 return 0;
888 }
889 return SOCKET_ERROR;
890 }
891
892 /***********************************************************************
893 * closesocket() (WINSOCK.3)
894 */
895 INT16 WINAPI WINSOCK_closesocket16(SOCKET16 s)
896 {
897 return (INT16)WSOCK32_closesocket(s);
898 }
899
900 /***********************************************************************
901 * connect() (WSOCK32.4)
902 */
903 INT WINAPI WSOCK32_connect(SOCKET s, struct sockaddr *name, INT namelen)
904 {
905 LPWSINFO pwsi = WINSOCK_GetIData();
906 #ifdef HAVE_IPX
907 struct ws_sockaddr_ipx* name2 = (struct ws_sockaddr_ipx *)name;
908 #endif
909
910 TRACE("(%08x): socket %04x, ptr %8x, length %d\n",
911 (unsigned)pwsi, s, (int) name, namelen);
912 #if DEBUG_SOCKADDR
913 dump_sockaddr(name);
914 #endif
915
916 if( _check_ws(pwsi, s) )
917 {
918 int fd = _get_sock_fd(s);
919 if (name && ((struct ws_sockaddr_ipx *)name)->sipx_family == WS_AF_PUP)
920 ((struct ws_sockaddr_ipx *)name)->sipx_family = AF_UNSPEC;
921 #ifdef HAVE_IPX
922 else if (name && ((struct ws_sockaddr_ipx *)name)->sipx_family == WS_AF_IPX)
923 {
924 name = (struct sockaddr *) malloc(sizeof(struct sockaddr_ipx));
925 memset(name, '\0', sizeof(struct sockaddr_ipx));
926 ((struct sockaddr_ipx *)name)->sipx_family = AF_IPX;
927 ((struct sockaddr_ipx *)name)->sipx_port = name2->sipx_port;
928 ((struct sockaddr_ipx *)name)->sipx_network = name2->sipx_network;
929 memcpy(((struct sockaddr_ipx *)name)->sipx_node,
930 name2->sipx_node, IPX_NODE_LEN);
931 namelen = sizeof(struct sockaddr_ipx);
932 }
933 #endif
934 if (connect(fd, name, namelen) == 0) {
935 close(fd);
936 goto connect_success;
937 }
938 if (errno == EINPROGRESS)
939 {
940 /* tell wineserver that a connection is in progress */
941 _enable_event(s, FD_CONNECT|FD_READ|FD_WRITE,
942 WS_FD_CONNECT|WS_FD_READ|WS_FD_WRITE,
943 WS_FD_CONNECTED|WS_FD_LISTENING);
944 if (_is_blocking(s))
945 {
946 int result;
947 /* block here */
948 do_block(fd, 6);
949 _sync_sock_state(s); /* let wineserver notice connection */
950 /* retrieve any error codes from it */
951 result = _get_sock_error(s, FD_CONNECT_BIT);
952 if (result)
953 SetLastError(result);
954 else {
955 close(fd);
956 goto connect_success;
957 }
958 }
959 else SetLastError(WSAEWOULDBLOCK);
960 close(fd);
961 }
962 else
963 {
964 SetLastError(wsaErrno());
965 close(fd);
966 }
967 }
968 #ifdef HAVE_IPX
969 if (name && ((struct sockaddr_ipx *)name)->sipx_family == AF_IPX)
970 free(name);
971 #endif
972 return SOCKET_ERROR;
973 connect_success:
974 #ifdef HAVE_IPX
975 if (((struct sockaddr_ipx *)name)->sipx_family == AF_IPX)
976 free(name);
977 #endif
978 _enable_event(s, FD_CONNECT|FD_READ|FD_WRITE,
979 WS_FD_CONNECTED|WS_FD_READ|WS_FD_WRITE,
980 WS_FD_CONNECT|WS_FD_LISTENING);
981 return 0;
982 }
983
984 /***********************************************************************
985 * connect() (WINSOCK.4)
986 */
987 INT16 WINAPI WINSOCK_connect16(SOCKET16 s, struct sockaddr *name, INT16 namelen)
988 {
989 return (INT16)WSOCK32_connect( s, name, namelen );
990 }
991
992 /***********************************************************************
993 * getpeername() (WSOCK32.5)
994 */
995 INT WINAPI WSOCK32_getpeername(SOCKET s, struct sockaddr *name,
996 INT *namelen)
997 {
998 LPWSINFO pwsi = WINSOCK_GetIData();
999 #ifdef HAVE_IPX
1000 struct ws_sockaddr_ipx* name2 = (struct ws_sockaddr_ipx *)name;
1001 #endif
1002
1003 TRACE("(%08x): socket: %04x, ptr %8x, ptr %8x\n",
1004 (unsigned)pwsi, s, (int) name, *namelen);
1005 if( _check_ws(pwsi, s) )
1006 {
1007 int fd = _get_sock_fd(s);
1008 if (getpeername(fd, name, namelen) == 0) {
1009 #ifdef HAVE_IPX
1010 if (((struct ws_sockaddr_ipx *)name)->sipx_family == AF_IPX) {
1011 name = (struct sockaddr *)
1012 malloc(namelen ? *namelen : sizeof(*name2));
1013 memcpy(name, name2, namelen ? *namelen : sizeof(*name2));
1014 name2->sipx_family = WS_AF_IPX;
1015 name2->sipx_network = ((struct sockaddr_ipx *)name)->sipx_network;
1016 name2->sipx_port = ((struct sockaddr_ipx *)name)->sipx_port;
1017 memcpy(name2->sipx_node,
1018 ((struct sockaddr_ipx *)name)->sipx_node, IPX_NODE_LEN);
1019 free(name);
1020 }
1021 #endif
1022 close(fd);
1023 return 0;
1024 }
1025 SetLastError(wsaErrno());
1026 close(fd);
1027 }
1028 return SOCKET_ERROR;
1029 }
1030
1031 /***********************************************************************
1032 * getpeername() (WINSOCK.5)
1033 */
1034 INT16 WINAPI WINSOCK_getpeername16(SOCKET16 s, struct sockaddr *name,
1035 INT16 *namelen16)
1036 {
1037 INT namelen32 = *namelen16;
1038 INT retVal = WSOCK32_getpeername( s, name, &namelen32 );
1039
1040 #if DEBUG_SOCKADDR
1041 dump_sockaddr(name);
1042 #endif
1043
1044 *namelen16 = namelen32;
1045 return (INT16)retVal;
1046 }
1047
1048 /***********************************************************************
1049 * getsockname() (WSOCK32.6)
1050 */
1051 INT WINAPI WSOCK32_getsockname(SOCKET s, struct sockaddr *name,
1052 INT *namelen)
1053 {
1054 LPWSINFO pwsi = WINSOCK_GetIData();
1055 #ifdef HAVE_IPX
1056 struct ws_sockaddr_ipx* name2 = (struct ws_sockaddr_ipx *)name;
1057 #endif
1058
1059 TRACE("(%08x): socket: %04x, ptr %8x, ptr %8x\n",
1060 (unsigned)pwsi, s, (int) name, (int) *namelen);
1061 if( _check_ws(pwsi, s) )
1062 {
1063 int fd = _get_sock_fd(s);
1064 if (getsockname(fd, name, namelen) == 0) {
1065 #ifdef HAVE_IPX
1066 if (((struct sockaddr_ipx *)name)->sipx_family == AF_IPX) {
1067 name = (struct sockaddr *)
1068 malloc(namelen ? *namelen : sizeof(*name2));
1069 memcpy(name, name2, namelen ? *namelen : sizeof(*name2));
1070 name2->sipx_family = WS_AF_IPX;
1071 name2->sipx_network = ((struct sockaddr_ipx *)name)->sipx_network;
1072 name2->sipx_port = ((struct sockaddr_ipx *)name)->sipx_port;
1073 memcpy(name2->sipx_node,
1074 ((struct sockaddr_ipx *)name)->sipx_node, IPX_NODE_LEN);
1075 free(name);
1076 }
1077 #endif
1078 close(fd);
1079 return 0;
1080 }
1081 SetLastError(wsaErrno());
1082 close(fd);
1083 }
1084 return SOCKET_ERROR;
1085 }
1086
1087 /***********************************************************************
1088 * getsockname() (WINSOCK.6)
1089 */
1090 INT16 WINAPI WINSOCK_getsockname16(SOCKET16 s, struct sockaddr *name,
1091 INT16 *namelen16)
1092 {
1093 INT retVal;
1094
1095 if( namelen16 )
1096 {
1097 INT namelen32 = *namelen16;
1098 retVal = WSOCK32_getsockname( s, name, &namelen32 );
1099 *namelen16 = namelen32;
1100
1101 #if DEBUG_SOCKADDR
1102 dump_sockaddr(name);
1103 #endif
1104
1105 }
1106 else retVal = SOCKET_ERROR;
1107 return (INT16)retVal;
1108 }
1109
1110
1111 /***********************************************************************
1112 * getsockopt() (WSOCK32.7)
1113 */
1114 INT WINAPI WSOCK32_getsockopt(SOCKET s, INT level,
1115 INT optname, char *optval, INT *optlen)
1116 {
1117 LPWSINFO pwsi = WINSOCK_GetIData();
1118
1119 TRACE("(%08x): socket: %04x, opt %d, ptr %8x, ptr %8x\n",
1120 (unsigned)pwsi, s, level, (int) optval, (int) *optlen);
1121 if( _check_ws(pwsi, s) )
1122 {
1123 int fd = _get_sock_fd(s);
1124 convert_sockopt(&level, &optname);
1125 if (getsockopt(fd, (int) level, optname, optval, optlen) == 0 )
1126 {
1127 close(fd);
1128 return 0;
1129 }
1130 SetLastError((errno == EBADF) ? WSAENOTSOCK : wsaErrno());
1131 close(fd);
1132 }
1133 return SOCKET_ERROR;
1134 }
1135
1136 /***********************************************************************
1137 * getsockopt() (WINSOCK.7)
1138 */
1139 INT16 WINAPI WINSOCK_getsockopt16(SOCKET16 s, INT16 level,
1140 INT16 optname, char *optval, INT16 *optlen)
1141 {
1142 INT optlen32;
1143 INT *p = &optlen32;
1144 INT retVal;
1145 if( optlen ) optlen32 = *optlen; else p = NULL;
1146 retVal = WSOCK32_getsockopt( s, (UINT16)level, optname, optval, p );
1147 if( optlen ) *optlen = optlen32;
1148 return (INT16)retVal;
1149 }
1150
1151 /***********************************************************************
1152 * htonl() (WINSOCK.8)(WSOCK32.8)
1153 */
1154 u_long WINAPI WINSOCK_htonl(u_long hostlong) { return( htonl(hostlong) ); }
1155 /***********************************************************************
1156 * htons() (WINSOCK.9)(WSOCK32.9)
1157 */
1158 u_short WINAPI WINSOCK_htons(u_short hostshort) { return( htons(hostshort) ); }
1159 /***********************************************************************
1160 * inet_addr() (WINSOCK.10)(WSOCK32.10)
1161 */
1162 u_long WINAPI WINSOCK_inet_addr(char *cp) { return( inet_addr(cp) ); }
1163 /***********************************************************************
1164 * ntohl() (WINSOCK.14)(WSOCK32.14)
1165 */
1166 u_long WINAPI WINSOCK_ntohl(u_long netlong) { return( ntohl(netlong) ); }
1167 /***********************************************************************
1168 * ntohs() (WINSOCK.15)(WSOCK32.15)
1169 */
1170 u_short WINAPI WINSOCK_ntohs(u_short netshort) { return( ntohs(netshort) ); }
1171
1172 /***********************************************************************
1173 * inet_ntoa() (WINSOCK.11)(WSOCK32.11)
1174 */
1175 char* WINAPI WSOCK32_inet_ntoa(struct in_addr in)
1176 {
1177 /* use "buffer for dummies" here because some applications have
1178 * propensity to decode addresses in ws_hostent structure without
1179 * saving them first...
1180 */
1181
1182 LPWSINFO pwsi = WINSOCK_GetIData();
1183
1184 if( pwsi )
1185 {
1186 char* s = inet_ntoa(in);
1187 if( s )
1188 {
1189 if( pwsi->dbuffer == NULL ) {
1190 /* Yes, 16: 4*3 digits + 3 '.' + 1 '\0' */
1191 if((pwsi->dbuffer = (char*) SEGPTR_ALLOC(16)) == NULL )
1192 {
1193 SetLastError(WSAENOBUFS);
1194 return NULL;
1195 }
1196 }
1197 strcpy(pwsi->dbuffer, s);
1198 return pwsi->dbuffer;
1199 }
1200 SetLastError(wsaErrno());
1201 }
1202 return NULL;
1203 }
1204
1205 SEGPTR WINAPI WINSOCK_inet_ntoa16(struct in_addr in)
1206 {
1207 char* retVal = WSOCK32_inet_ntoa(in);
1208 return retVal ? SEGPTR_GET(retVal) : (SEGPTR)NULL;
1209 }
1210
1211 /***********************************************************************
1212 * ioctlsocket() (WSOCK32.12)
1213 */
1214 INT WINAPI WSOCK32_ioctlsocket(SOCKET s, LONG cmd, ULONG *argp)
1215 {
1216 LPWSINFO pwsi = WINSOCK_GetIData();
1217
1218 TRACE("(%08x): socket %04x, cmd %08lx, ptr %8x\n",
1219 (unsigned)pwsi, s, cmd, (unsigned) argp);
1220 if( _check_ws(pwsi, s) )
1221 {
1222 int fd = _get_sock_fd(s);
1223 long newcmd = cmd;
1224
1225 switch( cmd )
1226 {
1227 case WS_FIONREAD:
1228 newcmd=FIONREAD;
1229 break;
1230
1231 case WS_FIONBIO:
1232 newcmd=FIONBIO;
1233 if( _get_sock_mask(s) )
1234 {
1235 /* AsyncSelect()'ed sockets are always nonblocking */
1236 if (*argp) {
1237 close(fd);
1238 return 0;
1239 }
1240 SetLastError(WSAEINVAL);
1241 close(fd);
1242 return SOCKET_ERROR;
1243 }
1244 close(fd);
1245 if (*argp)
1246 _enable_event(s, 0, WS_FD_NONBLOCKING, 0);
1247 else
1248 _enable_event(s, 0, 0, WS_FD_NONBLOCKING);
1249 return 0;
1250
1251 case WS_SIOCATMARK:
1252 newcmd=SIOCATMARK;
1253 break;
1254
1255 case WS_IOW('f',125,u_long):
1256 WARN("Warning: WS1.1 shouldn't be using async I/O\n");
1257 SetLastError(WSAEINVAL);
1258 return SOCKET_ERROR;
1259
1260 default:
1261 /* Netscape tries hard to use bogus ioctl 0x667e */
1262 WARN("\tunknown WS_IOCTL cmd (%08lx)\n", cmd);
1263 }
1264 if( ioctl(fd, newcmd, (char*)argp ) == 0 )
1265 {
1266 close(fd);
1267 return 0;
1268 }
1269 SetLastError((errno == EBADF) ? WSAENOTSOCK : wsaErrno());
1270 close(fd);
1271 }
1272 return SOCKET_ERROR;
1273 }
1274
1275 /***********************************************************************
1276 * ioctlsocket() (WINSOCK.12)
1277 */
1278 INT16 WINAPI WINSOCK_ioctlsocket16(SOCKET16 s, LONG cmd, ULONG *argp)
1279 {
1280 return (INT16)WSOCK32_ioctlsocket( s, cmd, argp );
1281 }
1282
1283
1284 /***********************************************************************
1285 * listen() (WSOCK32.13)
1286 */
1287 INT WINAPI WSOCK32_listen(SOCKET s, INT backlog)
1288 {
1289 LPWSINFO pwsi = WINSOCK_GetIData();
1290
1291 TRACE("(%08x): socket %04x, backlog %d\n",
1292 (unsigned)pwsi, s, backlog);
1293 if( _check_ws(pwsi, s) )
1294 {
1295 int fd = _get_sock_fd(s);
1296 if (listen(fd, backlog) == 0)
1297 {
1298 close(fd);
1299 _enable_event(s, FD_ACCEPT,
1300 WS_FD_LISTENING,
1301 WS_FD_CONNECT|WS_FD_CONNECTED);
1302 return 0;
1303 }
1304 SetLastError(wsaErrno());
1305 }
1306 else SetLastError(WSAENOTSOCK);
1307 return SOCKET_ERROR;
1308 }
1309
1310 /***********************************************************************
1311 * listen() (WINSOCK.13)
1312 */
1313 INT16 WINAPI WINSOCK_listen16(SOCKET16 s, INT16 backlog)
1314 {
1315 return (INT16)WSOCK32_listen( s, backlog );
1316 }
1317
1318
1319 /***********************************************************************
1320 * recv() (WSOCK32.16)
1321 */
1322 INT WINAPI WSOCK32_recv(SOCKET s, char *buf, INT len, INT flags)
1323 {
1324 LPWSINFO pwsi = WINSOCK_GetIData();
1325
1326 TRACE("(%08x): socket %04x, buf %8x, len %d, "
1327 "flags %d\n", (unsigned)pwsi, s, (unsigned)buf,
1328 len, flags);
1329 if( _check_ws(pwsi, s) )
1330 {
1331 int fd = _get_sock_fd(s);
1332 INT length;
1333
1334 if (_is_blocking(s))
1335 {
1336 /* block here */
1337 /* FIXME: OOB and exceptfds? */
1338 do_block(fd, 1);
1339 }
1340 if ((length = recv(fd, buf, len, flags)) >= 0)
1341 {
1342 TRACE(" -> %i bytes\n", length);
1343
1344 close(fd);
1345 _enable_event(s, FD_READ, 0, 0);
1346 return length;
1347 }
1348 SetLastError(wsaErrno());
1349 close(fd);
1350 }
1351 else SetLastError(WSAENOTSOCK);
1352 WARN(" -> ERROR\n");
1353 return SOCKET_ERROR;
1354 }
1355
1356 /***********************************************************************
1357 * recv() (WINSOCK.16)
1358 */
1359 INT16 WINAPI WINSOCK_recv16(SOCKET16 s, char *buf, INT16 len, INT16 flags)
1360 {
1361 return (INT16)WSOCK32_recv( s, buf, len, flags );
1362 }
1363
1364
1365 /***********************************************************************
1366 * recvfrom() (WSOCK32.17)
1367 */
1368 INT WINAPI WSOCK32_recvfrom(SOCKET s, char *buf, INT len, INT flags,
1369 struct sockaddr *from, INT *fromlen32)
1370 {
1371 LPWSINFO pwsi = WINSOCK_GetIData();
1372 #ifdef HAVE_IPX
1373 struct ws_sockaddr_ipx* from2 = (struct ws_sockaddr_ipx *)from;
1374 #endif
1375
1376 TRACE("(%08x): socket %04x, ptr %08x, "
1377 "len %d, flags %d\n", (unsigned)pwsi, s, (unsigned)buf,
1378 len, flags);
1379 #if DEBUG_SOCKADDR
1380 if( from ) dump_sockaddr(from);
1381 else DPRINTF("from = NULL\n");
1382 #endif
1383
1384 if( _check_ws(pwsi, s) )
1385 {
1386 int fd = _get_sock_fd(s);
1387 int length;
1388
1389 if (_is_blocking(s))
1390 {
1391 /* block here */
1392 /* FIXME: OOB and exceptfds */
1393 do_block(fd, 1);
1394 }
1395 if ((length = recvfrom(fd, buf, len, flags, from, fromlen32)) >= 0)
1396 {
1397 TRACE(" -> %i bytes\n", length);
1398
1399 #ifdef HAVE_IPX
1400 if (from && ((struct sockaddr_ipx *)from)->sipx_family == AF_IPX) {
1401 from = (struct sockaddr *)
1402 malloc(fromlen32 ? *fromlen32 : sizeof(*from2));
1403 memcpy(from, from2, fromlen32 ? *fromlen32 : sizeof(*from2));
1404 from2->sipx_family = WS_AF_IPX;
1405 from2->sipx_network = ((struct sockaddr_ipx *)from)->sipx_network;
1406 from2->sipx_port = ((struct sockaddr_ipx *)from)->sipx_port;
1407 memcpy(from2->sipx_node,
1408 ((struct sockaddr_ipx *)from)->sipx_node, IPX_NODE_LEN);
1409 free(from);
1410 }
1411 #endif
1412 close(fd);
1413 _enable_event(s, FD_READ, 0, 0);
1414 return (INT16)length;
1415 }
1416 SetLastError(wsaErrno());
1417 close(fd);
1418 }
1419 else SetLastError(WSAENOTSOCK);
1420 WARN(" -> ERROR\n");
1421 #ifdef HAVE_IPX
1422 if (from && ((struct sockaddr_ipx *)from)->sipx_family == AF_IPX) {
1423 from = (struct sockaddr *)
1424 malloc(fromlen32 ? *fromlen32 : sizeof(*from2));
1425 memcpy(from, from2, fromlen32 ? *fromlen32 : sizeof(*from2));
1426 from2->sipx_family = WS_AF_IPX;
1427 from2->sipx_network = ((struct sockaddr_ipx *)from)->sipx_network;
1428 from2->sipx_port = ((struct sockaddr_ipx *)from)->sipx_port;
1429 memcpy(from2->sipx_node,
1430 ((struct sockaddr_ipx *)from)->sipx_node, IPX_NODE_LEN);
1431 free(from);
1432 }
1433 #endif
1434 return SOCKET_ERROR;
1435 }
1436
1437 /***********************************************************************
1438 * recvfrom() (WINSOCK.17)
1439 */
1440 INT16 WINAPI WINSOCK_recvfrom16(SOCKET16 s, char *buf, INT16 len, INT16 flags,
1441 struct sockaddr *from, INT16 *fromlen16)
1442 {
1443 INT fromlen32;
1444 INT *p = &fromlen32;
1445 INT retVal;
1446
1447 if( fromlen16 ) fromlen32 = *fromlen16; else p = NULL;
1448 retVal = WSOCK32_recvfrom( s, buf, len, flags, from, p );
1449 if( fromlen16 ) *fromlen16 = fromlen32;
1450 return (INT16)retVal;
1451 }
1452
1453 /***********************************************************************
1454 * select() (WINSOCK.18)(WSOCK32.18)
1455 */
1456 static INT __ws_select( BOOL b32, void *ws_readfds, void *ws_writefds, void *ws_exceptfds,
1457 struct timeval *timeout )
1458 {
1459 LPWSINFO pwsi = WINSOCK_GetIData();
1460
1461 TRACE("(%08x): read %8x, write %8x, excp %8x\n",
1462 (unsigned) pwsi, (unsigned) ws_readfds, (unsigned) ws_writefds, (unsigned) ws_exceptfds);
1463
1464 if( pwsi )
1465 {
1466 int highfd = 0;
1467 fd_set readfds, writefds, exceptfds;
1468 fd_set *p_read, *p_write, *p_except;
1469 int readfd[FD_SETSIZE], writefd[FD_SETSIZE], exceptfd[FD_SETSIZE];
1470
1471 p_read = fd_set_import(&readfds, pwsi, ws_readfds, &highfd, readfd, b32);
1472 p_write = fd_set_import(&writefds, pwsi, ws_writefds, &highfd, writefd, b32);
1473 p_except = fd_set_import(&exceptfds, pwsi, ws_exceptfds, &highfd, exceptfd, b32);
1474
1475 if( (highfd = select(highfd + 1, p_read, p_write, p_except, timeout)) > 0 )
1476 {
1477 fd_set_export(pwsi, &readfds, p_except, ws_readfds, readfd, b32);
1478 fd_set_export(pwsi, &writefds, p_except, ws_writefds, writefd, b32);
1479
1480 if (p_except && ws_exceptfds)
1481 {
1482 #define wsfds16 ((ws_fd_set16*)ws_exceptfds)
1483 #define wsfds32 ((ws_fd_set32*)ws_exceptfds)
1484 int i, j, count = (b32) ? wsfds32->fd_count : wsfds16->fd_count;
1485
1486 for (i = j = 0; i < count; i++)
1487 {
1488 int fd = exceptfd[i];
1489 if( fd >= 0 && FD_ISSET(fd, &exceptfds) )
1490 {
1491 if( b32 )
1492 wsfds32->fd_array[j++] = wsfds32->fd_array[i];
1493 else
1494 wsfds16->fd_array[j++] = wsfds16->fd_array[i];
1495 }
1496 if( fd >= 0 ) close(fd);
1497 exceptfd[i] = -1;
1498 }
1499 if( b32 )
1500 wsfds32->fd_count = j;
1501 else
1502 wsfds16->fd_count = j;
1503 #undef wsfds32
1504 #undef wsfds16
1505 }
1506 return highfd;
1507 }
1508 fd_set_unimport(ws_readfds, readfd, b32);
1509 fd_set_unimport(ws_writefds, writefd, b32);
1510 fd_set_unimport(ws_exceptfds, exceptfd, b32);
1511 if( ws_readfds ) ((ws_fd_set32*)ws_readfds)->fd_count = 0;
1512 if( ws_writefds ) ((ws_fd_set32*)ws_writefds)->fd_count = 0;
1513 if( ws_exceptfds ) ((ws_fd_set32*)ws_exceptfds)->fd_count = 0;
1514
1515 if( highfd == 0 ) return 0;
1516 SetLastError(wsaErrno());
1517 }
1518 return SOCKET_ERROR;
1519 }
1520
1521 INT16 WINAPI WINSOCK_select16(INT16 nfds, ws_fd_set16 *ws_readfds,
1522 ws_fd_set16 *ws_writefds, ws_fd_set16 *ws_exceptfds,
1523 struct timeval *timeout)
1524 {
1525 return (INT16)__ws_select( FALSE, ws_readfds, ws_writefds, ws_exceptfds, timeout );
1526 }
1527
1528 INT WINAPI WSOCK32_select(INT nfds, ws_fd_set32 *ws_readfds,
1529 ws_fd_set32 *ws_writefds, ws_fd_set32 *ws_exceptfds,
1530 struct timeval *timeout)
1531 {
1532 /* struct timeval is the same for both 32- and 16-bit code */
1533 return (INT)__ws_select( TRUE, ws_readfds, ws_writefds, ws_exceptfds, timeout );
1534 }
1535
1536
1537 /***********************************************************************
1538 * send() (WSOCK32.19)
1539 */
1540 INT WINAPI WSOCK32_send(SOCKET s, char *buf, INT len, INT flags)
1541 {
1542 LPWSINFO pwsi = WINSOCK_GetIData();
1543
1544 TRACE("(%08x): socket %04x, ptr %08x, length %d, flags %d\n",
1545 (unsigned)pwsi, s, (unsigned) buf, len, flags);
1546 if( _check_ws(pwsi, s) )
1547 {
1548 int fd = _get_sock_fd(s);
1549 int length;
1550
1551 if (_is_blocking(s))
1552 {
1553 /* block here */
1554 /* FIXME: exceptfds */
1555 do_block(fd, 2);
1556 }
1557 if ((length = send(fd, buf, len, flags)) < 0 )
1558 {
1559 SetLastError(wsaErrno());
1560 if( GetLastError() == WSAEWOULDBLOCK )
1561 _enable_event(s, FD_WRITE, 0, 0);
1562 }
1563 else
1564 {
1565 close(fd);
1566 return (INT16)length;
1567 }
1568 close(fd);
1569 }
1570 else SetLastError(WSAENOTSOCK);
1571 return SOCKET_ERROR;
1572 }
1573
1574 /***********************************************************************
1575 * send() (WINSOCK.19)
1576 */
1577 INT16 WINAPI WINSOCK_send16(SOCKET16 s, char *buf, INT16 len, INT16 flags)
1578 {
1579 return WSOCK32_send( s, buf, len, flags );
1580 }
1581
1582 /***********************************************************************
1583 * sendto() (WSOCK32.20)
1584 */
1585 INT WINAPI WSOCK32_sendto(SOCKET s, char *buf, INT len, INT flags,
1586 struct sockaddr *to, INT tolen)
1587 {
1588 LPWSINFO pwsi = WINSOCK_GetIData();
1589 #ifdef HAVE_IPX
1590 struct ws_sockaddr_ipx* to2 = (struct ws_sockaddr_ipx *)to;
1591 #endif
1592
1593 TRACE("(%08x): socket %04x, ptr %08x, length %d, flags %d\n",
1594 (unsigned)pwsi, s, (unsigned) buf, len, flags);
1595 if( _check_ws(pwsi, s) )
1596 {
1597 int fd = _get_sock_fd(s);
1598 INT length;
1599
1600 if (to && ((struct ws_sockaddr_ipx *)to)->sipx_family == WS_AF_PUP)
1601 ((struct ws_sockaddr_ipx *)to)->sipx_family = AF_UNSPEC;
1602 #ifdef HAVE_IPX
1603 else if (to &&
1604 ((struct ws_sockaddr_ipx *)to)->sipx_family == WS_AF_IPX)
1605 {
1606 to = (struct sockaddr *) malloc(sizeof(struct sockaddr_ipx));
1607 memset(to, '\0', sizeof(struct sockaddr_ipx));
1608 ((struct sockaddr_ipx *)to)->sipx_family = AF_IPX;
1609 ((struct sockaddr_ipx *)to)->sipx_port = to2->sipx_port;
1610 ((struct sockaddr_ipx *)to)->sipx_network = to2->sipx_network;
1611 memcpy(((struct sockaddr_ipx *)to)->sipx_node,
1612 to2->sipx_node, IPX_NODE_LEN);
1613 tolen = sizeof(struct sockaddr_ipx);
1614 }
1615 #endif
1616 if (_is_blocking(s))
1617 {
1618 /* block here */
1619 /* FIXME: exceptfds */
1620 do_block(fd, 2);
1621 }
1622 if ((length = sendto(fd, buf, len, flags, to, tolen)) < 0 )
1623 {
1624 SetLastError(wsaErrno());
1625 if( GetLastError() == WSAEWOULDBLOCK )
1626 _enable_event(s, FD_WRITE, 0, 0);
1627 }
1628 else {
1629 #ifdef HAVE_IPX
1630 if (to && ((struct sockaddr_ipx *)to)->sipx_family == AF_IPX) {
1631 free(to);
1632 }
1633 #endif
1634 close(fd);
1635 return length;
1636 }
1637 close(fd);
1638 }
1639 else SetLastError(WSAENOTSOCK);
1640 #ifdef HAVE_IPX
1641 if (to && ((struct sockaddr_ipx *)to)->sipx_family == AF_IPX) {
1642 free(to);
1643 }
1644 #endif
1645 return SOCKET_ERROR;
1646 }
1647
1648 /***********************************************************************
1649 * sendto() (WINSOCK.20)
1650 */
1651 INT16 WINAPI WINSOCK_sendto16(SOCKET16 s, char *buf, INT16 len, INT16 flags,
1652 struct sockaddr *to, INT16 tolen)
1653 {
1654 return (INT16)WSOCK32_sendto( s, buf, len, flags, to, tolen );
1655 }
1656
1657 /***********************************************************************
1658 * setsockopt() (WSOCK32.21)
1659 */
1660 INT WINAPI WSOCK32_setsockopt(SOCKET16 s, INT level, INT optname,
1661 char *optval, INT optlen)
1662 {
1663 LPWSINFO pwsi = WINSOCK_GetIData();
1664
1665 TRACE("(%08x): socket %04x, lev %d, opt %d, ptr %08x, len %d\n",
1666 (unsigned)pwsi, s, level, optname, (int) optval, optlen);
1667 if( _check_ws(pwsi, s) )
1668 {
1669 struct linger linger;
1670 int fd = _get_sock_fd(s);
1671 int woptval;
1672
1673 convert_sockopt(&level, &optname);
1674 if(optname == WS_SO_DONTLINGER) {
1675 linger.l_onoff = *((int*)optval) ? 0: 1;
1676 linger.l_linger = 0;
1677 optname=SO_LINGER;
1678 optval = (char*)&linger;
1679 optlen = sizeof(struct linger);
1680 }else{
1681 if (optname == SO_LINGER && optval) {
1682 /* yes, uses unsigned short in both win16/win32 */
1683 linger.l_onoff = ((UINT16*)optval)[0];
1684 linger.l_linger = ((UINT16*)optval)[1];
1685 /* FIXME: what is documented behavior if SO_LINGER optval
1686 is null?? */
1687 optval = (char*)&linger;
1688 optlen = sizeof(struct linger);
1689 } else if (optlen < sizeof(int)){
1690 woptval= *((INT16 *) optval);
1691 optval= (char*) &woptval;
1692 optlen=sizeof(int);
1693 }
1694 }
1695 if (setsockopt(fd, level, optname, optval, optlen) == 0)
1696 {
1697 close(fd);
1698 return 0;
1699 }
1700 SetLastError(wsaErrno());
1701 close(fd);
1702 }
1703 else SetLastError(WSAENOTSOCK);
1704 return SOCKET_ERROR;
1705 }
1706
1707 /***********************************************************************
1708 * setsockopt() (WINSOCK.21)
1709 */
1710 INT16 WINAPI WINSOCK_setsockopt16(SOCKET16 s, INT16 level, INT16 optname,
1711 char *optval, INT16 optlen)
1712 {
1713 if( !optval ) return SOCKET_ERROR;
1714 return (INT16)WSOCK32_setsockopt( s, (UINT16)level, optname, optval, optlen );
1715 }
1716
1717
1718 /***********************************************************************
1719 * shutdown() (WSOCK32.22)
1720 */
1721 INT WINAPI WSOCK32_shutdown(SOCKET s, INT how)
1722 {
1723 LPWSINFO pwsi = WINSOCK_GetIData();
1724
1725 TRACE("(%08x): socket %04x, how %i\n",
1726 (unsigned)pwsi, s, how );
1727 if( _check_ws(pwsi, s) )
1728 {
1729 int fd = _get_sock_fd(s);
1730 switch( how )
1731 {
1732 case 0: /* drop receives */
1733 _enable_event(s, 0, 0, WS_FD_READ);
1734 #ifdef SHUT_RD
1735 how = SHUT_RD;
1736 #endif
1737 break;
1738
1739 case 1: /* drop sends */
1740 _enable_event(s, 0, 0, WS_FD_WRITE);
1741 #ifdef SHUT_WR
1742 how = SHUT_WR;
1743 #endif
1744 break;
1745
1746 case 2: /* drop all */
1747 #ifdef SHUT_RDWR
1748 how = SHUT_RDWR;
1749 #endif
1750 default:
1751 WSAAsyncSelect( s, 0, 0, 0 );
1752 break;
1753 }
1754
1755 if (shutdown(fd, how) == 0)
1756 {
1757 if( how > 1 )
1758 {
1759 _enable_event(s, 0, 0, WS_FD_CONNECTED|WS_FD_LISTENING);
1760 }
1761 close(fd);
1762 return 0;
1763 }
1764 SetLastError(wsaErrno());
1765 close(fd);
1766 }
1767 else SetLastError(WSAENOTSOCK);
1768 return SOCKET_ERROR;
1769 }
1770
1771 /***********************************************************************
1772 * shutdown() (WINSOCK.22)
1773 */
1774 INT16 WINAPI WINSOCK_shutdown16(SOCKET16 s, INT16 how)
1775 {
1776 return (INT16)WSOCK32_shutdown( s, how );
1777 }
1778
1779
1780 /***********************************************************************
1781 * socket() (WSOCK32.23)
1782 */
1783 SOCKET WINAPI WSOCK32_socket(INT af, INT type, INT protocol)
1784 {
1785 LPWSINFO pwsi = WINSOCK_GetIData();
1786 struct create_socket_request *req = get_req_buffer();
1787
1788 TRACE("(%08x): af=%d type=%d protocol=%d\n",
1789 (unsigned)pwsi, af, type, protocol);
1790
1791 if( pwsi )
1792 {
1793 /* check the socket family */
1794 switch(af)
1795 {
1796 #ifdef HAVE_IPX
1797 case WS_AF_IPX: af = AF_IPX;
1798 #endif
1799 case AF_INET:
1800 case AF_UNSPEC: break;
1801 default: SetLastError(WSAEAFNOSUPPORT);
1802 return INVALID_SOCKET;
1803 }
1804
1805 /* check the socket type */
1806 switch(type)
1807 {
1808 case SOCK_STREAM:
1809 case SOCK_DGRAM:
1810 case SOCK_RAW: break;
1811 default: SetLastError(WSAESOCKTNOSUPPORT);
1812 return INVALID_SOCKET;
1813 }
1814
1815 /* check the protocol type */
1816 if ( protocol < 0 ) /* don't support negative values */
1817 { SetLastError(WSAEPROTONOSUPPORT); return INVALID_SOCKET; }
1818
1819 if ( af == AF_UNSPEC) /* did they not specify the address family? */
1820 switch(protocol)
1821 {
1822 case IPPROTO_TCP:
1823 if (type == SOCK_STREAM) { af = AF_INET; break; }
1824 case IPPROTO_UDP:
1825 if (type == SOCK_DGRAM) { af = AF_INET; break; }
1826 default: SetLastError(WSAEPROTOTYPE); return INVALID_SOCKET;
1827 }
1828
1829 req->family = af;
1830 req->type = type;
1831 req->protocol = protocol;
1832 req->access = GENERIC_READ|GENERIC_WRITE|SYNCHRONIZE;
1833 req->inherit = TRUE;
1834 sock_server_call( REQ_CREATE_SOCKET );
1835 if ( req->handle >= 0)
1836 {
1837 TRACE("\tcreated %04x\n", req->handle);
1838
1839 return req->handle;
1840 }
1841
1842 if (GetLastError() == WSAEACCES) /* raw socket denied */
1843 {
1844 if (type == SOCK_RAW)
1845 MESSAGE("WARNING: Trying to create a socket of type SOCK_RAW, will fail unless running as root\n");
1846 else
1847 MESSAGE("WS_SOCKET: not enough privileges to create socket, try running as root\n");
1848 SetLastError(WSAESOCKTNOSUPPORT);
1849 }
1850 }
1851
1852 WARN("\t\tfailed!\n");
1853 return INVALID_SOCKET;
1854 }
1855
1856 /***********************************************************************
1857 * socket() (WINSOCK.23)
1858 */
1859 SOCKET16 WINAPI WINSOCK_socket16(INT16 af, INT16 type, INT16 protocol)
1860 {
1861 return (SOCKET16)WSOCK32_socket( af, type, protocol );
1862 }
1863
1864
1865 /* ----------------------------------- DNS services
1866 *
1867 * IMPORTANT: 16-bit API structures have SEGPTR pointers inside them.
1868 * Also, we have to use wsock32 stubs to convert structures and
1869 * error codes from Unix to WSA, hence there is no direct mapping in
1870 * the relay32/wsock32.spec.
1871 */
1872
1873 static char* NULL_STRING = "NULL";
1874
1875 /***********************************************************************
1876 * gethostbyaddr() (WINSOCK.51)(WSOCK32.51)
1877 */
1878 static struct WIN_hostent* __ws_gethostbyaddr(const char *addr, int len, int type, int dup_flag)
1879 {
1880 LPWSINFO pwsi = WINSOCK_GetIData();
1881
1882 if( pwsi )
1883 {
1884 struct hostent* host;
1885 if( (host = gethostbyaddr(addr, len, type)) != NULL )
1886 if( WS_dup_he(pwsi, host, dup_flag) )
1887 return (struct WIN_hostent*)(pwsi->he);
1888 else
1889 SetLastError(WSAENOBUFS);
1890 else
1891 SetLastError((h_errno < 0) ? wsaErrno() : wsaHerrno());
1892 }
1893 return NULL;
1894 }
1895
1896 SEGPTR WINAPI WINSOCK_gethostbyaddr16(const char *addr, INT16 len, INT16 type)
1897 {
1898 struct WIN_hostent* retval;
1899 TRACE("ptr %08x, len %d, type %d\n",
1900 (unsigned) addr, len, type);
1901 retval = __ws_gethostbyaddr( addr, len, type, WS_DUP_SEGPTR );
1902 return retval ? SEGPTR_GET(retval) : ((SEGPTR)NULL);
1903 }
1904
1905 struct WIN_hostent* WINAPI WSOCK32_gethostbyaddr(const char *addr, INT len,
1906 INT type)
1907 {
1908 TRACE("ptr %08x, len %d, type %d\n",
1909 (unsigned) addr, len, type);
1910 return __ws_gethostbyaddr(addr, len, type, WS_DUP_LINEAR);
1911 }
1912
1913 /***********************************************************************
1914 * gethostbyname() (WINSOCK.52)(WSOCK32.52)
1915 */
1916 static struct WIN_hostent * __ws_gethostbyname(const char *name, int dup_flag)
1917 {
1918 LPWSINFO pwsi = WINSOCK_GetIData();
1919
1920 if( pwsi )
1921 {
1922 struct hostent* host;
1923 if( (host = gethostbyname(name)) != NULL )
1924 if( WS_dup_he(pwsi, host, dup_flag) )
1925 return (struct WIN_hostent*)(pwsi->he);
1926 else SetLastError(WSAENOBUFS);
1927 else SetLastError((h_errno < 0) ? wsaErrno() : wsaHerrno());
1928 }
1929 return NULL;
1930 }
1931
1932 SEGPTR WINAPI WINSOCK_gethostbyname16(const char *name)
1933 {
1934 struct WIN_hostent* retval;
1935 TRACE("%s\n", (name)?name:NULL_STRING);
1936 retval = __ws_gethostbyname( name, WS_DUP_SEGPTR );
1937 return (retval)? SEGPTR_GET(retval) : ((SEGPTR)NULL) ;
1938 }
1939
1940 struct WIN_hostent* WINAPI WSOCK32_gethostbyname(const char* name)
1941 {
1942 TRACE("%s\n", (name)?name:NULL_STRING);
1943 return __ws_gethostbyname( name, WS_DUP_LINEAR );
1944 }
1945
1946
1947 /***********************************************************************
1948 * getprotobyname() (WINSOCK.53)(WSOCK32.53)
1949 */
1950 static struct WIN_protoent* __ws_getprotobyname(const char *name, int dup_flag)
1951 {
1952 LPWSINFO pwsi = WINSOCK_GetIData();
1953
1954 if( pwsi )
1955 {
1956 struct protoent* proto;
1957 if( (proto = getprotobyname(name)) != NULL )
1958 if( WS_dup_pe(pwsi, proto, dup_flag) )
1959 return (struct WIN_protoent*)(pwsi->pe);
1960 else SetLastError(WSAENOBUFS);
1961 else SetLastError((h_errno < 0) ? wsaErrno() : wsaHerrno());
1962 }
1963 return NULL;
1964 }
1965
1966 SEGPTR WINAPI WINSOCK_getprotobyname16(const char *name)
1967 {
1968 struct WIN_protoent* retval;
1969 TRACE("%s\n", (name)?name:NULL_STRING);
1970 retval = __ws_getprotobyname(name, WS_DUP_SEGPTR);
1971 return retval ? SEGPTR_GET(retval) : ((SEGPTR)NULL);
1972 }
1973
1974 struct WIN_protoent* WINAPI WSOCK32_getprotobyname(const char* name)
1975 {
1976 TRACE("%s\n", (name)?name:NULL_STRING);
1977 return __ws_getprotobyname(name, WS_DUP_LINEAR);
1978 }
1979
1980
1981 /***********************************************************************
1982 * getprotobynumber() (WINSOCK.54)(WSOCK32.54)
1983 */
1984 static struct WIN_protoent* __ws_getprotobynumber(int number, int dup_flag)
1985 {
1986 LPWSINFO pwsi = WINSOCK_GetIData();
1987
1988 if( pwsi )
1989 {
1990 struct protoent* proto;
1991 if( (proto = getprotobynumber(number)) != NULL )
1992 if( WS_dup_pe(pwsi, proto, dup_flag) )
1993 return (struct WIN_protoent*)(pwsi->pe);
1994 else SetLastError(WSAENOBUFS);
1995 else SetLastError(WSANO_DATA);
1996 }
1997 return NULL;
1998 }
1999
2000 SEGPTR WINAPI WINSOCK_getprotobynumber16(INT16 number)
2001 {
2002 struct WIN_protoent* retval;
2003 TRACE("%i\n", number);
2004 retval = __ws_getprotobynumber(number, WS_DUP_SEGPTR);
2005 return retval ? SEGPTR_GET(retval) : ((SEGPTR)NULL);
2006 }
2007
2008 struct WIN_protoent* WINAPI WSOCK32_getprotobynumber(INT number)
2009 {
2010 TRACE("%i\n", number);
2011 return __ws_getprotobynumber(number, WS_DUP_LINEAR);
2012 }
2013
2014
2015 /***********************************************************************
2016 * getservbyname() (WINSOCK.55)(WSOCK32.55)
2017 */
2018 struct WIN_servent* __ws_getservbyname(const char *name, const char *proto, int dup_flag)
2019 {
2020 LPWSINFO pwsi = WINSOCK_GetIData();
2021
2022 if( pwsi )
2023 {
2024 struct servent* serv;
2025 int i = wsi_strtolo( pwsi, name, proto );
2026
2027 if( i ) {
2028 serv = getservbyname(pwsi->buffer,
2029 proto ? (pwsi->buffer + i) : NULL);
2030 if( serv != NULL )
2031 if( WS_dup_se(pwsi, serv, dup_flag) )
2032 return (struct WIN_servent*)(pwsi->se);
2033 else SetLastError(WSAENOBUFS);
2034 else {
2035 MESSAGE("service %s protocol %s not found; maybe you have add "
2036 "this to /etc/services\n", debugstr_a(pwsi->buffer),
2037 proto ? debugstr_a(pwsi->buffer+i):"*");
2038 SetLastError(WSANO_DATA);
2039 }
2040 }
2041 else SetLastError(WSAENOBUFS);
2042 } else SetLastError(WSANOTINITIALISED);
2043 return NULL;
2044 }
2045
2046 SEGPTR WINAPI WINSOCK_getservbyname16(const char *name, const char *proto)
2047 {
2048 struct WIN_servent* retval;
2049 TRACE("'%s', '%s'\n",
2050 (name)?name:NULL_STRING, (proto)?proto:NULL_STRING);
2051 retval = __ws_getservbyname(name, proto, WS_DUP_SEGPTR);
2052 return retval ? SEGPTR_GET(retval) : ((SEGPTR)NULL);
2053 }
2054
2055 struct WIN_servent* WINAPI WSOCK32_getservbyname(const char *name, const char *proto)
2056 {
2057 TRACE("'%s', '%s'\n",
2058 (name)?name:NULL_STRING, (proto)?proto:NULL_STRING);
2059 return __ws_getservbyname(name, proto, WS_DUP_LINEAR);
2060 }
2061
2062
2063 /***********************************************************************
2064 * getservbyport() (WINSOCK.56)(WSOCK32.56)
2065 */
2066 static struct WIN_servent* __ws_getservbyport(int port, const char* proto, int dup_flag)
2067 {
2068 LPWSINFO pwsi = WINSOCK_GetIData();
2069
2070 if( pwsi )
2071 {
2072 struct servent* serv;
2073 if (!proto || wsi_strtolo( pwsi, proto, NULL )) {
2074 if( (serv = getservbyport(port, (proto) ? pwsi->buffer : NULL)) != NULL ) {
2075 if( WS_dup_se(pwsi, serv, dup_flag) )
2076 return (struct WIN_servent*)(pwsi->se);
2077 else SetLastError(WSAENOBUFS);
2078 }
2079 else {
2080 MESSAGE("service on port %d protocol %s not found; maybe you have "
2081 "add this to /etc/services\n", ntohl(port),
2082 proto ? debugstr_a(pwsi->buffer) : "*");
2083 SetLastError(WSANO_DATA);
2084 }
2085 }
2086 else SetLastError(WSAENOBUFS);
2087 } else SetLastError(WSANOTINITIALISED);
2088 return NULL;
2089 }
2090
2091 SEGPTR WINAPI WINSOCK_getservbyport16(INT16 port, const char *proto)
2092 {
2093 struct WIN_servent* retval;
2094 TRACE("%i, '%s'\n",
2095 (int)port, (proto)?proto:NULL_STRING);
2096 retval = __ws_getservbyport(port, proto, WS_DUP_SEGPTR);
2097 return retval ? SEGPTR_GET(retval) : ((SEGPTR)NULL);
2098 }
2099
2100 struct WIN_servent* WINAPI WSOCK32_getservbyport(INT port, const char *proto)
2101 {
2102 TRACE("%i, '%s'\n",
2103 (int)port, (proto)?proto:NULL_STRING);
2104 return __ws_getservbyport(port, proto, WS_DUP_LINEAR);
2105 }
2106
2107
2108 /***********************************************************************
2109 * gethostname() (WSOCK32.57)
2110 */
2111 INT WINAPI WSOCK32_gethostname(char *name, INT namelen)
2112 {
2113 LPWSINFO pwsi = WINSOCK_GetIData();
2114
2115 TRACE("(%08x): name %s, len %d\n",
2116 (unsigned)pwsi, (name)?name:NULL_STRING, namelen);
2117 if( pwsi )
2118 {
2119 if (gethostname(name, namelen) == 0) return 0;
2120 SetLastError((errno == EINVAL) ? WSAEFAULT : wsaErrno());
2121 }
2122 return SOCKET_ERROR;
2123 }
2124
2125 /***********************************************************************
2126 * gethostname() (WINSOCK.57)
2127 */
2128 INT16 WINAPI WINSOCK_gethostname16(char *name, INT16 namelen)
2129 {
2130 return (INT16)WSOCK32_gethostname(name, namelen);
2131 }
2132
2133
2134 /* ------------------------------------- Windows sockets extensions -- *
2135 * *
2136 * ------------------------------------------------------------------- */
2137
2138 int WINAPI WSAEnumNetworkEvents(SOCKET s, WSAEVENT hEvent, LPWSANETWORKEVENTS lpEvent)
2139 {
2140 LPWSINFO pwsi = WINSOCK_GetIData();
2141 struct get_socket_event_request *req = get_req_buffer();
2142
2143 TRACE("(%08x): %08x, hEvent %08x, lpEvent %08x\n",
2144 (unsigned)pwsi, s, hEvent, (unsigned)lpEvent );
2145 if( _check_ws(pwsi, s) )
2146 {
2147 req->handle = s;
2148 req->service = TRUE;
2149 req->s_event = 0;
2150 req->c_event = hEvent;
2151 sock_server_call( REQ_GET_SOCKET_EVENT );
2152 lpEvent->lNetworkEvents = req->pmask;
2153 memcpy(lpEvent->iErrorCode, req->errors, sizeof(lpEvent->iErrorCode));
2154 return 0;
2155 }
2156 else SetLastError(WSAEINVAL);
2157 return SOCKET_ERROR;
2158 }
2159
2160 int WINAPI WSAEventSelect(SOCKET s, WSAEVENT hEvent, LONG lEvent)
2161 {
2162 LPWSINFO pwsi = WINSOCK_GetIData();
2163 struct set_socket_event_request *req = get_req_buffer();
2164
2165 TRACE("(%08x): %08x, hEvent %08x, event %08x\n",
2166 (unsigned)pwsi, s, hEvent, (unsigned)lEvent );
2167 if( _check_ws(pwsi, s) )
2168 {
2169 req->handle = s;
2170 req->mask = lEvent;
2171 req->event = hEvent;
2172 sock_server_call( REQ_SET_SOCKET_EVENT );
2173 return 0;
2174 }
2175 else SetLastError(WSAEINVAL);
2176 return SOCKET_ERROR;
2177 }
2178
2179 /***********************************************************************
2180 * WSAAsyncSelect() (WINSOCK.101)(WSOCK32.101)
2181 */
2182
2183 VOID CALLBACK WINSOCK_DoAsyncEvent( ULONG_PTR ptr )
2184 {
2185 ws_select_info *info = (ws_select_info*)ptr;
2186 LPWSINFO pwsi = info->pwsi;
2187 struct get_socket_event_request *req = get_req_buffer();
2188 unsigned int i, pmask, orphan = FALSE;
2189
2190 TRACE("socket %08x, event %08x\n", info->sock, info->event);
2191 SetLastError(0);
2192 req->handle = info->sock;
2193 req->service = TRUE;
2194 req->s_event = info->event; /* <== avoid race conditions */
2195 req->c_event = info->event;
2196 sock_server_call( REQ_GET_SOCKET_EVENT );
2197 if ( (GetLastError() == WSAENOTSOCK) || (GetLastError() == WSAEINVAL) )
2198 {
2199 /* orphaned event (socket closed or something) */
2200 pmask = WS_FD_SERVEVENT;
2201 orphan = TRUE;
2202 } else
2203 pmask = req->pmask;
2204 /* check for accepted sockets that needs to inherit WSAAsyncSelect */
2205 if (pmask & WS_FD_SERVEVENT) {
2206 int q;
2207 for (q=0; q<WS_ACCEPT_QUEUE; q++)
2208 if (pwsi->accept_old[q] == info->sock) {
2209 /* there's only one service thread per pwsi, no lock necessary */
2210 HANDLE as = pwsi->accept_new[q];
2211 if (as) {
2212 pwsi->accept_new[q] = 0;
2213 pwsi->accept_old[q] = 0;
2214 WSAAsyncSelect(as, info->hWnd, info->uMsg, info->lEvent);
2215 }
2216 }
2217 pmask &= ~WS_FD_SERVEVENT;
2218 }
2219 /* dispatch network events */
2220 for (i=0; i<FD_MAX_EVENTS; i++)
2221 if (pmask & (1<<i)) {
2222 TRACE("post: event bit %d, error %d\n", i, req->errors[i]);
2223 PostMessageA(info->hWnd, info->uMsg, info->sock,
2224 WSAMAKESELECTREPLY(1<<i, req->errors[i]));
2225 }
2226 /* cleanup */
2227 if (orphan)
2228 {
2229 TRACE("orphaned event, self-destructing\n");
2230 /* SERVICE_Delete closes the event object */
2231 SERVICE_Delete( info->service );
2232 WS_FREE(info);
2233 }
2234 }
2235
2236 INT WINAPI WSAAsyncSelect(SOCKET s, HWND hWnd, UINT uMsg, LONG lEvent)
2237 {
2238 LPWSINFO pwsi = WINSOCK_GetIData();
2239
2240 TRACE("(%08x): %04x, hWnd %04x, uMsg %08x, event %08x\n",
2241 (unsigned)pwsi, (SOCKET16)s, (HWND16)hWnd, uMsg, (unsigned)lEvent );
2242 if( _check_ws(pwsi, s) )
2243 {
2244 if( lEvent )
2245 {
2246 ws_select_info *info = (ws_select_info*)WS_ALLOC(sizeof(ws_select_info));
2247 if( info )
2248 {
2249 HANDLE hObj = CreateEventA( NULL, TRUE, FALSE, NULL );
2250 INT err;
2251
2252 info->sock = s;
2253 info->event = hObj;
2254 info->hWnd = hWnd;
2255 info->uMsg = uMsg;
2256 info->lEvent = lEvent;
2257 info->pwsi = pwsi;
2258 info->service = SERVICE_AddObject( hObj, WINSOCK_DoAsyncEvent, (ULONG_PTR)info );
2259
2260 err = WSAEventSelect( s, hObj, lEvent | WS_FD_SERVEVENT );
2261 if (err) {
2262 /* SERVICE_Delete closes the event object */
2263 SERVICE_Delete( info->service );
2264 WS_FREE(info);
2265 return err;
2266 }
2267
2268 return 0; /* success */
2269 }
2270 else SetLastError(WSAENOBUFS);
2271 }
2272 else
2273 {
2274 WSAEventSelect(s, 0, 0);
2275 return 0;
2276 }
2277 }
2278 else SetLastError(WSAEINVAL);
2279 return SOCKET_ERROR;
2280 }
2281
2282 INT16 WINAPI WSAAsyncSelect16(SOCKET16 s, HWND16 hWnd, UINT16 wMsg, LONG lEvent)
2283 {
2284 return (INT16)WSAAsyncSelect( s, hWnd, wMsg, lEvent );
2285 }
2286
2287 /***********************************************************************
2288 * WSARecvEx() (WSOCK32.1107)
2289 *
2290 * WSARecvEx is a Microsoft specific extension to winsock that is identical to recv
2291 * except that has an in/out argument call flags that has the value MSG_PARTIAL ored
2292 * into the flags parameter when a partial packet is read. This only applies to
2293 * sockets using the datagram protocol. This method does not seem to be implemented
2294 * correctly by microsoft as the winsock implementation does not set the MSG_PARTIAL
2295 * flag when a fragmented packet arrives.
2296 */
2297 INT WINAPI WSARecvEx(SOCKET s, char *buf, INT len, INT *flags) {
2298 FIXME("(WSARecvEx) partial packet return value not set \n");
2299
2300 return WSOCK32_recv(s, buf, len, *flags);
2301 }
2302
2303
2304 /***********************************************************************
2305 * WSARecvEx16() (WINSOCK.1107)
2306 *
2307 * See description for WSARecvEx()
2308 */
2309 INT16 WINAPI WSARecvEx16(SOCKET16 s, char *buf, INT16 len, INT16 *flags) {
2310 FIXME("(WSARecvEx16) partial packet return value not set \n");
2311
2312 return WINSOCK_recv16(s, buf, len, *flags);
2313 }
2314
2315
2316 /***********************************************************************
2317 * __WSAFDIsSet() (WINSOCK.151)
2318 */
2319 INT16 WINAPI __WSAFDIsSet16(SOCKET16 s, ws_fd_set16 *set)
2320 {
2321 int i = set->fd_count;
2322
2323 TRACE("(%d,%8lx(%i))\n", s,(unsigned long)set, i);
2324
2325 while (i--)
2326 if (set->fd_array[i] == s) return 1;
2327 return 0;
2328 }
2329
2330 /***********************************************************************
2331 * __WSAFDIsSet() (WSOCK32.151)
2332 */
2333 INT WINAPI __WSAFDIsSet(SOCKET s, ws_fd_set32 *set)
2334 {
2335 int i = set->fd_count;
2336
2337 TRACE("(%d,%8lx(%i))\n", s,(unsigned long)set, i);
2338
2339 while (i--)
2340 if (set->fd_array[i] == s) return 1;
2341 return 0;
2342 }
2343
2344 /***********************************************************************
2345 * WSAIsBlocking() (WINSOCK.114)(WSOCK32.114)
2346 */
2347 BOOL WINAPI WSAIsBlocking(void)
2348 {
2349 /* By default WinSock should set all its sockets to non-blocking mode
2350 * and poll in PeekMessage loop when processing "blocking" ones. This
2351 * function is supposed to tell if the program is in this loop. Our
2352 * blocking calls are truly blocking so we always return FALSE.
2353 *
2354 * Note: It is allowed to call this function without prior WSAStartup().
2355 */
2356
2357 TRACE("\n");
2358 return FALSE;
2359 }
2360
2361 /***********************************************************************
2362 * WSACancelBlockingCall() (WINSOCK.113)(WSOCK32.113)
2363 */
2364 INT WINAPI WSACancelBlockingCall(void)
2365 {
2366 LPWSINFO pwsi = WINSOCK_GetIData();
2367
2368 TRACE("(%08x)\n", (unsigned)pwsi);
2369
2370 if( pwsi ) return 0;
2371 return SOCKET_ERROR;
2372 }
2373
2374
2375 /***********************************************************************
2376 * WSASetBlockingHook16() (WINSOCK.109)
2377 */
2378 FARPROC16 WINAPI WSASetBlockingHook16(FARPROC16 lpBlockFunc)
2379 {
2380 FARPROC16 prev;
2381 LPWSINFO pwsi = WINSOCK_GetIData();
2382
2383 TRACE("(%08x): hook %08x\n",
2384 (unsigned)pwsi, (unsigned) lpBlockFunc);
2385 if( pwsi )
2386 {
2387 prev = (FARPROC16)pwsi->blocking_hook;
2388 pwsi->blocking_hook = (DWORD)lpBlockFunc;
2389 pwsi->flags &= ~WSI_BLOCKINGHOOK;
2390 return prev;
2391 }
2392 return 0;
2393 }
2394
2395
2396 /***********************************************************************
2397 * WSASetBlockingHook32()
2398 */
2399 FARPROC WINAPI WSASetBlockingHook(FARPROC lpBlockFunc)
2400 {
2401 FARPROC prev;
2402 LPWSINFO pwsi = WINSOCK_GetIData();
2403
2404 TRACE("(%08x): hook %08x\n",
2405 (unsigned)pwsi, (unsigned) lpBlockFunc);
2406 if( pwsi ) {
2407 prev = (FARPROC)pwsi->blocking_hook;
2408 pwsi->blocking_hook = (DWORD)lpBlockFunc;
2409 pwsi->flags |= WSI_BLOCKINGHOOK;
2410 return prev;
2411 }
2412 return NULL;
2413 }
2414
2415
2416 /***********************************************************************
2417 * WSAUnhookBlockingHook16() (WINSOCK.110)
2418 */
2419 INT16 WINAPI WSAUnhookBlockingHook16(void)
2420 {
2421 LPWSINFO pwsi = WINSOCK_GetIData();
2422
2423 TRACE("(%08x)\n", (unsigned)pwsi);
2424 if( pwsi ) return (INT16)(pwsi->blocking_hook = 0);
2425 return SOCKET_ERROR;
2426 }
2427
2428
2429 /***********************************************************************
2430 * WSAUnhookBlockingHook32()
2431 */
2432 INT WINAPI WSAUnhookBlockingHook(void)
2433 {
2434 LPWSINFO pwsi = WINSOCK_GetIData();
2435
2436 TRACE("(%08x)\n", (unsigned)pwsi);
2437 if( pwsi )
2438 {
2439 pwsi->blocking_hook = 0;
2440 pwsi->flags &= ~WSI_BLOCKINGHOOK;
2441 return 0;
2442 }
2443 return SOCKET_ERROR;
2444 }
2445
2446 /*
2447 * TCP/IP action codes.
2448 */
2449
2450
2451 #define WSCNTL_TCPIP_QUERY_INFO 0x00000000
2452 #define WSCNTL_TCPIP_SET_INFO 0x00000001
2453 #define WSCNTL_TCPIP_ICMP_ECHO 0x00000002
2454 #define WSCNTL_TCPIP_TEST 0x00000003
2455
2456
2457 /***********************************************************************
2458 * WsControl()
2459 *
2460 * WsControl seems to be an undocumented Win95 function. A lot of
2461 * discussion about WsControl can be found on the net, e.g.
2462 * Subject: Re: WSOCK32.DLL WsControl Exported Function
2463 * From: "Peter Rindfuss" <rindfuss-s@medea.wz-berlin.de>
2464 * Date: 1997/08/17
2465 */
2466
2467 DWORD WINAPI WsControl(DWORD protocoll,DWORD action,
2468 LPVOID inbuf,LPDWORD inbuflen,
2469 LPVOID outbuf,LPDWORD outbuflen)
2470 {
2471
2472 switch (action) {
2473 case WSCNTL_TCPIP_ICMP_ECHO:
2474 {
2475 unsigned int addr = *(unsigned int*)inbuf;
2476 #if 0
2477 int timeout= *(unsigned int*)(inbuf+4);
2478 short x1 = *(unsigned short*)(inbuf+8);
2479 short sendbufsize = *(unsigned short*)(inbuf+10);
2480 char x2 = *(unsigned char*)(inbuf+12);
2481 char ttl = *(unsigned char*)(inbuf+13);
2482 char service = *(unsigned char*)(inbuf+14);
2483 char type= *(unsigned char*)(inbuf+15); /* 0x2: don't fragment*/
2484 #endif
2485
2486 FIXME("(ICMP_ECHO) to 0x%08x stub \n", addr);
2487 break;
2488 }
2489 default:
2490 FIXME("(%lx,%lx,%p,%p,%p,%p) stub\n",
2491 protocoll,action,inbuf,inbuflen,outbuf,outbuflen);
2492 }
2493 return FALSE;
2494 }
2495 /*********************************************************
2496 * WS_s_perror WSOCK32.1108
2497 */
2498 void WINAPI WS_s_perror(LPCSTR message)
2499 {
2500 FIXME("(%s): stub\n",message);
2501 return;
2502 }
2503
2504
2505 /* ----------------------------------- end of API stuff */
2506
2507 /* ----------------------------------- helper functions -
2508 *
2509 * TODO: Merge WS_dup_..() stuff into one function that
2510 * would operate with a generic structure containing internal
2511 * pointers (via a template of some kind).
2512 */
2513
2514 static int list_size(char** l, int item_size)
2515 {
2516 int i,j = 0;
2517 if(l)
2518 { for(i=0;l[i];i++)
2519 j += (item_size) ? item_size : strlen(l[i]) + 1;
2520 j += (i + 1) * sizeof(char*); }
2521 return j;
2522 }
2523
2524 static int list_dup(char** l_src, char* ref, char* base, int item_size)
2525 {
2526 /* base is either either equal to ref or 0 or SEGPTR */
2527
2528 char* p = ref;
2529 char** l_to = (char**)ref;
2530 int i,j,k;
2531
2532 for(j=0;l_src[j];j++) ;
2533 p += (j + 1) * sizeof(char*);
2534 for(i=0;i<j;i++)
2535 { l_to[i] = base + (p - ref);
2536 k = ( item_size ) ? item_size : strlen(l_src[i]) + 1;
2537 memcpy(p, l_src[i], k); p += k; }
2538 l_to[i] = NULL;
2539 return (p - ref);
2540 }
2541
2542 /* ----- hostent */
2543
2544 static int hostent_size(struct hostent* p_he)
2545 {
2546 int size = 0;
2547 if( p_he )
2548 { size = sizeof(struct hostent);
2549 size += strlen(p_he->h_name) + 1;
2550 size += list_size(p_he->h_aliases, 0);
2551 size += list_size(p_he->h_addr_list, p_he->h_length ); }
2552 return size;
2553 }
2554
2555 int WS_dup_he(LPWSINFO pwsi, struct hostent* p_he, int flag)
2556 {
2557 /* Convert hostent structure into ws_hostent so that the data fits
2558 * into pwsi->buffer. Internal pointers can be linear, SEGPTR, or
2559 * relative to pwsi->buffer depending on "flag" value. Returns size
2560 * of the data copied (also in the pwsi->buflen).
2561 */
2562
2563 int size = hostent_size(p_he);
2564
2565 if( size )
2566 {
2567 struct ws_hostent* p_to;
2568 char* p_name,*p_aliases,*p_addr,*p_base,*p;
2569
2570 _check_buffer_he(pwsi, size);
2571 p_to = (struct ws_hostent*)pwsi->he;
2572 p = (char*)pwsi->he;
2573 p_base = (flag & WS_DUP_OFFSET) ? NULL
2574 : ((flag & WS_DUP_SEGPTR) ? (char*)SEGPTR_GET(p) : p);
2575 p += sizeof(struct ws_hostent);
2576 p_name = p;
2577 strcpy(p, p_he->h_name); p += strlen(p) + 1;
2578 p_aliases = p;
2579 p += list_dup(p_he->h_aliases, p, p_base + (p - (char*)pwsi->he), 0);
2580 p_addr = p;
2581 list_dup(p_he->h_addr_list, p, p_base + (p - (char*)pwsi->he), p_he->h_length);
2582
2583 p_to->h_addrtype = (INT16)p_he->h_addrtype;
2584 p_to->h_length = (INT16)p_he->h_length;
2585 p_to->h_name = (SEGPTR)(p_base + (p_name - (char*)pwsi->he));
2586 p_to->h_aliases = (SEGPTR)(p_base + (p_aliases - (char*)pwsi->he));
2587 p_to->h_addr_list = (SEGPTR)(p_base + (p_addr - (char*)pwsi->he));
2588
2589 size += (sizeof(struct ws_hostent) - sizeof(struct hostent));
2590 }
2591 return size;
2592 }
2593
2594 /* ----- protoent */
2595
2596 static int protoent_size(struct protoent* p_pe)
2597 {
2598 int size = 0;
2599 if( p_pe )
2600 { size = sizeof(struct protoent);
2601 size += strlen(p_pe->p_name) + 1;
2602 size += list_size(p_pe->p_aliases, 0); }
2603 return size;
2604 }
2605
2606 int WS_dup_pe(LPWSINFO pwsi, struct protoent* p_pe, int flag)
2607 {
2608 int size = protoent_size(p_pe);
2609 if( size )
2610 {
2611 struct ws_protoent* p_to;
2612 char* p_name,*p_aliases,*p_base,*p;
2613
2614 _check_buffer_pe(pwsi, size);
2615 p_to = (struct ws_protoent*)pwsi->pe;
2616 p = (char*)pwsi->pe;
2617 p_base = (flag & WS_DUP_OFFSET) ? NULL
2618 : ((flag & WS_DUP_SEGPTR) ? (char*)SEGPTR_GET(p) : p);
2619 p += sizeof(struct ws_protoent);
2620 p_name = p;
2621 strcpy(p, p_pe->p_name); p += strlen(p) + 1;
2622 p_aliases = p;
2623 list_dup(p_pe->p_aliases, p, p_base + (p - (char*)pwsi->pe), 0);
2624
2625 p_to->p_proto = (INT16)p_pe->p_proto;
2626 p_to->p_name = (SEGPTR)(p_base) + (p_name - (char*)pwsi->pe);
2627 p_to->p_aliases = (SEGPTR)((p_base) + (p_aliases - (char*)pwsi->pe));
2628
2629 size += (sizeof(struct ws_protoent) - sizeof(struct protoent));
2630 }
2631 return size;
2632 }
2633
2634 /* ----- servent */
2635
2636 static int servent_size(struct servent* p_se)
2637 {
2638 int size = 0;
2639 if( p_se )
2640 { size += sizeof(struct servent);
2641 size += strlen(p_se->s_proto) + strlen(p_se->s_name) + 2;
2642 size += list_size(p_se->s_aliases, 0); }
2643 return size;
2644 }
2645
2646 int WS_dup_se(LPWSINFO pwsi, struct servent* p_se, int flag)
2647 {
2648 int size = servent_size(p_se);
2649 if( size )
2650 {
2651 struct ws_servent* p_to;
2652 char* p_name,*p_aliases,*p_proto,*p_base,*p;
2653
2654 _check_buffer_se(pwsi, size);
2655 p_to = (struct ws_servent*)pwsi->se;
2656 p = (char*)pwsi->se;
2657 p_base = (flag & WS_DUP_OFFSET) ? NULL
2658 : ((flag & WS_DUP_SEGPTR) ? (char*)SEGPTR_GET(p) : p);
2659 p += sizeof(struct ws_servent);
2660 p_name = p;
2661 strcpy(p, p_se->s_name); p += strlen(p) + 1;
2662 p_proto = p;
2663 strcpy(p, p_se->s_proto); p += strlen(p) + 1;
2664 p_aliases = p;
2665 list_dup(p_se->s_aliases, p, p_base + (p - (char*)pwsi->se), 0);
2666
2667 p_to->s_port = (INT16)p_se->s_port;
2668 p_to->s_name = (SEGPTR)(p_base + (p_name - (char*)pwsi->se));
2669 p_to->s_proto = (SEGPTR)(p_base + (p_proto - (char*)pwsi->se));
2670 p_to->s_aliases = (SEGPTR)(p_base + (p_aliases - (char*)pwsi->se));
2671
2672 size += (sizeof(struct ws_servent) - sizeof(struct servent));
2673 }
2674 return size;
2675 }
2676
2677 /* ----------------------------------- error handling */
2678
2679 UINT16 wsaErrno(void)
2680 {
2681 int loc_errno = errno;
2682 #ifdef HAVE_STRERROR
2683 WARN("errno %d, (%s).\n", loc_errno, strerror(loc_errno));
2684 #else
2685 WARN("errno %d\n", loc_errno);
2686 #endif
2687
2688 switch(loc_errno)
2689 {
2690 case EINTR: return WSAEINTR;
2691 case EBADF: return WSAEBADF;
2692 case EPERM:
2693 case EACCES: return WSAEACCES;
2694 case EFAULT: return WSAEFAULT;
2695 case EINVAL: return WSAEINVAL;
2696 case EMFILE: return WSAEMFILE;
2697 case EWOULDBLOCK: return WSAEWOULDBLOCK;
2698 case EINPROGRESS: return WSAEINPROGRESS;
2699 case EALREADY: return WSAEALREADY;
2700 case ENOTSOCK: return WSAENOTSOCK;
2701 case EDESTADDRREQ: return WSAEDESTADDRREQ;
2702 case EMSGSIZE: return WSAEMSGSIZE;
2703 case EPROTOTYPE: return WSAEPROTOTYPE;
2704 case ENOPROTOOPT: return WSAENOPROTOOPT;
2705 case EPROTONOSUPPORT: return WSAEPROTONOSUPPORT;
2706 case ESOCKTNOSUPPORT: return WSAESOCKTNOSUPPORT;
2707 case EOPNOTSUPP: return WSAEOPNOTSUPP;
2708 case EPFNOSUPPORT: return WSAEPFNOSUPPORT;
2709 case EAFNOSUPPORT: return WSAEAFNOSUPPORT;
2710 case EADDRINUSE: return WSAEADDRINUSE;
2711 case EADDRNOTAVAIL: return WSAEADDRNOTAVAIL;
2712 case ENETDOWN: return WSAENETDOWN;
2713 case ENETUNREACH: return WSAENETUNREACH;
2714 case ENETRESET: return WSAENETRESET;
2715 case ECONNABORTED: return WSAECONNABORTED;
2716 case EPIPE:
2717 case ECONNRESET: return WSAECONNRESET;
2718 case ENOBUFS: return WSAENOBUFS;
2719 case EISCONN: return WSAEISCONN;
2720 case ENOTCONN: return WSAENOTCONN;
2721 case ESHUTDOWN: return WSAESHUTDOWN;
2722 case ETOOMANYREFS: return WSAETOOMANYREFS;
2723 case ETIMEDOUT: return WSAETIMEDOUT;
2724 case ECONNREFUSED: return WSAECONNREFUSED;
2725 case ELOOP: return WSAELOOP;
2726 case ENAMETOOLONG: return WSAENAMETOOLONG;
2727 case EHOSTDOWN: return WSAEHOSTDOWN;
2728 case EHOSTUNREACH: return WSAEHOSTUNREACH;
2729 case ENOTEMPTY: return WSAENOTEMPTY;
2730 #ifdef EPROCLIM
2731 case EPROCLIM: return WSAEPROCLIM;
2732 #endif
2733 #ifdef EUSERS
2734 case EUSERS: return WSAEUSERS;
2735 #endif
2736 #ifdef EDQUOT
2737 case EDQUOT: return WSAEDQUOT;
2738 #endif
2739 #ifdef ESTALE
2740 case ESTALE: return WSAESTALE;
2741 #endif
2742 #ifdef EREMOTE
2743 case EREMOTE: return WSAEREMOTE;
2744 #endif
2745
2746 /* just in case we ever get here and there are no problems */
2747 case 0: return 0;
2748 default:
2749 WARN("Unknown errno %d!\n", loc_errno);
2750 return WSAEOPNOTSUPP;
2751 }
2752 }
2753
2754 UINT16 wsaHerrno(void)
2755 {
2756 int loc_errno = h_errno;
2757
2758 WARN("h_errno %d.\n", loc_errno);
2759
2760 switch(loc_errno)
2761 {
2762 case HOST_NOT_FOUND: return WSAHOST_NOT_FOUND;
2763 case TRY_AGAIN: return WSATRY_AGAIN;
2764 case NO_RECOVERY: return WSANO_RECOVERY;
2765 case NO_DATA: return WSANO_DATA;
2766
2767 case 0: return 0;
2768 default:
2769 WARN("Unknown h_errno %d!\n", loc_errno);
2770 return WSAEOPNOTSUPP;
2771 }
2772 }
GSOC 2012 project to enhance the control panel