1 /* -*- c++ -*- */ 2 /* 3 * Copyright 2008,2009,2013 Free Software Foundation, Inc. 4 * 5 * This file is part of GNU Radio 6 * 7 * GNU Radio is free software; you can redistribute it and/or modify 8 * it under the terms of the GNU General Public License as published by 9 * the Free Software Foundation; either version 3, or (at your option) 10 * any later version. 11 * 12 * GNU Radio is distributed in the hope that it will be useful, 13 * but WITHOUT ANY WARRANTY; without even the implied warranty of 14 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the 15 * GNU General Public License for more details. 16 * 17 * You should have received a copy of the GNU General Public License along 18 * with this program; if not, write to the Free Software Foundation, Inc., 19 * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA. 20 */ 21 22 #ifndef INCLUDED_THREAD_BODY_WRAPPER_H 23 #define INCLUDED_THREAD_BODY_WRAPPER_H 24 25 #include <gnuradio/api.h> 26 #include <gnuradio/thread/thread.h> 27 #include <exception> 28 #include <iostream> 29 30 namespace gr { 31 namespace thread { 32 33 GR_RUNTIME_API void mask_signals(); 34 35 template <class F> 36 class thread_body_wrapper 37 { 38 private: 39 F d_f; 40 std::string d_name; 41 42 public: d_f(f)43 explicit thread_body_wrapper(F f, const std::string& name = "") : d_f(f), d_name(name) 44 { 45 } 46 operator()47 void operator()() 48 { 49 mask_signals(); 50 51 try { 52 d_f(); 53 } catch (boost::thread_interrupted const&) { 54 } catch (std::exception const& e) { 55 std::cerr << "thread[" << d_name << "]: " << e.what() << std::endl; 56 } catch (...) { 57 std::cerr << "thread[" << d_name << "]: " 58 << "caught unrecognized exception\n"; 59 } 60 } 61 }; 62 63 } /* namespace thread */ 64 } /* namespace gr */ 65 66 #endif /* INCLUDED_THREAD_BODY_WRAPPER_H */ 67