Merge branch 'next' of https://github.com/gnss-sdr/gnss-sdr into ssr

src/utils/nav-listener/main.cc

@@ -34,7 +34,15 @@ int main(int argc, char *argv[])
 
             while (true)
                 {
-                    udp_listener.print_content();
+                    gnss_sdr::navMsg message;
+                    if (udp_listener.receive_and_parse_nav_message(message))
+                        {
+                            udp_listener.print_message(message);
+                        }
+                    else
+                        {
+                            std::cout << "Error: the message cannot be parsed." << std::endl;
+                        }
                 }
         }
     catch (std::exception &e)

src/utils/nav-listener/nav_msg_udp_listener.cc

@@ -25,30 +25,34 @@ Nav_Msg_Udp_Listener::Nav_Msg_Udp_Listener(unsigned short port)
     socket.bind(endpoint, error);             // Bind the socket to the given local endpoint.
 }
 
-
+/**
-bool Nav_Msg_Udp_Listener::read_nav_message(gnss_sdr::navMsg &message)
+ * !\brief blocking call to read nav_message from UDP port
+ * \param[out] message navigation message class to contain parsed output
+ * \return true if message parsed succesfully, false ow
+ */
+bool Nav_Msg_Udp_Listener::receive_and_parse_nav_message(gnss_sdr::navMsg &message)
 {
     char buff[8192];  // Buffer for storing the received data.
 
-    message_ = message;
     // This call will block until one or more bytes of data has been received.
     int bytes = socket.receive(boost::asio::buffer(buff));
 
     std::string data(&buff[0], bytes);
     // Deserialize a stock of Nav_Msg objects from the binary string.
-    return message_.ParseFromString(data);
+    return message.ParseFromString(data);
 }
 
-
+/*
-bool Nav_Msg_Udp_Listener::print_content()
+ * !\brief prints navigation message content
+ * \param[in] message nav message to be printed
+ */
+void Nav_Msg_Udp_Listener::print_message(gnss_sdr::navMsg &message) const
 {
-    if (read_nav_message(message_))
+    std::string system = message.system();
-        {
+    std::string signal = message.signal();
-            std::string system = message_.system();
+    int prn = message.prn();
-            std::string signal = message_.signal();
+    int tow_at_current_symbol_ms = message.tow_at_current_symbol_ms();
-            int prn = message_.prn();
+    std::string nav_message = message.nav_message();
-            int tow_at_current_symbol_ms = message_.tow_at_current_symbol_ms();
-            std::string nav_message = message_.nav_message();
 
     std::cout << "\nNew Data received:\n";
     std::cout << "System: " << system << '\n';
@@ -58,11 +62,3 @@ bool Nav_Msg_Udp_Listener::print_content()
               << tow_at_current_symbol_ms << '\n';
     std::cout << "Nav message: " << nav_message << "\n\n";
 }
-    else
-        {
-            std::cout << "Error: the message cannot be parsed.\n";
-            return false;
-        }
-
-    return true;
-}

src/utils/nav-listener/nav_msg_udp_listener.h

@@ -23,15 +23,14 @@ class Nav_Msg_Udp_Listener
 {
 public:
     explicit Nav_Msg_Udp_Listener(unsigned short port);
-    bool print_content();
+    void print_message(gnss_sdr::navMsg &message) const;
+    bool receive_and_parse_nav_message(gnss_sdr::navMsg &message);
 
 private:
-    bool read_nav_message(gnss_sdr::navMsg &message);
     boost::asio::io_service io_service;
     boost::asio::ip::udp::socket socket;
     boost::system::error_code error;
     boost::asio::ip::udp::endpoint endpoint;
-    gnss_sdr::navMsg message_;
 };
 
 #endif