StdAfx.h File Reference

Defines
#define	MIX_VERSION   "00.11.06"
#define	MIX_VERSION_TESTING   true
#define	MIX_VERSION_TESTING_TEXT   "This is a testing/development version. Please do not expect it to work in a productive environment, and don't be surprised if you get unpredictive results or segmentation faults. If you don't like experiments, go and get the stable code.\n"
#define	NO_INFOSERVICE_TRHEADS
#define	LOG_COUNTRIES_INTERVALL   6
#define	DELAY_USERS_BUCKET_GROW_INTERVALL   100
#define	DELAY_USERS_BUCKET_GROW   10
#define	REPLAY_TIMESTAMP_PROPAGATION_INTERVALL   1
#define	KEEP_ALIVE_TRAFFIC_RECV_WAIT_TIME   75000
#define	KEEP_ALIVE_TRAFFIC_SEND_WAIT_TIME   65000
#define	MAX_POLLFD   8192
#define	CLIENTS_PER_IP   10
#define	CHANNELS_PER_CLIENT   50
#define	FIRST_MIX_RECEIVE_SYM_KEY_FROM_JAP_TIME_OUT   40000
#define	LAST_MIX_TO_PROXY_CONNECT_TIMEOUT   2000
#define	AI_LOGIN_SO_TIMEOUT   (UINT32) 10000
#define	LAST_MIX_TO_PROXY_SEND_TIMEOUT   (UINT32)5000
#define	MIX_TO_INFOSERVICE_TIMEOUT   30000
#define	NUM_LOGIN_WORKER_TRHEADS   10
#define	MAX_LOGIN_QUEUE   500
#define	MAX_USER_SEND_QUEUE   100000
#define	MAX_DATA_PER_CHANNEL   100000
#define	USER_SEND_BUFFER_RESUME   10000
#define	PAYMENT_ACCOUNT_CERT_TIMEOUT   180
#define	CLEANUP_THREAD_SLEEP_INTERVAL   60
#define	BALANCE_REQUEST_TIMEOUT   60
#define	MAX_SIGNATURE_ELEMENTS   10
#define	FLOW_CONTROL_SENDME_HARD_LIMIT   160
#define	FLOW_CONTROL_SENDME_SOFT_LIMIT   80
#define	MAX_READ_FROM_PREV_MIX_QUEUE_SIZE   10000000
#define	MAX_READ_FROM_NEXT_MIX_QUEUE_SIZE   10000000
#define	MAX_MIXIN_SEND_QUEUE_SIZE   10000000
#define	MAX_NEXT_MIX_QUEUE_SIZE   10000000
#define	DEFAULT_INFOSERVICE   "141.76.45.37"
#define	MIX_POOL_TIMEOUT   200
#define	DUMMY_CHANNEL   0
#define	FM_PACKET_STATS_LOG_INTERVALL   1
#define	LM_PACKET_STATS_LOG_INTERVALL   1
#define	MIX_CASCADE_PROTOCOL_VERSION_0_1_2   12
#define	MIX_CASCADE_PROTOCOL_VERSION_0_1_1   11
#define	MIX_CASCADE_PROTOCOL_VERSION_0_1_0   10
#define	MIX_CASCADE_PROTOCOL_VERSION_0_8   8
#define	MIX_CASCADE_PROTOCOL_VERSION_0_7   7
#define	MIX_CASCADE_PROTOCOL_VERSION_0_5   5
#define	MIX_CASCADE_PROTOCOL_VERSION_0_4   4
#define	MIX_CASCADE_PROTOCOL_VERSION_0_3   3
#define	MIX_CASCADE_PROTOCOL_VERSION_0_2   2
#define	MIX_CASCADE_PROTOCOL_VERSION   "0.81"
#define	PAYMENT_VERSION   "2.0"
#define	HAVE_UNIX_DOMAIN_PROTOCOL
#define	HAVE_VSNPRINTF
#define	HAVE_SNPRINTF
#define	HAVE_POLL
#define	HAVE_O_SYNC
#define	HAVE_PTHREAD_MUTEX_INIT
#define	HAVE_PTHREAD_COND_INIT
#define	HAVE_SEM_INIT
#define	HAVE_TCP_KEEPALIVE
#define	MSG_NOSIGNAL   0
#define	SOCKET   int
#define	ioctlsocket(a, b, c)   ioctl(a,b,c)
#define	closesocket(s)   close(s)
#define	SOCKET_ERROR   -1
#define	INVALID_SOCKET   -1
#define	SD_RECEIVE   0
#define	SD_SEND   1
#define	SD_BOTH   2
#define	GET_NET_ERROR   (errno)
#define	SET_NET_ERROR(x)   (errno = x)
#define	GET_NET_ERROR_STR(x)   (errno == E_TIMEDOUT ? "Connection timed out." : (errno == E_SOCKETCLOSED ? "Socket is closed." : strerror(x)))
#define	RESETERROR   errno=0;
#define	GETERROR   (errno)
#define	ERR_INTERN_TIMEDOUT   ETIMEDOUT
#define	ERR_INTERN_CONNREFUSED   ECONNREFUSED
#define	ERR_INTERN_WOULDBLOCK   EAGAIN
#define	ERR_INTERN_SOCKET_CLOSED   EBADF
#define	HAVE_PTHREAD_CV
#define	HAVE_PTHREAD_MUTEXES
#define	HAVE_PTHREAD_SEMAPHORE
#define	THREAD_RETURN   void*
#define	THREAD_RETURN_ERROR   return(NULL)
#define	THREAD_RETURN_SUCCESS   return (NULL)
#define	ASSERT(cond, msg)
#define	MY_XERCES_VERSION   "unknown"
#define	PAYMENT_VERSION_INFO   " (payment)"
#define	PAYMENT_COMPATIBILITY   "Payment"
#define	DATA_RETENTION_LOG_INFO
#define	NEW_FLOW_CONTROL_INFO   " (with new flow control)"
#define	NEW_FLOW_CONTROL_COMPATIBILITY   "NewFlowControl"
#define	NEW_CHANNEL_ENCRYPTION_INFO   " (with enhanced channel encryption)"
#define	NEW_CHANNEL_ENCRYPTION_COMPATIBILITY   "NewChannelEncryption"
#define	WITH_INTEGRITY_CHECK_INFO
#define	WITH_INTEGRITY_CHECK_COMPATIBILITY
#define	MIX_VERSION_INFO   "Mix-Version: " MIX_VERSION PAYMENT_VERSION_INFO DATA_RETENTION_LOG_INFO NEW_FLOW_CONTROL_INFO NEW_CHANNEL_ENCRYPTION_INFO WITH_INTEGRITY_CHECK_INFO "\nUsing: " OPENSSL_VERSION_TEXT "\nUsing Xerces-C: " MY_XERCES_VERSION "\n"
#define	MIX_VERSION_COMPATIBILITY   PAYMENT_COMPATIBILITY " " NEW_FLOW_CONTROL_COMPATIBILITY " " NEW_CHANNEL_ENCRYPTION_COMPATIBILITY " " WITH_INTEGRITY_CHECK_COMPATIBILITY
#define	MAX_ACCOUNTNUMBER   999999999999ULL
#define	MIN_ACCOUNTNUMBER   100000000000ULL
#define	ACCOUNT_NUMBER_SIZE   12
Typedefs
typedef int	socklen_t
typedef struct sockaddr	SOCKADDR
typedef SOCKADDR *	LPSOCKADDR
typedef struct hostent	HOSTENT

---

Define Documentation

#define ACCOUNT_NUMBER_SIZE   12

Referenced by CAAccountingDBInterface::__clearAccountStatus().

#define AI_LOGIN_SO_TIMEOUT   (UINT32) 10000

Referenced by CAFirstMix::doUserLogin_internal().

#define ASSERT	(		cond,
			msg
	)

Referenced by CAFirstMixA::closeConnection(), CASignature::decodeRS(), getDOMElementValue(), getNodeName(), getRandom(), CAFirstMixB::loop(), CASocketGroupEpoll::remove(), and CAAbstractXMLSignable::setSignature().

#define BALANCE_REQUEST_TIMEOUT   60

#define CHANNELS_PER_CLIENT   50

#define CLEANUP_THREAD_SLEEP_INTERVAL   60

Referenced by CATempIPBlockList::cleanupThreadMainLoop().

#define CLIENTS_PER_IP   10

#define closesocket

(

s

)

close(s)

Referenced by CADatagramSocket::close(), and CASocket::close().

#define DATA_RETENTION_LOG_INFO

#define DEFAULT_INFOSERVICE   "141.76.45.37"

Referenced by CACmdLnOptions::buildDefaultConfig().

#define DELAY_USERS_BUCKET_GROW   10

Referenced by CACmdLnOptions::CACmdLnOptions(), and CAFirstMixChannelList::CAFirstMixChannelList().

