CASocket.cpp

Go to the documentation of this file.

/*
Copyright (c) 2000, The JAP-Team
All rights reserved.
Redistribution and use in source and binary forms, with or without modification,
are permitted provided that the following conditions are met:
 
  - Redistributions of source code must retain the above copyright notice,
    this list of conditions and the following disclaimer.
 
  - Redistributions in binary form must reproduce the above copyright notice,
    this list of conditions and the following disclaimer in the documentation and/or
    other materials provided with the distribution.
 
  - Neither the name of the University of Technology Dresden, Germany nor the names of its contributors
    may be used to endorse or promote products derived from this software without specific
    prior written permission.
 
 
THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS ``AS IS'' AND ANY EXPRESS
OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY
AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS
BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
(INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA,
OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER
IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE
*/
#include "StdAfx.h"
#include "CASocket.hpp"
#include "CAUtil.hpp"
#include "CASocketAddrINet.hpp"
#ifdef HAVE_UNIX_DOMAIN_PROTOCOL
  #include "CASocketAddrUnix.hpp"
#endif
#include "CASingleSocketGroup.hpp"
#ifdef _DEBUG
  int sockets;
#endif
#include "CAMsg.hpp"
#include "CAUtil.hpp"
#define CLOSE_SEND    0x01
#define CLOSE_RECEIVE 0x02
#define CLOSE_BOTH    0x03
 
volatile UINT32 CASocket::m_u32NormalSocketsOpen=0; //how many "normal" sockets are open
UINT32 CASocket::m_u32MaxNormalSockets=0xFFFFFFFF; //how many "normal" sockets are allowed at max
CAMutex* CASocket::m_pcsClose=NULL;
 
CASocket::CASocket(bool bIsReservedSocket)
  {
    m_Socket=0;
    m_bSocketIsClosed=true;
    m_bIsReservedSocket=bIsReservedSocket;
    m_pSingleSocketGroupRead = NULL;
  }
 
SINT32 CASocket::setSocket(SOCKET s)
  {
    delete m_pSingleSocketGroupRead;
    m_Socket = s;
    if (s != 0)
      {
        m_pSingleSocketGroupRead = new CASingleSocketGroup(false);
        m_pSingleSocketGroupRead->add(m_Socket);
      }
    else
      {
        m_pSingleSocketGroupRead = NULL;
      }
    return E_SUCCESS;
  }
 
SINT32 CASocket::create()
  {
    return create(AF_INET, true);
  }
 
SINT32 CASocket::create(SINT32 type)
{
  return create(type, true);
}
 
SINT32 CASocket::create(bool a_bShowTypicalError)
{
  return create(AF_INET, a_bShowTypicalError);
}
 
SINT32 CASocket::create(SINT32 type, bool a_bShowTypicalError)
  {
    SOCKET s = INVALID_SOCKET;
    if(m_bSocketIsClosed)
    {
      if(m_bIsReservedSocket||m_u32NormalSocketsOpen<m_u32MaxNormalSockets)
      {
        s=::socket(type,SOCK_STREAM,0);
        //CAMsg::printMsg(LOG_DEBUG,"Opened socket: %d\n", m_Socket);
      }
      else
      {
        CAMsg::printMsg(LOG_CRIT,"Could not create a new normal Socket -- allowed number of normal sockets exceeded!\n");
        return E_SOCKET_LIMIT;
      }
    }
    else
      return E_UNKNOWN;
    if(s==INVALID_SOCKET)
      {
        setSocket(0);
        int er=GET_NET_ERROR;
        if (a_bShowTypicalError)
        {
          if(er==EMFILE)
          {
            CAMsg::printMsg(LOG_CRIT,"Could not create a new Socket!\n");
          }
          else
          {
            CAMsg::printMsg(LOG_CRIT,"Could not create a new Socket! - Error: %s (%i)\n",
              GET_NET_ERROR_STR(er), er);
          }
        }
        return E_SOCKET_CREATE;
      }
    m_bSocketIsClosed=false;
    m_pcsClose->lock();
    if(!m_bIsReservedSocket)
    {
      m_u32NormalSocketsOpen++;
    }
    m_pcsClose->unlock();
    setSocket(s);
    return E_SUCCESS;
  }
 
