Backtrack

setKeyResult = con->enc->SetEncryptionKeys(sk, sk);

Connection * con = server->GetConnection(node->toFrom);

memcpy( sk, theUserStatus.sessionKey().key(), theUserStatus.sessionKey().length());

int authResult = authenticateCustomer( pMsg->customerID, theUserStatus );

GLDP_UserStatus theUserStatus;

bool ClientConnect( ConnectionInfo * info, MessageNode * node)

case MC_CLIENT_CONNECT_MSG:

switch (currentMsgNo)

WORD currentMsgNo = msg->msgNo;

BaseMsgHeader * msg = (BaseMsgHeader *) node->buffer;

bool ProcessInput( MessageNode* node, ConnectionInfo * info)

poolInit.processCallback= ProcessInput;

PoolInitializer poolInit;

threadPool->Initialize(poolInit);

threadPool = new ThreadPool;

bool bFatalExit = processCallback( msg, (ConnectionInfo*)info->setupData );

MessageNode msg = (MessageNode) info->data;

ThreadInit * init = (ThreadInit *) ptr;

unsigned ThreadPool::Process(LPVOID ptr)

unsigned __stdcall ThreadPool::StartProcess(LPVOID ptr)

threadInfo[i]->threadHandle = (HANDLE) _beginthreadex( NULL, 0, StartProcess, &init, 0, (unsigned *) &threadInfo[i]->threadID);

===================================================================

con->enc->Decrypt(msg, con);

if(!(msg->flags & HEARTBEAT) && con->useEncryption)

#ifndef CLIENT_DECRYPTS_AND_DECOMPRESSES

void TCPMgr::MessageReceived(MessageNode *& inmsg, Connection * con)

MessageReceived( comp->msg, con ); // sets msg-> to NULL

if (comp->header.mcosig == (unsigned long)MCO_SIG_VAL)

if (con->status == ACTIVE || con->status == SOFT_KILL)

con = comp->con;

Connection *con; CompData *comp;

void SocketMgrCompletion::DoIncomming()

mgr->DoIncomming(); // get back into the class!

unsigned __stdcall SocketMgrCompletion::GetIncomming(LPVOID ptr)

hThread[0] = (HANDLE) _beginthreadex( NULL, 0, GetIncomming, &initThread, 0, &threadID[0] );

CommResult SocketMgrCompletion::Initialize(SocketInitializer & initData)

commResult = server->Initialize(init);

server = new SocketMgrCompletion;

static BSUCCESS DoSetup( ConnectionInfo * info )

BSUCCESS bSuccess = DoSetup( myOCI );

int main(int argc, char* argv[])