MayaFlux 0.4.0
Digital-First Multimedia Processing Framework
Loading...
Searching...
No Matches

◆ process_batch()

void MayaFlux::Nodes::Network::ResonatorNetwork::process_batch ( unsigned int  num_samples)
overridevirtual

Processes num_samples through all resonators and accumulates output.

Parameters
num_samplesNumber of audio samples to compute

For each sample, each resonator draws from its individual exciter (or the network-level exciter, or zero if none) and processes one sample. All resonator outputs are summed and normalised into m_last_audio_buffer.

Implements MayaFlux::Nodes::Network::NodeNetwork.

Definition at line 207 of file ResonatorNetwork.cpp.

208{
209 if (m_resonators.empty()) {
210 while (m_audio_buffer_lock.test_and_set(std::memory_order_acquire))
211 std::this_thread::yield();
212
213 m_last_audio_buffer.assign(num_samples, 0.0);
214 m_audio_buffer_lock.clear(std::memory_order_release);
215 return;
216 }
217
219
220 thread_local std::vector<double> scratch;
221 scratch.assign(num_samples, 0.0);
222
223 const double norm = 1.0 / static_cast<double>(m_resonators.size());
224
225 m_node_buffers.assign(m_resonators.size(), {});
226 for (auto& nb : m_node_buffers)
227 nb.reserve(num_samples);
228
229 std::vector<std::optional<std::span<const double>>> net_exc_bufs;
230 if (m_network_exciter) {
231 net_exc_bufs.reserve(m_resonators.size());
232 for (size_t ri = 0; ri < m_resonators.size(); ++ri)
233 net_exc_bufs.push_back(m_network_exciter->get_node_audio_buffer(ri));
234 }
235
236 for (size_t s = 0; s < num_samples; ++s) {
237 for (size_t ri = 0; ri < m_resonators.size(); ++ri) {
238 auto& r = m_resonators[ri];
239 double excitation = 0.0;
240
241 if (r.exciter) {
242 excitation = r.exciter->process_sample(0.0);
243 } else if (!net_exc_bufs.empty() && net_exc_bufs[ri] && s < net_exc_bufs[ri]->size()) {
244 excitation = (*net_exc_bufs[ri])[s];
245 } else if (m_exciter) {
246 excitation = m_exciter->process_sample(0.0);
247 }
248
249 const double out = r.filter->process_sample(excitation) * r.gain;
250 r.last_output = out;
251 m_node_buffers[ri].push_back(out);
252 scratch[s] += out * norm;
253 }
254 }
255
256 while (m_audio_buffer_lock.test_and_set(std::memory_order_acquire))
257 std::this_thread::yield();
258
259 m_last_audio_buffer.assign(scratch.begin(), scratch.end());
261 m_audio_buffer_lock.clear(std::memory_order_release);
262}
void apply_output_scale()
Apply m_output_scale to m_last_audio_buffer.
std::atomic_flag m_audio_buffer_lock
Spinlock guarding m_last_audio_buffer.
std::vector< double > m_last_audio_buffer
std::vector< std::vector< double > > m_node_buffers
Per-resonator sample buffers populated each process_batch()
std::shared_ptr< Node > m_exciter
networ-level shared exciter (may be nullptr)
void update_mapped_parameters()
Apply all registered parameter mappings for the current cycle.
std::shared_ptr< NodeNetwork > m_network_exciter
Optional NodeNetwork exciter for ONE_TO_ONE mapping (may be nullptr)

References MayaFlux::Nodes::Network::NodeNetwork::apply_output_scale(), MayaFlux::Nodes::Network::NodeNetwork::m_audio_buffer_lock, m_exciter, MayaFlux::Nodes::Network::NodeNetwork::m_last_audio_buffer, m_network_exciter, m_node_buffers, m_resonators, and update_mapped_parameters().

+ Here is the call graph for this function: