RDSModule.h

Go to the documentation of this file.

#ifndef _RDSMODULE_H
#define _RDSMODULE_H

#include <OpenTracker/OpenTracker.h>
#include <OpenTracker/dllinclude.h>
#include "RDSSource.h"

#include <ace/SOCK_Stream.h>
#include <ace/SOCK_Connector.h>

#include "rds.h"
#include <string>
#include <vector>

#define OP_RDS_RAW_READY 1
#define OP_RDS_PREPPED 3

#define byte char

namespace ot {

typedef struct
{
  short I;
  short R;
} COMPLEX;

typedef struct
{
  RDS_MSG_HDR rds_msg_hdr;
  RDS_INIT_PKT rds_init_pkt;
} INIT_MSG;


typedef struct
{
  unsigned int timestamp;
  int unused;
} RDS_PREPPED_PKT;



//  typedef std::map<int,std::map<int,std::map<int,short> > > MatrixMap;


  class OPENTRACKER_API RDSModule : public ThreadModule, public NodeFactory
  {
    // members
  protected:

    int stop;
    ACE_INET_Addr address;
    ACE_SOCK_Stream socket;
    ACE_SOCK_Connector connector;

    NodeVector sources;
    NodeVector sinks;

    int connect();

    // methods
  protected:
    void run();

  public:
    RDSModule();

    virtual ~RDSModule();
    virtual void init(StringTable& attributes, ConfigNode * localTree);
    virtual Node * createNode( const std::string& name,  StringTable& attributes);
    virtual void start();
    virtual void close();
    virtual void pushEvent();
    void onEventGenerated( Event& event, Node& generator);
  private:
    int validateData(RDS_RAW_READY_PKT * rdsRawReadyPkt);
    byte *pByteArray;
    void send_data();
    short **real_data;
    short **imag_data;
    short **raw_data;
    int channels;
    bool validate;
    bool bigendian;
    std::string data_order;
    int xsize;
    int ysize;

    friend class RDSSource;
  };
  OT_MODULE(RDSModule);
} // namespace ot

#endif

---