SINT32 CASocket::listen(const CASocketAddr& psa)
  {
    UINT32 iError;
    SINT32 type=psa.getType();
    if(m_bSocketIsClosed&&create(type)!=E_SUCCESS)
      return E_UNKNOWN;
#ifdef HAVE_UNIX_DOMAIN_PROTOCOL
    //we have to delete the file before...
    if(psa.getType()==AF_LOCAL)
      {
        UINT8* path=((CASocketAddrUnix&)psa).getPath();
        if(path!=NULL)
          {
            SINT32 ret=::unlink((char*)path);
            if(ret!=0)
              CAMsg::printMsg(LOG_ERR,"CASocket::listen() -- could not unlink unix domain socket file name %s -- a call to bind or listen may fail...\n",path);
            delete[] path;
            path = NULL;
          }
      }
#endif
    if(::bind(m_Socket,psa.LPSOCKADDR(),psa.getSize())==SOCKET_ERROR)
      {
        iError = GET_NET_ERROR;
        close();
        SET_NET_ERROR(iError);
        return E_SOCKET_BIND;
      }
    if(::listen(m_Socket,SOMAXCONN)==SOCKET_ERROR)
      {
        iError = GET_NET_ERROR;
        close();
        SET_NET_ERROR(iError);
        return E_SOCKET_LISTEN;
      }
    return E_SUCCESS;
  }
 
SINT32 CASocket::listen(UINT16 port)
  {
    CASocketAddrINet oSocketAddrINet(port);
    return listen(oSocketAddrINet);
  }
 
SINT32 CASocket::accept(CASocket &s)
  {
    if(m_bSocketIsClosed) //the accept socket should not be closed!!
      return E_SOCKETCLOSED;
    if(!s.m_bSocketIsClosed) //but the new socket should be closed!!!
      return E_UNKNOWN;
    if(m_u32NormalSocketsOpen>=m_u32MaxNormalSockets)
      {
        CAMsg::printMsg(LOG_CRIT,"CASocket::accept() -- Could not create a new normal Socket -- allowed number of normal sockets exeded!\n");
        return E_SOCKET_LIMIT;
      }
    SOCKET sock=::accept(m_Socket,NULL,NULL);
    if (sock == SOCKET_ERROR)
      {
        s.setSocket(0);
        if(GET_NET_ERROR==ERR_INTERN_SOCKET_CLOSED)
          return E_SOCKETCLOSED;
        return E_UNKNOWN;
      }
    s.setSocket(sock);
    m_pcsClose->lock();
    m_u32NormalSocketsOpen++;
    s.m_bSocketIsClosed=false;
    m_pcsClose->unlock();
    //CAMsg::printMsg(LOG_DEBUG,"Opened socket: %d\n", s.m_Socket);
 
    return E_SUCCESS;
  }
 
 
SINT32 CASocket::connect(const CASocketAddr & psa,UINT32 retry,UINT32 time)
  {
//    CAMsg::printMsg(LOG_DEBUG,"Socket:connect\n");
    if(m_bSocketIsClosed&&create()!=E_SUCCESS)
      {
        return E_UNKNOWN;
      }
#ifdef _DEBUG
    sockets++;
#endif
    int err=0;
    const SOCKADDR* addr=psa.LPSOCKADDR();
    int addr_len=psa.getSize();
    for(UINT32 i=0;i<retry;i++)
      {
//        CAMsg::printMsg(LOG_DEBUG,"Socket:connect-connect\n");
        err=::connect(m_Socket,addr,addr_len);
//        CAMsg::printMsg(LOG_DEBUG,"Socket:connect-connect-finished err: %i\n",err);
        if(err!=0)
          {
            err=GET_NET_ERROR;
            #ifdef _DEBUG
             CAMsg::printMsg(LOG_DEBUG,"Con-Error: %i\n",err);
            #endif
            if(err!=ERR_INTERN_TIMEDOUT&&err!=ERR_INTERN_CONNREFUSED)
              return E_UNKNOWN; //Should be better.....
            #ifdef _DEBUG
              CAMsg::printMsg(LOG_DEBUG,"Cannot connect... retrying\n");
            #endif
            sSleep((UINT16)time);
          }
        else
            return E_SUCCESS;
      }
    return err;
  }
 
 
