write() [6/16]

void MayaFlux::Portal::Forma::Bridge::write	(	const ElementRef &	ref,
		std::shared_ptr< Buffers::DataWriteProcessor >	target
	)

Route element value to a DataWriteProcessor each frame.

Parameters

ref	Owning Layer and element id.
target	DataWriteProcessor to call set_data() on.

Definition at line 231 of file Bridge.cpp.

{
    auto* rec = find_record(ref);
    if (!rec) {
        MF_ERROR(Journal::Component::Portal, Journal::Context::Init,
            "Bridge::write: unknown element id {}", ref.second);
        return;
    }
 
    auto name = make_task_name(ref.second, "geometry");
    rec->outbound_tasks.push_back(name);
 
    auto bulk = rec->bulk_reader;
    auto reader = rec->reader;
 
    if (bulk) {
        auto routine = [](Vruta::TaskScheduler&,
                           std::function<std::vector<float>()> b,
                           std::shared_ptr<Buffers::DataWriteProcessor> proc)
            -> Vruta::GraphicsRoutine {
            auto& p = co_await Kriya::GetGraphicsPromise {};
            while (!p.should_terminate) {
                proc->set_data(Kakshya::DataVariant { b() });
                co_await Kriya::FrameDelay { .frames_to_wait = 1 };
            }
        };
        m_scheduler.add_task(
            std::make_shared<Vruta::GraphicsRoutine>(
                routine(m_scheduler, std::move(bulk), std::move(target))),
            name, false);
    } else {
        auto routine = [](Vruta::TaskScheduler&,
                           std::function<float()> r,
                           std::shared_ptr<Buffers::DataWriteProcessor> proc)
            -> Vruta::GraphicsRoutine {
            auto& p = co_await Kriya::GetGraphicsPromise {};
            while (!p.should_terminate) {
                proc->set_data(std::vector<Kakshya::DataVariant> { Kakshya::DataVariant { std::vector<float> { r() } } });
                co_await Kriya::FrameDelay { .frames_to_wait = 1 };
            }
        };
        m_scheduler.add_task(
            std::make_shared<Vruta::GraphicsRoutine>(
                routine(m_scheduler, std::move(reader), std::move(target))),
            name, false);
    }
}

References MayaFlux::Vruta::TaskScheduler::add_task(), b, find_record(), MayaFlux::Kriya::FrameDelay::frames_to_wait, MayaFlux::Journal::Init, m_scheduler, make_task_name(), MF_ERROR, name, and MayaFlux::Journal::Portal.

Here is the call graph for this function: