mirrors/gnss-sdr
1
0
Fork 0
mirror of https://github.com/gnss-sdr/gnss-sdr synced 2025-01-05 15:00:33 +00:00
Code Issues Releases Wiki Activity

Stop on error

Browse Source
This commit is contained in:
Anthony Arnold 2015-05-15 18:41:51 +10:00
parent a02c659795
commit d912ea7500
2 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/algorithms/signal_source/gnuradio_blocks/rtl_tcp_signal_source_c.cc
View File

@ -152,6 +152,9 @@ int rtl_tcp_signal_source_c::work (int noutput_items,
{ {
gr_complex *out = reinterpret_cast <gr_complex *>( output_items[0] ); gr_complex *out = reinterpret_cast <gr_complex *>( output_items[0] );
int i = 0; int i = 0;
if (io_service_.stopped ()) {
return -1;
}
{ {
boost::mutex::scoped_lock lock (mutex_); boost::mutex::scoped_lock lock (mutex_);
@ -282,7 +285,7 @@ rtl_tcp_signal_source_c::handle_read (const boost::system::error_code &ec,
std::cout << "Error during read: " << ec << std::endl; std::cout << "Error during read: " << ec << std::endl;
LOG (WARNING) << "Error during read: " << ec; LOG (WARNING) << "Error during read: " << ec;
boost::mutex::scoped_lock lock (mutex_); boost::mutex::scoped_lock lock (mutex_);
buffer_.clear (); io_service_.stop ();
not_empty_.notify_one (); not_empty_.notify_one ();
} }
else { else {

2
src/algorithms/signal_source/gnuradio_blocks/rtl_tcp_signal_source_c.h
View File

@ -115,7 +115,7 @@ private:
} }
inline bool not_empty ( ) const { inline bool not_empty ( ) const {
return unread_ > 0; return unread_ > 0 && !io_service_.stopped ();
} }
}; };