X-Git-Url: https://main.carlh.net/gitweb/?p=dcpomatic.git;a=blobdiff_plain;f=src%2Flib%2Fsignal_manager.h;h=99e3b5c52c271277a64fd654d121303eed877505;hp=ae4306e3077ad51ed34f50b65da0bf8edcf461e1;hb=2d4e8c5f69cc694625ad95dcee554499605f823b;hpb=65274489101d5b5c503ea94d61d7ac5eb1372636 diff --git a/src/lib/signal_manager.h b/src/lib/signal_manager.h index ae4306e30..99e3b5c52 100644 --- a/src/lib/signal_manager.h +++ b/src/lib/signal_manager.h @@ -1,35 +1,40 @@ /* - Copyright (C) 2012-2015 Carl Hetherington + Copyright (C) 2012-2021 Carl Hetherington - This program is free software; you can redistribute it and/or modify + This file is part of DCP-o-matic. + + DCP-o-matic is free software; you can redistribute it and/or modify it under the terms of the GNU General Public License as published by the Free Software Foundation; either version 2 of the License, or (at your option) any later version. - This program is distributed in the hope that it will be useful, + DCP-o-matic is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details. You should have received a copy of the GNU General Public License - along with this program; if not, write to the Free Software - Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA. + along with DCP-o-matic. If not, see . */ + #ifndef DCPOMATIC_SIGNAL_MANAGER_H #define DCPOMATIC_SIGNAL_MANAGER_H -#include + +#include "exception_store.h" #include #include + class Signaller; + /** A class to allow signals to be emitted from non-UI threads and handled * by a UI thread. */ -class SignalManager : public boost::noncopyable +class SignalManager : public ExceptionStore { public: /** Create a SignalManager. Must be called from the UI thread */ @@ -39,16 +44,23 @@ public: _ui_thread = boost::this_thread::get_id (); } + virtual ~SignalManager () {} + + SignalManager (Signaller const&) = delete; + SignalManager& operator= (Signaller const&) = delete; + /* Do something next time the UI is idle */ template void when_idle (T f) { _service.post (f); } - /** Call this in the UI when it is idle */ + /** Call this in the UI when it is idle. + * @return Number of idle handlers that were executed. + */ size_t ui_idle () { - /* This executes any functors that have been post()ed to _service */ - return _service.poll (); + /* This executes one of the functors that has been post()ed to _service */ + return _service.poll_one (); } /** This should wake the UI and make it call ui_idle() */ @@ -67,7 +79,11 @@ private: void emit (T f) { if (boost::this_thread::get_id() == _ui_thread) { /* already in the UI thread */ - f (); + try { + f (); + } catch (...) { + store_current (); + } } else { /* non-UI thread; post to the service and wake up the UI */ _service.post (f); @@ -76,7 +92,7 @@ private: } friend class Signaller; - + /** A io_service which is used as the conduit for messages */ boost::asio::io_service _service; /** Object required to keep io_service from stopping when it has nothing to do */ @@ -85,6 +101,8 @@ private: boost::thread::id _ui_thread; }; + extern SignalManager* signal_manager; + #endif