application_intf.h

Go to the documentation of this file.

#pragma once
#include "runnable_intf.h"
#include "runnable.h"
#include <adtfucom3/adtf_ucom3.h>
 
namespace adtf
{
namespace services
{
namespace ant
{

class IApplication : public ucom::IObject
{
public:
    ADTF_IID(IApplication, "application.ant.services.adtf.iid");
 
public:
    class IJob : public ucom::ant::IObject, public base::ant::IRunnable
    {
    public:
        ADTF_IID(IJob, "job.application.ant.services.adtf.iid");
    };
 
public:
    virtual tResult Exec() = 0;

    virtual tResult Exit(tResult oExitResult = ERR_NOERROR) = 0;

    virtual tResult EnqueueJob(const ucom::ant::iobject_ptr<IJob>& oJob, bool bWait) = 0;
};
 
} // namespace ant
 
namespace quiet
{

class IApplication : public ant::IApplication
{
public:
    ADTF_IID(IApplication, "application.quiet.services.adtf.iid");
 
public:
    virtual void ProcessEvents(adtf::base::flash::tNanoSeconds tmMaxTime) = 0;
};
 
} // namespace quiet

template<typename CALLABLE>
class job_runnable final :
    public base::runnable<base::ant::IRunnable::RUN_JOB, ant::IApplication::IJob, base::flash::IRunnable, CALLABLE>
{
public:
    using base::runnable<base::ant::IRunnable::RUN_JOB, ant::IApplication::IJob, base::flash::IRunnable, CALLABLE>::
        runnable;
};

template<typename CALLABLE>
job_runnable(CALLABLE&&) -> job_runnable<CALLABLE&&>;

template<typename CALLABLE, std::enable_if_t<std::is_invocable_r<tResult, CALLABLE>::value, bool> = true>
inline tResult enqueue_job(CALLABLE&& fnJobFunction, bool bWait = false) noexcept
{
    ucom::object_ptr<ant::IApplication> pApp;
    RETURN_IF_FAILED(_runtime->GetObject(pApp));
    const ucom::object_ptr<ant::IApplication::IJob> pJob = ucom::make_object_ptr(job_runnable(
        [fnJobFunction = std::forward<CALLABLE>(fnJobFunction)]() noexcept -> tResult
        {
            RETURN_IF_FAILED(fnJobFunction());
            RETURN_NOERROR;
        }));
    RETURN_IF_FAILED(pApp->EnqueueJob(pJob, bWait));
    RETURN_NOERROR;
}
 
using quiet::IApplication;
} // namespace services
} // namespace adtf