2 #include <LV2/Context.hpp>
3 #include <LV2/lv2_atom_helpers.hpp>
5 #include <ossia/dataflow/fx_node.hpp>
6 #include <ossia/dataflow/port.hpp>
7 #include <ossia/detail/pod_vector.hpp>
11 template <
typename OnExecStart,
typename OnExecFinished>
12 struct lv2_node final :
public ossia::graph_node
15 ossia::float_vector fInControls, fOutControls, fParamMin, fParamMax, fParamInit,
17 std::vector<ossia::float_vector> fCVs;
18 std::vector<AtomBuffer> m_atom_ins, m_atom_outs;
19 std::vector<ossia::small_vector<Message, 2>> m_message_for_atom_ins;
21 LilvInstance* fInstance{};
22 std::unique_ptr<uint8_t[]> timePositionBuffer{};
28 std::vector<MatchedPort> m_atom_timePosition_midi;
29 std::vector<MatchedPort> m_atom_timePosition_owned;
32 OnExecFinished on_finished;
33 lv2_node(
LV2Data dat,
int sampleRate, OnExecStart os, OnExecFinished of)
38 const std::size_t audio_in_size = data.audio_in_ports.size();
39 const std::size_t audio_out_size = data.audio_out_ports.size();
40 const std::size_t control_in_size = data.control_in_ports.size();
41 const std::size_t control_out_size = data.control_out_ports.size();
42 const std::size_t midi_in_size = data.midi_in_ports.size();
43 const std::size_t midi_out_size = data.midi_out_ports.size();
44 const std::size_t time_in_size = data.time_Position_ports.size();
45 const std::size_t cv_size = data.cv_ports.size();
46 const std::size_t other_size = data.control_other_ports.size();
47 const std::size_t num_ports = data.effect.plugin.get_num_ports();
51 m_inlets.push_back(
new ossia::audio_inlet);
53 if(audio_out_size > 0)
55 m_outlets.push_back(
new ossia::audio_outlet);
58 for(std::size_t i = 0; i < cv_size; i++)
60 m_inlets.push_back(
new ossia::audio_inlet);
63 for(std::size_t i = 0; i < midi_in_size; i++)
65 m_inlets.push_back(
new ossia::midi_inlet);
67 for(std::size_t i = 0; i < midi_out_size; i++)
69 m_outlets.push_back(
new ossia::midi_outlet);
72 for(std::size_t i = 0; i < control_in_size; i++)
74 m_inlets.push_back(
new ossia::value_inlet);
76 for(std::size_t i = 0; i < control_out_size; i++)
78 m_outlets.push_back(
new ossia::value_outlet);
81 fInControls.resize(control_in_size);
82 fOutControls.resize(control_out_size);
83 fOtherControls.resize(other_size);
85 for(std::size_t i = 0; i < cv_size; i++)
90 fParamMin.resize(num_ports);
91 fParamMax.resize(num_ports);
92 fParamInit.resize(num_ports);
94 data.effect.plugin.get_port_ranges_float(
95 fParamMin.data(), fParamMax.data(), fParamInit.data());
97 fInstance = data.effect.instance;
98 data.effect.instance = fInstance;
101 throw std::runtime_error(
"Error while creating a LV2 plug-in");
104 m_atom_ins.reserve(midi_in_size);
105 m_message_for_atom_ins.resize(midi_in_size);
106 for(std::size_t i = 0; i < midi_in_size; i++)
108 m_atom_ins.emplace_back(
109 2048, data.host.atom_chunk_id, data.host.midi_event_id,
true);
112 m_atom_outs.reserve(midi_out_size);
113 for(std::size_t i = 0; i < midi_out_size; i++)
115 m_atom_outs.emplace_back(
116 2048, data.host.atom_chunk_id, data.host.midi_event_id,
false);
121 for(std::size_t i = 0; i < time_in_size; i++)
123 auto port_index = data.time_Position_ports[i];
125 bool is_midi =
false;
126 for(std::size_t midi_port_k = 0; midi_port_k < data.midi_in_ports.size();
129 int midi_port_index = data.midi_in_ports[midi_port_k];
130 if(midi_port_index == port_index)
132 m_atom_timePosition_midi.push_back(
133 MatchedPort{port_index, &m_atom_ins[midi_port_k]});
143 256, data.host.atom_chunk_id, data.host.time_Position_id,
true);
144 m_atom_timePosition_owned.push_back(MatchedPort{port_index, abuf});
149 if(lilv_plugin_has_feature(data.effect.plugin.me, data.host.work_schedule)
150 && lilv_plugin_has_extension_data(
151 data.effect.plugin.me, data.host.work_interface))
153 data.effect.worker =
static_cast<const LV2_Worker_Interface*
>(
154 lilv_instance_get_extension_data(fInstance, LV2_WORKER__interface));
157 for(std::size_t i = 0; i < control_in_size; i++)
159 auto port_i = data.control_in_ports[i];
160 fInControls[i] = fParamInit[port_i];
163 if(!m_atom_timePosition_midi.empty() || !m_atom_timePosition_owned.empty())
166 timePositionBuffer = std::make_unique<uint8_t[]>(256);
169 lilv_instance_activate(fInstance);
172 void connect_all_ports()
174 const std::size_t control_in_size = data.control_in_ports.size();
175 const std::size_t control_out_size = data.control_out_ports.size();
176 const std::size_t midi_in_size = data.midi_in_ports.size();
177 const std::size_t midi_out_size = data.midi_out_ports.size();
178 const std::size_t cv_size = data.cv_ports.size();
179 const std::size_t other_size = data.control_other_ports.size();
181 for(std::size_t i = 0; i < control_in_size; i++)
183 lilv_instance_connect_port(fInstance, data.control_in_ports[i], &fInControls[i]);
186 for(std::size_t i = 0; i < control_out_size; i++)
188 lilv_instance_connect_port(fInstance, data.control_out_ports[i], &fOutControls[i]);
191 for(std::size_t i = 0; i < cv_size; i++)
193 lilv_instance_connect_port(fInstance, data.cv_ports[i], fCVs[i].data());
196 for(std::size_t i = 0; i < other_size; i++)
198 lilv_instance_connect_port(
199 fInstance, data.control_other_ports[i], &fOtherControls[i]);
202 for(std::size_t i = 0; i < midi_in_size; i++)
204 lilv_instance_connect_port(
205 fInstance, data.midi_in_ports[i], &m_atom_ins[i].buf->atoms);
208 for(std::size_t i = 0; i < midi_out_size; i++)
210 auto& out_p = data.midi_out_ports[i];
211 auto atoms = &m_atom_outs[i].buf->atoms;
212 lilv_instance_connect_port(fInstance, out_p, atoms);
215 for(
auto& [index, port] : m_atom_timePosition_owned)
217 lilv_instance_connect_port(fInstance, index, &port->buf->atoms);
221 void all_notes_off() noexcept
override
228 const std::size_t audio_in_size = data.audio_in_ports.size();
229 const std::size_t cv_size = data.cv_ports.size();
230 const std::size_t midi_in_size = data.midi_in_ports.size();
231 const std::size_t control_in_size = data.control_in_ports.size();
237 int first_midi_idx = (audio_in_size > 0 ? 1 : 0) + cv_size;
238 for(std::size_t i = 0; i < m_atom_ins.size(); i++)
240 ossia::midi_port& ossia_port
241 = this->m_inlets[i + first_midi_idx]->template cast<ossia::midi_port>();
242 auto& lv2_port = m_atom_ins[i];
246 for(
const Message& msg : this->m_message_for_atom_ins[i])
248 auto atom = (LV2_Atom*)msg.body.data();
249 auto atom_data = (
const uint8_t*)LV2_ATOM_BODY(atom);
250 it.write(0, 0, atom->type, atom->size, atom_data);
254 for(
const libremidi::message& msg : ossia_port.messages)
257 msg.timestamp, 0, data.host.midi_event_id, msg.bytes.size(),
262 if(this->m_atom_timePosition_midi.size() != 0)
264 const LV2_Atom* atom = (
const LV2_Atom*)timePositionBuffer.get();
267 it.write(0, 0, atom->type, atom->size, (
const uint8_t*)LV2_ATOM_BODY(atom));
272 for(
auto& [port, atoms] : m_atom_timePosition_owned)
274 auto& lv2_port = atoms;
277 const LV2_Atom* atom = (
const LV2_Atom*)timePositionBuffer.get();
280 it.write(0, 0, atom->type, atom->size, (
const uint8_t*)LV2_ATOM_BODY(atom));
285 auto control_start = (audio_in_size > 0 ? 1 : 0) + midi_in_size + cv_size;
286 for(std::size_t i = control_start; i < control_in_size; i++)
288 auto& in = m_inlets[i]->template cast<ossia::value_port>().get_data();
292 if(
auto f = in.back().value.template target<float>())
294 fInControls[i - control_start] = *f;
300 void updateTime(
const ossia::token_request& tk, ossia::exec_state_facade st)
303 auto& forge = host.forge;
304 uint8_t* buffer = timePositionBuffer.get();
305 lv2_atom_forge_set_buffer(&forge, buffer, 256);
306 LV2_Atom_Forge_Frame frame;
307 lv2_atom_forge_object(&forge, &frame, 0, host.time_Position_id);
309 lv2_atom_forge_key(&forge, host.time_frame_id);
311 lv2_atom_forge_long(&forge, tk.start_date_to_physical(st.modelToSamples()));
313 lv2_atom_forge_key(&forge, host.time_framesPerSecond_id);
314 lv2_atom_forge_long(&forge, st.sampleRate());
316 lv2_atom_forge_key(&forge, host.time_speed_id);
317 lv2_atom_forge_float(&forge, tk.speed);
319 lv2_atom_forge_key(&forge, host.time_bar_id);
320 lv2_atom_forge_long(&forge, tk.musical_start_last_bar / 4.);
322 lv2_atom_forge_key(&forge, host.time_beat_id);
323 lv2_atom_forge_double(&forge, tk.musical_start_position);
325 auto barBeat = float(tk.musical_start_position - tk.musical_start_last_bar);
326 lv2_atom_forge_key(&forge, host.time_barBeat_id);
327 lv2_atom_forge_float(&forge, barBeat);
329 lv2_atom_forge_key(&forge, host.time_beatUnit_id);
330 lv2_atom_forge_int(&forge, 4);
332 lv2_atom_forge_key(&forge, host.time_beatsPerBar_id);
333 lv2_atom_forge_float(
334 &forge, 4 *
double(tk.signature.upper) /
double(tk.signature.lower));
336 lv2_atom_forge_key(&forge, host.time_beatsPerMinute_id);
337 lv2_atom_forge_float(&forge, tk.tempo);
339 lv2_atom_forge_pop(&forge, &frame);
342 void postProcess(int64_t offset)
344 if(data.effect.worker && data.effect.worker->work_response)
346 std::vector<char> vec;
347 while(data.effect.worker_datas.try_dequeue(vec))
349 data.effect.worker->work_response(
350 data.effect.instance->lv2_handle, vec.size(), vec.data());
354 if(data.effect.worker && data.effect.worker->end_run)
356 data.effect.worker->end_run(data.effect.instance->lv2_handle);
359 const std::size_t audio_out_size = data.audio_out_ports.size();
360 const std::size_t midi_out_size = data.midi_out_ports.size();
361 const std::size_t control_out_size = data.control_out_ports.size();
365 int first_midi_idx = (audio_out_size > 0 ? 1 : 0);
366 for(std::size_t i = 0; i < m_atom_outs.size(); i++)
368 ossia::midi_port& ossia_port
369 = this->m_outlets[i + first_midi_idx]->template cast<ossia::midi_port>();
373 LV2_ATOM_SEQUENCE_FOREACH(&lv2_port.buf->atoms, ev)
375 if(ev->body.type == host.midi_event_id)
377 libremidi::message msg;
378 msg.timestamp = ev->time.frames;
379 msg.bytes.resize(ev->body.size);
381 auto bytes = (uint8_t*)LV2_ATOM_BODY(&ev->body);
382 for(std::size_t i = 0; i < ev->body.size; i++)
384 msg.bytes[i] = bytes[i];
386 ossia_port.messages.push_back(std::move(msg));
395 auto control_start = (audio_out_size > 0 ? 1 : 0) + midi_out_size;
396 for(std::size_t i = control_start; i < control_out_size; i++)
398 auto& out = m_outlets[i]->template cast<ossia::value_port>();
400 out.write_value(fOutControls[i - control_start], offset);
408 port.buf->reset(
true);
410 for(
auto& [port, atoms] : m_atom_timePosition_owned)
412 atoms->buf->reset(
true);
416 port.buf->reset(
false);
419 for(
auto& mqueue : m_message_for_atom_ins)
425 lilv_instance_deactivate(fInstance);
426 if(!m_atom_timePosition_owned.empty())
427 for(
auto [port, atoms] : m_atom_timePosition_owned)
431 void run(
const ossia::token_request& tk, ossia::exec_state_facade st) noexcept
override
433 if(tk.date > tk.prev_date)
435 data.host.current = &data.effect;
436 if(!data.time_Position_ports.empty())
441 const auto [tick_start, samples] = st.timings(tk);
442 const auto audio_ins = data.audio_in_ports.size();
443 const auto audio_outs = data.audio_out_ports.size();
444 ossia::small_vector<ossia::float_vector, 2> in_vec;
445 in_vec.resize(audio_ins);
446 ossia::small_vector<ossia::float_vector, 2> out_vec;
447 out_vec.resize(audio_outs);
452 const auto& audio_in = m_inlets[0]->template cast<ossia::audio_port>();
453 for(std::size_t i = 0; i < audio_ins; i++)
455 in_vec[i].resize(samples);
456 if(audio_in.channels() > i)
458 for(std::size_t j = 0;
459 j < std::min(std::size_t(samples), audio_in.channel(i).size()); j++)
461 in_vec[i][j] = (float)audio_in.channel(i)[j];
464 lilv_instance_connect_port(
465 fInstance, data.audio_in_ports[i], in_vec[i].data());
471 for(std::size_t i = 0; i < audio_outs; i++)
473 out_vec[i].resize(samples);
474 lilv_instance_connect_port(
475 fInstance, data.audio_out_ports[i], out_vec[i].data());
479 lilv_instance_run(fInstance, samples);
483 auto& audio_out =
static_cast<ossia::audio_outlet*
>(m_outlets[0])->data;
484 audio_out.set_channels(audio_outs);
485 for(std::size_t i = 0; i < audio_outs; i++)
487 audio_out.channel(i).clear();
488 audio_out.channel(i).reserve(samples);
489 for(int64_t j = 0; j < samples; j++)
491 audio_out.channel(i).push_back((
double)out_vec[i][j]);
496 postProcess(tk.physical_start(st.modelToSamples()));
Definition: lv2_atom_helpers.hpp:195
Definition: lv2_atom_helpers.hpp:99
Definition: Context.hpp:49
Definition: Context.hpp:207
Definition: score-plugin-lv2/LV2/Node.hpp:24
Definition: score-plugin-lv2/LV2/Node.hpp:13
Definition: score-plugin-lv2/LV2/EffectModel.cpp:659