#include <allscale/monitor.hpp>

#include <allscale/work_item.hpp>

#include <allscale/components/monitor.hpp>

#include <hpx/include/components.hpp>

#include <hpx/util/detail/yield_k.hpp>

#include <vector>

typedef hpx::components::component<allscale::components::monitor> monitor_component;

HPX_REGISTER_COMPONENT(monitor_component)

namespace allscale {

bool monitor::enabled = false;

components::monitor* monitor::run(std::size_t rank)

{

return get_ptr();

}

void monitor::stop()

}

std::vector<monitor::event_function>& event_functions(monitor::event e)

{

static std::array<std::vector<monitor::event_function>, monitor::last_> functions;

return functions[e];

}

void monitor::connect(event e, event_function f)

{

event_functions(e).push_back(f);

}

void monitor::disconnect(event e, event_function f)

}

void monitor::signal(event e, work_item const& w)

}

void monitor::add_task_time(task_id::task_path const& path, task_times::time_t const& time)

}

components::monitor &monitor::get()

{

HPX_ASSERT(get_ptr());

return *get_ptr();

}

components::monitor *monitor::get_ptr()

{

static monitor m(hpx::get_locality_id());

components::monitor* res = m.component_.get();

for (std::size_t k = 0; !res; ++k)

{

hpx::util::detail::yield_k(k, "get component...");

res = m.component_.get();

}

res->init();

enabled = res->enable_monitor;

return res;

}

monitor::monitor(std::size_t rank)

}

}