#define DELAY_USERS_BUCKET_GROW_INTERVALL   100

Referenced by CACmdLnOptions::CACmdLnOptions(), and CAFirstMixChannelList::CAFirstMixChannelList().

#define DUMMY_CHANNEL   0

Referenced by CAPool::CAPool(), fm_loopReadFromMix(), fm_loopSendToMix(), lm_loopReadFromMix(), lm_loopSendToMix(), mm_loopReadFromMixAfter(), mm_loopReadFromMixBefore(), mm_loopSendToMixAfter(), and mm_loopSendToMixBefore().

#define ERR_INTERN_CONNREFUSED   ECONNREFUSED

Referenced by CASocket::connect(), CAMiddleMix::connectToNextMix(), and CAFirstMix::connectToNextMix().

#define ERR_INTERN_SOCKET_CLOSED   EBADF

Referenced by CASocket::accept(), and CAFirstMixA::accountTrafficDownstream().

#define ERR_INTERN_TIMEDOUT   ETIMEDOUT

Referenced by CASocket::connect(), CAMiddleMix::connectToNextMix(), and CAFirstMix::connectToNextMix().

#define ERR_INTERN_WOULDBLOCK   EAGAIN

Referenced by CASocket::receive(), and CASocket::send().

#define FIRST_MIX_RECEIVE_SYM_KEY_FROM_JAP_TIME_OUT   40000

Referenced by CAFirstMix::doUserLogin_internal().

#define FLOW_CONTROL_SENDME_HARD_LIMIT   160

Referenced by CALastMixA::loop().

#define FLOW_CONTROL_SENDME_SOFT_LIMIT   80

Referenced by CALocalProxy::init(), CALastMixA::loop(), and CALastMix::processKeyExchange().

#define FM_PACKET_STATS_LOG_INTERVALL   1

Referenced by CAFirstMix::init().

#define GET_NET_ERROR   (errno)

Referenced by CASocket::accept(), CASocket::close(), CASocket::connect(), CAMiddleMix::connectToNextMix(), CAFirstMix::connectToNextMix(), CASocket::create(), CACmdLnOptions::createSockets(), CAFirstMix::doUserLogin_internal(), fm_loopAcceptUsers(), CALastMix::init(), CASocket::listen(), mm_loopReadFromMixAfter(), CAMsg::openLog(), CAMiddleMix::processKeyExchange(), CALastMix::processKeyExchange(), CAFirstMix::processKeyExchange(), CASocket::receive(), CAMuxSocket::receive(), CASocketGroup::select(), CASocket::send(), CAMuxSocket::send(), CAInfoService::sendMixHelo(), CAInfoService::sendStatus(), CAFirstMixA::sendToUsers(), CASocket::setKeepAlive(), CAMsg::setLogOptions(), CACmdLnOptions::setNrOfFileDescriptors(), CACmdLnOptions::setTargetInterfaces(), and CACmdLnOptions::setUserID().

#define GET_NET_ERROR_STR

(

x

)

(errno == E_TIMEDOUT ? "Connection timed out." : (errno == E_SOCKETCLOSED ? "Socket is closed." : strerror(x)))

