mirrors/gnss-sdr
1
0
Fork 0
mirror of https://github.com/gnss-sdr/gnss-sdr synced 2025-02-14 18:10:10 +00:00
Code Issues Releases Wiki Activity

Added keyboard response functionality: Now it is possible to stop GNSS-SDR from the keyboard order "q"+ENTER

Browse Source 
git-svn-id: https://svn.code.sf.net/p/gnss-sdr/code/trunk@186 64b25241-fba3-4117-9849-534c7e92360d
This commit is contained in:
Javier Arribas 2012-03-16 12:04:36 +00:00
parent 984b782660
commit 5340adad36
2 changed files with 32 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
src/core/receiver/control_thread.cc
View File

@ -41,6 +41,8 @@
#include "gnss_flowgraph.h" #include "gnss_flowgraph.h"
#include "file_configuration.h" #include "file_configuration.h"
#include "control_message_factory.h" #include "control_message_factory.h"
#include <boost/thread/thread.hpp>
#include <iostream>
using google::LogMessage; using google::LogMessage;
@ -102,6 +104,9 @@ void ControlThread::run()
return; return;
} }
// start the keyboard_listener thread
keyboard_thread_ = boost::thread(&ControlThread::keyboard_listener, this);
// Main loop to read and process the control messages // Main loop to read and process the control messages
while (flowgraph_->running() && !stop_) while (flowgraph_->running() && !stop_)
{ {
@ -110,8 +115,8 @@ void ControlThread::run()
if (control_messages_ != 0) process_control_messages(); if (control_messages_ != 0) process_control_messages();
} }
keyboard_thread_.join();
flowgraph_->stop(); flowgraph_->stop();
LOG_AT_LEVEL(INFO) << "Flowgraph stopped"; LOG_AT_LEVEL(INFO) << "Flowgraph stopped";
} }
@ -199,3 +204,26 @@ void ControlThread::apply_action(unsigned int what)
} }
void ControlThread::keyboard_listener()
{
bool read_keys=true;
char c;
//std::cout<<"Keystroke reader start!"<<std::endl;
while(read_keys)
{
c= std::cin.get();
//std::cout<<"Keystroke received: "<<c<<std::endl;
if (c=='q')
{
std::cout<<"Quit keystroke order received, stopping GNSS-SDR !!"<<std::endl;
ControlMessageFactory* cmf = new ControlMessageFactory();
if (control_queue_ != gr_msg_queue_sptr()) {
control_queue_->handle(cmf->GetQueueMessage(200, 0));
}
delete cmf;
read_keys=false;
}
}
}

3
src/core/receiver/control_thread.h
View File

@ -37,6 +37,7 @@
#include <gnuradio/gr_msg_queue.h> #include <gnuradio/gr_msg_queue.h>
#include "control_message_factory.h" #include "control_message_factory.h"
#include <boost/thread/thread.hpp>
class GNSSFlowgraph; class GNSSFlowgraph;
class ConfigurationInterface; class ConfigurationInterface;
@ -123,6 +124,8 @@ private:
unsigned int processed_control_messages_; unsigned int processed_control_messages_;
unsigned int applied_actions_; unsigned int applied_actions_;
boost::thread keyboard_thread_;
void keyboard_listener();
}; };
#endif /*GNSS_SDR_CONTROL_THREAD_H_*/ #endif /*GNSS_SDR_CONTROL_THREAD_H_*/