#include <stdexcept> /* std::domain_error */
#include "igs_resource_thread.h"
#include "igs_resource_msg_from_err.h"

const HANDLE igs::resource::thread_run(
	unsigned(__stdcall *function)(void *), void *func_arg, const int priority)
{
	//unsigned thread_addr=0;
	HANDLE thread_id = reinterpret_cast<HANDLE>(::_beginthreadex(
		NULL, 0, function, func_arg, 0, NULL));
	if (0 == thread_id) {
		throw std::domain_error(igs_resource_msg_from_err(
			TEXT("_beginthreadex(-)"), errno));
	}
	/*
	vc2005 MSDN より
	BOOL SetThreadPriority(int nPriority);
	に与える値を優先度の高いものから順に並べます。
	THREAD_PRIORITY_TIME_CRITICAL		プロセスにより15 or 31
	THREAD_PRIORITY_HIGHEST			標準より2ポイント高い
	THREAD_PRIORITY_ABOVE_NORMAL		標準より1ポイント高い
	THREAD_PRIORITY_NORMAL		-1	標準
	THREAD_PRIORITY_BELOW_NORMAL		標準より1ポイント低い
	THREAD_PRIORITY_LOWEST			標準より2ポイント低い
	THREAD_PRIORITY_IDLE			プロセスにより1 or 16
	*/
	if (0 == ::SetThreadPriority(thread_id, priority)) {
		throw std::domain_error(igs_resource_msg_from_err(
			TEXT("SetThreadPriority(-)"), ::GetLastError()));
	}
	return thread_id;
}

/*
以下の関数でthreadの終了を見るよりも、
thread内で終了時に終了スイッチを入れる方法で感知する。
linuxでのやり方にあわせる。2011-03-30
*/
const bool igs::resource::thread_was_done(const HANDLE thread_id)
{
	DWORD exit_code = 0;
	if (0 == ::GetExitCodeThread(thread_id, &exit_code)) {
		throw std::domain_error(igs_resource_msg_from_err(
			"GetExitCodeThread(-)", ::GetLastError()));
	}
	if (exit_code == STILL_ACTIVE) {
		return false;
	}
	return true;
}
void igs::resource::thread_join(const HANDLE thread_id)
{
	thread_wait(thread_id);
	thread_close(thread_id);
}
void igs::resource::thread_wait(const HANDLE thread_id)
{
	/* _endthreadex(-)はスレッドハンドルを閉じない??? */
	if (WAIT_FAILED == ::WaitForSingleObject(thread_id, INFINITE)) {
		throw std::domain_error(igs_resource_msg_from_err(
			TEXT("WaitForSingleObject(-)"), ::GetLastError()));
	}
}
void igs::resource::thread_close(const HANDLE thread_id)
{
	if (0 == ::CloseHandle(thread_id)) {
		throw std::domain_error(igs_resource_msg_from_err(
			TEXT("CloseHandle(-)"), ::GetLastError()));
	}
}