EDDDataSource.cpp

Go to the documentation of this file.

#include <EDDSourceLib/inc/EDDDataSource.h>
#include <EDDSourceLib/inc/EDDMsgLoop.h>
#include <proto/EDDSourceMsg.h>
#include <string.h>

tcEDDDataSource::tcEDDDataSource(void)
: mnSourceId(-1)
, mnBytesSent(0)
{
}

tcEDDDataSource::~tcEDDDataSource(void)
{
}
    
void 
tcEDDDataSource::RegisterWithMsgLoop(void)
{
    mnSourceId = tcEDDMsgLoop::GetInstance()->AddDataSource(this);
}

void 
tcEDDDataSource::UnRegisterWithMsgLoop(void)
{
    if (0 <= mnSourceId)
    {
        tcEDDMsgLoop::GetInstance()->RemoveDataSource(mnSourceId);
    }
}

void
tcEDDDataSource::SendSourceDescMsg(char** apFields, char** apItems, int NumItems)
{
        char* buffer;
    tsEDDSourceDescMsg* lpMsg;
    int desclen = 0;
    int bufsize;
    for(int index = 0; index < NumItems; index++)
    {
        desclen += strlen(apItems[index]);
        desclen += strlen(apFields[index]);
        desclen += 2;
    }
        desclen++; // null terminate
    if (desclen < 3) desclen = 0;
    bufsize = sizeof(tsEDDSourceDescMsg)+desclen-3;
        buffer = new char[bufsize];
    lpMsg = (tsEDDSourceDescMsg*) buffer;
    lpMsg->maDescriptionData[0] = 0;
    for (int index = 0; index < NumItems; index++)
    {
        strcat(&lpMsg->maDescriptionData[0],apFields[index]);
        strcat(&lpMsg->maDescriptionData[0],"=");
        strcat(&lpMsg->maDescriptionData[0],apItems[index]);
        strcat(&lpMsg->maDescriptionData[0],";");
    }
        desclen = strlen(&lpMsg->maDescriptionData[0]);
    lpMsg->mnDelimiter = ';';
    BuildHeader(&lpMsg->msHeader, EDDMSGID_SOURCEDESCMSG, bufsize);
    tcEDDMsgLoop::GetInstance()->SendMsg(&lpMsg->msHeader,true);
    delete [] buffer;
}

bool 
tcEDDDataSource::IsSubscribed(void)
{
    return tcEDDMsgLoop::GetInstance()->IsSubscribed(mnSourceId);
}

void
tcEDDDataSource::BuildHeader(tsEDDMsgHdr* apMsgHdr, uint16_t MsgID, uint16_t len)
{
    apMsgHdr->mnSyncWord   = EDD_MSG_SYNC;
    apMsgHdr->mnMsgId      = MsgID;
    apMsgHdr->mnMsgLen     = len;
    apMsgHdr->mnVersion    = EDD_CURRENT_VER;
    apMsgHdr->mnDataSource = mnSourceId;
    apMsgHdr->mnAllSources = 0;    
    mnBytesSent += len;
}

---