---

coreClass.cpp

Go to the documentation of this file.

/********************************************************************
Description: The CoreClass Methods
part of the 3Dsia project
created: xandi, 080400

History:
    date,   name,       changes,                    in funtion
    180400  StonedBones added dynamic packet length

********************************************************************/


#include "misc.h"

#include <pthread.h>

#include <arpa/inet.h>
#include <sys/socket.h>

#include "../common/communication.h"

#include "../common/buffer.h"
#include "../common/protocol.h"
#include "../common/options.h"
#include "../common/config.h"
#include "../common/matrixThread.h"

#include "coreClass.h"
#include "quartz.h"


/*...................................................................
Description: This constructor does paramter-parsing
Args: ThreadArgs* targs
Returns:
Created: xandi, 080400
ToDo:
    a real parameter-parsing, providing switches like
        -s servername
        -l username
        -p password
        -a serveraddress
        -P port
        -....

Comments:
    this method should of course become a bit more flexible

Changes:
-------------------------------------------------------------------*/

coreClass::coreClass ( ThreadArgs* targs )
    {
    fprintf(stderr,"[cC.constructor] parsing %d parameters\n",targs->argc);
    mySocket   = 0;
    serverPort = 0;
    qObj       = 0;
    coreIn     = 0;
    coreOut    = 0;

    if ( targs->argc >= 4 )
        {
        username        = targs->argv[1];
        password        = targs->argv[2];
        serverAddress   = targs->argv[3];

        fprintf(stderr,"\nUsername: %s", username.c_str() );
        fprintf(stderr,"\tPassword: %s\n", password.c_str());
        fprintf(stderr,"Serveraddress: %s\n",serverAddress.c_str() );

        if ( targs->argc >= 5 )
            {
            fprintf(stderr,"Too many arguments - *snip* :)\n");
            }
        }
    else
        {
        username        = "clonewar";
        password        = "idpman";
        serverAddress   = DEFAULT_HOST;
        }

    serverPort = DEFAULT_PORT;
    }


/*...................................................................
Description: This constructor reads from the configuration file everything it knows about [servername]
Args: none
Returns: none
Created: 10.4.2000, StonedBones
[ToDo:]
[Comments:]
Changes:
-------------------------------------------------------------------*/

coreClass::coreClass () {
    mySocket   = 0;
    serverPort = 0;
    qObj       = 0;
    coreIn     = 0;
    coreOut    = 0;

    Config* tmpConfig = new Config ();

    tmpConfig->openConfig (CLIENT_CONFIG_FILE);

    if (tmpConfig->searchTag ("User")) {
    username = tmpConfig->getCharVariable ("Name");
    password = tmpConfig->getCharVariable ("Password");
    };
    if (tmpConfig->searchTag ("DefaultServer")) {
    serverAddress = tmpConfig->getCharVariable ("Adress");
    serverPort    = tmpConfig->getIntVariable ("Port");
    };

    if (username == "")       username      = "clonewar";
    if (password == "")       password      = "idpman";
    if (serverAddress == "")  serverAddress = DEFAULT_HOST;
    if (serverPort   == -111) serverPort    = DEFAULT_PORT;
};



/*...................................................................
Description: connect - connect to server
Args: void
Returns:
        0 succeeded
        1 didn't succeeded

Created: xandi, 080400
[ToDo:]
[Comments:]
Changes:
-------------------------------------------------------------------*/

bool coreClass::connectNow ( void )
    {
    fprintf(stderr,"[cC.connectNow] \n");

    ComArgs inArgs;
    ComArgs outArgs;

    inArgs.buffer  = coreIn  = new Buffer ( );
    outArgs.buffer = coreOut = new Buffer ( );

    bool check = connectTo ( serverAddress );

    inArgs.socket  = mySocket;
    outArgs.socket = mySocket;

    check  = pthread_create ( &incomingThread, NULL, IncomingThread, &inArgs );
    check += pthread_create ( &outgoingThread, NULL, OutgoingThread, &outArgs );

    check += handshake ( );
    check += authenticate ( );

    return check;
    }


/*...................................................................
Description: disconnect - disconnect to server
Args: void
Returns:
        0 succeeded
        1 didn't succeeded

Created: xandi, 080400
[ToDo:]
[Comments:]
Changes:
-------------------------------------------------------------------*/

bool coreClass::disconnectNow ( void )
    {
    fprintf(stderr,"Nooo, i don't let you, hahahaa!!\n");
    return 0;
    }


/*...................................................................
Description: connects to a server
Args: char* dotsandnumbers: TCP/IP adress ("127.0.0.1" rather than "localhost");
Returns: true on success
Created: StonedBones, ??.2.2000
ToDo:
    080400, support for DNS
[Comments:]
Changes:
    put from communication into coreClass,
    changed it so that it works with coreClass, 080400, xandi
-------------------------------------------------------------------*/

bool coreClass::connectTo ( string dotsandnumbers )
    {
    struct sockaddr_in address;
//    struct hostent*    host;

    fprintf(stderr,"[cC.connectTo] \n");
    address.sin_addr.s_addr = inet_addr (dotsandnumbers.c_str ());
    bzero ( & ( address.sin_zero ), 8 );


/*
    host = gethostbyname ( hostname );
    if (!host)
    return false;
    }; */

    if ((mySocket = socket (PF_INET, SOCK_STREAM, 0)) < 0) {
    return false;
    };

    address.sin_family = AF_INET;
    address.sin_port = htons (serverPort);

    if (connect (mySocket, (sockaddr *) &address, sizeof (address))) {
    return false;
    };

    return true;
    };


