{
i++;
DEBUG(binder_interface, "Start reading thread");
+ NOTICE(binder_interface, "%s device opened and reading", device.c_str());
can_devices_m_[device]->start_reading(*this);
}
else
return can_msg;
}
- has_can_message_ = false;
return can_msg;
}
can_message_q_.push(can_msg);
}
-bool can_bus_t::has_can_message()
-{
- return has_can_message_;
-}
-
openxc_VehicleMessage can_bus_t::next_vehicle_message()
{
openxc_VehicleMessage v_msg;
return v_msg;
}
- has_vehicle_message_ = false;
return v_msg;
}
void can_bus_t::push_new_vehicle_message(const openxc_VehicleMessage& v_msg)
{
vehicle_message_q_.push(v_msg);
- has_vehicle_message_ = true;
}
std::map<std::string, std::shared_ptr<can_bus_dev_t>> can_bus_t::get_can_devices()