diff options
Diffstat (limited to 'src/backend')
-rw-r--r-- | src/backend/postmaster/pgstat.c | 6 | ||||
-rw-r--r-- | src/backend/postmaster/postmaster.c | 9 |
2 files changed, 5 insertions, 10 deletions
diff --git a/src/backend/postmaster/pgstat.c b/src/backend/postmaster/pgstat.c index c59cc1d120d..95cd52e6442 100644 --- a/src/backend/postmaster/pgstat.c +++ b/src/backend/postmaster/pgstat.c @@ -13,7 +13,7 @@ * * Copyright (c) 2001-2003, PostgreSQL Global Development Group * - * $PostgreSQL: pgsql/src/backend/postmaster/pgstat.c,v 1.59 2004/03/09 05:11:52 momjian Exp $ + * $PostgreSQL: pgsql/src/backend/postmaster/pgstat.c,v 1.60 2004/03/10 21:12:46 momjian Exp $ * ---------- */ #include "postgres.h" @@ -327,7 +327,7 @@ pgstat_init(void) * messages will be discarded; backends won't block waiting to send * messages to the collector. */ - if (FCNTL_NONBLOCK(pgStatSock) < 0) + if (!set_noblock(pgStatSock)) { ereport(LOG, (errcode_for_socket_access(), @@ -1819,7 +1819,7 @@ pgstat_recvbuffer(void) * Set the write pipe to nonblock mode, so that we cannot block when * the collector falls behind. */ - if (FCNTL_NONBLOCK(writePipe) < 0) + if (!set_noblock(writePipe)) { ereport(LOG, (errcode_for_socket_access(), diff --git a/src/backend/postmaster/postmaster.c b/src/backend/postmaster/postmaster.c index 1bd80e1611c..2a420bfdbf0 100644 --- a/src/backend/postmaster/postmaster.c +++ b/src/backend/postmaster/postmaster.c @@ -37,7 +37,7 @@ * * * IDENTIFICATION - * $PostgreSQL: pgsql/src/backend/postmaster/postmaster.c,v 1.372 2004/03/09 05:11:52 momjian Exp $ + * $PostgreSQL: pgsql/src/backend/postmaster/postmaster.c,v 1.373 2004/03/10 21:12:46 momjian Exp $ * * NOTES * @@ -219,11 +219,6 @@ bool Db_user_namespace = false; char *rendezvous_name; -/* For FNCTL_NONBLOCK */ -#if defined(WIN32) || defined(__BEOS__) -long ioctlsocket_ret=1; -#endif - /* list of library:init-function to be preloaded */ char *preload_libraries_string = NULL; @@ -2365,7 +2360,7 @@ report_fork_failure_to_client(Port *port, int errnum) strerror(errnum)); /* Set port to non-blocking. Don't do send() if this fails */ - if (FCNTL_NONBLOCK(port->sock) < 0) + if (!set_noblock(port->sock)) return; send(port->sock, buffer, strlen(buffer) + 1, 0); |