SINT32 CASocket::connect(const CASocketAddr & psa,UINT32 msTimeOut)
  {
    if(m_bSocketIsClosed&&create(psa.getType())!=E_SUCCESS)
      {
        return E_UNKNOWN;
      }
#ifdef _DEBUG
    sockets++;
#endif
    bool bWasNonBlocking=false;
    getNonBlocking(&bWasNonBlocking);
    setNonBlocking(true);
    int err=0;
    const LPSOCKADDR addr=(const LPSOCKADDR)psa.LPSOCKADDR();
    int addr_len=psa.getSize();
 
    err=::connect(m_Socket,addr,addr_len);
    if(err==0)
      return E_SUCCESS;
    err=GET_NET_ERROR;
#ifdef _WIN32
    if(err!=WSAEWOULDBLOCK)
      return E_SOCKET_CONNECT;
#else
    if(err!=EINPROGRESS)
    {
      return E_SOCKET_CONNECT;
    }
#endif
 
#ifndef HAVE_POLL
    struct timeval tval;
    tval.tv_sec=msTimeOut/1000;
    tval.tv_usec=(msTimeOut%1000)*1000;
    fd_set readSet,writeSet;
    FD_ZERO(&readSet);
    FD_ZERO(&writeSet);
    #pragma warning( push )
    #pragma warning( disable : 4127 ) //Disable: Bedingter Ausdruck ist konstant
    FD_SET(m_Socket,&readSet);
    FD_SET(m_Socket,&writeSet);
    #pragma warning( pop )
    err=::select(m_Socket+1,&readSet,&writeSet,NULL,&tval);
#else
    struct pollfd opollfd;
    opollfd.fd=m_Socket;
    opollfd.events=POLLIN|POLLOUT;
    err=::poll(&opollfd,1,msTimeOut);
#endif
    if (err<1) //timeout or error Note: we do not check for !=1 here because for some strange reasons FreeBSD 8.0-rc2 returns: 2 - Why?
    {
      err = GET_NET_ERROR;
      close();
      SET_NET_ERROR(err);
      
      if (GET_NET_ERROR == EINPROGRESS)
      {
        return E_UNKNOWN;
      }
      
      return E_SOCKET_CONNECT;
    }
    socklen_t len=sizeof(err);
    err=0;
    if (::getsockopt(m_Socket,SOL_SOCKET,SO_ERROR,(char*)&err,&len)<0||err!=0) //error by connect
    {
      err = GET_NET_ERROR;
      close();
      SET_NET_ERROR(err);
      
      if (GET_NET_ERROR == EINPROGRESS)
      {
        return E_UNKNOWN;
      }
      
      return E_SOCKET_CONNECT;
    }
    setNonBlocking(bWasNonBlocking);
    return E_SUCCESS;
  }
 
SINT32 CASocket::close()
  {
    SINT32 ret;
 
    if(m_bSocketIsClosed)
    {
      return E_SUCCESS;
    }
 
    ret = m_pcsClose->lock();
    if (ret != E_SUCCESS)
    {
      CAMsg::printMsg(LOG_CRIT,
        "Could not get lock for closing socket! Error code: %d\n", ret);
      return ret;
    }
 
    if (!m_bSocketIsClosed)
    {
      shutdown(m_Socket,SHUT_RDWR); //call shutdown here because some OSes seems to ned it to
      //wakeup other threads which block in read() or write()
      ret=::closesocket(m_Socket);
      if(!m_bIsReservedSocket)
      {
        m_u32NormalSocketsOpen--;
      }
      //CAMsg::printMsg(LOG_DEBUG,"Open Sockets: %d\n", m_u32NormalSocketsOpen);
      //CAMsg::printMsg(LOG_DEBUG,"Closed socket: %d\n", m_Socket);
      setSocket(0);
      m_bSocketIsClosed=true;
    }
 
    if (ret != E_SUCCESS)
    {
      ret = GET_NET_ERROR;
    }
 
    m_pcsClose->unlock();
    return ret;
  }
 
