write() [11/12]

void MayaFlux::Portal::Forma::Bridge::write	(	uint32_t	id,
		std::shared_ptr< Buffers::DataWriteProcessor >	target
	)

Route element value to a DataWriteProcessor each frame.

Parameters

id	Element id.
target	DataWriteProcessor to call set_data() on.

Definition at line 198 of file Bridge.cpp.

{
    auto it = m_records.find(id);
    if (it == m_records.end()) {
        MF_ERROR(Journal::Component::Portal, Journal::Context::Init,
            "Bridge::write: unknown element id {}", id);
        return;
    }
 
    auto name = make_task_name(id, "geometry");
    it->second.outbound_tasks.push_back(name);
 
    auto bulk = it->second.bulk_reader;
    auto reader = it->second.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, MayaFlux::Kriya::FrameDelay::frames_to_wait, MayaFlux::Journal::Init, m_records, m_scheduler, make_task_name(), MF_ERROR, and MayaFlux::Journal::Portal.

Here is the call graph for this function: