EDDMsgLoop.h

Go to the documentation of this file.

#ifndef EDDMSGLOOP_H
#define EDDMSGLOOP_H

#include <stdio.h>
#include <stdlib.h>

#include <proto/EDDMsgHdr.h>

#ifndef EDD_EXPORT
#define EDD_EXPORT
#endif

// Forward Declarations
class tcEDDDataSource;
class tcEDDDataPipe;
class tcEDDThreadManager;
class tcEDDLockManager;

class EDD_EXPORT tcEDDMsgLoop
{
public:
    static tcEDDMsgLoop* GetInstance(void);
    
    int AddDataPipe(tcEDDDataPipe* apDataPipe);
    int RemoveDataPipe(int anPipeID);
    int AddDataSource(tcEDDDataSource* apDataSource);
    int RemoveDataSource(int anSourceID);

    static const unsigned int gnMaxDataPipes   = 10;  
    static const unsigned int gnMaxDataSources = 128; 
    
    int SendMsg(tsEDDMsgHdr* apBuffer, bool BrdCast = false);
    int GetMaxMessageLen(int anSourceID);
        
    static tcEDDMsgLoop* gpMsgLoop;  

        bool IsSubscribed(uint16_t anSourceId);
    
protected:
    virtual ~tcEDDMsgLoop(void);
    tcEDDMsgLoop(void);
    void InitOSDependencies(void);
    void HandleMessage(tsEDDMsgHdr* apMsg, int anPipeID);
    
    typedef enum
    {
        eeWaitSync,  
        eeGetHeader, 
        eeGetBytes   
    } teParseState;

    static int DispatchReceiverThread(void* anPipeID, void* apFoo, void* apGoo);
    int ReceiverThread(int anPipeID);

    tcEDDDataPipe*      maDataPipes[gnMaxDataPipes];  
    tcEDDDataSource*    maDataSources[gnMaxDataSources]; 
    unsigned int        maSubscriptionTable[gnMaxDataPipes][gnMaxDataSources]; 
    unsigned int        maRcvThreadHandles[gnMaxDataPipes]; 
    tcEDDThreadManager* mpThreadManager;  
    tcEDDLockManager*   mpLockManager;    
    int                 mhTableLock;      
    volatile bool       maShutdownThread[gnMaxDataPipes]; 
     
};

#endif

---