navigator: support DO_JUMP misison items

src/modules/navigator/navigator_mission.cpp

@@ -142,22 +142,19 @@ Mission::next_mission_available()
 int
 Mission::get_current_mission_item(struct mission_item_s *new_mission_item, bool *onboard, unsigned *index)
 {
+	int ret = ERROR;
+
 	/* try onboard mission first */
 	if (current_onboard_mission_available()) {
 
-		const ssize_t len = sizeof(struct mission_item_s);
+		ret = get_mission_item(DM_KEY_WAYPOINTS_ONBOARD, &_current_onboard_mission_index, new_mission_item);
-
+		if (ret == OK) {
-		if (dm_read(DM_KEY_WAYPOINTS_ONBOARD, _current_onboard_mission_index, new_mission_item, len) != len) {
+			_current_mission_type = MISSION_TYPE_ONBOARD;
-			/* not supposed to happen unless the datamanager can't access the SD card, etc. */
+			*onboard = true;
-			return ERROR;
+			*index = _current_onboard_mission_index;
 		}
 
-		_current_mission_type = MISSION_TYPE_ONBOARD;
+	/* otherwise fallback to offboard */
-		*onboard = true;
-		*index = _current_onboard_mission_index;
-
-		/* otherwise fallback to offboard */
-
 	} else if (current_offboard_mission_available()) {
 
 		dm_item_t dm_current;
@@ -169,42 +166,34 @@ Mission::get_current_mission_item(struct mission_item_s *new_mission_item, bool
 			dm_current = DM_KEY_WAYPOINTS_OFFBOARD_1;
 		}
 
-		const ssize_t len = sizeof(struct mission_item_s);
+		ret = get_mission_item(dm_current, &_current_offboard_mission_index, new_mission_item);
-
+		if (ret == OK) {
-		if (dm_read(dm_current, _current_offboard_mission_index, new_mission_item, len) != len) {
+			_current_mission_type = MISSION_TYPE_OFFBOARD;
-			/* not supposed to happen unless the datamanager can't access the SD card, etc. */
+			*onboard = false;
-			_current_mission_type = MISSION_TYPE_NONE;
+			*index = _current_offboard_mission_index;
-			return ERROR;
 		}
 
-		_current_mission_type = MISSION_TYPE_OFFBOARD;
-		*onboard = false;
-		*index = _current_offboard_mission_index;
-
 	} else {
 		/* happens when no more mission items can be added as a next item */
 		_current_mission_type = MISSION_TYPE_NONE;
-		return ERROR;
+		ret == ERROR;
 	}
 
-	return OK;
+	return ret;
 }
 
 int
 Mission::get_next_mission_item(struct mission_item_s *new_mission_item)
 {
+	int ret = ERROR;
+
 	/* try onboard mission first */
 	if (next_onboard_mission_available()) {
 
-		const ssize_t len = sizeof(struct mission_item_s);
+		unsigned next_onboard_mission_index = _current_onboard_mission_index + 1;
-
+		ret = get_mission_item(DM_KEY_WAYPOINTS_ONBOARD, &next_onboard_mission_index, new_mission_item);
-		if (dm_read(DM_KEY_WAYPOINTS_ONBOARD, _current_onboard_mission_index + 1, new_mission_item, len) != len) {
-			/* not supposed to happen unless the datamanager can't access the SD card, etc. */
-			return ERROR;
-		}
-
-		/* otherwise fallback to offboard */
 
+	/* otherwise fallback to offboard */
 	} else if (next_offboard_mission_available()) {
 
 		dm_item_t dm_current;
@@ -216,19 +205,14 @@ Mission::get_next_mission_item(struct mission_item_s *new_mission_item)
 			dm_current = DM_KEY_WAYPOINTS_OFFBOARD_1;
 		}
 
-		const ssize_t len = sizeof(struct mission_item_s);
+		unsigned next_offboard_mission_index = _current_offboard_mission_index + 1;
-
+		ret = get_mission_item(dm_current, &next_offboard_mission_index, new_mission_item);
-		if (dm_read(dm_current, _current_offboard_mission_index + 1, new_mission_item, len) != len) {
-			/* not supposed to happen unless the datamanager can't access the SD card, etc. */
-			return ERROR;
-		}
 
 	} else {
 		/* happens when no more mission items can be added as a next item */
-		return ERROR;
+		ret = ERROR;
 	}
-
+	return ret;
-	return OK;
 }
 
 
@@ -316,3 +300,33 @@ Mission::publish_mission_result()
 	/* reset reached bool */
 	_mission_result.mission_reached = false;
 }
+
+int
+Mission::get_mission_item(const dm_item_t dm_item, unsigned *mission_index, struct mission_item_s *new_mission_item)
+{
+	/* repeat several to get the mission item because we might have to follow multiple DO_JUMPS */
+	for (int i=0; i<10; i++) {
+
+		const ssize_t len = sizeof(struct mission_item_s);
+
+		/* read mission item from datamanager */
+		if (dm_read(dm_item, *mission_index, new_mission_item, len) != len) {
+			/* not supposed to happen unless the datamanager can't access the SD card, etc. */
+			return ERROR;
+		}
+
+		/* check for DO_JUMP item */
+		if (new_mission_item->nav_cmd == NAV_CMD_DO_JUMP) {
+			/* set new mission item index and repeat
+			 * we don't have to validate here, if it's invalid, we should realize this later .*/
+			*mission_index = new_mission_item->do_jump_mission_index;
+		} else {
+			/* if it's not a DO_JUMP, then we were successful */
+			return OK;
+		}
+	}
+
+	/* we have given up, we don't want to cycle forever */
+	warnx("ERROR: cycling through mission items without success");
+	return ERROR;
+}

src/modules/navigator/navigator_mission.h

@@ -77,6 +77,8 @@ public:
 	void		publish_mission_result();
 
 private:
+	int		get_mission_item(const dm_item_t dm_item, unsigned *mission_index, struct mission_item_s *new_mission_item);
+
 	bool		current_onboard_mission_available();
 	bool		current_offboard_mission_available();
 	bool		next_onboard_mission_available();