sockets.c

/*
 +----------------------------------------------------------------------+
 | Copyright (c) The PHP Group |
 +----------------------------------------------------------------------+
 | This source file is subject to version 3.01 of the PHP license, |
 | that is bundled with this package in the file LICENSE, and is |
 | available through the world-wide-web at the following url: |
 | https://www.php.net/license/3_01.txt |
 | If you did not receive a copy of the PHP license and are unable to |
 | obtain it through the world-wide-web, please send a note to |
 | license@php.net so we can mail you a copy immediately. |
 +----------------------------------------------------------------------+
 | Authors: Chris Vandomelen <chrisv@b0rked.dhs.org> |
 | Sterling Hughes <sterling@php.net> |
 | |
 | WinSock: Daniel Beulshausen <daniel@php4win.de> |
 +----------------------------------------------------------------------+
 */

/* Code originally from ext/sockets */

#include<stdio.h>
#include<fcntl.h>

#include"php.h"

PHPAPIintsocketpair_win32(intdomain, inttype, intprotocol, SOCKETsock[2], intoverlapped)
{
structsockaddr_inaddress;
SOCKETredirect;
intsize=sizeof(address);

if (domain!=AF_INET) {
WSASetLastError(WSAENOPROTOOPT);
return-1;
 }

sock[1] =redirect=INVALID_SOCKET;

sock[0] =socket(domain, type, protocol);
if (INVALID_SOCKET==sock[0]) {
 goto error;
 }

address.sin_addr.s_addr=INADDR_ANY;
address.sin_family=AF_INET;
address.sin_port=0;

if (bind(sock[0], (structsockaddr*) &address, sizeof(address)) !=0) {
 goto error;
 }

if (getsockname(sock[0], (structsockaddr*) &address, &size) !=0) {
 goto error;
 }

if (listen(sock[0], 2) !=0) {
 goto error;
 }

if (overlapped) {
sock[1] =socket(domain, type, protocol);
 } else {
sock[1] =WSASocket(domain, type, protocol, NULL, 0, 0);
 }

if (INVALID_SOCKET==sock[1]) {
 goto error;
 }

address.sin_addr.s_addr=htonl(INADDR_LOOPBACK);
if (connect(sock[1], (structsockaddr*) &address, sizeof(address)) !=0) {
 goto error;
 }

redirect=accept(sock[0], (structsockaddr*) &address, &size);
if (INVALID_SOCKET==redirect) {
 goto error;
 }

closesocket(sock[0]);
sock[0] =redirect;

return0;

error:
closesocket(redirect);
closesocket(sock[0]);
closesocket(sock[1]);
WSASetLastError(WSAECONNABORTED);
return-1;
}

PHPAPIintsocketpair(intdomain, inttype, intprotocol, SOCKETsock[2])
{
returnsocketpair_win32(domain, type, protocol, sock, 1);
}