1b0230e4df
Will be needed if we want loolwsd to run on Windows. Then we will have one process receiving the connections from WebSocket clients and sending the accepted connection sockets to child processes thatr might be already running, either because they have been "pre-forked", or because of a collaboration scenario where new clients join a session working on a document. But initially we will write this as if for Unix only, so development of this migratory socket stuff is paused for now. (And it isn't even clear whether the API design so far is a good idea and elegantly implementable.)
111 lines
3.4 KiB
C
111 lines
3.4 KiB
C
/* socketpair.c
|
|
* Copyright 2007 by Nathan C. Myers <ncm@cantrip.org>; some rights reserved.
|
|
* This code is Free Software. It may be copied freely, in original or
|
|
* modified form, subject only to the restrictions that (1) the author is
|
|
* relieved from all responsibilities for any use for any purpose, and (2)
|
|
* this copyright notice must be retained, unchanged, in its entirety. If
|
|
* for any reason the author might be held responsible for any consequences
|
|
* of copying or use, license is withheld.
|
|
*/
|
|
|
|
/* Changes:
|
|
* 2010-02-25:
|
|
* set SO_REUSEADDR option to avoid leaking some windows resource.
|
|
* Windows System Error 10049, "Event ID 4226 TCP/IP has reached
|
|
* the security limit imposed on the number of concurrent TCP connect
|
|
* attempts." Bleah.
|
|
* 2007-04-25:
|
|
* preserve value of WSAGetLastError() on all error returns.
|
|
* 2007-04-22: (Thanks to Matthew Gregan <kinetik@flim.org>)
|
|
* s/EINVAL/WSAEINVAL/ fix trivial compile failure
|
|
* s/socket/WSASocket/ enable creation of sockets suitable as stdin/stdout
|
|
* of a child process.
|
|
* add argument make_overlapped
|
|
*/
|
|
|
|
#include <string.h>
|
|
|
|
#ifdef _WIN32
|
|
# include <winsock2.h>
|
|
# include <windows.h>
|
|
# include <io.h>
|
|
#else
|
|
# include <sys/types.h>
|
|
# include <sys/socket.h>
|
|
#endif
|
|
|
|
#ifdef _WIN32
|
|
|
|
/* dumb_socketpair:
|
|
* If make_overlapped is nonzero, both sockets created will be usable for
|
|
* "overlapped" operations via WSASend etc. If make_overlapped is zero,
|
|
* socks[0] (only) will be usable with regular ReadFile etc., and thus
|
|
* suitable for use as stdin or stdout of a child process. Note that the
|
|
* sockets must be closed with closesocket() regardless.
|
|
*/
|
|
|
|
int dumb_socketpair(SOCKET socks[2], int make_overlapped)
|
|
{
|
|
union {
|
|
struct sockaddr_in inaddr;
|
|
struct sockaddr addr;
|
|
} a;
|
|
SOCKET listener;
|
|
int e;
|
|
socklen_t addrlen = sizeof(a.inaddr);
|
|
DWORD flags = (make_overlapped ? WSA_FLAG_OVERLAPPED : 0);
|
|
int reuse = 1;
|
|
|
|
if (socks == 0) {
|
|
WSASetLastError(WSAEINVAL);
|
|
return SOCKET_ERROR;
|
|
}
|
|
|
|
listener = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
|
|
if (listener == INVALID_SOCKET)
|
|
return SOCKET_ERROR;
|
|
|
|
memset(&a, 0, sizeof(a));
|
|
a.inaddr.sin_family = AF_INET;
|
|
a.inaddr.sin_addr.s_addr = htonl(INADDR_LOOPBACK);
|
|
a.inaddr.sin_port = 0;
|
|
|
|
socks[0] = socks[1] = INVALID_SOCKET;
|
|
do {
|
|
if (setsockopt(listener, SOL_SOCKET, SO_REUSEADDR,
|
|
(char*) &reuse, (socklen_t) sizeof(reuse)) == -1)
|
|
break;
|
|
if (bind(listener, &a.addr, sizeof(a.inaddr)) == SOCKET_ERROR)
|
|
break;
|
|
if (getsockname(listener, &a.addr, &addrlen) == SOCKET_ERROR)
|
|
break;
|
|
if (listen(listener, 1) == SOCKET_ERROR)
|
|
break;
|
|
socks[0] = WSASocket(AF_INET, SOCK_STREAM, 0, NULL, 0, flags);
|
|
if (socks[0] == INVALID_SOCKET)
|
|
break;
|
|
if (connect(socks[0], &a.addr, sizeof(a.inaddr)) == SOCKET_ERROR)
|
|
break;
|
|
socks[1] = accept(listener, NULL, NULL);
|
|
if (socks[1] == INVALID_SOCKET)
|
|
break;
|
|
|
|
closesocket(listener);
|
|
return 0;
|
|
|
|
} while (0);
|
|
|
|
e = WSAGetLastError();
|
|
closesocket(listener);
|
|
closesocket(socks[0]);
|
|
closesocket(socks[1]);
|
|
WSASetLastError(e);
|
|
return SOCKET_ERROR;
|
|
}
|
|
#else
|
|
int dumb_socketpair(int socks[2], int dummy)
|
|
{
|
|
(void) dummy;
|
|
return socketpair(AF_LOCAL, SOCK_STREAM, 0, socks);
|
|
}
|
|
#endif
|