CALastMix.cpp File Reference

Functions
THREAD_RETURN	lm_loopLog (void *param)
THREAD_RETURN	lm_loopSendToMix (void *param)
	How to end this thread: 0.
THREAD_RETURN	lm_loopReadFromMix (void *pParam)

---

Function Documentation

THREAD_RETURN lm_loopLog

(

void *

param

)

References logMemoryUsage(), CALastMix::m_bRunLog, CALastMix::m_logDownloadedBytes, CALastMix::m_logDownloadedPackets, CALastMix::m_logUploadedBytes, CALastMix::m_logUploadedPackets, print64(), CAMsg::printMsg(), sSleep(), and THREAD_RETURN_SUCCESS.

THREAD_RETURN lm_loopReadFromMix

(

void *

pParam

)

References CASocketGroup::add(), CAQueue::add(), t_MixPacket::channel, CHANNEL_DUMMY, t_MixPacket::data, DATA_SIZE, diff64(), DUMMY_CHANNEL, E_TIMEDOUT, ev_net_prevConnectionClosed, t_MixPacket::flags, getcurrentTimeMicros(), getcurrentTimeMillis(), getRandom(), CAQueue::getSize(), CALastMix::m_bRestart, CALastMix::m_pMuxIn, CALastMix::m_pQueueReadFromMix, CAMix::m_u32KeepAliveRecvInterval, MAX_READ_FROM_PREV_MIX_QUEUE_SIZE, MIX_POOL_TIMEOUT, MIXPACKET_SIZE, MONITORING_FIRE_NET_EVENT, msSleep(), t_queue_entry::packet, CAPool::pool(), CAMsg::printMsg(), CAMuxSocket::receive(), CASocketGroup::select(), setZero64(), and THREAD_RETURN_SUCCESS.

THREAD_RETURN lm_loopSendToMix

(

void *

param

)

How to end this thread: 0.

set m_bRestart=true; 1. Close connection to next mix 2. put a byte in the Mix-Output-Queue

References t_MixPacket::channel, CHANNEL_DATA, CHANNEL_DUMMY, t_MixPacket::data, DATA_SIZE, DUMMY_CHANNEL, E_SUCCESS, E_TIMEDOUT, ev_net_prevConnectionClosed, t_MixPacket::flags, getcurrentTimeMicros(), CAQueue::getOrWait(), getRandom(), isZero64(), len, CALastMix::m_bRestart, CALastMix::m_pMuxIn, CALastMix::m_pQueueSendToMix, CAMix::m_u32KeepAliveSendInterval, MIX_POOL_TIMEOUT, MIXPACKET_SIZE, MONITORING_FIRE_NET_EVENT, t_queue_entry::packet, CAPool::pool(), CAMsg::printMsg(), CAMuxSocket::send(), setZero64(), and THREAD_RETURN_SUCCESS.