121 lines
2.9 KiB
C++
121 lines
2.9 KiB
C++
/*
|
|
* \brief Fiasco.OC-specific implementation of core's startup Thread API.
|
|
* \author Norman Feske
|
|
* \author Stefan Kalkowski
|
|
* \date 2006-05-03
|
|
*/
|
|
|
|
/*
|
|
* Copyright (C) 2006-2017 Genode Labs GmbH
|
|
*
|
|
* This file is part of the Genode OS framework, which is distributed
|
|
* under the terms of the GNU Affero General Public License version 3.
|
|
*/
|
|
|
|
/* Genode includes */
|
|
#include <base/thread.h>
|
|
#include <base/sleep.h>
|
|
#include <trace/source_registry.h>
|
|
|
|
/* base-internal includes */
|
|
#include <base/internal/stack.h>
|
|
|
|
/* core includes */
|
|
#include <platform.h>
|
|
#include <core_env.h>
|
|
|
|
namespace Fiasco {
|
|
#include <l4/sys/debugger.h>
|
|
#include <l4/sys/factory.h>
|
|
#include <l4/sys/scheduler.h>
|
|
#include <l4/sys/thread.h>
|
|
}
|
|
|
|
using namespace Genode;
|
|
|
|
|
|
void Thread::_deinit_platform_thread()
|
|
{
|
|
warning(__func__, ": not implemented yet!");
|
|
}
|
|
|
|
|
|
void Thread::_init_platform_thread(size_t, Type) { }
|
|
|
|
|
|
void Thread::start()
|
|
{
|
|
using namespace Fiasco;
|
|
|
|
/* create and start platform thread */
|
|
Platform_thread &pt = *new (platform().core_mem_alloc())
|
|
Platform_thread(_stack->name().string());
|
|
|
|
platform_specific().core_pd().bind_thread(pt);
|
|
|
|
l4_utcb_t *foc_utcb = (l4_utcb_t *)(pt.utcb());
|
|
|
|
native_thread() = Native_thread(pt.gate().remote);
|
|
|
|
utcb()->foc_utcb = foc_utcb;
|
|
|
|
_thread_cap =
|
|
reinterpret_cap_cast<Cpu_thread>(Native_capability(pt.thread().local));
|
|
|
|
pt.pager(platform_specific().core_pager());
|
|
|
|
l4_utcb_tcr_u(foc_utcb)->user[UTCB_TCR_BADGE] = (unsigned long) pt.gate().local.data();
|
|
l4_utcb_tcr_u(foc_utcb)->user[UTCB_TCR_THREAD_OBJ] = (addr_t)this;
|
|
|
|
pt.start((void *)_thread_start, stack_top());
|
|
|
|
struct Core_trace_source : public Trace::Source::Info_accessor,
|
|
private Trace::Control,
|
|
private Trace::Source
|
|
{
|
|
Thread &thread;
|
|
Platform_thread &platform_thread;
|
|
|
|
/**
|
|
* Trace::Source::Info_accessor interface
|
|
*/
|
|
Info trace_source_info() const override
|
|
{
|
|
uint64_t const sc_time = 0;
|
|
addr_t const kcap = (addr_t) platform_thread.pager_object_badge();
|
|
|
|
using namespace Fiasco;
|
|
l4_kernel_clock_t ec_time = 0;
|
|
l4_msgtag_t res = l4_thread_stats_time(kcap, &ec_time);
|
|
if (l4_error(res))
|
|
Genode::error("cpu time for ", thread.name(),
|
|
" is not available ", l4_error(res));
|
|
|
|
return { Session_label("core"), thread.name(),
|
|
Trace::Execution_time(ec_time, sc_time, 10000,
|
|
platform_thread.prio()),
|
|
thread._affinity };
|
|
}
|
|
|
|
Core_trace_source(Trace::Source_registry ®istry, Thread &t,
|
|
Platform_thread &pt)
|
|
:
|
|
Trace::Control(),
|
|
Trace::Source(*this, *this), thread(t), platform_thread(pt)
|
|
{
|
|
registry.insert(this);
|
|
}
|
|
};
|
|
|
|
new (platform().core_mem_alloc()) Core_trace_source(Trace::sources(),
|
|
*this, pt);
|
|
}
|
|
|
|
|
|
void Thread::cancel_blocking()
|
|
{
|
|
/*
|
|
* Within core, we never need to unblock threads
|
|
*/
|
|
}
|