// TaskManager.cpp

#include "TaskManager.h"

// #pragma mark -
// #pragma mark ----- Task -----

// constructor
Task::Task(const char* name)
	: fName(name),
	  fThread(-1),
	  fTerminating(false),
	  fDone(true)
{
}

// destructor
Task::~Task()
{
}

// Run
status_t
Task::Run()
{
	const char* name = (fName.GetLength() > 0 ? fName.GetString() : "task");
#if USER
	fThread = spawn_thread(&_ThreadEntry, name, B_NORMAL_PRIORITY, this);
#else
	fThread = spawn_kernel_thread(&_ThreadEntry, name, B_NORMAL_PRIORITY, this);
#endif
	if (fThread < 0)
		return fThread;
	fDone = false;
	resume_thread(fThread);
	return B_OK;
}

// Terminate
void
Task::Terminate()
{
	fTerminating = true;
	Stop();
	if (fThread >= 0) {
		int32 result;
		wait_for_thread(fThread, &result);
	}
}

// IsDone
bool
Task::IsDone() const
{
	return fDone;
}

// Stop();
void
Task::Stop()
{
}

// SetDone
void
Task::SetDone(bool done)
{
	fDone = 0;
}

// _ThreadEntry
int32
Task::_ThreadEntry(void* data)
{
	return ((Task*)data)->_Thread();
}

// _Thread
int32
Task::_Thread()
{
	Execute();
	return 0;
}


// #pragma mark -
// #pragma mark ----- TaskManager -----

// constructor
TaskManager::TaskManager()
	: fTasks()
{
}

// destructor
TaskManager::~TaskManager()
{
	TerminateAllTasks();
}

// RunTask
status_t
TaskManager::RunTask(Task* task)
{
	if (!task)
		return B_BAD_VALUE;
	fTasks.Insert(task);
	status_t error = task->Run();
	if (error != B_OK) {
		fTasks.Remove(task);
		delete task;
	}
	return error;
}

// RemoveDoneTasks
void
TaskManager::RemoveDoneTasks()
{
	Task* task = fTasks.First();
	while (task) {
		Task* next = fTasks.GetNext(task);
		if (task->IsDone()) {
			fTasks.Remove(task);
			task->Terminate();
			delete task;
		}
		task = next;
	}
}

// TerminateAllTasks
void
TaskManager::TerminateAllTasks()
{
	while (Task* task = fTasks.First()) {
		fTasks.Remove(task);
		task->Terminate();
		delete task;
	}
}