aboutsummaryrefslogtreecommitdiff
path: root/src/modules/uavcan/uavcan_main.cpp
diff options
context:
space:
mode:
authorPavel Kirienko <pavel.kirienko@gmail.com>2014-08-24 00:06:47 +0400
committerPavel Kirienko <pavel.kirienko@gmail.com>2014-08-24 00:06:47 +0400
commite9da8303161a1e1f012b7c5d770249c3d606fcbf (patch)
treec85cfd68be91c746661d64056c27a20377811b9b /src/modules/uavcan/uavcan_main.cpp
parent0f124963d4f0c07afa94d96b779a0d28b0fbd66f (diff)
downloadpx4-firmware-e9da8303161a1e1f012b7c5d770249c3d606fcbf.tar.gz
px4-firmware-e9da8303161a1e1f012b7c5d770249c3d606fcbf.tar.bz2
px4-firmware-e9da8303161a1e1f012b7c5d770249c3d606fcbf.zip
UAVCAN: initializing all bridges by default
Diffstat (limited to 'src/modules/uavcan/uavcan_main.cpp')
-rw-r--r--src/modules/uavcan/uavcan_main.cpp111
1 files changed, 22 insertions, 89 deletions
diff --git a/src/modules/uavcan/uavcan_main.cpp b/src/modules/uavcan/uavcan_main.cpp
index a15f83696..19b54b9cf 100644
--- a/src/modules/uavcan/uavcan_main.cpp
+++ b/src/modules/uavcan/uavcan_main.cpp
@@ -217,11 +217,12 @@ int UavcanNode::init(uavcan::NodeID node_id)
{
int ret = -1;
- /* do regular cdev init */
+ // Do regular cdev init
ret = CDev::init();
- if (ret != OK)
+ if (ret != OK) {
return ret;
+ }
_node.setName("org.pixhawk.pixhawk");
@@ -229,10 +230,24 @@ int UavcanNode::init(uavcan::NodeID node_id)
fill_node_info();
- /* initializing the bridges UAVCAN <--> uORB */
+ // Actuators
ret = _esc_controller.init();
- if (ret < 0)
+ if (ret < 0) {
return ret;
+ }
+
+ // Sensor bridges
+ IUavcanSensorBridge::make_all(_node, _sensor_bridges);
+ auto br = _sensor_bridges.getHead();
+ while (br != nullptr) {
+ ret = br->init();
+ if (ret < 0) {
+ warnx("cannot init sensor bridge '%s' (%d)", br->get_name(), ret);
+ return ret;
+ }
+ warnx("sensor bridge '%s' init ok", br->get_name());
+ br = br->getSibling();
+ }
return _node.start();
}
@@ -522,62 +537,10 @@ UavcanNode::print_info()
warnx("not running, start first");
}
- warnx("actuators control groups: sub: %u / req: %u / fds: %u", (unsigned)_groups_subscribed, (unsigned)_groups_required, _poll_fds_num);
- warnx("mixer: %s", (_mixers == nullptr) ? "NONE" : "OK");
-}
-
-int UavcanNode::sensor_enable(const char *bridge_name)
-{
- int retval = -1;
-
- (void)pthread_mutex_lock(&_node_mutex);
-
- // Checking if such bridge already exists
- {
- auto pos = _sensor_bridges.getHead();
- while (pos != nullptr) {
- if (!std::strncmp(pos->get_name(), bridge_name, IUavcanSensorBridge::MAX_NAME_LEN)) {
- warnx("sensor bridge '%s' already exists", bridge_name);
- retval = -1;
- goto leave;
- }
- pos = pos->getSibling();
- }
- }
-
- // Creating and initing
- {
- auto bridge = IUavcanSensorBridge::make(get_node(), bridge_name);
- if (bridge == nullptr) {
- warnx("cannot create sensor bridge '%s'", bridge_name);
- retval = -1;
- goto leave;
- }
-
- assert(!std::strncmp(bridge->get_name(), bridge_name, IUavcanSensorBridge::MAX_NAME_LEN));
-
- retval = bridge->init();
- if (retval >= 0) {
- _sensor_bridges.add(bridge);
- } else {
- delete bridge;
- }
- }
-
-leave:
- (void)pthread_mutex_unlock(&_node_mutex);
- return retval;
-}
-
-void UavcanNode::sensor_print_enabled()
-{
(void)pthread_mutex_lock(&_node_mutex);
- auto pos = _sensor_bridges.getHead();
- while (pos != nullptr) {
- warnx("%s", pos->get_name());
- pos = pos->getSibling();
- }
+ warnx("actuators control groups: sub: %u / req: %u / fds: %u", (unsigned)_groups_subscribed, (unsigned)_groups_required, _poll_fds_num);
+ warnx("mixer: %s", (_mixers == nullptr) ? "NONE" : "OK");
(void)pthread_mutex_unlock(&_node_mutex);
}
@@ -588,12 +551,7 @@ void UavcanNode::sensor_print_enabled()
static void print_usage()
{
warnx("usage: \n"
- "\tuavcan start\n"
- "\tuavcan sensor enable <sensor name>\n"
- "\tuavcan sensor list");
-
- warnx("known sensor bridges:");
- IUavcanSensorBridge::print_known_names("\t");
+ "\tuavcan {start|status|stop}");
}
extern "C" __EXPORT int uavcan_main(int argc, char *argv[]);
@@ -645,31 +603,6 @@ int uavcan_main(int argc, char *argv[])
::exit(0);
}
- if (!std::strcmp(argv[1], "sensor")) {
- if (argc < 3) {
- print_usage();
- ::exit(1);
- }
-
- if (!std::strcmp(argv[2], "list")) {
- inst->sensor_print_enabled();
- ::exit(0);
- }
-
- if (argc < 4) {
- print_usage();
- ::exit(1);
- }
-
- if (!std::strcmp(argv[2], "enable")) {
- const int res = inst->sensor_enable(argv[3]);
- if (res < 0) {
- warnx("failed to enable sensor '%s': error %d", argv[3], res);
- }
- ::exit(0);
- }
- }
-
print_usage();
::exit(1);
}