/*-
 * Copyright (c) 2014-present MongoDB, Inc.
 * Copyright (c) 2008-2014 WiredTiger, Inc.
 *	All rights reserved.
 *
 * See the file LICENSE for redistribution information.
 */

#include "wt_internal.h"

/*
 * __wt_thread_create --
 *     Create a new thread of control.
 */
int
__wt_thread_create(
  WT_SESSION_IMPL *session, wt_thread_t *tidret, WT_THREAD_CALLBACK (*func)(void *), void *arg)
{
    /*
     * Creating a thread isn't a memory barrier, but WiredTiger commonly sets flags and or state and
     * then expects worker threads to start. Include a barrier to ensure safety in those cases.
     */
    WT_FULL_BARRIER();

    /* Spawn a new thread of control. */
    tidret->id = (HANDLE)_beginthreadex(NULL, 0, func, arg, 0, NULL);
    if (tidret->id != 0) {
        tidret->created = true;
        return (0);
    }

    WT_RET_MSG(session, __wt_errno(), "thread create: _beginthreadex");
}

/*
 * __wt_thread_join --
 *     Wait for a thread of control to exit.
 */
int
__wt_thread_join(WT_SESSION_IMPL *session, wt_thread_t *tid)
{
    WT_DECL_RET;
    DWORD windows_error;

    /* Only attempt to join if thread was created successfully */
    if (!tid->created)
        return (0);
    tid->created = false;

    /*
     * Joining a thread isn't a memory barrier, but WiredTiger commonly sets flags and or state and
     * then expects worker threads to halt. Include a barrier to ensure safety in those cases.
     */
    WT_FULL_BARRIER();

    if ((windows_error = WaitForSingleObject(tid->id, INFINITE)) != WAIT_OBJECT_0) {
        if (windows_error == WAIT_FAILED)
            windows_error = __wt_getlasterror();

        /* If we fail to wait, we will leak handles, do not continue. */
        return (__wt_panic(session, __wt_map_windows_error(windows_error),
          "thread join: WaitForSingleObject: %s", __wt_formatmessage(session, windows_error)));
    }

    if (CloseHandle(tid->id) == 0) {
        windows_error = __wt_getlasterror();
        ret = __wt_map_windows_error(windows_error);
        __wt_err(
          session, ret, "thread join: CloseHandle: %s", __wt_formatmessage(session, windows_error));
        return (ret);
    }

    return (0);
}

/*
 * __wt_thread_id --
 *     Return an arithmetic representation of a thread ID on POSIX.
 */
void
__wt_thread_id(uintmax_t *id)
{
    *id = (uintmax_t)GetCurrentThreadId();
}

/*
 * __wt_thread_str --
 *     Fill in a printable version of the process and thread IDs.
 */
int
__wt_thread_str(char *buf, size_t buflen)
{
    return (__wt_snprintf(buf, buflen, "%" PRIu64 ":%" PRIu64, (uint64_t)GetCurrentProcessId(),
      (uint64_t)GetCurrentThreadId));
}

/*
 * __wt_process_id --
 *     Return the process ID assigned by the operating system.
 */
uintmax_t
__wt_process_id(void)
{
    return (uintmax_t)GetCurrentProcessId();
}