#include <stdexcept> /* std::domain_error */</stdexcept>

#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>(</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()));

  }

}