/*
Copyright (c) 2013 Microsoft Corporation. All rights reserved.
Released under Apache 2.0 license as described in the file LICENSE.

Author: Leonardo de Moura
*/
#include "interrupt.h"

namespace lean {

thread_local std::atomic_bool g_interrupt;

void request_interrupt() {
    g_interrupt.store(true);
}

void reset_interrupt() {
    g_interrupt.store(false);
}

bool interrupted() {
    return g_interrupt.load();
}

void check_interrupt() {
    if (interrupted())
        throw interrupt();
}

std::atomic_bool * interruptible_thread::get_flag_addr() {
    return &g_interrupt;
}

bool interruptible_thread::interrupted() const {
    std::atomic_bool * f = m_flag_addr.load();
    if (f == nullptr)
        return false;
    return f->load();
}

bool interruptible_thread::request_interrupt() {
    std::atomic_bool * f = m_flag_addr.load();
    if (f == nullptr)
        return false;
    f->store(true);
    return true;
}

void interruptible_thread::join() {
    m_thread.join();
}

bool interruptible_thread::joinable() {
    return m_thread.joinable();
}

}