/*
 * Copyright 2021-2022, Andrew Lindesay <apl@lindesay.co.nz>.
 * All rights reserved. Distributed under the terms of the MIT License.
 */
#ifndef THREADED_PROCESS_NODE_H
#define THREADED_PROCESS_NODE_H

#include "AbstractProcessNode.h"


class ThreadedProcessNode : public AbstractProcessNode {
public:
                                                                ThreadedProcessNode(AbstractProcess* process,
                                                                        int32 startTimeoutSeconds);
                                                                ThreadedProcessNode(AbstractProcess* process);
        virtual                                         ~ThreadedProcessNode();

        virtual status_t                        Start();
        virtual status_t                        RequestStop();
        virtual bool                            IsRunning();

private:
                        void                            _RunProcessStart();
                        void                            _RunProcessExit();
        static  status_t                        _RunProcessThreadEntry(void* cookie);
        static  void                            _RunProcessThreadExit(void* cookie);

private:
                        thread_id                       fWorker;
                        int32                           fStartTimeoutSeconds;
};

#endif // THREADED_PROCESS_NODE_H