GatewayEmulatorThread< Listener > Class Template Reference

Public Member Functions
	GatewayEmulatorThread (const SessionSettings::LicenseStores &licenseStores, const std::string &host, Port port, std::unique_ptr< Listener > clientMessageListener)
	~GatewayEmulatorThread ()
void	wait (std::chrono::seconds timeout=std::chrono::seconds(10))
const Testing::Gateway &	gateway () const noexcept

Detailed Description

template<class Listener>
class Samples::GatewayEmulatorThread< Listener >

Definition at line 91 of file Emulator.h.

Constructor & Destructor Documentation

GatewayEmulatorThread()

template<class Listener>

GatewayEmulatorThread ( const SessionSettings::LicenseStores & licenseStores, const std::string & host, Port port, std::unique_ptr< Listener > clientMessageListener )

inline

Definition at line 94 of file Emulator.h.

        : gateway_(licenseStores, port, host.c_str(), std::chrono::seconds{10}, std::chrono::seconds{10})
        , clientMessageListener_(std::move(clientMessageListener))
    {
        std::promise<void> emulatorTaskPromise;
        emulatorTaskDone_ = emulatorTaskPromise.get_future();
 
        std::thread(
            std::bind(
                [&](std::promise<void>& p)
                {
                    try
                    {
                        gateway_.run(*clientMessageListener_, &stopRequested_);
                        p.set_value();
                    }
                    catch (const std::exception& ex)
                    {
                        std::cerr << "Exception in Emulator's thread: " << ex.what() << '.' << std::endl;
                        p.set_exception(std::current_exception());
                    }
                    catch (...)
                    {
                        std::cerr << "UNKNOWN Exception in Emulator's thread." << std::endl;
                        p.set_exception(std::current_exception());
                    }
                },
                std::move(emulatorTaskPromise)))
            .detach();
    }

~GatewayEmulatorThread()

template<class Listener>

~GatewayEmulatorThread ( )

inline

Definition at line 125 of file Emulator.h.

    {
        stopRequested_.store(true);
 
        if(emulatorTaskDone_.valid())
            emulatorTaskDone_.wait_for(std::chrono::seconds(10));
    }

Member Function Documentation

gateway()

template<class Listener>

const Testing::Gateway & gateway ( ) const

inlinenoexcept

Definition at line 143 of file Emulator.h.

    {
        return gateway_;
    }

wait()

template<class Listener>

void wait ( std::chrono::seconds timeout = std::chrono::seconds(10) )

inline

Definition at line 133 of file Emulator.h.

    {
        if(emulatorTaskDone_.valid())
        {
            std::future<void> f = std::move(emulatorTaskDone_);
            f.wait_for(timeout);
            f.get();
        }
    }