SINT32 CASocket::send(const UINT8* buff,UINT32 len)
  {
    if(len==0)
      return 0; //nothing to send
    int ret;
    SINT32 ef=0;
    do
      {
        ret=::send(m_Socket,(char*)buff,len,MSG_NOSIGNAL);
        #ifdef _DEBUG
          if(ret==SOCKET_ERROR)
            CAMsg::printMsg(LOG_DEBUG,"Fehler beim Socket-send: %i (Socket: %i)\n",GET_NET_ERROR,m_Socket);
        #endif
      }
    while(ret==SOCKET_ERROR&&(ef=GET_NET_ERROR)==EINTR);
    if(ret==SOCKET_ERROR)
      {
        if(ef==ERR_INTERN_WOULDBLOCK)
          {
            #ifdef _DEBUG
              CAMsg::printMsg(LOG_DEBUG,"Fehler beim Socket-send: E_AGAIN\n");
            #endif
            return E_AGAIN;
          }
        #ifdef _DEBUG
          CAMsg::printMsg(LOG_DEBUG,"Fehler beim Socket-send:E_UNKNOWN (ef=%i)\n",ef);
        #endif
        return E_UNKNOWN;
      }
    return ret;
  }
 
 
SINT32 CASocket::sendTimeOut(const UINT8* buff,UINT32 len,UINT32 msTimeOut)
{
  SINT32 ret;
  SINT32 aktTimeOut=0;
  bool bWasNonBlocking;
  getNonBlocking(&bWasNonBlocking);
  if(bWasNonBlocking) //we are in non-blocking mode
  {
    ret=send(buff,len);
  }
  else
  {
    aktTimeOut=getSendTimeOut();
    if(aktTimeOut>0&&(UINT32)aktTimeOut==msTimeOut) //we already have the right timeout
    {
      ret=send(buff,len);
    }
    else if(aktTimeOut<0||setSendTimeOut(msTimeOut)!=E_SUCCESS)
    {//do it complicate but still to simple!!!! more work TODO
      setNonBlocking(true);
      ret=send(buff,len);
      if(ret==E_AGAIN)
        {
          CAMsg::printMsg(LOG_DEBUG,"Send again...\n");
          msSleep((UINT16)msTimeOut);
          ret=send(buff,len);
        }
      setNonBlocking(bWasNonBlocking);
    }
    else
    {
      ret=send(buff,len);
      setSendTimeOut(aktTimeOut);
    }
  }
  return ret;
}
 
 
SINT32 CASocket::sendFullyTimeOut(const UINT8* buff,UINT32 len, UINT32 msTimeOut, UINT32 msTimeOutSingleSend)
{
  if(len==0)
  {
    return E_SUCCESS; //nothing to send
  }
 
  SINT32 ret;
  SINT32 aktTimeOut=0;
  UINT64 startupTime, currentMillis;
  CASingleSocketGroup* pSingleSocketGroup = NULL;
 
  bool bWasNonBlocking;
  getNonBlocking(&bWasNonBlocking);
  aktTimeOut=getSendTimeOut();
  getcurrentTimeMillis(startupTime);
 
  if(bWasNonBlocking)
  {
    //we are in non-blocking mode
#ifdef _DEBUG
    CAMsg::printMsg(LOG_DEBUG, "CASocket::sendFullyTimeOut() -->non-blocking case\n");
#endif
    return sendFully(buff, len);
  }
  else if (setSendTimeOut(msTimeOutSingleSend)!=E_SUCCESS)
  {
    // it is not possible to set the socket timeout
    CAMsg::printMsg(LOG_ERR,"CASocket::sendFullyTimeOut() - could not set socket timeout!\n");
    return sendFully(buff, len);
  }
  else
  {
    SINT32 retval = E_UNKNOWN;
    for(;;)
    {
      getcurrentTimeMillis(currentMillis);
      if (currentMillis >= (startupTime + msTimeOut))
      {
        #ifdef DEBUG
        CAMsg::printMsg(LOG_DEBUG,"CASocket::sendFullyTimeOut() - timed out!\n");
        #endif
        setSendTimeOut(aktTimeOut);
        SET_NET_ERROR(E_TIMEDOUT);
        retval=E_TIMEDOUT;
        break;
      }
 
      ret=send(buff,len);
#ifdef DEBUG
      CAMsg::printMsg(LOG_DEBUG, "CASocket::sendFullyTimeOut() - send returned %i (expected: %u)!\n",ret,len);
#endif
      if((UINT32)ret==len)
      {
        setSendTimeOut(aktTimeOut);
        retval=E_SUCCESS;
        break;
      }
      else if(ret==E_AGAIN)
      {
        if (pSingleSocketGroup == NULL)
        {
          pSingleSocketGroup = new CASingleSocketGroup(true);
          pSingleSocketGroup->add(*this);
        }
        ret= pSingleSocketGroup->select(1000);
        if(ret>=0||ret==E_TIMEDOUT)
          continue;
        #ifdef _DEBUG
          CAMsg::printMsg(LOG_DEBUG,"CASocket::sendTimeOutFully() - error near select_once() ret=%i\n",ret);
        #endif
        setSendTimeOut(aktTimeOut);
        retval=E_UNKNOWN;
        break;
      }
      else if(ret<0)
      {
        #ifdef _DEBUG
          CAMsg::printMsg(LOG_DEBUG,"CASocket::sendTimeOutFully() - send returned %i\n",ret);
        #endif
        setSendTimeOut(aktTimeOut);
        retval=E_UNKNOWN;
        break;
      }
      len-=ret;
      buff+=ret;
    }
    if (pSingleSocketGroup != NULL)
      delete pSingleSocketGroup;
    return retval;
  }
}
 
