CASocketGroup Class Reference

Inheritance diagram for CASocketGroup:

Public Member Functions
	CASocketGroup (bool bWrite)
	~CASocketGroup ()
SINT32	setPoolForWrite (bool bWrite)
SINT32	add (SOCKET &s)
SINT32	add (CASocket &s)
SINT32	add (CAMuxSocket &s)
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)

Private Attributes
fd_set	m_fdset
fd_set	m_signaled_set
fd_set *	m_set_read
fd_set *	m_set_write
SINT32	m_max
CAMutex	m_csFD_SET

Constructor & Destructor Documentation

CASocketGroup()

CASocketGroup::CASocketGroup

(

bool

bWrite

)

References m_fdset, m_max, m_signaled_set, MAX_POLLFD, and setPoolForWrite().

~CASocketGroup()

CASocketGroup::~CASocketGroup

(

)

Member Function Documentation

add() [1/3]

SINT32 CASocketGroup::add

(

CAMuxSocket &

s

)

References E_SUCCESS, CAMuxSocket::getSocket(), CAMutex::lock(), m_csFD_SET, m_fdset, m_max, and CAMutex::unlock().

add() [2/3]

SINT32 CASocketGroup::add

(

CASocket &

s

)

References E_SUCCESS, CASocket::getSocket(), CAMutex::lock(), m_csFD_SET, m_fdset, m_max, and CAMutex::unlock().

add() [3/3]

SINT32 CASocketGroup::add

(

SOCKET &

s

)

References E_SUCCESS, CAMutex::lock(), m_csFD_SET, m_fdset, m_max, and CAMutex::unlock().

Referenced by CAChain::addToSocketGroup(), CAMuxSocket::receive(), CAClientSocket::receiveFully(), CASocket::sendFully(), CASocket::sendFullyTimeOut(), and CASocket::setSocket().

isSignaled() [1/3]

bool CASocketGroup::isSignaled

(

CAMuxSocket &

s

)

References CAMuxSocket::getSocket(), and m_signaled_set.

isSignaled() [2/3]

bool CASocketGroup::isSignaled

(

CASocket &

s

)

References CASocket::getSocket(), and m_signaled_set.

isSignaled() [3/3]

bool CASocketGroup::isSignaled

(

CASocket *

ps

)

References CASocket::getSocket(), and m_signaled_set.

remove() [1/2]

SINT32 CASocketGroup::remove

(

CAMuxSocket &

s

)

References E_SUCCESS, CAMuxSocket::getSocket(), CAMutex::lock(), m_csFD_SET, m_fdset, and CAMutex::unlock().

remove() [2/2]

SINT32 CASocketGroup::remove

(

CASocket &

s

)

References E_SUCCESS, CASocket::getSocket(), CAMutex::lock(), m_csFD_SET, m_fdset, and CAMutex::unlock().

Referenced by CAChain::removeFromSocketGroup().

select() [1/2]

SINT32 CASocketGroup::select

(

)

References GET_NET_ERROR, CAMutex::lock(), m_csFD_SET, m_fdset, m_max, m_set_read, m_set_write, m_signaled_set, CAMsg::printMsg(), SOCKET_ERROR, and CAMutex::unlock().

Referenced by CAMuxSocket::receive(), CAClientSocket::receiveFully(), CASocket::receiveFullyT(), CASocket::receiveLine(), select(), CASingleSocketGroup::select_once(), CASocket::sendFully(), and CASocket::sendFullyTimeOut().

select() [2/2]

SINT32 CASocketGroup::select

(

UINT32

time_ms

)

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

References E_TIMEDOUT, E_UNKNOWN, GET_NET_ERROR, CAMutex::lock(), m_csFD_SET, m_fdset, m_max, m_set_read, m_set_write, m_signaled_set, CAMsg::printMsg(), select(), SOCKET_ERROR, and CAMutex::unlock().

setPoolForWrite()

SINT32 CASocketGroup::setPoolForWrite

(

bool

bWrite

)

References E_SUCCESS, m_set_read, m_set_write, m_signaled_set, and MAX_POLLFD.

Referenced by CASocketGroup().

Member Data Documentation

m_csFD_SET

CAMutex CASocketGroup::m_csFD_SET

private

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

m_fdset

fd_set CASocketGroup::m_fdset

private

Referenced by add(), CASocketGroup(), remove(), and select().

m_max

SINT32 CASocketGroup::m_max

private

Referenced by add(), CASocketGroup(), and select().

m_set_read

fd_set* CASocketGroup::m_set_read

private

Referenced by select(), and setPoolForWrite().

m_set_write

fd_set * CASocketGroup::m_set_write

private

Referenced by select(), and setPoolForWrite().

m_signaled_set

fd_set CASocketGroup::m_signaled_set

private

Referenced by CASocketGroup(), isSignaled(), select(), and setPoolForWrite().