polyml/libpolyml/network.cpp

160     POLYEXTERNALSYMBOL POLYUNSIGNED PolyNetworkShutdown(FirstArgument threadId, PolyWord skt, PolyWord smode);
175     POLYEXTERNALSYMBOL POLYUNSIGNED PolyNetworkGetSocketError(FirstArgument threadId, PolyWord skt);
176     POLYEXTERNALSYMBOL POLYUNSIGNED PolyNetworkConnect(FirstArgument threadId, PolyWord skt, PolyWord addr);
177     POLYEXTERNALSYMBOL POLYUNSIGNED PolyNetworkAccept(FirstArgument threadId, PolyWord skt);
555     WinSocket(SOCKET skt) : socket(skt) {}
611 static Handle wrapStreamSocket(TaskData *taskData, SOCKET skt)
614         WinSocket *winskt = new WinSocket(skt);
629 static Handle wrapStreamSocket(TaskData *taskData, SOCKET skt)
631     return wrapFileDescriptor(taskData, skt);
736 POLYUNSIGNED PolyNetworkGetSocketError(FirstArgument threadId, PolyWord skt)
745         SOCKET sock = getStreamSocket(taskData, skt);
847 POLYEXTERNALSYMBOL POLYUNSIGNED PolyNetworkConnect(FirstArgument threadId, PolyWord skt, PolyWord addr)
854         SOCKET sock = getStreamSocket(taskData, skt);
868 POLYEXTERNALSYMBOL POLYUNSIGNED PolyNetworkAccept(FirstArgument threadId, PolyWord skt)
877         SOCKET sock = getStreamSocket(taskData, skt);
1127         SOCKET skt = 0;
1129             skt = socket(af, type, proto);
1130         } while (skt == INVALID_SOCKET && GETERROR == CALLINTERRUPTED);
1132         if (skt == INVALID_SOCKET)
1138         if (ioctlsocket(skt, FIONBIO, &onOff) != 0)
1141         if (ioctl(skt, FIONBIO, &onOff) < 0)
1145             closesocket(skt);
1147             close(skt);
1151         result = wrapStreamSocket(taskData, skt);
1293         SOCKET skt = getStreamSocket(taskData, sock);
1308         if (setsockopt(skt, SOL_SOCKET, SO_LINGER,
1329         SOCKET skt = getStreamSocket(taskData, sock);
1333         if (getsockopt(skt, SOL_SOCKET, SO_LINGER, (char*)& linger, &size) != 0)
1358         SOCKET skt = getStreamSocket(taskData, sock);
1361         if (getpeername(skt, (struct sockaddr*) & sockA, &size) != 0)
1385         SOCKET skt = getStreamSocket(taskData, sock);
1388         if (getsockname(skt, (struct sockaddr*) & sockA, &size) != 0)
1411         SOCKET skt = getStreamSocket(taskData, sock);
1414         if (ioctlsocket(skt, FIONREAD, &readable) != 0)
1418         if (ioctl(skt, FIONREAD, &readable) < 0)
1441         SOCKET skt = getStreamSocket(taskData, sock);
1444         if (ioctlsocket(skt, SIOCATMARK, &atMark) != 0)
1448         if (ioctl(skt, SIOCATMARK, &atMark) < 0)
1470         SOCKET skt = getStreamSocket(taskData, sock);
1473         if (bind(skt, psock, (int)psAddr->length) != 0)
1484 POLYUNSIGNED PolyNetworkListen(FirstArgument threadId, PolyWord skt, PolyWord back)
1492          SOCKET sock = getStreamSocket(taskData, skt);
1505 POLYUNSIGNED PolyNetworkShutdown(FirstArgument threadId, PolyWord skt, PolyWord smode)
1513         SOCKET sock = getStreamSocket(taskData, skt);
1548         SOCKET skt[2];
1552             skPRes = socketpair(af, type, proto, skt);
1557         if (ioctl(skt[0], FIONBIO, &onOff) < 0 ||
1558             ioctl(skt[1], FIONBIO, &onOff) < 0)
1560             close(skt[0]);
1561             close(skt[1]);
1564         Handle str_token1 = wrapStreamSocket(taskData, skt[0]);
1565         Handle str_token2 = wrapStreamSocket(taskData, skt[1]);