CASocketGroupEpoll Class Reference

#include <CASocketGroupEpoll.hpp>

Collaboration diagram for CASocketGroupEpoll:

Public Member Functions
	CASocketGroupEpoll (bool bWrite)
	~CASocketGroupEpoll ()
SINT32	setPoolForWrite (bool bWrite)
SINT32	add (CASocket &s)
	Adds the socket s to the socket group. More...
SINT32	add (CAMuxSocket &s)
	Adds the socket s to the socket group. More...
SINT32	add (CASocket &s, void *datapointer)
SINT32	add (CAMuxSocket &s, void *datapointer)
	Adds the socket s to the socket group. More...
SINT32	remove (CASocket &s)
SINT32	remove (CAMuxSocket &s)
SINT32	select ()
SINT32	select (UINT32 time_ms)
	Waits for events on the sockets. More...
bool	isSignaled (CASocket &s)
bool	isSignaled (CASocket *ps)
bool	isSignaled (CAMuxSocket &s)
bool	isSignaled (void *datapointer)
void *	getFirstSignaledSocketData ()
void *	getNextSignaledSocketData ()

Private Attributes
EPOLL_HANDLE	m_hEPFD
struct epoll_event *	m_pEvents
struct epoll_event *	m_pEpollEvent
SINT32	m_iNumOfReadyFD
SINT32	m_iAktSignaledSocket
CAMutex *	m_pcsFD_SET

Detailed Description

Definition at line 42 of file CASocketGroupEpoll.hpp.

Constructor & Destructor Documentation

CASocketGroupEpoll()

CASocketGroupEpoll::CASocketGroupEpoll

(

bool

bWrite

)

Definition at line 31 of file CASocketGroupEpoll.cpp.

  {
    m_pcsFD_SET = new CAMutex();
    m_hEPFD=epoll_create(MAX_POLLFD);
    m_pEpollEvent=new struct epoll_event;
    memset(m_pEpollEvent,0,sizeof(struct epoll_event));
    m_pEvents=new struct epoll_event[MAX_POLLFD];
    setPoolForWrite(bWrite);
  }

References m_hEPFD, m_pcsFD_SET, m_pEpollEvent, m_pEvents, MAX_POLLFD, and setPoolForWrite().

Here is the call graph for this function:

~CASocketGroupEpoll()

CASocketGroupEpoll::~CASocketGroupEpoll

(

)

Definition at line 41 of file CASocketGroupEpoll.cpp.

  {
    epoll_close(m_hEPFD);
    delete[] m_pEvents;
    m_pEvents = NULL;
    delete m_pEpollEvent;
    m_pEpollEvent = NULL;
    delete m_pcsFD_SET;
  }

References epoll_close, m_hEPFD, m_pcsFD_SET, m_pEpollEvent, and m_pEvents.

Member Function Documentation

add() [1/4]

SINT32 CASocketGroupEpoll::add ( CAMuxSocket &  s )

inline

Adds the socket s to the socket group.

Definition at line 56 of file CASocketGroupEpoll.hpp.

      {
        return add(s, NULL);
      }

References add().

Here is the call graph for this function:

add() [2/4]

SINT32 CASocketGroupEpoll::add ( CAMuxSocket &  s, void *  datapointer  )

inline

Adds the socket s to the socket group.

Additional one can set a parameter datapointer, which is assoziated with the socket s

Definition at line 95 of file CASocketGroupEpoll.hpp.

        {
          return add(*(s.getCASocket()),datapointer);
        }

References add(), and CAMuxSocket::getCASocket().

Here is the call graph for this function:

add() [3/4]

SINT32 CASocketGroupEpoll::add ( CASocket &  s )

inline

Adds the socket s to the socket group.

Definition at line 50 of file CASocketGroupEpoll.hpp.

      {
        return add(s,NULL);
      }

Referenced by add(), CALocalProxy::loop(), CAFirstMixA::loop(), CALastMixA::loop(), and CAFirstMixB::loop().

Here is the caller graph for this function:

add() [4/4]

SINT32 CASocketGroupEpoll::add ( CASocket &  s, void *  datapointer  )

inline

Definition at line 65 of file CASocketGroupEpoll.hpp.

        {
          SINT32 ret=E_SUCCESS;
          m_pcsFD_SET->lock();
          SOCKET socket=s.getSocket();
          if (datapointer != NULL)
            m_pEpollEvent->data.ptr = datapointer;
          else
            m_pEpollEvent->data.fd = socket;
 
          if (epoll_ctl(m_hEPFD, EPOLL_CTL_ADD, socket, m_pEpollEvent) != 0)
            {
              SINT32 err = GETERROR;
              if (err == EEXIST)
                {
                  ret=E_ALREADY_CONTAINED;
                }
              else
                {
                  CAMsg::printMsg(LOG_DEBUG, "Failed to add socket %i to epoll group --- errno: %i\n", socket, err);
                  ret = E_UNKNOWN;
                }
            }
          m_pcsFD_SET->unlock();
          return ret;
        }

