Acore::AsyncProcessResultImplementation Class Reference

Inheritance diagram for Acore::AsyncProcessResultImplementation:

Public Member Functions
	AsyncProcessResultImplementation (std::string executable_, std::vector< std::string > args_, std::string logger_, std::string input_file_, bool secure)
	AsyncProcessResultImplementation (AsyncProcessResultImplementation const &)=delete
AsyncProcessResultImplementation &	operator= (AsyncProcessResultImplementation const &)=delete
	AsyncProcessResultImplementation (AsyncProcessResultImplementation &&)=delete
AsyncProcessResultImplementation &	operator= (AsyncProcessResultImplementation &&)=delete
int	StartProcess ()
void	SetFuture (std::future< int > result_)
std::future< int > &	GetFutureResult () override
void	Terminate () override
	Tries to terminate the process. More...
Public Member Functions inherited from Acore::AsyncProcessResult
virtual	~AsyncProcessResult ()
virtual std::future< int > &	GetFutureResult ()=0
virtual void	Terminate ()=0
	Tries to terminate the process. More...

Private Attributes
std::string const	executable
std::vector< std::string > const	args
std::string const	logger
std::string const	input_file
bool const	is_secure
std::atomic< bool >	was_terminated
Optional< std::shared_ptr< std::future< int > > >	result
Optional< std::reference_wrapper< child > >	my_child

Detailed Description

Constructor & Destructor Documentation

AsyncProcessResultImplementation() [1/3]

Acore::AsyncProcessResultImplementation::AsyncProcessResultImplementation ( std::string  executable_, std::vector< std::string >  args_, std::string  logger_, std::string  input_file_, bool  secure  )

inlineexplicit

            : executable(std::move(executable_)), args(std::move(args_)),
            logger(std::move(logger_)), input_file(input_file_),
            is_secure(secure), was_terminated(false) { }

AsyncProcessResultImplementation() [2/3]

Acore::AsyncProcessResultImplementation::AsyncProcessResultImplementation ( AsyncProcessResultImplementation const &  )

delete

AsyncProcessResultImplementation() [3/3]

Acore::AsyncProcessResultImplementation::AsyncProcessResultImplementation ( AsyncProcessResultImplementation &&  )

delete

Member Function Documentation

GetFutureResult()

std::future< int > & Acore::AsyncProcessResultImplementation::GetFutureResult ( )

inlineoverridevirtual

Returns the future which contains the result of the process as soon it is finished.

Implements Acore::AsyncProcessResult.

        {
            ASSERT(*result, "The process wasn't started!");
            return **result;
        }

References ASSERT, and result.

operator=() [1/2]

AsyncProcessResultImplementation & Acore::AsyncProcessResultImplementation::operator= ( AsyncProcessResultImplementation &&  )

delete

operator=() [2/2]

AsyncProcessResultImplementation & Acore::AsyncProcessResultImplementation::operator= ( AsyncProcessResultImplementation const &  )

delete

SetFuture()

void Acore::AsyncProcessResultImplementation::SetFuture ( std::future< int >  result_ )

inline

        {
            result = std::make_shared<std::future<int>>(std::move(result_));
        }

References result.

StartProcess()

int Acore::AsyncProcessResultImplementation::StartProcess ( )

inline

        {
            ASSERT(!my_child, "Process started already!");
 
            return CreateChildProcess([&](child& c) -> int
            {
                int exitCode;
                my_child = std::reference_wrapper<child>(c);
 
                try
                {
                    c.wait();
                    exitCode = c.exit_code();
                }
                catch (...)
                {
                    exitCode = EXIT_FAILURE;
                }
 
                my_child.reset();
                return was_terminated ? EXIT_FAILURE : exitCode;
 
            }, executable, args, logger, input_file, is_secure);
        }

References args, ASSERT, Acore::CreateChildProcess(), executable, input_file, is_secure, logger, my_child, and was_terminated.

Terminate()

void Acore::AsyncProcessResultImplementation::Terminate ( )

inlineoverridevirtual

Tries to terminate the process.

Implements Acore::AsyncProcessResult.

        {
            if (my_child)
            {
                was_terminated = true;
                try
                {
                    my_child->get().terminate();
                }
                catch (...)
                {
                    // Do nothing
                }
            }
        }

References my_child, and was_terminated.

Member Data Documentation

args

std::vector<std::string> const Acore::AsyncProcessResultImplementation::args

private

Referenced by StartProcess().

executable

std::string const Acore::AsyncProcessResultImplementation::executable

private

Referenced by StartProcess().

input_file

std::string const Acore::AsyncProcessResultImplementation::input_file

private

Referenced by StartProcess().

is_secure

bool const Acore::AsyncProcessResultImplementation::is_secure

private

Referenced by StartProcess().

logger

std::string const Acore::AsyncProcessResultImplementation::logger

private

Referenced by StartProcess().

my_child

Optional<std::reference_wrapper<child> > Acore::AsyncProcessResultImplementation::my_child

private

Referenced by StartProcess(), and Terminate().

result

Optional<std::shared_ptr<std::future<int> > > Acore::AsyncProcessResultImplementation::result

private

Referenced by GetFutureResult(), and SetFuture().

was_terminated

std::atomic<bool> Acore::AsyncProcessResultImplementation::was_terminated

private

Referenced by StartProcess(), and Terminate().