debugfuture.hh

Go to the documentation of this file.

#ifndef _DRAMA2_DEBUGFUTURE_INC
#define _DRAMA2_DEBUGFUTURE_INC
/*
 *  History:
      12-Jan-2017 - TJF - Original version.
 
 */
 
#include <drama.hh>
#include <future>
#include <typeinfo>
 
namespace drama {
    /* Used internally by Future - not for user access */
    extern bool _futureDebugGlobalLogDetails;
 
 
    template <class T>
    class Future : public  std::future<T> {
        using BaseFuture=std::future<T>;
    private:
        std::string _name;         // Name used in messages.
        std::string _type;
        bool _logDetails = false;  // Object specific log flag.
    public:
 
        void LogOn() {
            _logDetails = true;
        }
        static void GlobalLogOn() {
             _futureDebugGlobalLogDetails = true;
        }
        void LogOff() {
            _logDetails = false;
        }
        static void GlobalLogOff() {
             _futureDebugGlobalLogDetails = false;
        }
        static bool GetGlobalLogState()  {
            return _futureDebugGlobalLogDetails;
        }
        bool GetLogState() const {
            return _logDetails;
        }
        void SetName(const std::string &newName) {
            _name = newName;
        }
 
        Future(const std::string &name="unnamed", 
               bool logOn=false) noexcept : _name(name), _logDetails(logOn) {
                   T a;
                   _type = typeid(a).name();
        }
 
        Future(const Future&) = delete; 
 
 
        Future& operator=(Future &&rhs) noexcept  {
            *this = std::move(rhs);
            return *this;
        }
 
        Future& operator=( BaseFuture &&rhs) noexcept {
            *((BaseFuture *)(this)) = std::move(rhs);
            if ((_logDetails)||( _futureDebugGlobalLogDetails))
            {
                std::cerr << fmt::format("drama::Future<{0}> \"{1}\" assigned",
                                   _type, _name) << std::endl;
            }
            return *this;
        }
 
 
        Future& operator=(const Future &)  = delete;
 
        T get() {
            if ((_logDetails)||( _futureDebugGlobalLogDetails))
            {
                std::cerr << fmt::format("drama::Future<{0}> \"{1}\" get() invoked", 
                                   _type, _name) << std::endl;
            }
            /*
             * Run get() on the base class.  This may throw and we
             * want to log that.
             */
            T result;
            try
            {
                result = ((BaseFuture *)(this))->get();
            }
            catch (...)
            {
                if ((_logDetails)||( _futureDebugGlobalLogDetails))
                {
                    std::cerr << fmt::format("drama::Future<{0}> \"{1}\" get() threw", 
                                       _type, _name) << std::endl;
                }
                throw;
            }
            /*
             * did not throw.
             */
            if ((_logDetails)||( _futureDebugGlobalLogDetails))
            {
                std::cerr << fmt::format("drama::Future<{0}> \"{1}\" get() returning", 
                                   _type, _name) << std::endl;
            }
            return result;
        }
 
         ~Future() {
            if ((_logDetails)||( _futureDebugGlobalLogDetails))
            {
                std::cerr << fmt::format("drama::Future<{0}> \"{1}\" destroyed", 
                                   _type, _name) << std::endl;
            }
        }
 
    };
 
 
    template <>
    class Future<void> : public std::future<void> {
        using BaseFuture = std::future<void>;
    private:
        std::string _name;          // Name used in messages.
        bool _logDetails = false;   // Object specific log flag.
    public:
 
        void LogOn() {
            _logDetails = true;
        }
        static void GlobalLogOn() {
             _futureDebugGlobalLogDetails = true;
        }
        void LogOff() {
            _logDetails = false;
        }
        static void GlobalLogOff() {
            _futureDebugGlobalLogDetails = false;
        }
        static bool GetGlobalLogState()  {
            return _futureDebugGlobalLogDetails;
        }
        bool GetLogState() const {
            return _logDetails;
        }
        void SetName(const std::string &newName) {
            _name = newName;
        }
 
        Future(const std::string &name="unnamed", bool logOn=false) noexcept : _name(name), _logDetails(logOn) {}
        Future(const Future&) = delete; 
 
        Future& operator=(Future &&rhs) noexcept  {
            _name = std::move(rhs._name);
            _logDetails = rhs._logDetails;
            return *this;
        }
 
        Future& operator=(BaseFuture &&rhs) noexcept {
            *((BaseFuture *)(this)) = std::move(rhs);
            if ((_logDetails)||( _futureDebugGlobalLogDetails))
            {
                std::cerr << fmt::format("drama::Future<void> \"{0}\" assigned", _name) << std::endl;
            }
            return *this;
        }
        Future& operator=(const Future &)  = delete;
 
        void get() {
            if ((_logDetails)||( _futureDebugGlobalLogDetails))
            {
                std::cerr << fmt::format("drama::Future<void> \"{0}\" get() invoked", _name) << std::endl;
            }
            /*
             * Run get() on the base class.  This may throw and we
             * want to log that.
             */
            try
            {
                ((BaseFuture *)(this))->get();
            }
            catch (...)
            {
                if ((_logDetails)||( _futureDebugGlobalLogDetails))
                {
                    std::cerr << fmt::format("drama::Future<void> \"{0}\" get() threw", _name) << std::endl;
                }
                throw;
            }
            /*
             * did not throw.
             */
            if ((_logDetails)||( _futureDebugGlobalLogDetails))
            {
                std::cerr << fmt::format("drama::Future<void> \"{0}\" get() returning", _name) << std::endl;
            }
        }
        ~Future() {
            if ((_logDetails)||( _futureDebugGlobalLogDetails))
            {
                if (valid())
                {
                    std::cerr << fmt::format("drama::Future<void> \"{0}\" destroyed - but is still valid (which could be a problem)!!", _name) << std::endl;
                }
                else
                {
                    std::cerr << fmt::format("drama::Future<void> \"%\" destroyed - was not valid (which is ok).", _name) << std::endl;
                }
            }
        }
 
    };
 
 
 
} // namespace drama
 
#endif  /* defined _DRAMA2_SDP_INC */