References E_SUCCESS, E_UNKNOWN, GETERROR, CASocket::getSocket(), CAMutex::lock(), m_hEPFD, m_pcsFD_SET, m_pEpollEvent, CAMsg::printMsg(), SOCKET, and CAMutex::unlock().

Here is the call graph for this function:

getFirstSignaledSocketData()

void* CASocketGroupEpoll::getFirstSignaledSocketData ( )

inline

Definition at line 202 of file CASocketGroupEpoll.hpp.

        {
          m_iAktSignaledSocket=0;
          if(m_iNumOfReadyFD>0)
            return m_pEvents[0].data.ptr;
          return NULL;
        }

References m_iAktSignaledSocket, m_iNumOfReadyFD, and m_pEvents.

Referenced by CAFirstMixA::loop(), CALastMixA::loop(), CAFirstMixB::loop(), CALastMixB::loop(), and CAFirstMixA::sendToUsers().

Here is the caller graph for this function:

getNextSignaledSocketData()

void* CASocketGroupEpoll::getNextSignaledSocketData ( )

inline

Definition at line 211 of file CASocketGroupEpoll.hpp.

        {
          m_iAktSignaledSocket++;
          if(m_iNumOfReadyFD>m_iAktSignaledSocket)
            return m_pEvents[m_iAktSignaledSocket].data.ptr;
          return NULL;
        }

References m_iAktSignaledSocket, m_iNumOfReadyFD, and m_pEvents.

Referenced by CAFirstMixA::loop(), CALastMixA::loop(), CAFirstMixB::loop(), CALastMixB::loop(), and CAFirstMixA::sendToUsers().

Here is the caller graph for this function:

isSignaled() [1/4]

bool CASocketGroupEpoll::isSignaled ( CAMuxSocket &  s )

inline

Definition at line 179 of file CASocketGroupEpoll.hpp.

        {
          SINT32 socket=s.getSocket();
          for(SINT32 i=0;i<m_iNumOfReadyFD;i++)
            {
              if(socket==m_pEvents[i].data.fd)
                return true;
            }
          return false;
        }

References data, CAMuxSocket::getSocket(), m_iNumOfReadyFD, and m_pEvents.

Here is the call graph for this function:

isSignaled() [2/4]

bool CASocketGroupEpoll::isSignaled ( CASocket &  s )

inline

Definition at line 155 of file CASocketGroupEpoll.hpp.

        {
          SINT32 socket=s.getSocket();
          for(SINT32 i=0;i<m_iNumOfReadyFD;i++)
            {
              if(socket==m_pEvents[i].data.fd)
                return true;
            }
          return false;
        }

References data, CASocket::getSocket(), m_iNumOfReadyFD, and m_pEvents.

Referenced by CAChain::isSignaledInSocketGroup(), CALocalProxy::loop(), CAFirstMixA::loop(), CALastMixA::loop(), CAFirstMixB::loop(), and CAFirstMixA::sendToUsers().

Here is the call graph for this function:

Here is the caller graph for this function:

isSignaled() [3/4]

bool CASocketGroupEpoll::isSignaled ( CASocket *  ps )

inline

Definition at line 167 of file CASocketGroupEpoll.hpp.

        {
        SINT32 socket=ps->getSocket();
          for(SINT32 i=0;i<m_iNumOfReadyFD;i++)
            {
              if(socket==m_pEvents[i].data.fd)
                return true;
            }
          return false;
        }

References data, CASocket::getSocket(), m_iNumOfReadyFD, and m_pEvents.

Here is the call graph for this function:

isSignaled() [4/4]

bool CASocketGroupEpoll::isSignaled ( void *  datapointer )

inline

Definition at line 191 of file CASocketGroupEpoll.hpp.

        {
          for(SINT32 i=0;i<m_iNumOfReadyFD;i++)
            {
              if(datapointer==m_pEvents[i].data.ptr)
                return true;
            }
          return false;
        }

References data, m_iNumOfReadyFD, and m_pEvents.

remove() [1/2]

SINT32 CASocketGroupEpoll::remove ( CAMuxSocket &  s )

inline

Definition at line 111 of file CASocketGroupEpoll.hpp.

        {
          return remove(*(s.getCASocket()));
        }

References CAMuxSocket::getCASocket(), and remove().

Here is the call graph for this function:

remove() [2/2]

SINT32 CASocketGroupEpoll::remove ( CASocket &  s )

inline

Definition at line 100 of file CASocketGroupEpoll.hpp.

        {
          SINT32 ret=E_SUCCESS;
          m_pcsFD_SET->lock();
          if(epoll_ctl(m_hEPFD,EPOLL_CTL_DEL,s.getSocket(),m_pEpollEvent)!=0)
            ret=E_UNKNOWN;
          ASSERT(ret==E_SUCCESS,"Error in Epoll socket group remove")
            m_pcsFD_SET->unlock();
          return ret;
        }

References ASSERT, E_SUCCESS, E_UNKNOWN, CASocket::getSocket(), CAMutex::lock(), m_hEPFD, m_pcsFD_SET, m_pEpollEvent, and CAMutex::unlock().

