Changeset 153 in pacpusframework for branches/2.0-beta1/include/Pacpus/kernel/InputOutputInterface.h
- Timestamp:
- 08/01/13 11:42:22 (11 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
branches/2.0-beta1/include/Pacpus/kernel/InputOutputInterface.h
r152 r153 5 5 #include <Pacpus/kernel/InputOutputBase.h> 6 6 #include <QApplication> 7 #include <QByteArray> 8 #include <QThread> 7 9 #include <typeinfo> 8 9 #include <QDebug>10 #include <QThread>11 12 #include <QByteArray>13 14 //#define ADD_INPUT(name, ComponentType, DataType, functionName) \15 // inputs().insert((name), new InputInterface<DataType, ComponentType> ((name), this, &ComponentType::functionName))16 //#define ADD_OUTPUT(name, ComponentType, DataType) \17 // outputs().insert((name), new OutputInterface<DataType, ComponentType> ((name), this))18 19 //#define GET_INPUT(name, ComponentType, DataType) \20 // dynamic_cast<InputInterface<DataType, ComponentType> *> (input.value(name))21 //#define GET_OUTPUT(name, ComponentType, DataType) \22 // dynamic_cast<OutputInterface<DataType, ComponentType> *> (output.value(name))23 10 24 11 namespace pacpus { … … 61 48 PacpusTypedEvent<T> * typedEvent = dynamic_cast<PacpusTypedEvent<T> *> (event); 62 49 63 //qDebug() << "Reciever " << getSignature() << " thread " << QThread::currentThread() << " Data & " << & typedEvent->data_;50 LOG_DEBUG("Receiver " << getSignature() << " thread " << QThread::currentThread() << " Data & " << & typedEvent->data_); 64 51 65 52 //if(_component) get state 66 53 67 54 if (typedEvent->timerange() < 500 && readingMode() == TimeBounded) { 68 //LOG_WARN("Incorrect TimeRange (0), switch to NeverSkip");69 qDebug() << "Incorrect TimeRange (0), switch to NeverSkip";70 readingMode() = NeverSkip;}55 LOG_WARN("Incorrect TimeRange (0), switch to NeverSkip"); 56 readingMode() = NeverSkip; 57 } 71 58 72 59 switch (readingMode()) { 73 60 case TimeBounded: 74 //qDebug() << "Input " << this->getSignature().leftJustified(20) << QString("Time bournded").leftJustified(15) << road_time()- typedEvent->t_ << "\t" << typedEvent->tr_;61 LOG_DEBUG("Input " << this->getSignature().leftJustified(20) << QString("Time bournded").leftJustified(15) << road_time()- typedEvent->t_ << "\t" << typedEvent->tr_); 75 62 76 63 if (road_time() - typedEvent->time() > typedEvent->timerange()) { 77 qDebug() << "Data skip " << this->getSignature();64 LOG_DEBUG("Data skip " << this->getSignature()); 78 65 break; 79 66 } … … 83 70 84 71 case GetLast: 85 //qDebug() << "Input " << this->getSignature().leftJustified(20) << QString("GetLast").leftJustified(15) << road_time() - typedEvent->t_ << "\t" << typedEvent->tr_;72 LOG_DEBUG("Input " << this->getSignature().leftJustified(20) << QString("GetLast").leftJustified(15) << road_time() - typedEvent->t_ << "\t" << typedEvent->tr_); 86 73 87 74 (dynamic_cast<C*>(component())->*method)(typedEvent->data()); 88 QCoreApplication::removePostedEvents(this,TYPED_EVENT); // delete all remining events 75 // delete all remaining events 76 QCoreApplication::removePostedEvents(this, TYPED_EVENT); 89 77 break; 90 78 91 79 case NeverSkip: 92 //qDebug() << "Input " << this->getSignature().leftJustified(20) << QString("NeverSkip").leftJustified(15) << road_time() - typedEvent->t_ << "\t" << typedEvent->tr_;80 LOG_DEBUG("Input " << this->getSignature().leftJustified(20) << QString("NeverSkip").leftJustified(15) << road_time() - typedEvent->t_ << "\t" << typedEvent->tr_); 93 81 94 82 default: … … 118 106 119 107 default: 120 121 qDebug() << "Unknown event ID " << event->type(); 108 LOG_WARN("Unknown event ID " << event->type()); 122 109 break; 123 110 } … … 152 139 153 140 // Used by Components to send data througth typed output 154 void send(const T & data, road_time_t t = road_time(), road_timerange_t tr = 0) {155 141 void send(const T & data, road_time_t t = road_time(), road_timerange_t tr = 0) 142 { 156 143 //QSharedPointer<T> sharedPointer = new T(data); 157 144 158 for (QList<ConnectionBase>::iterator it = connections().begin(); it != connections().end(); ++it){145 for (QList<ConnectionBase>::iterator it = connections().begin(); it != connections().end(); ++it) { 159 146 QApplication::postEvent(it->getInterface(),new PacpusTypedEvent<T>(TYPED_EVENT,data,t,tr),it->getPriority()); // Event is delete by the event loop handler 160 147 //qDebug() << "sender " << it->getInterface()->getSignature() << " thread " << QThread::currentThread() << " Data & " << &data << " ";
Note:
See TracChangeset
for help on using the changeset viewer.