/*...................................................................
Description: handshakes with server
Args: <none>
Returns: true on success
Created: StonedBones, ??.2.2000
[ToDo:]
[Comments:]
Changes:
    changed so it works with the new threadsystem, xandi, 080400
    cleaned up a bit.. xandi, 090400
-------------------------------------------------------------------*/

bool coreClass::handshake ()
    {
    packet* pak = new packet;
    bool check = false;

    fprintf(stderr,"[cC.handshake] \n");

    pak->h.header[0] = PROT_HANDSHAKE;
    pak->h.header[1] = HANDSHAKE_GREETING;
    pak->h.header[2] = VERSION_MAJOR;
    pak->h.header[3] = VERSION_MINOR;
    pak->h.header[4] = PATCH_LEVEL;

    pak->data = "MATRIX?";

    coreOut->write ( pak );

    while ( coreIn->isEmpty () );

    pak = coreIn->read ();

    check  = ( ( pak->h.header[0] != PROT_HANDSHAKE ) || ( pak->h.header[1] != HANDSHAKE_GREETING ) );
    check += ( ( pak->h.header[2] > VERSION_MAJOR ) || ( pak->h.header[3] > VERSION_MINOR ) );

    if (!check) fprintf(stderr,"[cC.handshake] successful!\n");

    delete pak;
    return check;
    }


/*...................................................................
Description: authenticates with name and password
Args: char* name: username; char* passwd: password
Returns: true on success
Created: StonedBones, ??.2.2000
[ToDo:]
[Comments:]
Changes:
        changed it to work with new threadsystem,
        cleaned up a bit..                       090400, xandi
-------------------------------------------------------------------*/

//#ifdef AUTHPASSWORD //what was that good for again?

bool coreClass::authenticate ( void )
    {
    packet* pak = new packet;
    bool check = false;

    fprintf (stderr, "[auth.debug] trying authentication using %s and %s...\n",username.c_str(),password.c_str());

    pak->h.header[0] = PROT_AUTHENTICATE;
    pak->h.header[1] = AUTH_PASSWORD;
    pak->h.header[2] = strlen (username.c_str());
    pak->h.header[3] = strlen (password.c_str());

    pak->data = username;
    pak->data+= password;

    coreOut->write ( pak );

    while ( coreIn->isEmpty () );

    pak = coreIn->read ();

    check  = ( ( pak->h.header[0] != PROT_AUTHENTICATE) || (pak->h.header[1] != AUTH_PASSWORD ) );
    check += !( pak->data == "Authentication successful !" );

//    qObj   = new QuartzClass ( coreOut, PROT_GET_ALL_CHANGED, 25 );
//    check += pthread_create ( &quartzThread, NULL, QuartzThread, qObj );

    delete pak;
    return check;
    }

//#endif //#ifdef AUTHPASSWORD


Buffer* coreClass::getBuffer ( int whichbuffer )
    {
    if ( whichbuffer == INCOMING )
        return coreIn;
    if ( whichbuffer == OUTGOING )
        return coreOut;

    fprintf(stderr,"[coreClass::getBuffer] you dumb! (sorry, but i had to say that ;)\n");
    return 0;
    }


void coreClass::startQuartz ( unsigned int freq )
    {
    qObj   = new QuartzClass ( coreOut, PROT_GET_ALL_CHANGED, freq );
    if ( pthread_create ( &quartzThread, NULL, QuartzThread, qObj ) )
        {
        cerr << "unable to start quartzthread..\n";
        exit(1);
        }
    }

void coreClass::setUpdateFreq ( unsigned int framesPerSecond )
    {
    if ( !framesPerSecond )
        {
        fprintf(stderr,"[cc.setUpdateFreq] who would do that??\n");
        exit (1);
        }

    if ( !qObj)
        {
        fprintf(stderr,"coreClass::setUpdateFreq - THIS FUNCTION MUST NOT BE CALLED BEFORE THE QUARTZTHREAD IS STARTED!!\n");
        exit(1);
        }
    qObj->setFrequency ( framesPerSecond );
    fprintf(stderr,"[cc.setUpdateFreq] %d frames per second mean update every %d microseconds\n",framesPerSecond,1000000/framesPerSecond);
    }


/*
void coreClass::accessMatrix ( string matrixname )
    {
    packet* pak;
    pak = new packet;

    fprintf (stderr, "[cC.accessMatrix] trying to access a matrix...\n");

    pak->h.header[0] = PROT_MATRIX_STUFF;
    pak->h.header[1] = PROT_ACCESS_MATRIX;

    pak->data = matrixname;

    coreOut->write ( pak );

    fprintf(stderr,"[cC.accessMatrix] completed.....\n");
    }
*/

/*
bool Communication::dummyAddObject ( char* name )
    {
    int amount;
    packet bufpak;

    fprintf (stderr, "trying to add an object %s...\n",name);
    amount = sizeof (packet);

    bufpak.h.header[0] = PROT_MATRIX_STUFF;
    bufpak.h.header[1] = PROT_ADD_OBJECT;


    strcpy (bufpak.data, name);

    sendData (bufpak);

    bufpak = recvData ();

    if ((bufpak.h.header[0] != PROT_REQUEST_REPLY))
        {
        return false;
        }

    return true;
    }

bool Communication::dummyGetObject ( int number )
    {
    int amount;
    packet bufpak;

    fprintf (stderr, "trying to get an object %d...\n",number);
    amount = sizeof (packet);

    bufpak.h.header[0] = PROT_MATRIX_STUFF;
    bufpak.h.header[1] = PROT_GET_OBJECT;
    bufpak.h.header[2] = number;

    sendData (bufpak);

    bufpak = recvData ();

    if ((bufpak.h.header[0] != PROT_REQUEST_REPLY))
        {
        return false;
        }

    return true;
    }

*/

---