summaryrefslogtreecommitdiff
path: root/ndb
diff options
context:
space:
mode:
authorstewart@mysql.com <>2005-09-15 00:21:25 +1000
committerstewart@mysql.com <>2005-09-15 00:21:25 +1000
commit9e5e9603b56aa193e9817563f6af5231375c1750 (patch)
tree505aa0cf1e61879aa2cd274c6c41b1c9e861c743 /ndb
parentee3925346782b3cd9014c47f3ea591efa26fec96 (diff)
downloadmariadb-git-9e5e9603b56aa193e9817563f6af5231375c1750.tar.gz
BUG#13136 NdbTCP.cpp compile failure on OSX 10.2
use select if poll is unavailable.
Diffstat (limited to 'ndb')
-rw-r--r--ndb/src/common/portlib/NdbTCP.cpp32
-rw-r--r--ndb/src/common/portlib/win32/NdbTCP.c2
2 files changed, 33 insertions, 1 deletions
diff --git a/ndb/src/common/portlib/NdbTCP.cpp b/ndb/src/common/portlib/NdbTCP.cpp
index 768292ac7c0..41471548b7e 100644
--- a/ndb/src/common/portlib/NdbTCP.cpp
+++ b/ndb/src/common/portlib/NdbTCP.cpp
@@ -86,6 +86,7 @@ Ndb_getInAddr(struct in_addr * dst, const char *address) {
int Ndb_check_socket_hup(NDB_SOCKET_TYPE sock)
{
+#ifdef HAVE_POLL
struct pollfd pfd[1];
int r;
@@ -97,4 +98,35 @@ int Ndb_check_socket_hup(NDB_SOCKET_TYPE sock)
return 1;
return 0;
+#else /* HAVE_POLL */
+ fd_set readfds, writefds, errorfds;
+ struct timeval tv= {0,0};
+ int s_err;
+ int s_err_size= sizeof(s_err);
+
+ FD_ZERO(&readfds);
+ FD_ZERO(&writefds);
+ FD_ZERO(&errorfds);
+
+ FD_SET(sock, &readfds);
+ FD_SET(sock, &writefds);
+ FD_SET(sock, &errorfds);
+
+ if(select(1, &readfds, &writefds, &errorfds, &tv)<0)
+ return 1;
+
+ if(FD_ISSET(sock,&errorfds))
+ return 1;
+
+ s_err=0;
+ if (getsockopt(sock, SOL_SOCKET, SO_ERROR, (char*) &s_err, &s_err_size) != 0)
+ return(1);
+
+ if (s_err)
+ { /* getsockopt could succeed */
+ return(1); /* but return an error... */
+ }
+
+ return 0;
+#endif /* HAVE_POLL */
}
diff --git a/ndb/src/common/portlib/win32/NdbTCP.c b/ndb/src/common/portlib/win32/NdbTCP.c
index a14cd4409eb..5d6c0ae5c7d 100644
--- a/ndb/src/common/portlib/win32/NdbTCP.c
+++ b/ndb/src/common/portlib/win32/NdbTCP.c
@@ -52,7 +52,7 @@ int Ndb_check_socket_hup(NDB_SOCKET_TYPE sock)
FD_SET(sock, &writefds);
FD_SET(sock, &errorfds);
- if(select(1, &readfds, &writefds, &errorfds, &t)==SOCKET_ERROR)
+ if(select(1, &readfds, &writefds, &errorfds, &tv)==SOCKET_ERROR)
return 1;
if(FD_ISSET(sock,&errorfds))