75{
76 auto network = wrapper.entity();
77 const auto& spec = wrapper.spec();
80
81 auto activation = std::make_shared<Kriya::TemporalActivation>(
83
84 activation->activate_network(
network, spec.seconds, node_token);
85
86 static std::vector<std::shared_ptr<Kriya::TemporalActivation>> active_timers;
87 active_timers.push_back(activation);
88
89 if (active_timers.size() > 100) {
90 std::erase_if(active_timers, [](const std::shared_ptr<Kriya::TemporalActivation>& t) {
91 return !t->is_active();
92 });
93 }
94
96}
Core::GlobalNetworkConfig network
MAYAFLUX_API Vruta::ProcessingToken get_task_token(Domain domain)
Extracts task processing token from domain.
MAYAFLUX_API Nodes::ProcessingToken get_node_token(Domain domain)
Extracts node processing token from domain.
std::shared_ptr< Nodes::NodeGraphManager > get_node_graph_manager()
Gets the node graph manager from the default engine.
std::shared_ptr< Buffers::BufferManager > get_buffer_manager()
Gets the buffer manager from the default engine.
std::shared_ptr< Vruta::TaskScheduler > get_scheduler()
Gets the task scheduler from the default engine.
std::optional< Domain > domain