diff options
Diffstat (limited to 'src/backend/port/pipe.c')
-rw-r--r-- | src/backend/port/pipe.c | 95 |
1 files changed, 0 insertions, 95 deletions
diff --git a/src/backend/port/pipe.c b/src/backend/port/pipe.c deleted file mode 100644 index 357f5ecc011..00000000000 --- a/src/backend/port/pipe.c +++ /dev/null @@ -1,95 +0,0 @@ -/*------------------------------------------------------------------------- - * - * pipe.c - * pipe() - * - * Copyright (c) 1996-2012, PostgreSQL Global Development Group - * - * This is a replacement version of pipe for Win32 which allows - * returned handles to be used in select(). Note that read/write calls - * must be replaced with recv/send. - * - * IDENTIFICATION - * src/backend/port/pipe.c - * - *------------------------------------------------------------------------- - */ - -#include "postgres.h" - -#ifdef WIN32 -int -pgpipe(int handles[2]) -{ - SOCKET s; - struct sockaddr_in serv_addr; - int len = sizeof(serv_addr); - - handles[0] = handles[1] = INVALID_SOCKET; - - if ((s = socket(AF_INET, SOCK_STREAM, 0)) == INVALID_SOCKET) - { - ereport(LOG, (errmsg_internal("pgpipe could not create socket: %ui", WSAGetLastError()))); - return -1; - } - - memset((void *) &serv_addr, 0, sizeof(serv_addr)); - serv_addr.sin_family = AF_INET; - serv_addr.sin_port = htons(0); - serv_addr.sin_addr.s_addr = htonl(INADDR_LOOPBACK); - if (bind(s, (SOCKADDR *) &serv_addr, len) == SOCKET_ERROR) - { - ereport(LOG, (errmsg_internal("pgpipe could not bind: %ui", WSAGetLastError()))); - closesocket(s); - return -1; - } - if (listen(s, 1) == SOCKET_ERROR) - { - ereport(LOG, (errmsg_internal("pgpipe could not listen: %ui", WSAGetLastError()))); - closesocket(s); - return -1; - } - if (getsockname(s, (SOCKADDR *) &serv_addr, &len) == SOCKET_ERROR) - { - ereport(LOG, (errmsg_internal("pgpipe could not getsockname: %ui", WSAGetLastError()))); - closesocket(s); - return -1; - } - if ((handles[1] = socket(PF_INET, SOCK_STREAM, 0)) == INVALID_SOCKET) - { - ereport(LOG, (errmsg_internal("pgpipe could not create socket 2: %ui", WSAGetLastError()))); - closesocket(s); - return -1; - } - - if (connect(handles[1], (SOCKADDR *) &serv_addr, len) == SOCKET_ERROR) - { - ereport(LOG, (errmsg_internal("pgpipe could not connect socket: %ui", WSAGetLastError()))); - closesocket(s); - return -1; - } - if ((handles[0] = accept(s, (SOCKADDR *) &serv_addr, &len)) == INVALID_SOCKET) - { - ereport(LOG, (errmsg_internal("pgpipe could not accept socket: %ui", WSAGetLastError()))); - closesocket(handles[1]); - handles[1] = INVALID_SOCKET; - closesocket(s); - return -1; - } - closesocket(s); - return 0; -} - - -int -piperead(int s, char *buf, int len) -{ - int ret = recv(s, buf, len, 0); - - if (ret < 0 && WSAGetLastError() == WSAECONNRESET) - /* EOF on the pipe! (win32 socket based implementation) */ - ret = 0; - return ret; -} - -#endif |