/*
 * 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