---

quartz.cpp

Go to the documentation of this file.

/********************************************************************
Description: The Quartz ;)
part of the 3Dsia project
created: xandi, 250400

History:
    date,   name,       changes,                    in funtion

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


/*...................................................................
Description: quartz
Args: ThreadArgs* targs
Returns: none
Created: xandi, 250400
[ToDo:]
[Comments:]
Changes:
-------------------------------------------------------------------*/

#include "misc.h"
#include "quartz.h"

QuartzClass::QuartzClass ( Buffer* bufferIn, int reqPackType, int freq )
    {
    qbuf = bufferIn;
    requestPacket = reqPackType;
    frequency = freq;

    #ifdef DEBUG
    fprintf(stderr,"[QUARTZCLASS (%d): %d %d %d\n",this,qbuf,requestPacket,frequency);
    #endif
    }

void QuartzClass::setFrequency ( int freq )
    {
    frequency = freq;
    }

int QuartzClass::getFrequency ( void )
    {
    return frequency;
    }

int QuartzClass::getRequestPacket ( void )
    {
    return requestPacket;
    }

Buffer* QuartzClass::getBuf ( void )
    {
    return qbuf;
    }

void* QuartzThread ( void* qObj )
    {
    QuartzClass* myQuartzObject = (QuartzClass*) qObj;

    fprintf(stderr,"[qT] Quartz Thread started.. frequency: %d\n",myQuartzObject->getFrequency());

    while (1)
        {
        #ifdef DEBUGEXTREME
        fprintf(stderr,"[qT] %d,%d,%d,%d",myQuartzObject
                                         ,myQuartzObject->getFrequency()
                                         ,myQuartzObject->getRequestPacket()
                                         ,myQuartzObject->getBuf());
        #endif

        int test = myQuartzObject->getFrequency();

        if ( !test ) test = 1;

        usleep ( (int)( 1000000 / test ) );

        packet* pak;
        pak = new packet;

        pak->h.header[0] = myQuartzObject->getRequestPacket();

        #ifdef DEBUG
        fprintf(stderr,"[asking myQuartzObject(%p)->getBuf()]\n",myQuartzObject);
        #endif

        Buffer* myqbuf = myQuartzObject->getBuf();

        #ifdef DEBUG
        fprintf(stderr,"[attempting to write into buffer (%p)]\n",myqbuf);
        #endif

        if ( myqbuf )
            myqbuf->write ( pak );
        else
            exit(1);

        #ifdef DEBUG
        fprintf(stderr,"[sending update request successful]\n");
        #endif
        }

    }

---