Referenced by CAMiddleMix::connectToNextMix(), CAFirstMix::connectToNextMix(), CASocket::create(), CACmdLnOptions::createSockets(), CAFirstMix::doUserLogin_internal(), CALastMix::init(), CAFirstMix::init(), mm_loopReadFromMixAfter(), CAMiddleMix::processKeyExchange(), CALastMix::processKeyExchange(), CAFirstMix::processKeyExchange(), CASocket::receive(), CAMuxSocket::receive(), CAInfoService::sendMixHelo(), CAInfoService::sendStatus(), CAFirstMixA::sendToUsers(), CASocket::setKeepAlive(), CAMsg::setLogOptions(), CACmdLnOptions::setNrOfFileDescriptors(), CACmdLnOptions::setTargetInterfaces(), and CACmdLnOptions::setUserID().

#define GETERROR   (errno)

#define HAVE_O_SYNC

#define HAVE_POLL

#define HAVE_PTHREAD_COND_INIT

#define HAVE_PTHREAD_CV

#define HAVE_PTHREAD_MUTEX_INIT

#define HAVE_PTHREAD_MUTEXES

#define HAVE_PTHREAD_SEMAPHORE

#define HAVE_SEM_INIT

#define HAVE_SNPRINTF

#define HAVE_TCP_KEEPALIVE

#define HAVE_UNIX_DOMAIN_PROTOCOL

#define HAVE_VSNPRINTF

#define INVALID_SOCKET   -1

Referenced by CADatagramSocket::create(), and CASocket::create().

#define ioctlsocket	(		a,
			b,
			c
	)		ioctl(a,b,c)

Referenced by CASocket::setNonBlocking().

#define KEEP_ALIVE_TRAFFIC_RECV_WAIT_TIME   75000

Referenced by CACmdLnOptions::setKeepAliveTraffic().

#define KEEP_ALIVE_TRAFFIC_SEND_WAIT_TIME   65000

Referenced by CACmdLnOptions::setKeepAliveTraffic().

#define LAST_MIX_TO_PROXY_CONNECT_TIMEOUT   2000

Referenced by CALastMixA::loop(), CALastMixB::loop(), and CACmdLnOptions::setTargetInterfaces().

#define LAST_MIX_TO_PROXY_SEND_TIMEOUT   (UINT32)5000

Referenced by CALastMixA::loop(), and CALastMixB::loop().

#define LM_PACKET_STATS_LOG_INTERVALL   1

Referenced by CALastMix::init().

#define LOG_COUNTRIES_INTERVALL   6

Referenced by iplist_loopDoLogCountries().

#define MAX_ACCOUNTNUMBER   999999999999ULL

Referenced by CAAccountingDBInterface::__clearAccountStatus().

#define MAX_DATA_PER_CHANNEL   100000

#define MAX_LOGIN_QUEUE   500

Referenced by CAAccountingInstance::CAAccountingInstance(), and CAFirstMix::init().

#define MAX_MIXIN_SEND_QUEUE_SIZE   10000000

Referenced by CALastMixA::loop(), and CALastMixB::loop().

#define MAX_NEXT_MIX_QUEUE_SIZE   10000000

Referenced by CAFirstMixB::loop(), and CAFirstMixA::loop().

#define MAX_POLLFD   8192

Referenced by CALastMixChannelList::add(), CAFirstMixChannelList::add(), CAChainTable::CAChainTable(), CAFirstMixChannelList::CAFirstMixChannelList(), CALastMixChannelList::CALastMixChannelList(), CASocketGroupEpoll::CASocketGroupEpoll(), CAChainTable::createEntry(), CAFirstMixChannelList::decDelayBuckets(), fml_loopDelayBuckets(), CAFirstMixChannelList::hasDelayBuckets(), CALastMixB::loop(), CASocketGroupEpoll::select(), CAFirstMixChannelList::setDelayParameters(), and CASocketGroup::setPoolForWrite().

#define MAX_READ_FROM_NEXT_MIX_QUEUE_SIZE   10000000

Referenced by fm_loopReadFromMix(), and mm_loopReadFromMixAfter().

#define MAX_READ_FROM_PREV_MIX_QUEUE_SIZE   10000000

Referenced by lm_loopReadFromMix(), and mm_loopReadFromMixBefore().

#define MAX_SIGNATURE_ELEMENTS   10

