---

coreThread.cpp File Reference

#include "misc.h"
#include "coreClass.h"
#include "../common/databaseAccess.h"
#include "parseObject.h"

Go to the source code of this file.

Functions
void*	coreThread ( void* targz )
	The coreThread. More...
Variables
Buffer*	coreBufferIn = 0
	The coreThread's buffer. More...
map<int,Buffer*>	clientBufferIn
	The buffers the matrixThread's clients (those are coreThread and outputThread) read from. More...

---

Function Documentation

void * coreThread ( void * targs)

The coreThread.

Parameters:

targs

passes the arguments which came from main()

Definition at line 34 of file coreThread.cpp.

{
    ThreadArgs* targs = (ThreadArgs*) targz;
    coreClass* cc = new coreClass ( targs );

    extern Buffer* outputBufferIn;

    Buffer* coreIn = 0;
    Buffer* comOut = 0;

    packet* pak = 0;

    if ( cc->connectNow() )
        {
        fprintf(stderr,"[coreThread] unable to connect to host\n");
        pthread_exit (NULL);
        }

    if ( ! (coreIn = cc->getBuffer ( INCOMING ) ) )
        exit (1);
    if ( ! (comOut = cc->getBuffer ( OUTGOING ) ) )
        exit (1);
    if ( !outputBufferIn )
        exit (1);


    clientBufferIn[CLIENT_CORE] = coreIn;
    DatabaseAccess dbAccess ( CLIENT_CORE );

    int myObjectID = 0;

    // <TEMPORARILY>
    coreBufferIn = coreIn;
    // </TEMPORARILY>

    cc->startQuartz    ( 25 );
//    cc->setUpdateFreq ( 10 );

    while (1)
        {
        if ( !coreIn->isEmpty() )
            {
            pak = coreIn->read ();

#ifdef DEBUG
            fprintf ( stderr, "[coT] got a packet %d \n", pak->h.header[0]);
#endif

            switch ( pak->h.header[0] )
                {
/*                case PROT_ACCESS_MATRIX:
                    {
                    cc->accessMatrix ( pak->data );
                    delete pak;
                    break;
                    }
*/
                case PROT_REGISTER_ENTITY_REPLY:
                    {

                    //OK, You can now send your avatardata!!! COOL!! :))
                    myObjectID = pak->h.header[1];
                    fprintf(stderr,"[coT] my Avatar ID is %d\n",myObjectID);

                    pak->h.header[0] = PROT_AVATAR_HULL;
                    pak->data = readFile( "clonewar.avatar" );

                    comOut->write ( pak );


                    packet* xpak = new packet;
                    xpak->h.header[0] = PROT_OUTPUT_VISUAL;
                    xpak->h.header[1] = VISUAL_MY_OBJECT;
                    xpak->h.header[2] = myObjectID;

                    outputBufferIn->write ( xpak );

                    break;
                    }


                case PROT_SEND_MSG:
                    {
#ifdef DEBUG
                    fprintf(stderr,"[coT] trying to send a message...\n");
#endif
                    comOut->write (pak);
                    break;
                    }

                case PROT_TEXT_MSG:
                    {
                    outputBufferIn->write ( pak );
                    break;
                    }

                case PROT_CHAT_MSG:
                    {
                    fprintf(stderr,"[coT] trying to send a message...\n");

                    comOut->write (pak);
                    break;
                    }


                case PROT_CHANGE_POSITION:
                    {
                    comOut->write ( pak );
                    break;
                    }

                case PROT_RECEIVE_OBJECT:
                    {
                    /*******************************************************
                    header[1]   ObjectID
                    data        the name of the object
                    *******************************************************/
#ifdef DEBUG
                    fprintf(stderr,"[coT] Received an object\n");
#endif
                    dbAccess.addObject ( pak->h.header[1], pak->data  );

                    delete pak;
                    pak = 0;
                    break;
                    }


                case PROT_RECEIVE_ATOM:
                    {
                    /*******************************************************
                    header[1]   ObjectID
                    header[2]   atom Type
                    header[3]   atomID
                    header[4]   valueType
                    data        the atom data
                    *******************************************************/

#ifdef DEBUG2
                    fprintf(stderr,"[coT] Received an atom %d %d %d %d %s\n",pak->h.header[1], pak->h.header[2], pak->h.header[3],pak->h.header[4], pak->data.c_str());
#endif

                    dbAccess.addAtom ( pak->h.header[3], pak->h.header[1], pak->h.header[2], pak->data );
//                    dbAccess.addAtom ( pak->h.header[3], pak->h.header[1], pak->h.header[2],pak->h.header[4], pak->data );

                    delete pak;
                    pak = 0;
                    break;
                    }


                case PROT_OUTPUT_VISUAL:
                    {
#ifdef DEBUG
                    fprintf(stderr,"[coT] getting a PROT_OUTPUT_VISUAL\n");
#endif
                    outputBufferIn->write ( pak );
                    break;
                    }

                case PROT_OUTPUT_DUMMY:
                    {
#ifdef DEBUG
                    fprintf(stderr,"[coT] getting a PROT_OUTPUT_DUMMY\n");
#endif
                    outputBufferIn->write ( pak );
                    break;
                    }


                default:
                    {
//#ifdef DEBUG
                    fprintf(stderr,"[coreThread] packet number: %d\n",pak->h.header[0]);
//#endif
                    delete pak;
                    pak = 0;
                    break;
                    }
                }
            }
        }
    }

---

Variable Documentation

map<int,Buffer *> clientBufferIn

The buffers the matrixThread's clients (those are coreThread and outputThread) read from.

Definition at line 32 of file coreThread.cpp.

Buffer * coreBufferIn = 0

The coreThread's buffer.

Definition at line 30 of file coreThread.cpp.

---