SINT32 CASocket::sendFully(const UINT8* buff,UINT32 len)
  {
    if(len==0)
      return E_SUCCESS; //nothing to send
    SINT32 ret;
    CASingleSocketGroup* pSingleSocketGroup = NULL;
    SINT32 retval = E_UNKNOWN;
    for(;;)
      {
        ret=send(buff,len);
        if((UINT32)ret==len)
          return E_SUCCESS;
        else if(ret==E_AGAIN)
          {
            if (pSingleSocketGroup == NULL)
            {
              pSingleSocketGroup = new CASingleSocketGroup(true);
              pSingleSocketGroup->add(*this);
            }
 
            ret= pSingleSocketGroup->select(1000);
            if(ret>=0||ret==E_TIMEDOUT)
              continue;
            #ifdef _DEBUG
              CAMsg::printMsg(LOG_DEBUG,"CASocket::sendFully() - error near select_once() ret=%i\n",ret);
            #endif
            retval=E_UNKNOWN;
            break;
          }
        else if(ret<0)
          {
            #ifdef _DEBUG
              CAMsg::printMsg(LOG_DEBUG,"CASocket::sendFully() - send returned %i\n",ret);
            #endif
            retval=E_UNKNOWN;
            break;
          }
        len-=ret;
        buff+=ret;
      }
    if (pSingleSocketGroup != NULL)
      delete pSingleSocketGroup;
    return retval;
}
 
SINT32 CASocket::receive(UINT8* buff,UINT32 len)
  {
    int ret;
    int ef=0;
    do
      {
        ret=::recv(m_Socket,(char*)buff,len,MSG_NOSIGNAL);
      }
    while(ret==SOCKET_ERROR&&(ef=GET_NET_ERROR)==EINTR);
    if(ret==SOCKET_ERROR)
      {
        if(ef==ERR_INTERN_WOULDBLOCK)
          return E_AGAIN;
      }
#ifdef _DEBUG
    if(ret==SOCKET_ERROR)
        CAMsg::printMsg(LOG_DEBUG,"CASocket Receive error %d (%s)\n",ef,GET_NET_ERROR_STR(ef));
#endif
    return ret;
  }
 
SINT32 CASocket::receiveFullyT(UINT8* buff,UINT32 len,UINT32 msTimeOut)
  {
    SINT32 ret;
    UINT32 pos=0;
    UINT64 currentTime,endTime;
    getcurrentTimeMillis(currentTime);
    set64(endTime,currentTime);
    add64(endTime,msTimeOut);
//    CASingleSocketGroup oSG(false);
//    oSG.add(*this);
    for(;;)
      {
        ret = m_pSingleSocketGroupRead->select(msTimeOut);
        if(ret==1)
          {
            ret=receive(buff+pos,len);
            if(ret<=0)
              return E_UNKNOWN;
            pos+=ret;
            len-=ret;
          }
        else if(ret==E_TIMEDOUT)
        {
          return E_TIMEDOUT;
        }
        if(len==0)
          return E_SUCCESS;
        getcurrentTimeMillis(currentTime);
        if(!isLesser64(currentTime,endTime))
        {
          SET_NET_ERROR(E_TIMEDOUT);
          return E_TIMEDOUT;
        }
        msTimeOut=diff64(endTime,currentTime);
      }
  }
 
