159 static int32_t GetUpdateBlockInfo(struct UpdateBlockInfo &infos, Uscript::UScriptEnv &env,  in GetUpdateBlockInfo()  argument
172     int32_t ret = context.GetParam(pos++, infos.partitionName);  in GetUpdateBlockInfo()
177     ret = context.GetParam(pos++, infos.transferName);  in GetUpdateBlockInfo()
182     ret = context.GetParam(pos++, infos.newDataName);  in GetUpdateBlockInfo()
187     ret = context.GetParam(pos++, infos.patchDataName);  in GetUpdateBlockInfo()
193     LOG(INFO) << "ExecuteUpdateBlock::updating  " << infos.partitionName << " ...";  in GetUpdateBlockInfo()
194     infos.devPath = GetBlockDeviceByMountPoint(infos.partitionName);  in GetUpdateBlockInfo()
196     if (infos.partitionName != "/userdata") {  in GetUpdateBlockInfo()
198         infos.devPath += suffix;  in GetUpdateBlockInfo()
201     infos.devPath = "/data/updater" + infos.partitionName;  in GetUpdateBlockInfo()
203     LOG(INFO) << "ExecuteUpdateBlock::updating  dev path : " << infos.devPath;  in GetUpdateBlockInfo()
204     if (infos.devPath.empty()) {  in GetUpdateBlockInfo()
212     Uscript::UScriptContext &context, const UpdateBlockInfo &infos)  in ExecuteTransferCommand()  argument
217     transferParams->storeBase = std::string("/data/updater") + infos.partitionName + "_tmp";  in ExecuteTransferCommand()
218     transferParams->retryFile = std::string("/data/updater") + infos.partitionName + "_retry";  in ExecuteTransferCommand()
219     transferParams->devPath = infos.devPath;  in ExecuteTransferCommand()
251 static int InitThread(const struct UpdateBlockInfo &infos, TransferManagerPtr tm)  in InitThread()  argument
261     writerThreadInfo->newPatch = infos.newDataName;  in InitThread()
266 static int32_t ExtractDiffPackageAndLoad(const UpdateBlockInfo &infos, Uscript::UScriptEnv &env,  in ExtractDiffPackageAndLoad()  argument
270     LOG(DEBUG) << "partitionName is " << infos.partitionName;  in ExtractDiffPackageAndLoad()
271     const FileInfo *info = env.GetPkgManager()->GetFileInfo(infos.partitionName);  in ExtractDiffPackageAndLoad()
276     std::string diffPackage = std::string("/data/updater") + infos.partitionName;  in ExtractDiffPackageAndLoad()
284     ret = env.GetPkgManager()->ExtractFile(infos.partitionName, outStream);  in ExtractDiffPackageAndLoad()
306 static int32_t DoExecuteUpdateBlock(const UpdateBlockInfo &infos, TransferManagerPtr tm,  in DoExecuteUpdateBlock()  argument
310     GetWriteDevPath(infos.devPath, infos.partitionName, devPath);  in DoExecuteUpdateBlock()
318     int32_t ret = ExecuteTransferCommand(fd, lines, tm, context, infos);  in DoExecuteUpdateBlock()
319     SyncWriteDevPath(fd, infos.partitionName);  in DoExecuteUpdateBlock()
324         PartitionRecord::GetInstance().RecordPartitionUpdateStatus(infos.partitionName, true);  in DoExecuteUpdateBlock()
360 static int32_t ExtractPatchDatFile(Uscript::UScriptEnv &env, const UpdateBlockInfo &infos,  in ExtractPatchDatFile()  argument
372     std::string fileName = std::string(UPDATER_PATH) + "/" + infos.patchDataName;  in ExtractPatchDatFile()
378     ret = env.GetPkgManager()->ExtractFile(infos.patchDataName, outStream);  in ExtractPatchDatFile()
390     UpdateBlockInfo infos {};  in ExecuteUpdateBlock()  local
391     if (GetUpdateBlockInfo(infos, env, context) != USCRIPT_SUCCESS) {  in ExecuteUpdateBlock()
397         if (PartitionRecord::GetInstance().IsPartitionUpdated(infos.partitionName)) {  in ExecuteUpdateBlock()
398             LOG(INFO) << infos.partitionName << " already updated, skip";  in ExecuteUpdateBlock()
403     if (ExtractDiffPackageAndLoad(infos, env, context) != USCRIPT_SUCCESS) {  in ExecuteUpdateBlock()
410     if (ExtractFileByName(env, infos.transferName, outStream,  in ExecuteUpdateBlock()
427     LOG(INFO) << "Start unpack new data thread done. Get patch data: " << infos.patchDataName;  in ExecuteUpdateBlock()
429     int ret = transferParams->isUpdaterMode ? ExtractFileByName(env, infos.patchDataName, outStream,  in ExecuteUpdateBlock()
431         infos, outStream, transferParams->patchDatFile);  in ExecuteUpdateBlock()
437     if (InitThread(infos, tm.get()) != 0) {  in ExecuteUpdateBlock()
444     return DoExecuteUpdateBlock(infos, tm.get(), outStream, lines, context);  in ExecuteUpdateBlock()
553     UpdateBlockInfo infos {};  in DoBlocksVerify()  local
554     infos.partitionName = partitionName;  in DoBlocksVerify()
555     infos.transferName = GetPartName(partitionName) + ".transfer.list";  in DoBlocksVerify()
560     if (ExtractFileByName(env, infos.transferName, outStream,  in DoBlocksVerify()
562         LOG(ERROR) << "Error to extract " << infos.transferName;  in DoBlocksVerify()