Home
last modified time | relevance | path

Searched refs:stream (Results 1 - 25 of 95) sorted by relevance

1234

/base/startup/init/services/param/linux/
H A Dparam_msgadp.c47 int ParamServerCreate(ParamTaskPtr *stream, const ParamStreamInfo *streamInfo) in ParamServerCreate() argument
49 PARAM_CHECK(stream != NULL && streamInfo != NULL, return -1, "Invalid param"); in ParamServerCreate()
56 return LE_CreateStreamServer(LE_GetDefaultLoop(), stream, &info); in ParamServerCreate()
59 int ParamStreamCreate(ParamTaskPtr *stream, ParamTaskPtr server, in ParamStreamCreate() argument
62 PARAM_CHECK(stream != NULL && streamInfo != NULL, return -1, "Invalid stream"); in ParamStreamCreate()
76 LE_STATUS status = LE_AcceptStreamClient(LE_GetDefaultLoop(), server, stream, &info); in ParamStreamCreate()
81 void *ParamGetTaskUserData(const ParamTaskPtr stream) in ParamGetTaskUserData() argument
83 PARAM_CHECK(stream != NULL, return NULL, "Invalid stream"); in ParamGetTaskUserData()
87 ParamTaskSendMsg(const ParamTaskPtr stream, const ParamMessage *msg) ParamTaskSendMsg() argument
103 ParamEventTaskCreate(ParamTaskPtr *stream, LE_ProcessAsyncEvent eventProcess) ParamEventTaskCreate() argument
109 ParamEventSend(const ParamTaskPtr stream, uint64_t eventId, const char *content, uint32_t size) ParamEventSend() argument
116 ParamTaskClose(const ParamTaskPtr stream) ParamTaskClose() argument
119 LE_CloseTask(LE_GetDefaultLoop(), stream); ParamTaskClose() local
[all...]
H A Dparam_message.h74 typedef int (*RecvMessage)(const ParamTaskPtr stream, const ParamMessage *msg);
87 int ParamTaskClose(const ParamTaskPtr stream);
88 int ParamServerCreate(ParamTaskPtr *stream, const ParamStreamInfo *streamInfo);
89 int ParamStreamCreate(ParamTaskPtr *stream, ParamTaskPtr server,
91 int ParamTaskSendMsg(const ParamTaskPtr stream, const ParamMessage *msg);
93 int ParamEventTaskCreate(ParamTaskPtr *stream, LE_ProcessAsyncEvent eventProcess);
94 int ParamEventSend(const ParamTaskPtr stream, uint64_t eventId, const char *content, uint32_t size);
96 void *ParamGetTaskUserData(const ParamTaskPtr stream);
/base/powermgr/thermal_manager/application/protector/src/
H A Dthermal_protector_utils.cpp29 FILE *stream = fopen(path.c_str(), "w+"); in WriteFile() local
30 if (stream == nullptr) { in WriteFile()
33 size_t ret = fwrite(buf.c_str(), strlen(buf.c_str()), 1, stream); in WriteFile()
37 int32_t state = fseek(stream, 0, SEEK_SET); in WriteFile()
39 fclose(stream); in WriteFile()
42 state = fclose(stream); in WriteFile()
/base/update/updater/services/package/pkg_manager/
H A Dpkg_managerImpl.cpp93 PkgStreamPtr stream = (*iter1).second; in ClearPkgFile() local
94 delete stream; in ClearPkgFile()
95 stream = nullptr; in ClearPkgFile()
172 PkgStreamPtr stream = nullptr; in CreatePackage() local
173 int32_t ret = CreatePkgStream(stream, path, 0, PkgStream::PkgStreamType_Write); in CreatePackage()
179 PkgFilePtr pkgFile = CreatePackage(PkgStreamImpl::ConvertPkgStream(stream), in CreatePackage()
183 ClosePkgStream(stream); in CreatePackage()
191 PKG_LOGE("Create stream fail %s", files[i].first.c_str()); in CreatePackage()
224 PkgFilePtr PkgManagerImpl::CreatePackage(PkgStreamPtr stream, PkgFile::PkgType type, PkgInfoPtr header) in CreatePackage() argument
228 std::string pkgName = stream in CreatePackage()
252 ParsePackage(StreamPtr stream, std::vector<std::string> &fileIds, int32_t type) ParsePackage() argument
353 PkgStreamPtr stream = nullptr; ExtraAndLoadPackage() local
385 PkgStreamPtr stream = nullptr; LoadPackage() local
395 LoadPackageWithStream(const std::string &packagePath, const std::string &keyPath, std::vector<std::string> &fileIds, uint8_t type, StreamPtr stream) LoadPackageWithStream() argument
408 LoadPackageWithStream(const std::string &packagePath, std::vector<std::string> &fileIds, PkgFile::PkgType type, PkgStreamPtr stream) LoadPackageWithStream() argument
507 CreatePkgStream(StreamPtr &stream, const std::string &fileName, const PkgBuffer &buffer) CreatePkgStream() argument
518 CreatePkgStream(StreamPtr &stream, const std::string &fileName, uint64_t fileLen, RingBuffer *buffer) CreatePkgStream() argument
531 DoCreatePkgStream(PkgStreamPtr &stream, const std::string &fileName, int32_t type) DoCreatePkgStream() argument
570 CreatePkgStream(PkgStreamPtr &stream, const std::string &fileName, size_t size, int32_t type) DoCreatePkgStream() argument
613 CreatePkgStream(PkgStreamPtr &stream, const std::string &fileName, PkgStream::ExtractFileProcessor processor, const void *context) DoCreatePkgStream() argument
624 ClosePkgStream(PkgStreamPtr &stream) DoCreatePkgStream() argument
718 DoGenerateFileDigest(PkgStreamPtr stream, uint8_t flags, const size_t fileLen, PkgBuffer &buff, std::pair<DigestAlgorithm::DigestAlgorithmPtr, DigestAlgorithm::DigestAlgorithmPtr> &algorithm) DoCreatePkgStream() argument
770 GenerateFileDigest(PkgStreamPtr stream, uint8_t digestMethod, uint8_t flags, std::vector<std::vector<uint8_t>> &digestInfos, size_t hashBufferLen) DoCreatePkgStream() argument
831 Sign(PkgStreamPtr stream, size_t offset, const PkgInfoPtr &info) DoCreatePkgStream() argument
1070 PkgStreamPtr stream = nullptr; DoCreatePkgStream() local
[all...]
H A Dpkg_manager_impl.h60 int32_t DecompressBuffer(FileInfoPtr info, const PkgBuffer &buffer, StreamPtr stream) const override;
62 int32_t CompressBuffer(FileInfoPtr info, const PkgBuffer &buffer, StreamPtr stream) const override;
67 std::vector<std::string> &fileIds, uint8_t type, StreamPtr stream) override;
69 int32_t ParsePackage(StreamPtr stream, std::vector<std::string> &fileIds, int32_t type) override;
71 int32_t CreatePkgStream(StreamPtr &stream, const std::string &fileName, const PkgBuffer &buffer) override;
73 int32_t CreatePkgStream(PkgStreamPtr &stream, const std::string &fileName,
76 int32_t CreatePkgStream(StreamPtr &stream, const std::string &fileName,
93 int32_t CreatePkgStream(PkgStreamPtr &stream, const std::string &fileName, size_t size, int32_t type) override;
95 void ClosePkgStream(PkgStreamPtr &stream) override;
102 PkgFilePtr CreatePackage(PkgStreamPtr stream, PkgFil
[all...]
/base/security/security_guard/services/security_collector/src/
H A Ddata_collection.cpp181 std::ifstream stream(SA_CONFIG_PATH, std::ios::in); in GetCollectorPath()
182 if (!stream.is_open()) { in GetCollectorPath()
186 ErrorCode ret = CheckFileStream(stream); in GetCollectorPath()
188 LOGE("check file stream error, ret=%{public}d", ret); in GetCollectorPath()
189 stream.close(); in GetCollectorPath()
192 nlohmann::json json = nlohmann::json::parse(stream, nullptr, false); in GetCollectorPath()
193 stream.close(); in GetCollectorPath()
228 std::ifstream stream(SA_CONFIG_PATH, std::ios::in); in GetCollectorType()
229 if (!stream.is_open()) { in GetCollectorType()
234 ErrorCode ret = CheckFileStream(stream); in GetCollectorType()
274 CheckFileStream(std::ifstream &stream) CheckFileStream() argument
[all...]
/base/update/updater/test/fuzztest/UpdaterStartUpdaterProc_fuzzer/
H A DUpdaterStartUpdaterProc_fuzzer.cpp51 PkgManager::StreamPtr stream = nullptr; in BuildFileDigest() local
54 int32_t ret = packageManager->CreatePkgStream(stream, packagePath, 0, PkgStream::PkgStreamType_Read); in BuildFileDigest()
56 PKG_LOGE("Create input stream fail %s", packagePath.c_str()); in BuildFileDigest()
57 packageManager->ClosePkgStream(stream); in BuildFileDigest()
61 size_t fileLen = stream->GetFileLength(); in BuildFileDigest()
63 PKG_LOGE("Invalid file len %zu to load %s", fileLen, stream->GetFileName().c_str()); in BuildFileDigest()
64 packageManager->ClosePkgStream(stream); in BuildFileDigest()
74 PKG_LOGE("Invalid file %s", stream->GetFileName().c_str()); in BuildFileDigest()
75 packageManager->ClosePkgStream(stream); in BuildFileDigest()
84 ret = stream in BuildFileDigest()
[all...]
/base/update/updater/test/unittest/updater_binary/
H A Dupdater_binary_unittest.cpp74 PkgManager::StreamPtr stream = nullptr; in BuildFileDigest() local
75 int32_t ret = pkgManager->CreatePkgStream(stream, packagePath, 0, PkgStream::PkgStreamType_Read); in BuildFileDigest()
77 LOG(ERROR) << "Create input stream fail " << packagePath; in BuildFileDigest()
78 pkgManager->ClosePkgStream(stream); in BuildFileDigest()
82 size_t fileLen = stream->GetFileLength(); in BuildFileDigest()
84 LOG(ERROR) << "invalid file to load " << stream->GetFileName(); in BuildFileDigest()
85 pkgManager->ClosePkgStream(stream); in BuildFileDigest()
95 LOG(ERROR) << "Invalid file " << stream->GetFileName(); in BuildFileDigest()
96 pkgManager->ClosePkgStream(stream); in BuildFileDigest()
105 ret = stream in BuildFileDigest()
[all...]
/base/update/updater/test/fuzztest/package_fuzzer/
H A Dpkg_fuzz_test.h95 PkgManager::StreamPtr stream = nullptr; in BuildFileDigest() local
96 int32_t ret = pkgManager_->CreatePkgStream(stream, pkgPath, 0, PkgStream::PkgStreamType_Read); in BuildFileDigest()
98 PKG_LOGE("Create input stream fail %s", pkgPath.c_str()); in BuildFileDigest()
101 size_t fileLength = stream->GetFileLength(); in BuildFileDigest()
103 PKG_LOGE("Invalid file len %zu to load %s", fileLength, stream->GetFileName().c_str()); in BuildFileDigest()
104 pkgManager_->ClosePkgStream(stream); in BuildFileDigest()
114 PKG_LOGE("Invalid file %s", stream->GetFileName().c_str()); in BuildFileDigest()
115 pkgManager_->ClosePkgStream(stream); in BuildFileDigest()
123 ret = stream->Read(buff, offset, bufSize, readLen); in BuildFileDigest()
125 PKG_LOGE("read buffer fail %s", stream in BuildFileDigest()
[all...]
/base/update/updater/test/unittest/package/
H A Dpkg_test.h72 PkgManager::StreamPtr stream = nullptr; in BuildFileDigest() local
73 int32_t ret = pkgManager_->CreatePkgStream(stream, packagePath, 0, PkgStream::PkgStreamType_Read); in BuildFileDigest()
75 PKG_LOGE("Create input stream fail %s", packagePath.c_str()); in BuildFileDigest()
78 size_t fileLen = stream->GetFileLength(); in BuildFileDigest()
80 PKG_LOGE("Invalid file len %zu to load %s", fileLen, stream->GetFileName().c_str()); in BuildFileDigest()
81 pkgManager_->ClosePkgStream(stream); in BuildFileDigest()
91 PKG_LOGE("Invalid file %s", stream->GetFileName().c_str()); in BuildFileDigest()
92 pkgManager_->ClosePkgStream(stream); in BuildFileDigest()
100 ret = stream->Read(buff, offset, buffSize, readLen); in BuildFileDigest()
102 PKG_LOGE("read buffer fail %s", stream in BuildFileDigest()
[all...]
H A Dpkg_package_unittest.cpp44 explicit TestFile(PkgManager::PkgManagerPtr pkgManager, PkgStreamPtr stream) in TestFile() argument
45 : PkgFileImpl(pkgManager, stream, PKG_TYPE_MAX) {} in TestFile()
77 PkgManager::StreamPtr stream = nullptr; in TestPkgFile() local
80 int ret = pkgManager_->CreatePkgStream(stream, packagePath, 0, PkgStream::PkgStreamType_Read); in TestPkgFile()
81 auto file = std::make_unique<Lz4PkgFile>(pkgManager_, PkgStreamImpl::ConvertPkgStream(stream)); in TestPkgFile()
89 ret = entry->Init(&fileInfo.fileInfo, PkgStreamImpl::ConvertPkgStream(stream)); in TestPkgFile()
99 PkgManager::StreamPtr stream = nullptr; in TestPkgFileInvalid() local
102 int ret = pkgManager_->CreatePkgStream(stream, packagePath, 0, PkgStream::PkgStreamType_Read); in TestPkgFileInvalid()
105 PkgStreamImpl::ConvertPkgStream(stream)); in TestPkgFileInvalid()
107 ret = file->AddEntry(&fileInfo, PkgStreamImpl::ConvertPkgStream(stream)); in TestPkgFileInvalid()
118 PkgManager::StreamPtr stream = nullptr; TestBigZipEntry() local
[all...]
H A Dpkg_manager_unittest.cpp40 constexpr auto WINDOWBITS = -15; // 32kb window; negative to indicate a raw stream.
177 std::unique_ptr<TestPkgStream> stream = std::make_unique<TestPkgStream>(pkgManager_, path); in TestPkgStreamImpl() local
178 EXPECT_NE(stream, nullptr); in TestPkgStreamImpl()
185 int ret = ((PkgStreamPtr)(stream.get()))->Read(buffer, start, size, readLen); in TestPkgStreamImpl()
188 ret = ((PkgStreamPtr)(stream.get()))->GetBuffer(data); in TestPkgStreamImpl()
191 ret = ((PkgStreamPtr)(stream.get()))->GetStreamType(); in TestPkgStreamImpl()
201 auto stream = std::make_unique<FileStream>(pkgManager_, testPackageName, nullptr, 0); in TestInvalidStream() local
206 int ret = stream->Read(buffer, start, bufferSize, readLen); in TestInvalidStream()
380 PkgManager::StreamPtr stream, void *mappedData, std::vector<uint8_t> &digest) in CheckDataIntegrityLz4()
385 int32_t ret = pkgManager_->DecompressBuffer(&lz4Info.fileInfo, buffer, stream); in CheckDataIntegrityLz4()
379 CheckDataIntegrityLz4(Hpackage::Lz4FileInfo &lz4Info, size_t fileSize, PkgManager::StreamPtr stream, void *mappedData, std::vector<uint8_t> &digest) CheckDataIntegrityLz4() argument
414 PkgManager::StreamPtr stream = nullptr; TestDecompressLz4() local
489 CheckDataIntegrityGzip(Hpackage::ZipFileInfo &zipInfo, size_t fileSize, PkgManager::StreamPtr stream, void *mappedData, std::vector<uint8_t> &digest) CheckDataIntegrityGzip() argument
524 PkgManager::StreamPtr stream = nullptr; TestDecompressGzip() local
569 PkgManager::StreamPtr stream = nullptr; TestCompressBuffer() local
[all...]
/base/startup/init/services/loopevent/task/
H A Dle_streamtask.c29 StreamTask *stream = (StreamTask *)taskHandle; in HandleSendMsg_() local
30 LE_Buffer *buffer = GetFirstBuffer(stream); in HandleSendMsg_()
42 FreeBuffer(loopHandle, stream, buffer); in HandleSendMsg_()
43 buffer = GetFirstBuffer(stream); in HandleSendMsg_()
45 if (IsBufferEmpty(stream)) { in HandleSendMsg_()
94 StreamConnectTask *stream = (StreamConnectTask *)handle; in HandleStreamEvent_() local
99 status = HandleSendMsg_(loopHandle, handle, stream->sendMessageComplete); in HandleStreamEvent_()
102 status = HandleRecvMsg_(loopHandle, handle, stream->recvMessage, stream->handleRecvMsg); in HandleStreamEvent_()
105 if (stream in HandleStreamEvent_()
[all...]
H A Dle_asynctask.c33 StreamTask *task = &asyncTask->stream; in DoAsyncEvent_()
61 while (!IsBufferEmpty(&asyncTask->stream)) { in LE_DoAsyncEvent()
78 if (!IsBufferEmpty(&asyncTask->stream)) { in HandleAsyncEvent_()
104 printf("\tfd: %d \n", eventTask->stream.base.taskId.fd); in DumpEventTaskInfo_()
120 task->stream.base.handleEvent = HandleAsyncEvent_; in LE_CreateAsyncTask()
121 task->stream.base.innerClose = HandleAsyncTaskClose_; in LE_CreateAsyncTask()
122 task->stream.base.dumpTaskInfo = DumpEventTaskInfo_; in LE_CreateAsyncTask()
123 OH_ListInit(&task->stream.buffHead); in LE_CreateAsyncTask()
124 LoopMutexInit(&task->stream.mutex); in LE_CreateAsyncTask()
/base/update/updater/test/fuzztest/extractandexecutescript_fuzzer/
H A Dextractandexecutescript_fuzzer.cpp188 PkgManager::StreamPtr stream = nullptr; in BuildFileDigest() local
189 int32_t ret = packageManager->CreatePkgStream(stream, packagePath, 0, PkgStream::PkgStreamType_Read); in BuildFileDigest()
191 PKG_LOGE("Create input stream fail %s", packagePath.c_str()); in BuildFileDigest()
192 packageManager->ClosePkgStream(stream); in BuildFileDigest()
195 size_t fileLen = stream->GetFileLength(); in BuildFileDigest()
198 packageManager->ClosePkgStream(stream); in BuildFileDigest()
202 PKG_LOGE("Invalid file len %zu to load %s", fileLen, stream->GetFileName().c_str()); in BuildFileDigest()
203 packageManager->ClosePkgStream(stream); in BuildFileDigest()
212 PKG_LOGE("Invalid file %s", stream->GetFileName().c_str()); in BuildFileDigest()
213 packageManager->ClosePkgStream(stream); in BuildFileDigest()
[all...]
/base/powermgr/thermal_manager/utils/native/src/
H A Dfile_operation.cpp65 FILE *stream = fopen(path.c_str(), "w+"); in WriteFile() local
66 if (stream == nullptr) { in WriteFile()
69 size_t ret = fwrite(buf.c_str(), strlen(buf.c_str()), 1, stream); in WriteFile()
73 int32_t state = fseek(stream, 0, SEEK_SET); in WriteFile()
75 fclose(stream); in WriteFile()
78 state = fclose(stream); in WriteFile()
/base/update/updater/test/unittest/diffpatch/
H A Dimage_patch_unittest.cpp45 PkgManager::StreamPtr &stream, bool memory, size_t expandedLen) in TestDecompressData()
47 return DecompressData(pkgManager, buffer, stream, memory, expandedLen); in TestDecompressData()
96 PkgManager::StreamPtr stream; in HWTEST_F() local
99 int32_t ret = test.TestDecompressData(pkgManager, buffer, stream, memory, expandedLen); in HWTEST_F()
102 ret = test.TestDecompressData(pkgManager, buffer, stream, memory, expandedLen); in HWTEST_F()
105 ret = test.TestDecompressData(pkgManager, buffer, stream, memory, expandedLen); in HWTEST_F()
44 TestDecompressData(PkgManager::PkgManagerPtr &pkgManager, PkgBuffer buffer, PkgManager::StreamPtr &stream, bool memory, size_t expandedLen) TestDecompressData() argument
/base/update/updater/services/flow_update/update_bin/
H A Dbin_process.cpp74 LOG(ERROR) << "Error to create output stream"; in Execute()
94 PkgManager::StreamPtr stream) in ExtractBinFile()
98 stream->Stop(); in ExtractBinFile()
119 ret = pkgManager->CreatePkgStream(processStream, upgradeFileName, processor, stream); in ExtractBinFile()
121 LOG(ERROR) << "Error to create output stream"; in ExtractBinFile()
203 PkgManager::StreamPtr stream) in ProcessBinFile()
205 if (stream == nullptr) { in ProcessBinFile()
206 LOG(ERROR) << "Error to get file stream"; in ProcessBinFile()
211 stream->Stop(); in ProcessBinFile()
228 innerFileNames, PkgFile::PKG_TYPE_UPGRADE, stream); in ProcessBinFile()
93 ExtractBinFile(Uscript::UScriptEnv &env, Uscript::UScriptContext &context, PkgManager::StreamPtr stream) ExtractBinFile() argument
202 ProcessBinFile(Uscript::UScriptEnv &env, Uscript::UScriptContext &context, PkgManager::StreamPtr stream) ProcessBinFile() argument
273 ComponentProcess(Uscript::UScriptEnv &env, PkgManager::StreamPtr stream, const std::string &name, const Hpackage::FileInfo &fileInfo) ComponentProcess() argument
[all...]
H A Dbin_process.h34 Hpackage::PkgManager::StreamPtr stream);
35 int32_t ComponentProcess(Uscript::UScriptEnv &env, Hpackage::PkgManager::StreamPtr stream,
41 Hpackage::PkgManager::StreamPtr stream);
/base/powermgr/battery_manager/test/utils/
H A Dtest_utils.cpp55 std::ofstream stream(path.c_str()); in WriteMock()
56 if (!stream.is_open()) { in WriteMock()
60 stream << content.c_str() << std::endl; in WriteMock()
61 stream.close(); in WriteMock()
/base/notification/distributed_notification_service/services/ans/src/
H A Dadvanced_notification_utils.cpp340 std::shared_ptr<NotificationFlags> notificationFlags, std::stringstream &stream) in ExtendDumpForFlags()
346 stream << "\t\tReminderFlags : " << notificationFlags->GetReminderFlags() << "\n"; in ExtendDumpForFlags()
351 stream << "\t\tSound : " << isEnable << "\n"; in ExtendDumpForFlags()
356 stream << "\t\tVibration : " << isEnable << "\n"; in ExtendDumpForFlags()
357 stream << "\t\tLockScreenVisbleness : " << notificationFlags->IsLockScreenVisblenessEnabled() << "\n"; in ExtendDumpForFlags()
358 stream << "\t\tBanner : " << notificationFlags->IsBannerEnabled() << "\n"; in ExtendDumpForFlags()
359 stream << "\t\tLightScreen : " << notificationFlags->IsLightScreenEnabled() << "\n"; in ExtendDumpForFlags()
360 stream << "\t\tStatusIcon : " << notificationFlags->IsStatusIconEnabled() << "\n"; in ExtendDumpForFlags()
367 std::stringstream stream; in ActiveNotificationDump() local
386 stream in ActiveNotificationDump()
339 ExtendDumpForFlags( std::shared_ptr<NotificationFlags> notificationFlags, std::stringstream &stream) ExtendDumpForFlags() argument
414 std::stringstream stream; RecentNotificationDump() local
460 std::stringstream stream; DistributedNotificationDump() local
506 std::stringstream stream; TimeToString() local
[all...]
/base/update/updater/test/fuzztest/scriptmanager_fuzzer/
H A Dscriptmanager_fuzzer.cpp69 int32_t CreatePkgStream(StreamPtr &stream, const std::string &fileName, const PkgBuffer &buffer) override
71 PKG_LOGI("create pkg stream success for %s ", fileName.c_str());
72 stream = new MemoryMapStream(this, fileName, buffer, PkgStream::PkgStreamType_Buffer);
96 auto stream = static_cast<MemoryMapStream *>(output); variable
98 stream->GetBuffer(buffer);
106 int32_t CreatePkgStream(StreamPtr &stream, const std::string &fileName,
122 stream = new FileStream(this, realFileName, file, PkgStream::PkgStreamType_Read);
128 void ClosePkgStream(StreamPtr &stream) override
130 delete stream;
/base/update/updater/test/unittest/script/
H A Dscript_unittest.cpp72 int32_t CreatePkgStream(StreamPtr &stream, const std::string &fileName, const PkgBuffer &buffer) override
74 stream = new MemoryMapStream(this, fileName, buffer, PkgStream::PkgStreamType_Buffer);
85 auto stream = static_cast<MemoryMapStream *>(output); variable
100 stream->GetBuffer(buffer);
108 int32_t CreatePkgStream(StreamPtr &stream, const std::string &fileName,
127 stream = new FileStream(this, fileNameReal, file, PkgStream::PkgStreamType_Read);
130 void ClosePkgStream(StreamPtr &stream) override
132 delete stream;
/base/update/updater/services/diffpatch/patch/
H A Dupdate_patch.cpp139 Hpackage::PkgManager::StreamPtr stream = nullptr; in ApplyBlockPatch() local
140 int32_t ret = pkgManager->CreatePkgStream(stream, "", {oldInfo.buffer, oldInfo.length}); in ApplyBlockPatch()
141 if (stream == nullptr || ret != PKG_SUCCESS) { in ApplyBlockPatch()
142 PATCH_LOGE("Failed to create stream"); in ApplyBlockPatch()
143 pkgManager->ClosePkgStream(stream); in ApplyBlockPatch()
148 std::unique_ptr<BlocksStreamPatch> patch = std::make_unique<BlocksStreamPatch>(patchInfo, stream, writer); in ApplyBlockPatch()
151 pkgManager->ClosePkgStream(stream); in ApplyBlockPatch()
156 pkgManager->ClosePkgStream(stream); in ApplyBlockPatch()
185 Hpackage::PkgManager::StreamPtr stream = nullptr; in ApplyBlockPatch() local
186 ret = pkgManager->CreatePkgStream(stream, "", {oldInf in ApplyBlockPatch()
212 ApplyBlockPatch(const PatchBuffer &patchInfo, Hpackage::PkgManager::StreamPtr stream, UpdatePatchWriterPtr writer) ApplyBlockPatch() argument
[all...]
/base/hiviewdfx/hiview/base/utility/include/
H A Dstring_util.h71 std::stringstream stream; in IsConvertable() local
72 stream << inValue; in IsConvertable()
74 stream >> outValue; in IsConvertable()
76 stream.clear(); in IsConvertable()
77 stream.str(""); in IsConvertable()
78 stream << (value + 0); in IsConvertable()
79 std::string tempValue = stream.str(); in IsConvertable()

Completed in 26 milliseconds

1234