Referenced by CAFirstMixA::closeConnection(), CALocalProxy::loop(), CALastMixA::loop(), CAFirstMixB::loop(), remove(), and CAChain::removeFromAllSocketGroupsInternal().

Here is the call graph for this function:

Here is the caller graph for this function:

select() [1/2]

SINT32 CASocketGroupEpoll::select ( )

inline

Definition at line 116 of file CASocketGroupEpoll.hpp.

        {
        m_pcsFD_SET->lock();
          m_iNumOfReadyFD=epoll_wait(m_hEPFD,m_pEvents,MAX_POLLFD,-1);
          if(m_iNumOfReadyFD>0)
            {
              m_pcsFD_SET->unlock();
              return m_iNumOfReadyFD;
            }
          m_pcsFD_SET->unlock();
          return E_UNKNOWN;
        }

References E_UNKNOWN, CAMutex::lock(), m_hEPFD, m_iNumOfReadyFD, m_pcsFD_SET, m_pEvents, MAX_POLLFD, and CAMutex::unlock().

Referenced by CALocalProxy::loop(), CAFirstMixA::loop(), CALastMixA::loop(), CAFirstMixB::loop(), CALastMixB::loop(), and CAFirstMixA::sendToUsers().

Here is the call graph for this function:

Here is the caller graph for this function:

select() [2/2]

SINT32 CASocketGroupEpoll::select ( UINT32  time_ms )

inline

Waits for events on the sockets.

If after ms milliseconds no event occurs, E_TIMEDOUT is returned

Parameters

time_ms

- maximum milliseconds to wait

Return values

E_TIMEDOUT,if	other ms milliseconds no event occurs
E_UNKNOWN,if	an error occured

Returns

number of read/writeable sockets

Definition at line 136 of file CASocketGroupEpoll.hpp.

        {
          m_pcsFD_SET->lock();
          m_iNumOfReadyFD=epoll_wait(m_hEPFD,m_pEvents,MAX_POLLFD,time_ms);
          if(m_iNumOfReadyFD>0)
            {
              m_pcsFD_SET->unlock();
              return m_iNumOfReadyFD;
            }
          else if(m_iNumOfReadyFD==0)
            {
              m_pcsFD_SET->unlock();
              return E_TIMEDOUT;
            }
          m_pcsFD_SET->unlock();
          return E_UNKNOWN;
        }

References E_TIMEDOUT, E_UNKNOWN, CAMutex::lock(), m_hEPFD, m_iNumOfReadyFD, m_pcsFD_SET, m_pEvents, MAX_POLLFD, and CAMutex::unlock().

Here is the call graph for this function:

setPoolForWrite()

SINT32 CASocketGroupEpoll::setPoolForWrite

(

bool

bWrite

)

Definition at line 51 of file CASocketGroupEpoll.cpp.

  {
    if(bWrite)
      m_pEpollEvent->events=EPOLLOUT|EPOLLERR|EPOLLHUP;
    else
      m_pEpollEvent->events=EPOLLIN| EPOLLERR|EPOLLHUP;
    return E_SUCCESS;
  }

References E_SUCCESS, and m_pEpollEvent.

Referenced by CASocketGroupEpoll().

Here is the caller graph for this function:

Member Data Documentation

m_hEPFD

EPOLL_HANDLE CASocketGroupEpoll::m_hEPFD

private

Definition at line 220 of file CASocketGroupEpoll.hpp.

Referenced by add(), CASocketGroupEpoll(), remove(), select(), and ~CASocketGroupEpoll().

m_iAktSignaledSocket

SINT32 CASocketGroupEpoll::m_iAktSignaledSocket

private

Definition at line 224 of file CASocketGroupEpoll.hpp.

Referenced by getFirstSignaledSocketData(), and getNextSignaledSocketData().

m_iNumOfReadyFD

SINT32 CASocketGroupEpoll::m_iNumOfReadyFD

private

Definition at line 223 of file CASocketGroupEpoll.hpp.

Referenced by getFirstSignaledSocketData(), getNextSignaledSocketData(), isSignaled(), and select().

m_pcsFD_SET

CAMutex* CASocketGroupEpoll::m_pcsFD_SET

private

Definition at line 225 of file CASocketGroupEpoll.hpp.

Referenced by add(), CASocketGroupEpoll(), remove(), select(), and ~CASocketGroupEpoll().

m_pEpollEvent

struct epoll_event* CASocketGroupEpoll::m_pEpollEvent

private

Definition at line 222 of file CASocketGroupEpoll.hpp.

Referenced by add(), CASocketGroupEpoll(), remove(), setPoolForWrite(), and ~CASocketGroupEpoll().

m_pEvents

struct epoll_event* CASocketGroupEpoll::m_pEvents

private

Definition at line 221 of file CASocketGroupEpoll.hpp.

Referenced by CASocketGroupEpoll(), getFirstSignaledSocketData(), getNextSignaledSocketData(), isSignaled(), select(), and ~CASocketGroupEpoll().

---

The documentation for this class was generated from the following files:

• CASocketGroupEpoll.hpp
• CASocketGroupEpoll.cpp