Method LoadAllPlugins

src/plugin/plugin_manager.cpp:646–718

}

void lgraph::SingleLanguagePluginManager::LoadAllPlugins(KvTransaction& txn) {
    auto it = table_->GetIterator(txn);
    for (it->GotoFirstKey(); it->IsValid(); it->Next()) {
        if (!IsNameKey(it->GetKey().AsString())) continue;
        std::string name = it->GetKey().AsString();
        try {
            // load plugin info
            std::unique_ptr<PluginInfoBase> pinfo(impl_->CreatePluginInfo());
            Value v = it->GetValue();
            fma_common::BinaryBuffer info(v.Data(), v.Size());
            fma_common::BinaryRead(info, *pinfo);
            // write file
            bool need_write_file = false;
            {
                // check if commit changes
                if (!isHashUpTodate(txn, name)) need_write_file = true;
            }
            if (!need_write_file) {
                // check if local file exist
                std::string so_key = GetSoKey(name);
                auto so_it = table_->GetIterator(txn, Value::ConstRef(so_key));
                FMA_DBG_ASSERT(so_it->IsValid());
                std::string path = impl_->GetPluginPath(name);
                const std::string& so = so_it->GetValue().AsString();
                auto& fs = fma_common::FileSystem::GetFileSystem(path);
                if (fs.FileExists(path)) {
                    std::string file_content = ReadWholeFile(path, "plugin binary file");
                    if (file_content != so) need_write_file = true;
                } else {
                    need_write_file = true;
                }
            }
            // need_write_file might have changed
            if (need_write_file) {
                std::string zip_key = GetZipKey(name);
                std::string cpp_key = GetCppKey(name);
                std::string so_key = GetSoKey(name);
                std::string cython_key = GetCythonKey(name);
                if (table_->HasKey(txn, Value::ConstRef(zip_key))) {
                    auto zip_it = table_->GetIterator(txn, Value::ConstRef(zip_key));
                    const std::string& zip = zip_it->GetValue().AsString();
                    std::string exe = CompilePluginFromZip(name, zip);
                    WriteWholeFile(impl_->GetPluginPath(name), exe, "");
                    UpdateSoToKvStore(txn, name, exe);
                } else if (table_->HasKey(txn, Value::ConstRef(cpp_key))) {
                    auto file_it = table_->GetIterator(txn, Value::ConstRef(cpp_key));
                    const std::string& file = file_it->GetValue().AsString();
                    std::string exe = CompilePluginFromCpp(name, file);
                    WriteWholeFile(impl_->GetPluginPath(name), exe, "");
                    UpdateSoToKvStore(txn, name, exe);
                } else if (table_->HasKey(txn, Value::ConstRef(cython_key))) {
                    auto file_it = table_->GetIterator(txn, Value::ConstRef(cython_key));
                    const std::string& file = file_it->GetValue().AsString();
                    std::string exe = CompilePluginFromCython(name, file);
                    WriteWholeFile(impl_->GetPluginPath(name), exe, "");
                    UpdateSoToKvStore(txn, name, exe);
                } else if (table_->HasKey(txn, Value::ConstRef(so_key))) {
                    auto file_it = table_->GetIterator(txn, Value::ConstRef(so_key));