mirror of
https://github.com/RIOT-OS/RIOT.git
synced 2024-12-29 04:50:03 +01:00
99 lines
2.3 KiB
C++
99 lines
2.3 KiB
C++
/*
|
|
* Copyright (C) 2015 Hamburg University of Applied Sciences (HAW)
|
|
*
|
|
* This file is subject to the terms and conditions of the GNU Lesser
|
|
* General Public License v2.1. See the file LICENSE in the top level
|
|
* directory for more details.
|
|
*/
|
|
|
|
/**
|
|
* @ingroup cpp11-compat
|
|
* @{
|
|
*
|
|
* @file
|
|
* @brief C++11 thread drop in replacement
|
|
*
|
|
* @author Raphael Hiesgen <raphael.hiesgen (at) haw-hamburg.de>
|
|
*
|
|
* @}
|
|
*/
|
|
|
|
#include "vtimer.h"
|
|
|
|
#include <cerrno>
|
|
#include <system_error>
|
|
|
|
#include "riot/thread.hpp"
|
|
|
|
using namespace std;
|
|
|
|
namespace riot {
|
|
|
|
thread::~thread() {
|
|
if (joinable()) {
|
|
terminate();
|
|
}
|
|
}
|
|
|
|
void thread::join() {
|
|
if (this->get_id() == this_thread::get_id()) {
|
|
throw system_error(make_error_code(errc::resource_deadlock_would_occur),
|
|
"Joining this leads to a deadlock.");
|
|
}
|
|
if (joinable()) {
|
|
auto status = thread_getstatus(m_handle);
|
|
if (status != STATUS_NOT_FOUND && status != STATUS_STOPPED) {
|
|
m_data->joining_thread = sched_active_pid;
|
|
thread_sleep();
|
|
}
|
|
m_handle = thread_uninitialized;
|
|
} else {
|
|
throw system_error(make_error_code(errc::invalid_argument),
|
|
"Can not join an unjoinable thread.");
|
|
}
|
|
// missing: no_such_process system error
|
|
}
|
|
|
|
void thread::detach() {
|
|
if (joinable()) {
|
|
m_handle = thread_uninitialized;
|
|
} else {
|
|
throw system_error(make_error_code(errc::invalid_argument),
|
|
"Can not detach an unjoinable thread.");
|
|
}
|
|
}
|
|
|
|
unsigned thread::hardware_concurrency() noexcept {
|
|
// there is currently no API for this
|
|
return 1;
|
|
}
|
|
|
|
namespace this_thread {
|
|
|
|
void sleep_for(const chrono::nanoseconds& ns) {
|
|
using namespace chrono;
|
|
if (ns > nanoseconds::zero()) {
|
|
seconds s = duration_cast<seconds>(ns);
|
|
timespec ts;
|
|
using ts_sec = decltype(ts.tv_sec);
|
|
constexpr ts_sec ts_sec_max = numeric_limits<ts_sec>::max();
|
|
if (s.count() < ts_sec_max) {
|
|
ts.tv_sec = static_cast<ts_sec>(s.count());
|
|
ts.tv_nsec = static_cast<decltype(ts.tv_nsec)>((ns - s).count());
|
|
} else {
|
|
ts.tv_sec = ts_sec_max;
|
|
ts.tv_nsec = giga::num - 1;
|
|
}
|
|
timex_t reltime;
|
|
reltime.seconds = ts.tv_sec;
|
|
reltime.microseconds = ts.tv_nsec / 1000u;
|
|
vtimer_t timer;
|
|
vtimer_set_wakeup(&timer, reltime, sched_active_pid);
|
|
thread_sleep();
|
|
}
|
|
}
|
|
|
|
} // namespace this_thread
|
|
|
|
} // namespace riot
|