diff options
| author | fcolin | 2007-02-01 13:05:04 +0000 |
|---|---|---|
| committer | fcolin | 2007-02-01 13:05:04 +0000 |
| commit | 05ae352ec6ef8196b84dbbc8feaf9c49f0596516 (patch) | |
| tree | 4be885c7325ca6a6aaea7fe92908fa6e94b89679 /Bus | |
| parent | 4dade8fc54f663a0b47a3615c7224b78a2e7b0f1 (diff) | |
| download | ivy-cplusplus-05ae352ec6ef8196b84dbbc8feaf9c49f0596516.zip ivy-cplusplus-05ae352ec6ef8196b84dbbc8feaf9c49f0596516.tar.gz ivy-cplusplus-05ae352ec6ef8196b84dbbc8feaf9c49f0596516.tar.bz2 ivy-cplusplus-05ae352ec6ef8196b84dbbc8feaf9c49f0596516.tar.xz | |
Utilisateur : Fcolin Date : 23/05/01 Heure : 10:25 Archivé dans $/Ivy (vss 9)
Diffstat (limited to 'Bus')
| -rw-r--r-- | Bus/Ivy/ThreadedSocket.cxx | 11 |
1 files changed, 6 insertions, 5 deletions
diff --git a/Bus/Ivy/ThreadedSocket.cxx b/Bus/Ivy/ThreadedSocket.cxx index a9a1760..d113f8e 100644 --- a/Bus/Ivy/ThreadedSocket.cxx +++ b/Bus/Ivy/ThreadedSocket.cxx @@ -160,7 +160,7 @@ int CThreadedSocket::Connect(const SOCKADDR* lpSockAddr, int nSockAddrLen) ok = connect(m_hSocket, lpSockAddr, nSockAddrLen);
if ( !ok )
{
- int err = GetLastError();
+ int err = this->GetLastError();
if ( err == 0 ) return err;
TRACE( "***************************************Error connect %d\n", err);
if ( err != WSAEWOULDBLOCK )
@@ -262,7 +262,7 @@ int CThreadedSocket::SendTo(const void* lpBuf, int nBufLen, UINT nHostPort, cons sockAddr.sin_port = htons((u_short)nHostPort);
return SendTo(lpBuf, nBufLen, (SOCKADDR*)&sockAddr, sizeof(sockAddr), nFlags);
-}
+ }
int CThreadedSocket::AddMember( const char * lpszHostAddress )
{
int multicast_ttl = 64; // region
@@ -406,7 +406,7 @@ UINT CThreadedSocket::SocketReader( ) FD_SET(m_hSocket, &exceptfds);
err = select( 1, &readfds, &writefds, &exceptfds, NULL );
- sock_err = GetLastError();
+ sock_err = this->GetLastError();
switch ( err )
{
@@ -427,6 +427,7 @@ UINT CThreadedSocket::SocketReader( ) if ( FD_ISSET(m_hSocket, &readfds) )
{
+ readcount = 0;
IOCtl( FIONREAD, &readcount );
if ( listen_mode )
OnAccept( sock_err );
@@ -491,7 +492,7 @@ UINT CThreadedSocket::SocketWriter( ) if (m_hSocket != INVALID_SOCKET)
Close();
h_writer = NULL;
- return GetLastError();
+ return this->GetLastError();
break;
}
if (m_hSocket != INVALID_SOCKET)
@@ -499,7 +500,7 @@ UINT CThreadedSocket::SocketWriter( ) FD_SET(m_hSocket, &writefds);
err = select( 1, NULL, &writefds, NULL, NULL );
- sock_err = GetLastError();
+ sock_err = this->GetLastError();
switch ( err )
{
|