diff --git a/src/backend/distributed/connection/connection_management.c b/src/backend/distributed/connection/connection_management.c index 724a6ec39..aff9c2f58 100644 --- a/src/backend/distributed/connection/connection_management.c +++ b/src/backend/distributed/connection/connection_management.c @@ -10,9 +10,7 @@ #include "postgres.h" -#ifdef HAVE_POLL_H #include -#endif #include "libpq-fe.h" diff --git a/src/backend/distributed/executor/multi_client_executor.c b/src/backend/distributed/executor/multi_client_executor.c index 022281e3b..e7252ef62 100644 --- a/src/backend/distributed/executor/multi_client_executor.c +++ b/src/backend/distributed/executor/multi_client_executor.c @@ -27,15 +27,10 @@ #include #include -#ifdef HAVE_POLL_H #include -#endif #ifdef HAVE_SYS_POLL_H #include #endif -#ifdef HAVE_SYS_SELECT_H -#include -#endif /* Local pool to track active connections */ @@ -886,9 +881,6 @@ ClientConnectionReady(MultiConnection *connection, { bool clientConnectionReady = false; int pollResult = 0; - - /* we use poll(2) if available, otherwise select(2) */ -#ifdef HAVE_POLL int fileDescriptorCount = 1; int immediateTimeout = 0; int pollEventMask = 0; @@ -908,33 +900,6 @@ ClientConnectionReady(MultiConnection *connection, pollFileDescriptor.revents = 0; pollResult = poll(&pollFileDescriptor, fileDescriptorCount, immediateTimeout); -#else /* !HAVE_POLL */ - - fd_set readFileDescriptorSet; - fd_set writeFileDescriptorSet; - fd_set exceptionFileDescriptorSet; - struct timeval immediateTimeout = { 0, 0 }; - int connectionFileDescriptor = PQsocket(connection); - - FD_ZERO(&readFileDescriptorSet); - FD_ZERO(&writeFileDescriptorSet); - FD_ZERO(&exceptionFileDescriptorSet); - - if (pollingStatus == PGRES_POLLING_READING) - { - FD_SET(connectionFileDescriptor, &exceptionFileDescriptorSet); - FD_SET(connectionFileDescriptor, &readFileDescriptorSet); - } - else if (pollingStatus == PGRES_POLLING_WRITING) - { - FD_SET(connectionFileDescriptor, &exceptionFileDescriptorSet); - FD_SET(connectionFileDescriptor, &writeFileDescriptorSet); - } - - pollResult = select(connectionFileDescriptor + 1, &readFileDescriptorSet, - &writeFileDescriptorSet, &exceptionFileDescriptorSet, - &immediateTimeout); -#endif /* HAVE_POLL */ if (pollResult > 0) { @@ -957,7 +922,7 @@ ClientConnectionReady(MultiConnection *connection, else { /* - * poll() or select() can set errno to EFAULT (when socket is not + * poll() can set errno to EFAULT (when socket is not * contained in the calling program's address space), EBADF (invalid * file descriptor), EINVAL (invalid arguments to select or poll), * and ENOMEM (no space to allocate file descriptor tables). Out of @@ -966,7 +931,7 @@ ClientConnectionReady(MultiConnection *connection, */ Assert(errno == ENOMEM); ereport(ERROR, (errcode_for_socket_access(), - errmsg("select()/poll() failed: %m"))); + errmsg("poll() failed: %m"))); } }