Referenced by CACertStore::verifyMixCert(), and CAMultiSignature::verifyXML().

#define MAX_USER_SEND_QUEUE   100000

#define MIN_ACCOUNTNUMBER   100000000000ULL

Referenced by CAAccountingDBInterface::__clearAccountStatus().

#define MIX_CASCADE_PROTOCOL_VERSION   "0.81"

Referenced by CAFirstMix::processKeyExchange().

#define MIX_CASCADE_PROTOCOL_VERSION_0_1_0   10

Referenced by CALocalProxy::processKeyExchange().

#define MIX_CASCADE_PROTOCOL_VERSION_0_1_1   11

#define MIX_CASCADE_PROTOCOL_VERSION_0_1_2   12

#define MIX_CASCADE_PROTOCOL_VERSION_0_2   2

Referenced by CALocalProxy::processKeyExchange().

#define MIX_CASCADE_PROTOCOL_VERSION_0_3   3

Referenced by CALocalProxy::processKeyExchange().

#define MIX_CASCADE_PROTOCOL_VERSION_0_4   4

Referenced by CALocalProxy::processKeyExchange().

#define MIX_CASCADE_PROTOCOL_VERSION_0_5   5

#define MIX_CASCADE_PROTOCOL_VERSION_0_7   7

#define MIX_CASCADE_PROTOCOL_VERSION_0_8   8

#define MIX_POOL_TIMEOUT   200

Referenced by fm_loopReadFromMix(), fm_loopSendToMix(), lm_loopReadFromMix(), lm_loopSendToMix(), mm_loopReadFromMixAfter(), and mm_loopReadFromMixBefore().

#define MIX_TO_INFOSERVICE_TIMEOUT   30000

Referenced by CAInfoService::sendCascadeHelo(), CAInfoService::sendMixHelo(), and CAInfoService::sendStatus().

#define MIX_VERSION   "00.11.06"

Referenced by CAMix::appendCompatibilityInfo(), CAMix::checkCompatibility(), and CACmdLnOptions::processXmlConfiguration().

#define MIX_VERSION_COMPATIBILITY   PAYMENT_COMPATIBILITY " " NEW_FLOW_CONTROL_COMPATIBILITY " " NEW_CHANNEL_ENCRYPTION_COMPATIBILITY " " WITH_INTEGRITY_CHECK_COMPATIBILITY

Referenced by CAMix::checkCompatibility().

#define MIX_VERSION_INFO   "Mix-Version: " MIX_VERSION PAYMENT_VERSION_INFO DATA_RETENTION_LOG_INFO NEW_FLOW_CONTROL_INFO NEW_CHANNEL_ENCRYPTION_INFO WITH_INTEGRITY_CHECK_INFO "\nUsing: " OPENSSL_VERSION_TEXT "\nUsing Xerces-C: " MY_XERCES_VERSION "\n"

Referenced by CACmdLnOptions::parse(), and CACmdLnOptions::setLoggingOptions().

#define MIX_VERSION_TESTING   true

Referenced by CACmdLnOptions::parse(), and CACmdLnOptions::setLoggingOptions().

#define MIX_VERSION_TESTING_TEXT   "This is a testing/development version. Please do not expect it to work in a productive environment, and don't be surprised if you get unpredictive results or segmentation faults. If you don't like experiments, go and get the stable code.\n"

Referenced by CACmdLnOptions::parse(), and CACmdLnOptions::setLoggingOptions().

#define MSG_NOSIGNAL   0

Referenced by CADatagramSocket::receive(), CASocket::receive(), CADatagramSocket::send(), and CASocket::send().

#define MY_XERCES_VERSION   "unknown"

#define NEW_CHANNEL_ENCRYPTION_COMPATIBILITY   "NewChannelEncryption"

Referenced by CAMix::appendCompatibilityInfo(), and CAMix::checkCompatibility().

#define NEW_CHANNEL_ENCRYPTION_INFO   " (with enhanced channel encryption)"

#define NEW_FLOW_CONTROL_COMPATIBILITY   "NewFlowControl"

Referenced by CAMix::appendCompatibilityInfo(), and CAMix::checkCompatibility().

