Changeset 206 in pacpusframework for trunk/include/Pacpus/kernel


Ignore:
Timestamp:
Oct 30, 2013, 12:26:34 PM (11 years ago)
Author:
Marek Kurdej
Message:

Major: cleaned connection interfaces.

Location:
trunk/include/Pacpus/kernel
Files:
4 edited

Legend:

Unmodified
Added
Removed

  • trunk/include/Pacpus/kernel/ComponentBase.h

    r202 r206  
    8484    /// Ctor of ComponentBase.
    8585    /// @param name Name of your component.
    86     ComponentBase(const QString& name);
     86    ComponentBase(const QString & name);
    8787
    8888    /// Dtor of ComponentBase.
    … …  
    100100    /// @return Name of the component.
    101101    QString getName() const;
     102   
     103    /// @returns @b true if the component has been started and is active (working)
     104    bool isActive() const;
    102105
    103106protected:
    … …  
    170173    }
    171174
    172     bool isActive() const;
    173175    void setActive(bool isActive);
    174176    bool isRecording() const;

  • trunk/include/Pacpus/kernel/InputOutputBase.h

    r200 r206  
    3232    virtual std::size_t getDataSize() const = 0;
    3333    virtual const std::type_info & getDataType() const = 0;
     34   
     35    //virtual PacpusEvent * getEventTemplate() = 0;
    3436   
    3537    void addConnection(ConnectionBase connection);
    … …  
    99101    QStringList getInputConnectedList();
    100102
    101     void send(/*const*/ QByteArray & data);
     103    //void send(/*const*/ QByteArray & data);
    102104};
    103105

  • trunk/include/Pacpus/kernel/InputOutputInterface.h

    r202 r206  
    2323        : InputInterfaceBase(name, component, component)
    2424        , method(processMethod)
    25     {}
     25    {
     26    }
    2627
    2728    ~InputInterface()
    28     {}
     29    {
     30    }
    2931
    3032    std::size_t getDataSize() const
    … …  
    3941
    4042    // FIXME: what's the purpose of this function?
    41     PacpusEvent * getEventTemplate()
    42     {
    43         return new PacpusTypedEvent<T>(TYPED_EVENT);
    44     }
     43    //PacpusEvent * getEventTemplate()
     44    //{
     45    //    return new PacpusTypedEvent<T>(TYPED_EVENT);
     46    //}
    4547
    4648    // FIXME: what's the purpose of this function?
    4749    void customEvent(QEvent * event)
    4850    {
    49         // TODO check component state started
    50         //if (_component) get state
     51        // check that component has been started
     52        if ((NULL == getComponent()) || (!getComponent()->isActive())) {
     53            LOG_DEBUG("component is not active");
     54            return;
     55        }
     56       
     57        LOG_DEBUG("Receiver: " << getSignature());
     58
     59        //PacpusTypedEvent<T> * typedEvent = dynamic_cast<PacpusTypedEvent<T> *>(event);
     60        PacpusEvent * pacpusEvent = dynamic_cast<PacpusEvent *>(event);
     61        if (!pacpusEvent) {
     62            LOG_WARN("dynamic_cast failed: not a PacpusEvent");
     63            return;
     64        }
     65        PacpusTypedEvent<T> * typedEvent = dynamic_cast<PacpusTypedEvent<T> *>(pacpusEvent);
     66        if (!typedEvent) {
     67            LOG_WARN("dynamic_cast failed: incompatible event types");
     68            return;
     69        }
     70
    5171        switch (event->type()) {
    5272        case TYPED_EVENT:
    53             {
    54             PacpusTypedEvent<T> * typedEvent = dynamic_cast<PacpusTypedEvent<T> *> (event);
    55 
    56             LOG_DEBUG("Receiver: " << getSignature());
    57 
    58             if (typedEvent->timerange() < 500 && readingMode() == TimeBounded) {
     73            if (TimeBounded == readingMode() && typedEvent->timerange() < 500) {
    5974                LOG_WARN("Incorrect TimeRange (0), switch to NeverSkip");
    6075                readingMode() = NeverSkip;
    … …  
    6378            switch (readingMode()) {
    6479            case TimeBounded:
    65 
    6680                if (road_time() - typedEvent->time() > typedEvent->timerange()) {
    67                     LOG_DEBUG("Data skipped, receiver: " << this->getSignature());
     81                    LOG_TRACE("Data skipped, receiver: " << this->getSignature());
    6882                    break;
    6983                }
    … …  
    7387
    7488            case GetLast:
    75 
    7689                (dynamic_cast<C*>(component())->*method)(typedEvent->data());
    7790                // delete all remaining events
    … …  
    8598            default:
    8699                LOG_WARN("Unknown reading mode " << readingMode());
     100                break;
    87101            }
    88102            break;
    89         }
    90103
    91104        // Add here new event type if needed
    … …  
    95108            break;
    96109        }
    97     event->accept();
     110        event->accept();
    98111    }
    99112
    100113    // TODO for Pulling mode (not yet implemented !!!)
    101     T & getData() {
     114    T & getData()
     115    {
    102116        T data;
    103117        // TODO ask output data;
    104 
    105118        return data;
    106119    }
    … …  
    125138    {}
    126139
    127     // Used by Components to send data througth typed output
     140    /// Send data through a typed output
    128141    void send(const T & data, road_time_t t = road_time(), road_timerange_t tr = 0);
    129142   
    … …  
    150163        //  It is not safe to access the event after it has been posted.   
    151164        QEvent * newEvent = new PacpusTypedEvent<T>(TYPED_EVENT, data, t, tr);
    152         QCoreApplication::postEvent(it->getInterface(), newEvent, it->getPriority());
     165        QCoreApplication::postEvent(
     166            it->getInterface(),
     167            newEvent,
     168            it->getPriority()
     169        );
    153170        LOG_DEBUG("Sender: " << it->getInterface()->getSignature());
    154171        LOG_DEBUG("Data &: " << &data);

  • trunk/include/Pacpus/kernel/PacpusEvent.h

    r196 r206  
    3838
    3939    // TODO: should we make it virtual pure ???
    40     virtual QDataStream& streamOut(QDataStream& out)
     40    virtual QDataStream & streamOut(QDataStream & out)
    4141    {
    4242        return out;
    … …  
    7777{
    7878public:
    79     TypedData(const T& data)
    80     : m_data(data)
     79    TypedData(const T & data)
     80        : m_data(data)
    8181    {
    8282    }
    … …  
    9696    }
    9797
    98     size_t size() const
     98    std::size_t size() const
    9999    {
    100100        return sizeof(T);
    … …  
    112112public:
    113113    // FIXME: why we need `data = T()` ???
    114     PacpusTypedEvent(PacpusEventType type, const T & data = T(), road_time_t t = road_time(), road_timerange_t tr = 0 )
     114    PacpusTypedEvent(PacpusEventType type, const T & data/* = T()*/, road_time_t t = road_time(), road_timerange_t tr = 0)
    115115        : PacpusEvent(type, t, tr)
    116116        , TypedData<T>(data)
    117     {}
     117    {
     118    }
     119   
     120    /// Conversion constructor from another PacpusTypedEvent,
     121    /// when T is convertible to S
     122    template <typename S>
     123    PacpusTypedEvent(const PacpusTypedEvent<S> & other)
     124        : PacpusEvent(static_cast<PacpusEventType>(other.type()), other.time(), other.timerange())
     125        , TypedData<T>(other.data())
     126    {
     127    }
    118128
    119129    ~PacpusTypedEvent()
    120     {}
    121 
    122     QDataStream& streamOut(QDataStream& out)
     130    {
     131    }
     132
     133    QDataStream & streamOut(QDataStream & out)
    123134    {
    124135        // FIXME Stream Data errors
    … …  
    126137    }
    127138
    128     QDataStream& streamIn(QDataStream& in)
     139    QDataStream & streamIn(QDataStream & in)
    129140    {
    130141        return in >> (quint64&) time() >> timerange() /*>> m_data*/;
    … …  
    135146{
    136147public:
    137     GenericData(const char* data, size_t size)
     148    GenericData(const char * data, size_t size)
    138149        : m_data(NULL)
    139150        , m_dataSize(size)
    … …  
    164175    }
    165176
    166     size_t size() const
     177    std::size_t size() const
    167178    {
    168179        return m_dataSize;
    … …  
    170181
    171182private:
    172     char* m_data;
    173     size_t m_dataSize;
     183    char * m_data;
     184    std::size_t m_dataSize;
    174185};
    175186
    … …  
    179190{
    180191public:
    181     PacpusGenericEvent(PacpusEventType type, const char* data, size_t size)
     192    PacpusGenericEvent(PacpusEventType type, const char * data, size_t size)
    182193        : PacpusEvent(type)
    183194        , GenericData(data, size)
    … …  
    192203} // namespace pacpus
    193204
    194 PACPUSLIB_API inline QDataStream& operator<< (QDataStream& out, pacpus::PacpusEvent& ev)
     205PACPUSLIB_API inline QDataStream & operator<<(QDataStream & out, pacpus::PacpusEvent & ev)
    195206{
    196207    /*return ev.streamOut(out);*/
    … …  
    198209}
    199210
    200 PACPUSLIB_API inline QDataStream& operator>> (QDataStream& in, pacpus::PacpusEvent& ev)
     211PACPUSLIB_API inline QDataStream & operator>>(QDataStream & in, pacpus::PacpusEvent & ev)
    201212{
    202213    /*return ev.streamIn(in);*/
Note: See TracChangeset for help on using the changeset viewer.