SINT32 CASocket::receiveLine(UINT8* line, UINT32 maxLen, UINT32 msTimeOut)
{
  UINT32 i = 0;
  UINT8 byte = 0;
  SINT32 ret = 0;
  UINT64 currentTime, endTime;
  getcurrentTimeMillis(currentTime);
  set64(endTime,currentTime);
  add64(endTime,msTimeOut);
//  CASingleSocketGroup oSG(false);
//  oSG.add(*this);
  do
  {
      ret = m_pSingleSocketGroupRead->select(msTimeOut);
    if(ret == 1)
    {
      ret = receive(&byte, 1);
      if(byte == '\r' || byte == '\n')
      {
        line[i++] = 0;
      }
      else
      {
        line[i++] = byte;
      }
    }
    else if(ret == E_TIMEDOUT)
    {
      return E_TIMEDOUT;
    }
    getcurrentTimeMillis(currentTime);
    if(!isLesser64(currentTime,endTime))
    {
      SET_NET_ERROR(E_TIMEDOUT);
      return E_TIMEDOUT;
    }
    msTimeOut=diff64(endTime,currentTime);
  }
  while(byte != '\n' && i<maxLen && ret > 0);
 
  return ret;
}
 
SINT32 CASocket::peek(UINT8* buff,UINT32 len)
  {
    int ret;
    int ef=0;
    do
      {
        ret=::recv(m_Socket,(char*)buff,len,MSG_NOSIGNAL|MSG_PEEK);
      }
    while(ret==SOCKET_ERROR&&(ef=GET_NET_ERROR)==EINTR);
    if(ret==SOCKET_ERROR)
      {
        if(ef==ERR_INTERN_WOULDBLOCK)
          return E_AGAIN;
      }
#ifdef _DEBUG
    if(ret==SOCKET_ERROR)
        CAMsg::printMsg(LOG_DEBUG,"CASocket peek() error %d (%s)\n",ef,GET_NET_ERROR_STR(ef));
#endif
    return ret;
  }
 
 
SINT32 CASocket::getLocalIP(UINT8 r_Ip[4])
{
      struct sockaddr_in addr;
      socklen_t namelen=sizeof(struct sockaddr_in);
      if(getsockname(m_Socket,(struct sockaddr*)&addr,&namelen)==SOCKET_ERROR)
         return SOCKET_ERROR;
      memcpy(r_Ip,&addr.sin_addr,4);
      return E_SUCCESS;
}
 
SINT32 CASocket::getLocalPort()
  {
    struct sockaddr_in addr;
    socklen_t namelen=sizeof(struct sockaddr_in);
    if(getsockname(m_Socket,(struct sockaddr*)&addr,&namelen)==SOCKET_ERROR)
      return SOCKET_ERROR;
    return ntohs(addr.sin_port);
  }
 
SINT32 CASocket::getPeerIP(UINT8 ip[4])
  {
    struct sockaddr_in addr;
    socklen_t namelen=sizeof(struct sockaddr_in);
    if(getpeername(m_Socket,(struct sockaddr*)&addr,&namelen)==SOCKET_ERROR)
      return SOCKET_ERROR;
    memcpy(ip,&addr.sin_addr,4);
    return E_SUCCESS;
  }
 
SINT32 CASocket::getPeerPort()
  {
    struct sockaddr_in addr;
    socklen_t namelen=sizeof(struct sockaddr_in);
    if(getpeername(m_Socket,(struct sockaddr*)&addr,&namelen)==SOCKET_ERROR)
      return SOCKET_ERROR;
    return ntohs(addr.sin_port);
  }
 
SINT32 CASocket::setReuseAddr(bool b)
  {
    int val=0;
    if(b) val=1;
    return setsockopt(m_Socket,SOL_SOCKET,SO_REUSEADDR,(char*)&val,sizeof(val));
  }
 
SINT32 CASocket::setRecvBuff(UINT32 r)
  {
    int val=r;
    return setsockopt(m_Socket,SOL_SOCKET,SO_RCVBUF,(char*)&val,sizeof(val));
  }
 
SINT32 CASocket::getRecvBuff()
  {
    int val;
    socklen_t size=sizeof(val);
    if(getsockopt(m_Socket,SOL_SOCKET,SO_RCVBUF,(char*)&val,&size)==SOCKET_ERROR)
      return E_UNKNOWN;
    else
      return val;
  }
SINT32 CASocket::setSendBuff(SINT32 r)
  {
    if(r<0)
      return E_UNKNOWN;
    SINT32 val=r;
    SINT32 ret=setsockopt(m_Socket,SOL_SOCKET,SO_SNDBUF,(char*)&val,sizeof(val));
    if(ret!=0)
      return E_UNKNOWN;
    return getSendBuff();
  }
 