#define NEW_FLOW_CONTROL_INFO   " (with new flow control)"

#define NO_INFOSERVICE_TRHEADS

#define NUM_LOGIN_WORKER_TRHEADS   10

Referenced by CAAccountingInstance::CAAccountingInstance(), and CAFirstMix::init().

#define PAYMENT_ACCOUNT_CERT_TIMEOUT   180

#define PAYMENT_COMPATIBILITY   "Payment"

Referenced by CAMix::appendCompatibilityInfo(), and CAMix::checkCompatibility().

#define PAYMENT_VERSION   "2.0"

Referenced by CAMix::initMixCascadeInfo(), and CAFirstMix::processKeyExchange().

#define PAYMENT_VERSION_INFO   " (payment)"

#define REPLAY_TIMESTAMP_PROPAGATION_INTERVALL   1

Referenced by CAMiddleMix::init(), and CALastMix::init().

#define RESETERROR   errno=0;

#define SD_BOTH   2

#define SD_RECEIVE   0

#define SD_SEND   1

#define SET_NET_ERROR

(

x

)

(errno = x)

Referenced by CASocket::connect(), CAFirstMix::doUserLogin_internal(), CASocket::listen(), CAMsg::openLog(), CASocket::receiveFullyT(), CASocket::receiveLine(), CASingleSocketGroup::select_once(), and CASocket::sendFullyTimeOut().

#define SOCKET   int

Referenced by CASocketGroupEpoll::add(), and CAFirstMixA::sendToUsers().

#define SOCKET_ERROR   -1

Referenced by CASocket::accept(), CADatagramSocket::bind(), CADatagramSocket::close(), CADatagramSocket::create(), CASocket::getLocalIP(), CASocket::getLocalPort(), CASocket::getNonBlocking(), CASocket::getPeerIP(), CASocket::getPeerPort(), CASocket::getRecvBuff(), CASocket::getSendBuff(), CASocket::getSendTimeOut(), CASocket::listen(), CALastMixA::loop(), CAFirstMixB::loop(), CALastMixB::loop(), CALocalProxy::loop(), mm_loopReadFromMixAfter(), mm_loopReadFromMixBefore(), CATLSClientSocket::receive(), CASocket::receive(), CAMuxSocket::receive(), CASocketGroup::select(), CADatagramSocket::send(), CATLSClientSocket::send(), CASocket::send(), and CASocket::setKeepAlive().

#define THREAD_RETURN   void*

Referenced by CAInfoService::sendHelo().

#define THREAD_RETURN_ERROR   return(NULL)

Referenced by consumer(), and producer().

#define THREAD_RETURN_SUCCESS   return (NULL)

Referenced by CATempIPBlockList::cleanupThreadMainLoop(), consumer(), db_loopMaintenance(), fm_loopAcceptUsers(), fm_loopDoUserLogin(), fm_loopLog(), fm_loopReadFromMix(), fm_loopSendToMix(), fml_loopDelayBuckets(), CAInfoService::InfoLoop(), iplist_loopDoLogCountries(), lm_loopLog(), lm_loopReadFromMix(), lm_loopSendToMix(), CAAccountingSettleThread::mainLoop(), mm_loopReadFromMixAfter(), mm_loopReadFromMixBefore(), mm_loopSendToMixAfter(), mm_loopSendToMixBefore(), CAAccountingInstance::processThread(), producer(), replaydb_loopMaintenance(), rp_loopPropagateTimestamp(), CAInfoService::TCascadeHelo(), CAInfoService::TCascadeStatus(), threadReConfigure(), CAInfoService::TMixHelo(), and worker_thread_main_loop().

#define USER_SEND_BUFFER_RESUME   10000

#define WITH_INTEGRITY_CHECK_COMPATIBILITY

Referenced by CAMix::appendCompatibilityInfo(), and CAMix::checkCompatibility().

#define WITH_INTEGRITY_CHECK_INFO

---

Typedef Documentation

typedef struct hostent HOSTENT

typedef SOCKADDR* LPSOCKADDR

typedef struct sockaddr SOCKADDR

typedef int socklen_t