/* -------------------------------------------------------------------------
- * Project: GSocket (Generic Socket) for WX
- * Name: gsocket.c
- * Authors: David Elliott (C++ conversion, maintainer)
- * Guilhem Lavaux,
- * Guillermo Rodriguez Garcia <guille@iies.es>
- * Purpose: GSocket main Unix and OS/2 file
- * Licence: The wxWindows licence
- * CVSID: $Id$
+ * Project: GSocket (Generic Socket) for WX
+ * Name: gsocket.c
+ * Copyright: (c) Guilhem Lavaux
+ * Licence: wxWindows Licence
+ * Authors: David Elliott (C++ conversion, maintainer)
+ * Guilhem Lavaux,
+ * Guillermo Rodriguez Garcia <guille@iies.es>
+ * Purpose: GSocket main Unix and OS/2 file
+ * Licence: The wxWindows licence
+ * CVSID: $Id$
* -------------------------------------------------------------------------
*/
# if __GLIBC__ == 2
# define SOCKLEN_T socklen_t
# endif
+# elif defined(__WXMAC__)
+# define SOCKLEN_T socklen_t
# else
# define SOCKLEN_T int
# endif
#define SOCKOPTLEN_T SOCKLEN_T
#endif
-/*
- * OSX 10.2 has int args instead of SOCKLENXXX_T
- */
-#if defined( __WXMAC__ ) || defined ( __WXCOCOA__ )
-# if ( MAC_OS_X_VERSION_MAX_ALLOWED <= MAC_OS_X_VERSION_10_2 )
-# undef SOCKOPTLEN_T
-# undef SOCKLEN_T
-# define SOCKOPTLEN_T int
-# define SOCKLEN_T int
-# endif
-#endif
-
/*
* MSW defines this, Unices don't.
*/
signal(SIGPIPE, old_handler); \
}
+/* If a SIGPIPE is issued by a socket call on a remotely closed socket,
+ the program will "crash" unless it explicitly handles the SIGPIPE.
+ By using MSG_NOSIGNAL, the SIGPIPE is suppressed. Later, we will
+ use SO_NOSIGPIPE (if available), the BSD equivalent. */
#ifdef MSG_NOSIGNAL
# define GSOCKET_MSG_NOSIGNAL MSG_NOSIGNAL
#else /* MSG_NOSIGNAL not available (FreeBSD including OS X) */
assert(this);
-#ifndef __DARWIN__
- /* Reenable CONNECTION events */
- Enable(GSOCK_CONNECTION);
-#endif
-
/* If the socket has already been created, we exit immediately */
if (m_fd == INVALID_SOCKET || !m_server)
{
connection->m_fd = accept(m_fd, &from, (SOCKLEN_T *) &fromlen);
-#ifdef __DARWIN__
/* Reenable CONNECTION events */
Enable(GSOCK_CONNECTION);
-#endif
if (connection->m_fd == INVALID_SOCKET)
{
* For stream (connection oriented) sockets, GSocket_Connect() tries
* to establish a client connection to a server using the peer address
* as established with GSocket_SetPeer(). Returns GSOCK_NOERROR if the
- * connection has been succesfully established, or one of the error
+ * connection has been successfully established, or one of the error
* codes listed below. Note that for nonblocking sockets, a return
* value of GSOCK_WOULDBLOCK doesn't mean a failure. The connection
* request can be completed later; you should use GSocket_Select()
/* Connect it to the peer address, with a timeout (see below) */
ret = connect(m_fd, m_peer->m_addr, m_peer->m_len);
+ /* We only call Enable_Events if we know e aren't shutting down the socket */
+
if (m_non_blocking)
{
gs_gui_functions->Enable_Events(this);
}
/* GSocket_GetError:
- * Returns the last error occured for this socket. Note that successful
+ * Returns the last error occurred for this socket. Note that successful
* operations do not clear this back to GSOCK_NOERROR, so use it only
* after an error.
*/
* assume that it can write since the first OUTPUT event, and no more
* OUTPUT events will be generated unless an error occurs.
* GSOCK_CONNECTION:
- * Connection succesfully established, for client sockets, or incoming
+ * Connection successfully established, for client sockets, or incoming
* client connection, for server sockets. Wait for this event (also watch
* out for GSOCK_LOST) after you issue a nonblocking GSocket_Connect() call.
* GSOCK_LOST:
do
{
ret = recv(m_fd, buffer, size, GSOCKET_MSG_NOSIGNAL);
- } while (ret == -1 && errno == EINTR);
+ } while (ret == -1 && errno == EINTR); /* Loop until not interrupted */
return ret;
}
do
{
ret = recvfrom(m_fd, buffer, size, 0, &from, (SOCKLEN_T *) &fromlen);
- } while (ret == -1 && errno == EINTR);
+ } while (ret == -1 && errno == EINTR); /* Loop until not interrupted */
if (ret == -1)
return -1;
do
{
ret = send(m_fd, (char *)buffer, size, GSOCKET_MSG_NOSIGNAL);
- } while (ret == -1 && errno == EINTR);
+ } while (ret == -1 && errno == EINTR); /* Loop until not interrupted */
#ifndef __VISAGECPP__
UNMASK_SIGNAL();
#endif
do
{
ret = sendto(m_fd, (char *)buffer, size, 0, addr, len);
- } while (ret == -1 && errno == EINTR);
+ } while (ret == -1 && errno == EINTR); /* Loop until not interrupted */
#ifndef __VISAGECPP__
UNMASK_SIGNAL();
#endif
}
else
{
+ /* Do not throw a lost event in cases where the socket isn't really lost */
if ((errno == EWOULDBLOCK) || (errno == EAGAIN) || (errno == EINTR))
{
CALL_CALLBACK(this, GSOCK_INPUT);
if (inet_aton(hostname, addr) == 0)
{
#elif defined(HAVE_INET_ADDR)
- if ( (addr->s_addr = inet_addr(hostname)) == (in_addr_t)-1 )
+ if ( (addr->s_addr = inet_addr(hostname)) == (unsigned)-1 )
{
#else
/* Use gethostbyname by default */