This is a live mirror of the Perl 5 development currently hosted at https://github.com/perl/perl5
more complete support for implicit thread/interpreter pointer,
[perl5.git] / win32 / win32sck.c
CommitLineData
326b05e3 1/* win32sck.c
68dc0745
PP
2 *
3 * (c) 1995 Microsoft Corporation. All rights reserved.
4 * Developed by hip communications inc., http://info.hip.com/info/
5 * Portions (c) 1993 Intergraph Corporation. All rights reserved.
6 *
7 * You may distribute under the terms of either the GNU General Public
8 * License or the Artistic License, as specified in the README file.
9 */
0a753a76 10
390b85e7 11#define WIN32IO_IS_STDIO
55d25626 12#define WIN32SCK_IS_STDSCK
0a753a76 13#define WIN32_LEAN_AND_MEAN
a835ef8a
NIS
14#ifdef __GNUC__
15#define Win32_Winsock
16#endif
390b85e7 17#include <windows.h>
0a753a76
PP
18#include "EXTERN.h"
19#include "perl.h"
c69f6586
GS
20
21#if defined(PERL_OBJECT)
22#define NO_XSLOCKS
23extern CPerlObj* pPerl;
24#include "XSUB.h"
25#endif
26
58a50f62 27#include "Win32iop.h"
0a753a76
PP
28#include <sys/socket.h>
29#include <fcntl.h>
30#include <sys/stat.h>
31#include <assert.h>
390b85e7 32#include <io.h>
0a753a76 33
68dc0745 34/* thanks to Beverly Brown (beverly@datacube.com) */
326b05e3 35#ifdef USE_SOCKETS_AS_HANDLES
58a50f62 36# define OPEN_SOCKET(x) win32_open_osfhandle(x,O_RDWR|O_BINARY)
326b05e3 37# define TO_SOCKET(x) _get_osfhandle(x)
0a753a76 38#else
0a753a76
PP
39# define OPEN_SOCKET(x) (x)
40# define TO_SOCKET(x) (x)
68dc0745 41#endif /* USE_SOCKETS_AS_HANDLES */
0a753a76 42
401ef382 43#ifdef USE_THREADS
326b05e3
GS
44#define StartSockets() \
45 STMT_START { \
46 if (!wsock_started) \
47 start_sockets(); \
401ef382 48 set_socktype(); \
326b05e3 49 } STMT_END
401ef382
SN
50#else
51#define StartSockets() \
52 STMT_START { \
53 if (!wsock_started) { \
54 start_sockets(); \
55 set_socktype(); \
56 } \
57 } STMT_END
58#endif
326b05e3
GS
59
60#define EndSockets() \
61 STMT_START { \
62 if (wsock_started) \
63 WSACleanup(); \
64 } STMT_END
65
66#define SOCKET_TEST(x, y) \
67 STMT_START { \
68 StartSockets(); \
69 if((x) == (y)) \
70 errno = WSAGetLastError(); \
71 } STMT_END
72
73#define SOCKET_TEST_ERROR(x) SOCKET_TEST(x, SOCKET_ERROR)
74
137443ea
PP
75static struct servent* win32_savecopyservent(struct servent*d,
76 struct servent*s,
77 const char *proto);
0a753a76 78
c53bd28a
NIS
79#ifdef USE_THREADS
80#ifdef USE_DECLSPEC_THREAD
0a753a76 81__declspec(thread) struct servent myservent;
401ef382 82__declspec(thread) int init_socktype;
c53bd28a
NIS
83#else
84#define myservent (thr->i.Wservent)
401ef382 85#define init_socktype (thr->i.Winit_socktype)
c53bd28a
NIS
86#endif
87#else
88static struct servent myservent;
89#endif
90
326b05e3 91static int wsock_started = 0;
68dc0745
PP
92
93void
326b05e3 94start_sockets(void)
68dc0745
PP
95{
96 unsigned short version;
97 WSADATA retdata;
98 int ret;
68dc0745 99
68dc0745
PP
100 /*
101 * initalize the winsock interface and insure that it is
102 * cleaned up at exit.
103 */
104 version = 0x101;
326b05e3
GS
105 if(ret = WSAStartup(version, &retdata))
106 croak("Unable to locate winsock library!\n");
68dc0745 107 if(retdata.wVersion != version)
326b05e3 108 croak("Could not find version 1.1 of winsock dll\n");
68dc0745
PP
109
110 /* atexit((void (*)(void)) EndSockets); */
401ef382
SN
111 wsock_started = 1;
112}
0a753a76 113
401ef382
SN
114void
115set_socktype(void)
116{
0a753a76 117#ifdef USE_SOCKETS_AS_HANDLES
401ef382
SN
118#ifdef USE_THREADS
119 dTHR;
120 if(!init_socktype) {
121#endif
122 int iSockOpt = SO_SYNCHRONOUS_NONALERT;
68dc0745
PP
123 /*
124 * Enable the use of sockets as filehandles
125 */
326b05e3 126 setsockopt(INVALID_SOCKET, SOL_SOCKET, SO_OPENTYPE,
68dc0745 127 (char *)&iSockOpt, sizeof(iSockOpt));
401ef382
SN
128#ifdef USE_THREADS
129 init_socktype = 1;
130 }
131#endif
68dc0745 132#endif /* USE_SOCKETS_AS_HANDLES */
0a753a76
PP
133}
134
135
136#ifndef USE_SOCKETS_AS_HANDLES
f3986ebb 137#undef fdopen
68dc0745 138FILE *
f3986ebb 139my_fdopen(int fd, char *mode)
0a753a76 140{
68dc0745
PP
141 FILE *fp;
142 char sockbuf[256];
143 int optlen = sizeof(sockbuf);
144 int retval;
0a753a76 145
326b05e3 146 if (!wsock_started)
fb73857a 147 return(fdopen(fd, mode));
0a753a76 148
326b05e3
GS
149 retval = getsockopt((SOCKET)fd, SOL_SOCKET, SO_TYPE, sockbuf, &optlen);
150 if(retval == SOCKET_ERROR && WSAGetLastError() == WSAENOTSOCK) {
fb73857a 151 return(fdopen(fd, mode));
68dc0745 152 }
0a753a76 153
68dc0745
PP
154 /*
155 * If we get here, then fd is actually a socket.
156 */
fc36a67e 157 Newz(1310, fp, 1, FILE);
68dc0745
PP
158 if(fp == NULL) {
159 errno = ENOMEM;
160 return NULL;
161 }
0a753a76 162
68dc0745
PP
163 fp->_file = fd;
164 if(*mode == 'r')
165 fp->_flag = _IOREAD;
166 else
167 fp->_flag = _IOWRT;
168
169 return fp;
0a753a76 170}
68dc0745 171#endif /* USE_SOCKETS_AS_HANDLES */
0a753a76
PP
172
173
68dc0745
PP
174u_long
175win32_htonl(u_long hostlong)
0a753a76 176{
326b05e3
GS
177 StartSockets();
178 return htonl(hostlong);
0a753a76
PP
179}
180
68dc0745
PP
181u_short
182win32_htons(u_short hostshort)
0a753a76 183{
326b05e3
GS
184 StartSockets();
185 return htons(hostshort);
0a753a76
PP
186}
187
68dc0745
PP
188u_long
189win32_ntohl(u_long netlong)
0a753a76 190{
326b05e3
GS
191 StartSockets();
192 return ntohl(netlong);
0a753a76
PP
193}
194
68dc0745
PP
195u_short
196win32_ntohs(u_short netshort)
0a753a76 197{
326b05e3
GS
198 StartSockets();
199 return ntohs(netshort);
0a753a76
PP
200}
201
202
0a753a76 203
68dc0745
PP
204SOCKET
205win32_accept(SOCKET s, struct sockaddr *addr, int *addrlen)
0a753a76 206{
68dc0745 207 SOCKET r;
0a753a76 208
326b05e3 209 SOCKET_TEST((r = accept(TO_SOCKET(s), addr, addrlen)), INVALID_SOCKET);
68dc0745 210 return OPEN_SOCKET(r);
0a753a76
PP
211}
212
68dc0745
PP
213int
214win32_bind(SOCKET s, const struct sockaddr *addr, int addrlen)
0a753a76 215{
68dc0745 216 int r;
0a753a76 217
326b05e3 218 SOCKET_TEST_ERROR(r = bind(TO_SOCKET(s), addr, addrlen));
68dc0745 219 return r;
0a753a76
PP
220}
221
68dc0745
PP
222int
223win32_connect(SOCKET s, const struct sockaddr *addr, int addrlen)
0a753a76 224{
68dc0745 225 int r;
0a753a76 226
326b05e3 227 SOCKET_TEST_ERROR(r = connect(TO_SOCKET(s), addr, addrlen));
68dc0745 228 return r;
0a753a76
PP
229}
230
231
68dc0745
PP
232int
233win32_getpeername(SOCKET s, struct sockaddr *addr, int *addrlen)
0a753a76 234{
68dc0745 235 int r;
0a753a76 236
326b05e3 237 SOCKET_TEST_ERROR(r = getpeername(TO_SOCKET(s), addr, addrlen));
68dc0745 238 return r;
0a753a76
PP
239}
240
68dc0745
PP
241int
242win32_getsockname(SOCKET s, struct sockaddr *addr, int *addrlen)
0a753a76 243{
68dc0745 244 int r;
0a753a76 245
326b05e3 246 SOCKET_TEST_ERROR(r = getsockname(TO_SOCKET(s), addr, addrlen));
68dc0745 247 return r;
0a753a76
PP
248}
249
68dc0745
PP
250int
251win32_getsockopt(SOCKET s, int level, int optname, char *optval, int *optlen)
0a753a76 252{
68dc0745 253 int r;
0a753a76 254
326b05e3 255 SOCKET_TEST_ERROR(r = getsockopt(TO_SOCKET(s), level, optname, optval, optlen));
68dc0745 256 return r;
0a753a76
PP
257}
258
2d7a9237 259int
68dc0745 260win32_ioctlsocket(SOCKET s, long cmd, u_long *argp)
0a753a76 261{
68dc0745 262 int r;
0a753a76 263
326b05e3 264 SOCKET_TEST_ERROR(r = ioctlsocket(TO_SOCKET(s), cmd, argp));
68dc0745 265 return r;
0a753a76
PP
266}
267
68dc0745
PP
268int
269win32_listen(SOCKET s, int backlog)
0a753a76 270{
68dc0745 271 int r;
0a753a76 272
326b05e3 273 SOCKET_TEST_ERROR(r = listen(TO_SOCKET(s), backlog));
68dc0745 274 return r;
0a753a76
PP
275}
276
68dc0745
PP
277int
278win32_recv(SOCKET s, char *buf, int len, int flags)
0a753a76 279{
68dc0745 280 int r;
0a753a76 281
326b05e3 282 SOCKET_TEST_ERROR(r = recv(TO_SOCKET(s), buf, len, flags));
68dc0745 283 return r;
0a753a76
PP
284}
285
68dc0745
PP
286int
287win32_recvfrom(SOCKET s, char *buf, int len, int flags, struct sockaddr *from, int *fromlen)
0a753a76 288{
68dc0745 289 int r;
e4449fe1 290 int frombufsize = *fromlen;
0a753a76 291
326b05e3 292 SOCKET_TEST_ERROR(r = recvfrom(TO_SOCKET(s), buf, len, flags, from, fromlen));
e4449fe1
GS
293 /* Winsock's recvfrom() only returns a valid 'from' when the socket
294 * is connectionless. Perl expects a valid 'from' for all types
295 * of sockets, so go the extra mile.
296 */
297 if (r != SOCKET_ERROR && frombufsize == *fromlen)
298 (void)win32_getpeername(s, from, fromlen);
68dc0745 299 return r;
0a753a76
PP
300}
301
68dc0745
PP
302/* select contributed by Vincent R. Slyngstad (vrs@ibeam.intel.com) */
303int
55d25626 304win32_select(int nfds, Perl_fd_set* rd, Perl_fd_set* wr, Perl_fd_set* ex, const struct timeval* timeout)
0a753a76 305{
55d25626
GS
306 int r;
307#ifdef USE_SOCKETS_AS_HANDLES
308 Perl_fd_set dummy;
68dc0745 309 int i, fd, bit, offset;
55d25626 310 FD_SET nrd, nwr, nex, *prd, *pwr, *pex;
0a753a76 311
7e3be867
GS
312 /* winsock seems incapable of dealing with all three null fd_sets,
313 * so do the (millisecond) sleep as a special case
314 */
315 if (!(rd || wr || ex)) {
87c2f9c4
BZ
316 if (timeout)
317 Sleep(timeout->tv_sec * 1000 +
318 timeout->tv_usec / 1000); /* do the best we can */
319 else
320 Sleep(UINT_MAX);
7e3be867
GS
321 return 0;
322 }
f2bb5751 323 StartSockets();
55d25626 324 PERL_FD_ZERO(&dummy);
68dc0745
PP
325 if (!rd)
326 rd = &dummy, prd = NULL;
327 else
328 prd = &nrd;
329 if (!wr)
330 wr = &dummy, pwr = NULL;
331 else
332 pwr = &nwr;
333 if (!ex)
334 ex = &dummy, pex = NULL;
335 else
336 pex = &nex;
0a753a76 337
68dc0745
PP
338 FD_ZERO(&nrd);
339 FD_ZERO(&nwr);
340 FD_ZERO(&nex);
341 for (i = 0; i < nfds; i++) {
342 fd = TO_SOCKET(i);
55d25626 343 if (PERL_FD_ISSET(i,rd))
68dc0745 344 FD_SET(fd, &nrd);
55d25626 345 if (PERL_FD_ISSET(i,wr))
68dc0745 346 FD_SET(fd, &nwr);
55d25626 347 if (PERL_FD_ISSET(i,ex))
68dc0745
PP
348 FD_SET(fd, &nex);
349 }
350
326b05e3 351 SOCKET_TEST_ERROR(r = select(nfds, prd, pwr, pex, timeout));
0a753a76 352
68dc0745
PP
353 for (i = 0; i < nfds; i++) {
354 fd = TO_SOCKET(i);
55d25626
GS
355 if (PERL_FD_ISSET(i,rd) && !FD_ISSET(fd, &nrd))
356 PERL_FD_CLR(i,rd);
357 if (PERL_FD_ISSET(i,wr) && !FD_ISSET(fd, &nwr))
358 PERL_FD_CLR(i,wr);
359 if (PERL_FD_ISSET(i,ex) && !FD_ISSET(fd, &nex))
360 PERL_FD_CLR(i,ex);
68dc0745 361 }
55d25626
GS
362#else
363 SOCKET_TEST_ERROR(r = select(nfds, rd, wr, ex, timeout));
364#endif
68dc0745 365 return r;
0a753a76
PP
366}
367
68dc0745
PP
368int
369win32_send(SOCKET s, const char *buf, int len, int flags)
0a753a76 370{
68dc0745 371 int r;
0a753a76 372
326b05e3 373 SOCKET_TEST_ERROR(r = send(TO_SOCKET(s), buf, len, flags));
68dc0745 374 return r;
0a753a76
PP
375}
376
68dc0745
PP
377int
378win32_sendto(SOCKET s, const char *buf, int len, int flags,
379 const struct sockaddr *to, int tolen)
0a753a76 380{
68dc0745 381 int r;
0a753a76 382
326b05e3 383 SOCKET_TEST_ERROR(r = sendto(TO_SOCKET(s), buf, len, flags, to, tolen));
68dc0745 384 return r;
0a753a76
PP
385}
386
68dc0745
PP
387int
388win32_setsockopt(SOCKET s, int level, int optname, const char *optval, int optlen)
0a753a76 389{
68dc0745 390 int r;
0a753a76 391
326b05e3 392 SOCKET_TEST_ERROR(r = setsockopt(TO_SOCKET(s), level, optname, optval, optlen));
68dc0745 393 return r;
0a753a76
PP
394}
395
68dc0745
PP
396int
397win32_shutdown(SOCKET s, int how)
0a753a76 398{
68dc0745 399 int r;
0a753a76 400
326b05e3 401 SOCKET_TEST_ERROR(r = shutdown(TO_SOCKET(s), how));
68dc0745 402 return r;
0a753a76
PP
403}
404
3a25acb4
GS
405int
406win32_closesocket(SOCKET s)
407{
408 int r;
409
410 SOCKET_TEST_ERROR(r = closesocket(TO_SOCKET(s)));
411 return r;
412}
413
68dc0745
PP
414SOCKET
415win32_socket(int af, int type, int protocol)
0a753a76 416{
68dc0745 417 SOCKET s;
0a753a76
PP
418
419#ifndef USE_SOCKETS_AS_HANDLES
326b05e3 420 SOCKET_TEST(s = socket(af, type, protocol), INVALID_SOCKET);
0a753a76 421#else
3a25acb4 422 StartSockets();
326b05e3
GS
423 if((s = socket(af, type, protocol)) == INVALID_SOCKET)
424 errno = WSAGetLastError();
68dc0745
PP
425 else
426 s = OPEN_SOCKET(s);
427#endif /* USE_SOCKETS_AS_HANDLES */
0a753a76 428
68dc0745 429 return s;
0a753a76
PP
430}
431
fb73857a
PP
432#undef fclose
433int
434my_fclose (FILE *pf)
435{
326b05e3
GS
436 int osf, retval;
437 if (!wsock_started) /* No WinSock? */
438 return(fclose(pf)); /* Then not a socket. */
439 osf = TO_SOCKET(fileno(pf));/* Get it now before it's gone! */
440 retval = fclose(pf); /* Must fclose() before closesocket() */
441 if (osf != -1
442 && closesocket(osf) == SOCKET_ERROR
443 && WSAGetLastError() != WSAENOTSOCK)
444 {
445 return EOF;
446 }
447 return retval;
fb73857a
PP
448}
449
68dc0745
PP
450struct hostent *
451win32_gethostbyaddr(const char *addr, int len, int type)
0a753a76 452{
68dc0745 453 struct hostent *r;
0a753a76 454
326b05e3 455 SOCKET_TEST(r = gethostbyaddr(addr, len, type), NULL);
68dc0745 456 return r;
0a753a76
PP
457}
458
68dc0745
PP
459struct hostent *
460win32_gethostbyname(const char *name)
0a753a76 461{
68dc0745 462 struct hostent *r;
0a753a76 463
326b05e3 464 SOCKET_TEST(r = gethostbyname(name), NULL);
68dc0745 465 return r;
0a753a76
PP
466}
467
68dc0745
PP
468int
469win32_gethostname(char *name, int len)
0a753a76 470{
68dc0745 471 int r;
0a753a76 472
326b05e3 473 SOCKET_TEST_ERROR(r = gethostname(name, len));
68dc0745 474 return r;
0a753a76
PP
475}
476
68dc0745
PP
477struct protoent *
478win32_getprotobyname(const char *name)
0a753a76 479{
68dc0745 480 struct protoent *r;
0a753a76 481
326b05e3 482 SOCKET_TEST(r = getprotobyname(name), NULL);
68dc0745 483 return r;
0a753a76
PP
484}
485
68dc0745
PP
486struct protoent *
487win32_getprotobynumber(int num)
0a753a76 488{
68dc0745 489 struct protoent *r;
0a753a76 490
326b05e3 491 SOCKET_TEST(r = getprotobynumber(num), NULL);
68dc0745 492 return r;
0a753a76
PP
493}
494
68dc0745
PP
495struct servent *
496win32_getservbyname(const char *name, const char *proto)
0a753a76 497{
68dc0745 498 struct servent *r;
c53bd28a
NIS
499 dTHR;
500
326b05e3 501 SOCKET_TEST(r = getservbyname(name, proto), NULL);
68dc0745
PP
502 if (r) {
503 r = win32_savecopyservent(&myservent, r, proto);
504 }
505 return r;
0a753a76
PP
506}
507
68dc0745
PP
508struct servent *
509win32_getservbyport(int port, const char *proto)
0a753a76 510{
68dc0745 511 struct servent *r;
c53bd28a 512 dTHR;
0a753a76 513
326b05e3 514 SOCKET_TEST(r = getservbyport(port, proto), NULL);
68dc0745
PP
515 if (r) {
516 r = win32_savecopyservent(&myservent, r, proto);
517 }
518 return r;
0a753a76
PP
519}
520
f998180f
GS
521int
522win32_ioctl(int i, unsigned int u, char *data)
523{
524 u_long argp = (u_long)data;
525 int retval;
526
527 if (!wsock_started) {
528 croak("ioctl implemented only on sockets");
529 /* NOTREACHED */
530 }
531
532 retval = ioctlsocket(TO_SOCKET(i), (long)u, &argp);
533 if (retval == SOCKET_ERROR) {
534 if (WSAGetLastError() == WSAENOTSOCK) {
535 croak("ioctl implemented only on sockets");
536 /* NOTREACHED */
537 }
538 errno = WSAGetLastError();
539 }
540 return retval;
541}
542
68dc0745
PP
543char FAR *
544win32_inet_ntoa(struct in_addr in)
0a753a76 545{
326b05e3
GS
546 StartSockets();
547 return inet_ntoa(in);
0a753a76
PP
548}
549
68dc0745
PP
550unsigned long
551win32_inet_addr(const char FAR *cp)
0a753a76 552{
326b05e3
GS
553 StartSockets();
554 return inet_addr(cp);
0a753a76 555}
68dc0745
PP
556
557/*
558 * Networking stubs
559 */
0a753a76 560
68dc0745
PP
561void
562win32_endhostent()
0a753a76 563{
326b05e3 564 croak("endhostent not implemented!\n");
0a753a76
PP
565}
566
68dc0745
PP
567void
568win32_endnetent()
0a753a76 569{
326b05e3 570 croak("endnetent not implemented!\n");
0a753a76
PP
571}
572
68dc0745
PP
573void
574win32_endprotoent()
0a753a76 575{
326b05e3 576 croak("endprotoent not implemented!\n");
0a753a76
PP
577}
578
68dc0745
PP
579void
580win32_endservent()
0a753a76 581{
326b05e3 582 croak("endservent not implemented!\n");
0a753a76
PP
583}
584
585
68dc0745
PP
586struct netent *
587win32_getnetent(void)
0a753a76 588{
326b05e3 589 croak("getnetent not implemented!\n");
68dc0745 590 return (struct netent *) NULL;
0a753a76
PP
591}
592
68dc0745
PP
593struct netent *
594win32_getnetbyname(char *name)
0a753a76 595{
326b05e3 596 croak("getnetbyname not implemented!\n");
68dc0745 597 return (struct netent *)NULL;
0a753a76
PP
598}
599
68dc0745
PP
600struct netent *
601win32_getnetbyaddr(long net, int type)
0a753a76 602{
326b05e3 603 croak("getnetbyaddr not implemented!\n");
68dc0745 604 return (struct netent *)NULL;
0a753a76
PP
605}
606
68dc0745
PP
607struct protoent *
608win32_getprotoent(void)
0a753a76 609{
326b05e3 610 croak("getprotoent not implemented!\n");
68dc0745 611 return (struct protoent *) NULL;
0a753a76
PP
612}
613
68dc0745
PP
614struct servent *
615win32_getservent(void)
0a753a76 616{
326b05e3 617 croak("getservent not implemented!\n");
68dc0745 618 return (struct servent *) NULL;
0a753a76
PP
619}
620
68dc0745
PP
621void
622win32_sethostent(int stayopen)
0a753a76 623{
326b05e3 624 croak("sethostent not implemented!\n");
0a753a76
PP
625}
626
627
68dc0745
PP
628void
629win32_setnetent(int stayopen)
0a753a76 630{
326b05e3 631 croak("setnetent not implemented!\n");
0a753a76
PP
632}
633
634
68dc0745
PP
635void
636win32_setprotoent(int stayopen)
0a753a76 637{
326b05e3 638 croak("setprotoent not implemented!\n");
0a753a76
PP
639}
640
641
68dc0745
PP
642void
643win32_setservent(int stayopen)
0a753a76 644{
326b05e3 645 croak("setservent not implemented!\n");
0a753a76
PP
646}
647
137443ea
PP
648static struct servent*
649win32_savecopyservent(struct servent*d, struct servent*s, const char *proto)
650{
651 d->s_name = s->s_name;
652 d->s_aliases = s->s_aliases;
653 d->s_port = s->s_port;
0af56dfe 654#ifndef __BORLANDC__ /* Buggy on Win95 and WinNT-with-Borland-WSOCK */
137443ea
PP
655 if (!IsWin95() && s->s_proto && strlen(s->s_proto))
656 d->s_proto = s->s_proto;
0af56dfe
GS
657 else
658#endif
c69f6586 659 if (proto && strlen(proto))
137443ea
PP
660 d->s_proto = (char *)proto;
661 else
662 d->s_proto = "tcp";
663
664 return d;
665}
666
0a753a76 667