SINT32 CASocket::getSendBuff()
  {
    SINT32 val;
    socklen_t size=sizeof(val);
    if(getsockopt(m_Socket,SOL_SOCKET,SO_SNDBUF,(char*)&val,&size)==SOCKET_ERROR)
      return E_UNKNOWN;
    else
      return val;
  }
 
SINT32 CASocket::setSendTimeOut(UINT32 msTimeOut)
  {
    timeval t;
    t.tv_sec=msTimeOut/1000;
    t.tv_usec=(msTimeOut%1000)*1000;
    return setsockopt(m_Socket,SOL_SOCKET,SO_SNDTIMEO,(char*)&t,sizeof(t));
  }
 
SINT32 CASocket::getSendTimeOut()
  {
    timeval val;
    socklen_t size=sizeof(val);
    if(getsockopt(m_Socket,SOL_SOCKET,SO_SNDTIMEO,(char*)&val,&size)==SOCKET_ERROR)
      return E_UNKNOWN;
    else
      return val.tv_sec*1000+val.tv_usec/1000;
  }
 
SINT32 CASocket::setKeepAlive(bool b)
  {
    int val=0;
    if(b) val=1;
    if(setsockopt(m_Socket,SOL_SOCKET,SO_KEEPALIVE,(char*)&val,sizeof(val))==SOCKET_ERROR)
    {
      int errnum=GET_NET_ERROR;
      CAMsg::printMsg(LOG_ERR, "Could not set KEEP_ALIVE options. Reason: %s (%i)\n", GET_NET_ERROR_STR(errnum), errnum);
      return E_UNKNOWN;
    }
    return E_SUCCESS;
  }
 
SINT32 CASocket::setKeepAlive(UINT32 sec)
  {
    if(setKeepAlive(true)!=E_SUCCESS)
    {
      return E_UNKNOWN;
    }
 
#ifdef HAVE_TCP_KEEPALIVE
    int val=sec;
    if(setsockopt(m_Socket,IPPROTO_TCP,TCP_KEEPALIVE,(char*)&val,sizeof(val))==SOCKET_ERROR)
    {
      CAMsg::printMsg(LOG_ERR,"Socket option TCP-KEEP-ALIVE was not set! Reason: %s (%i)\n",
          GET_NET_ERROR_STR(GET_NET_ERROR), GET_NET_ERROR);
      return E_UNKNOWN;
    }
    return E_SUCCESS;
#else
    CAMsg::printMsg(LOG_INFO,"Socket option TCP-KEEP-ALIVE was not set as it is not available on this machine.\n");
    return E_UNKNOWN;
#endif
  }
 
 
SINT32 CASocket::setNonBlocking(bool b)
  {
    if(b)
      {
        #ifndef _WIN32
            int flags=fcntl(m_Socket,F_GETFL,0);
            fcntl(m_Socket,F_SETFL,flags|O_NONBLOCK);
        #else
            unsigned long flags=1;
            ioctlsocket(m_Socket,FIONBIO,&flags);
        #endif
      }
    else
      {
        #ifndef _WIN32
            int flags=fcntl(m_Socket,F_GETFL,0);
            fcntl(m_Socket,F_SETFL,flags&~O_NONBLOCK);
        #else
            unsigned long flags=0;
            ioctlsocket(m_Socket,FIONBIO,&flags);
        #endif
      }
    return E_SUCCESS;
  }
 
SINT32 CASocket::getNonBlocking(bool* b)
  {
    #ifndef _WIN32
        int flags=fcntl(m_Socket,F_GETFL,0);
        *b=((flags&O_NONBLOCK)==O_NONBLOCK);
        return E_SUCCESS;
    #else
        return SOCKET_ERROR;
    #endif
  }
 
SINT32 CASocket::getMaxOpenSockets()
{
  CASocket* parSocket=new CASocket[10001];
  UINT32 maxSocket=0;
  for(UINT32 t=0;t<10001;t++)
    {
    if(parSocket[t].create(false)!=E_SUCCESS)
      {
      maxSocket=t;
      break;
      }
    }
  for(UINT32 t=0;t<maxSocket;t++)
    {
    parSocket[t].close();
    }
  delete []parSocket;
  parSocket = NULL;
  return maxSocket;
}