AuroraMiddleware/wxWidgets
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

removed GSocket_[Un]Streamed

Browse Source 
git-svn-id: https://svn.wxwidgets.org/svn/wx/wxWidgets/trunk@28524 c3d73ce0-8a6f-49c7-b76d-6d57e0e08775
This commit is contained in:
Vadim Zeitlin 2004-07-28 00:35:33 +00:00
parent 64133c38ea
commit 8f6819d763
1 changed files with 26 additions and 23 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

49
src/msw/gsocket.c
View File

@ -160,6 +160,7 @@ GSocket *GSocket_new(void)
socket->m_timeout.tv_sec = 10 * 60; /* 10 minutes */
socket->m_timeout.tv_usec = 0;
socket->m_establishing = FALSE;
socket->m_reusable = FALSE;
/* Per-socket GUI-specific initialization */
success = _GSocket_GUI_Init_Socket(socket);
@ -375,7 +376,6 @@ GSocketError GSocket_SetServer(GSocket *sck)
/* Initialize all fields */
sck->m_server = TRUE;
sck->m_stream = TRUE;
sck->m_oriented = TRUE;
/* Create the socket */
sck->m_fd = socket(sck->m_local->m_realfamily, SOCK_STREAM, 0);
@ -389,6 +389,13 @@ GSocketError GSocket_SetServer(GSocket *sck)
ioctlsocket(sck->m_fd, FIONBIO, (u_long FAR *) &arg);
_GSocket_Enable_Events(sck);
/* allow a socket to re-bind if the socket is in the TIME_WAIT
state after being previously closed.
*/
if (sck->m_reusable) {
setsockopt(sck->m_fd, SOL_SOCKET, SO_REUSEADDR, (const char*)&arg, sizeof(u_long));
}
/* Bind to the local address,
* retrieve the actual address bound,
* and listen up to 5 connections.
@ -472,7 +479,6 @@ GSocket *GSocket_WaitConnection(GSocket *sck)
/* Initialize all fields */
connection->m_server = FALSE;
connection->m_stream = TRUE;
connection->m_oriented = TRUE;
/* Setup the peer address field */
connection->m_peer = GAddress_new();
@ -497,6 +503,24 @@ GSocket *GSocket_WaitConnection(GSocket *sck)
return connection;
}
/* GSocket_SetReusable:
* Simply sets the m_resuable flag on the socket. GSocket_SetServer will
* make the appropriate setsockopt() call.
* Implemented as a GSocket function because clients (ie, wxSocketServer)
* don't have access to the GSocket struct information.
* Returns TRUE if the flag was set correctly, FALSE if an error occured
* (ie, if the parameter was NULL)
*/
int GSocket_SetReusable(GSocket *socket)
{
/* socket must not be null, and must not be in use/already bound */
if (NULL != socket && socket->m_fd == INVALID_SOCKET) {
socket->m_reusable = TRUE;
return TRUE;
}
return FALSE;
}
/* Client specific parts */
/* GSocket_Connect:
@ -546,7 +570,6 @@ GSocketError GSocket_Connect(GSocket *sck, GSocketStream stream)
/* Streamed or dgram socket? */
sck->m_stream = (stream == GSOCK_STREAMED);
sck->m_oriented = TRUE;
sck->m_server = FALSE;
sck->m_establishing = FALSE;
@ -646,7 +669,6 @@ GSocketError GSocket_SetNonOriented(GSocket *sck)
/* Initialize all fields */
sck->m_stream = FALSE;
sck->m_server = FALSE;
sck->m_oriented = FALSE;
/* Create the socket */
sck->m_fd = socket(sck->m_local->m_realfamily, SOCK_DGRAM, 0);
@ -1005,25 +1027,6 @@ GSocketError GSocket_SetSockOpt(GSocket *socket, int level, int optname,
return GSOCK_OPTERR;
}
GSocketError GSocket_SetReuseAddr(GSocket *socket)
{
/* allow a socket to re-bind if the socket is in the TIME_WAIT
state after being previously closed.
*/
u_long arg = 1;
setsockopt(socket->m_fd, SOL_SOCKET, SO_REUSEADDR, (const char*)&arg, sizeof(u_long));
}
void GSocket_Streamed(GSocket *socket)
{
socket->m_stream = TRUE;
}
void GSocket_Unstreamed(GSocket *socket)
{
socket->m_stream = FALSE;
}
/* Internals (IO) */
/* _GSocket_Input_Timeout: