| 342 | } |
| 343 | |
| 344 | void DataSourceRuntimeHost::setDataEngineTarget(DataEngine* target) { |
| 345 | // Mirrors setObjectStoreTarget but for scalar writes. Retargets the |
| 346 | // source-level write host and every parser binding so all scalar pushes |
| 347 | // land on the secondary engine during pause and on the primary on resume. |
| 348 | source_write_host_.setTarget(target); |
| 349 | for (auto& [_id, binding] : parser_bindings_) { |
| 350 | if (binding.write_host != nullptr) { |
| 351 | binding.write_host->setTarget(target); |
| 352 | } |
| 353 | } |
| 354 | } |
| 355 | |
| 356 | bool DataSourceRuntimeHost::fail(PJ_error_t* out_error, const char* message) noexcept { |
| 357 | last_error_ = message; |