AbstractSource(re, config),
d(new T(re, config, *this))
{
- AbstractSource* source = dynamic_cast<AbstractSource*>(this);
- if(source && re)
- re->setSupported(supported(), source);
+
}
template<typename T>
mSupported.push_back(DatabaseLogging);
mSupported.push_back(DatabasePlayback);
- routingEngine->setSupported(supported(), this);
+ routingEngine->updateSupported(supported(), PropertyList(), this);
if(config.find("startOnLoad")!= config.end())
{
delete shared;
shared = NULL;
- routingEngine->setSupported(mSupported, this);
+ routingEngine->updateSupported(mSupported, PropertyList(), this);
}
void DatabaseSink::propertyChanged(AbstractPropertyType *value)
if(!ListPlusPlus<VehicleProperty::Property>(&mSupported).contains(property))
{
mSupported.push_back(property);
- routingEngine->setSupported(mSupported, this);
+ routingEngine->updateSupported(mSupported, PropertyList(), this);
}
DBObject obj;
}
else {
murphyProperties[propertyName] = prop;
- m_re->setSupported(supported(), this);
+ m_re->updateSupported(supported(), PropertyList(), this);
}
// cout << "updating property!" << endl;
}
// TODO: read supported values from configuration?
- m_re->setSupported(supported(), this);
+ m_re->updateSupported(supported(), PropertyList(), this);
// set up the connection with Murphy
if (!m_address.empty())
m_supportedProperties.push_back(Obd2Connected);
- re->setSupported(supported(), this);
- /*if (openPort(std::string("/dev/pts/7"),115200))
- {
- printf("Error opening OBD2 port\n");
- }*/
+ re->updateSupported(supported(), PropertyList(), this);
+
statusQueue = g_async_queue_new();
commandQueue = g_async_queue_new();
subscriptionAddQueue = g_async_queue_new();