Home
last modified time | relevance | path

Searched defs:stream (Results 1 – 25 of 75) sorted by relevance

123

/base/startup/init/services/param/linux/
Dparam_msgadp.c47 int ParamServerCreate(ParamTaskPtr *stream, const ParamStreamInfo *streamInfo) in ParamServerCreate()
59 int ParamStreamCreate(ParamTaskPtr *stream, ParamTaskPtr server, in ParamStreamCreate()
81 void *ParamGetTaskUserData(const ParamTaskPtr stream) in ParamGetTaskUserData()
87 int ParamTaskSendMsg(const ParamTaskPtr stream, const ParamMessage *msg) in ParamTaskSendMsg()
103 int ParamEventTaskCreate(ParamTaskPtr *stream, LE_ProcessAsyncEvent eventProcess) in ParamEventTaskCreate()
109 int ParamEventSend(const ParamTaskPtr stream, uint64_t eventId, const char *content, uint32_t size) in ParamEventSend()
116 int ParamTaskClose(const ParamTaskPtr stream) in ParamTaskClose()
/base/update/updater/test/unittest/script/
Dscript_unittest.h75 int32_t CreatePkgStream(StreamPtr &stream, const std::string &fileName, size_t size, in CreatePkgStream()
80 int32_t CreatePkgStream(StreamPtr &stream, const std::string &fileName, in CreatePkgStream()
85 …int32_t CreatePkgStream(StreamPtr &stream, const std::string &fileName, const PkgBuffer &buffer) o… in CreatePkgStream()
89 void ClosePkgStream(StreamPtr &stream) override { } in ClosePkgStream()
103 int32_t ParsePackage(StreamPtr stream, std::vector<std::string> &fileIds, int32_t type) override in ParsePackage()
110 std::vector<std::string> &fileIds, uint8_t type, StreamPtr stream) override in LoadPackageWithStream()
114 int32_t CreatePkgStream(StreamPtr &stream, const std::string &fileName, in CreatePkgStream()
Dscript_unittest.cpp72 …int32_t CreatePkgStream(StreamPtr &stream, const std::string &fileName, const PkgBuffer &buffer) o… in CreatePkgStream()
85 auto stream = static_cast<MemoryMapStream *>(output); in ExtractFile() local
108 int32_t CreatePkgStream(StreamPtr &stream, const std::string &fileName, in CreatePkgStream()
130 void ClosePkgStream(StreamPtr &stream) override in ClosePkgStream()
/base/update/updater/services/package/pkg_manager/
Dpkg_managerImpl.cpp93 PkgStreamPtr stream = (*iter1).second; in ClearPkgFile() local
172 PkgStreamPtr stream = nullptr; in CreatePackage() local
224 PkgFilePtr PkgManagerImpl::CreatePackage(PkgStreamPtr stream, PkgFile::PkgType type, PkgInfoPtr hea… in CreatePackage()
252 int32_t PkgManagerImpl::ParsePackage(StreamPtr stream, std::vector<std::string> &fileIds, int32_t t… in ParsePackage()
353 PkgStreamPtr stream = nullptr; in ExtraAndLoadPackage() local
385 PkgStreamPtr stream = nullptr; in LoadPackage() local
396 std::vector<std::string> &fileIds, uint8_t type, StreamPtr stream) in LoadPackageWithStream()
409 std::vector<std::string> &fileIds, PkgFile::PkgType type, PkgStreamPtr stream) in LoadPackageWithStream()
507 int32_t PkgManagerImpl::CreatePkgStream(StreamPtr &stream, const std::string &fileName, const PkgBu… in CreatePkgStream()
518 int32_t PkgManagerImpl::CreatePkgStream(StreamPtr &stream, const std::string &fileName, in CreatePkgStream()
[all …]
/base/update/updater/test/unittest/package/
Dpkg_package_unittest.cpp44 explicit TestFile(PkgManager::PkgManagerPtr pkgManager, PkgStreamPtr stream) in TestFile()
77 PkgManager::StreamPtr stream = nullptr; in TestPkgFile() local
99 PkgManager::StreamPtr stream = nullptr; in TestPkgFileInvalid() local
118 PkgManager::StreamPtr stream = nullptr; in TestBigZipEntry() local
Dpkg_manager_unittest.cpp177 std::unique_ptr<TestPkgStream> stream = std::make_unique<TestPkgStream>(pkgManager_, path); in TestPkgStreamImpl() local
201 auto stream = std::make_unique<FileStream>(pkgManager_, testPackageName, nullptr, 0); in TestInvalidStream() local
380 PkgManager::StreamPtr stream, void *mappedData, std::vector<uint8_t> &digest) in CheckDataIntegrityLz4()
414 PkgManager::StreamPtr stream = nullptr; in TestDecompressLz4() local
431 [&](Hpackage::PkgManager::StreamPtr stream) { in TestDecompressLz4()
490 PkgManager::StreamPtr stream, void *mappedData, std::vector<uint8_t> &digest) in CheckDataIntegrityGzip()
524 PkgManager::StreamPtr stream = nullptr; in TestDecompressGzip() local
541 [&](Hpackage::PkgManager::StreamPtr stream) { in TestDecompressGzip()
569 PkgManager::StreamPtr stream = nullptr; in TestCompressBuffer() local
582 [&](Hpackage::PkgManager::StreamPtr stream) { in TestCompressBuffer()
/base/update/updater/test/unittest/updater_binary/
Dupdate_binary_unittest.h79 …int32_t CreatePkgStream(Hpackage::PkgManager::StreamPtr &stream, const std::string &fileName, size… in CreatePkgStream()
88 …int32_t CreatePkgStream(Hpackage::PkgManager::StreamPtr &stream, const std::string &fileName, size… in CreatePkgStream()
/base/update/updater/test/fuzztest/scriptmanager_fuzzer/
Dscriptmanager_fuzzer.cpp69 …int32_t CreatePkgStream(StreamPtr &stream, const std::string &fileName, const PkgBuffer &buffer) o… in CreatePkgStream()
96 auto stream = static_cast<MemoryMapStream *>(output); in ExtractFile() local
106 int32_t CreatePkgStream(StreamPtr &stream, const std::string &fileName, in CreatePkgStream()
128 void ClosePkgStream(StreamPtr &stream) override in ClosePkgStream()
/base/powermgr/thermal_manager/application/protector/src/
Dthermal_protector_utils.cpp29 FILE *stream = fopen(path.c_str(), "w+"); in WriteFile() local
/base/startup/init/services/loopevent/task/
Dle_task.c32 BaseTask *stream = (BaseTask *)task; in GetSocketFd() local
62 StreamTask *stream = (StreamTask *)task; in CloseTask() local
208 BaseTask *stream = (BaseTask *)handle; in LE_GetUserData() local
Dle_task.h95 StreamTask stream; member
104 StreamTask stream; member
115 StreamTask stream; member
/base/update/updater/services/flow_update/update_bin/
Dbin_process.cpp94 PkgManager::StreamPtr stream) in ExtractBinFile()
203 PkgManager::StreamPtr stream) in ProcessBinFile()
273 …ptInstructionBinFlowWrite::ComponentProcess(Uscript::UScriptEnv &env, PkgManager::StreamPtr stream, in ComponentProcess()
/base/update/updater/services/package/pkg_package/
Dpkg_lz4file.h57 : PkgFileImpl(manager, stream, PkgFile::PKG_TYPE_LZ4) in PkgFileImpl() argument
Dpkg_pkgfile.h27 PkgFileImpl(PkgManager::PkgManagerPtr manager, PkgStreamPtr stream, PkgType type) in PkgFileImpl()
/base/update/updater/services/diffpatch/patch/
Dupdate_patch.cpp139 Hpackage::PkgManager::StreamPtr stream = nullptr; in ApplyBlockPatch() local
185 Hpackage::PkgManager::StreamPtr stream = nullptr; in ApplyBlockPatch() local
213 Hpackage::PkgManager::StreamPtr stream, UpdatePatchWriterPtr writer) in ApplyBlockPatch()
Dblocks_patch.h69 Hpackage::PkgManager::StreamPtr stream, UpdatePatchWriterPtr writer) in BlocksStreamPatch()
Dimage_patch.cpp126 Hpackage::PkgManager::StreamPtr stream = nullptr; in ApplyImagePatch() local
165 Hpackage::PkgManager::StreamPtr &stream, bool memory, size_t expandedLen) const in DecompressData()
/base/update/updater/services/diffpatch/diff/
Dblocks_diff.h90 …BlocksStreamDiff(std::fstream &stream, size_t offset) : BlocksDiff(), stream_(stream), offset_(off… in BlocksStreamDiff()
/base/security/security_guard/services/security_collector/src/
Ddata_collection.cpp171 std::ifstream stream(SA_CONFIG_PATH, std::ios::in); in GetCollectorPath() local
219 std::ifstream stream(SA_CONFIG_PATH, std::ios::in); in GetCollectorType() local
265 ErrorCode DataCollection::CheckFileStream(std::ifstream &stream) in CheckFileStream()
/base/update/updater/test/unittest/diffpatch/
Dimage_patch_unittest.cpp45 PkgManager::StreamPtr &stream, bool memory, size_t expandedLen) in TestDecompressData()
96 PkgManager::StreamPtr stream; variable
/base/powermgr/battery_manager/test/utils/
Dtest_utils.cpp55 std::ofstream stream(path.c_str()); in WriteMock() local
/base/hiviewdfx/hiview/base/utility/include/
Dstring_util.h71 std::stringstream stream; in IsConvertable() local
/base/update/updater/services/diffpatch/bzip2/
Dbzip2_adapter.h54 explicit BZip2StreamAdapter(std::fstream &stream) : BZip2Adapter(), outStream_(stream) {} in BZip2StreamAdapter()
/base/powermgr/thermal_manager/utils/native/src/
Dfile_operation.cpp65 FILE *stream = fopen(path.c_str(), "w+"); in WriteFile() local
/base/web/webview/interfaces/kits/napi/webviewcontroller/
Dnapi_web_scheme_handler_request.cpp291 WebHttpBodyStream* stream = new (std::nothrow) WebHttpBodyStream(env, arkWebPostStream); in JS_HttpBodyStream() local
299 WebHttpBodyStream *stream = reinterpret_cast<WebHttpBodyStream *>(data); in JS_HttpBodyStream() local
1168 WebHttpBodyStream *stream = new WebHttpBodyStream(env); in JS_Constructor() local
1172 WebHttpBodyStream *stream = (WebHttpBodyStream *)data; in JS_Constructor() local
1186 WebHttpBodyStream *stream = nullptr; in JS_Initialize() local
1257 WebHttpBodyStream *stream = nullptr; in JS_Read() local
1308 WebHttpBodyStream *stream = nullptr; in JS_GetSize() local
1327 WebHttpBodyStream *stream = nullptr; in JS_GetPostion() local
1346 WebHttpBodyStream *stream = nullptr; in JS_IsChunked() local
1365 WebHttpBodyStream *stream = nullptr; in JS_IsEof() local
[all …]

123