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