Définition de Sink dans le Graph manager
This commit is contained in:
@@ -105,7 +105,20 @@ public:
|
||||
break;
|
||||
}
|
||||
case SINK: {
|
||||
// TODO
|
||||
// Gérer le Sink
|
||||
auto new_sink = new SinkSimulator(
|
||||
"M_" + std::to_string(m->pool_id) + "_" + std::to_string(m->machine_id),
|
||||
SinkParameters{}
|
||||
);
|
||||
|
||||
_sinks.push_back(new_sink);
|
||||
this->add_child(MACHINE + machine_index, new_sink);
|
||||
|
||||
// PoolRouter -> Sink
|
||||
out({_pool_routers.back(), artis::factory::PoolRouter::outputs::OUT_M + m->machine_id})
|
||||
>> in({new_sink, artis::factory::Sink::inputs::IN});
|
||||
|
||||
++machine_index;
|
||||
break;
|
||||
}
|
||||
case SEPARATOR: {
|
||||
|
||||
Reference in New Issue
Block a user