| /base/update/updater/services/diffpatch/bzip2/ |
| H A D | bzip2_adapter.cpp | 24 (void)memset_s(&stream_, sizeof(bz_stream), 0, sizeof(bz_stream));
in Open()
25 int32_t ret = BZ2_bzCompressInit(&stream_, BLOCK_SIZE_BEST, 0, 0);
in Open()
39 int32_t ret = BZ2_bzCompressEnd(&stream_);
in Close()
50 stream_.next_in = reinterpret_cast<char*>(srcData.buffer);
in WriteData()
51 stream_.avail_in = srcData.length;
in WriteData()
54 stream_.avail_out = buffer_.size() - offset_ - dataSize_;
in WriteData()
55 stream_.next_out = next;
in WriteData()
58 ret = BZ2_bzCompress(&stream_, BZ_RUN);
in WriteData()
59 if (stream_.avail_out == 0) {
in WriteData()
60 dataSize_ += stream_ in WriteData()
[all...] |
| H A D | bzip2_adapter.h | 35 bz_stream stream_ {};
81 bz_stream stream_ {};
|
| /base/security/security_guard/services/config_manager/src/ |
| H A D | base_config.cpp | 29 if (!stream_.is_open()) { in Check()
34 stream_.seekg(0, std::ios::end); in Check()
35 std::ios::pos_type len = stream_.tellg(); in Check()
38 stream_.close(); in Check()
41 stream_.seekg(0, std::ios::beg); in Check()
47 if (stream_.is_open()) { in ~BaseConfig()
48 stream_.close(); in ~BaseConfig()
|
| H A D | event_config.cpp | 53 stream_ = std::ifstream(path, std::ios::in); in Load()
54 if (!stream_.is_open()) { in Load()
63 if (!stream_.is_open()) { in Parse()
67 nlohmann::json jsonObj = nlohmann::json::parse(stream_, nullptr, false); in Parse()
68 stream_.close(); in Parse()
89 if (!stream_.is_open()) { in Update()
93 nlohmann::json jsonObj = nlohmann::json::parse(stream_, nullptr, false); in Update()
94 stream_.close(); in Update()
|
| H A D | model_config.cpp | 47 stream_ = std::ifstream(path, std::ios::in); in Load()
48 if (!stream_.is_open()) { in Load()
57 if (!stream_.is_open()) { in Parse()
61 nlohmann::json jsonObj = nlohmann::json::parse(stream_, nullptr, false); in Parse()
62 stream_.close(); in Parse()
83 if (!stream_.is_open()) { in Update()
87 nlohmann::json jsonObj = nlohmann::json::parse(stream_, nullptr, false); in Update()
88 stream_.close(); in Update()
|
| /base/update/updater/services/package/pkg_manager/ |
| H A D | pkg_stream.cpp | 68 if (stream_ != nullptr) { in ~FileStream()
69 fflush(stream_); in ~FileStream()
70 fclose(stream_); in ~FileStream()
71 stream_ = nullptr; in ~FileStream()
78 if (stream_ == nullptr) { in Read()
89 if (fseeko64(stream_, start, SEEK_SET) != 0) { in Read()
103 readLen = fread(data.buffer, 1, needRead, stream_); in Read()
118 if (stream_ == nullptr) { in Write()
122 if (fseeko64(stream_, start, SEEK_SET) != 0) { in Write()
126 size_t len = fwrite(data.buffer, size, 1, stream_); in Write()
[all...] |
| H A D | pkg_stream.h | 92 : PkgStreamImpl(pkgManager, fileName), stream_(stream), fileLength_(0), streamType_(streamType) {} in FileStream()
112 FILE *stream_; member in Hpackage::FileStream
|
| /base/update/updater/services/diffpatch/diff/ |
| H A D | update_diff.cpp | 39 if (stream_ != nullptr) {
in GetPkgBuffer()
40 ret = stream_->GetBuffer(pkgBuffer);
in GetPkgBuffer()
69 ret = pkgManager_->CreatePkgStream(stream_, packageName, buffer);
in Parse()
77 ret = pkgManager_->ParsePackage(stream_, fileIds_, type_);
in Parse()
82 ret = pkgManager_->ParsePackage(stream_, fileIds_, type_);
in Parse()
87 ret = pkgManager_->ParsePackage(stream_, fileIds_, type_);
in Parse()
|
| H A D | blocks_diff.h | 90 BlocksStreamDiff(std::fstream &stream, size_t offset) : BlocksDiff(), stream_(stream), offset_(offset) {}
in BlocksStreamDiff()
97 std::fstream &stream_;
member in UpdatePatch::BlocksStreamDiff
|
| H A D | blocks_diff.cpp | 213 std::unique_ptr<DeflateAdapter> bzip2Adapter = std::make_unique<BZip2StreamAdapter>(stream_);
in CreateBZip2Adapter()
253 PATCH_DEBUG("WritePatchHeader %zu", static_cast<size_t>(stream_.tellp()));
in WritePatchHeader()
260 stream_.seekp(offset_, std::ios::beg);
in WritePatchHeader()
261 stream_.write(BSDIFF_MAGIC, std::char_traits<char>::length(BSDIFF_MAGIC));
in WritePatchHeader()
264 stream_.write(reinterpret_cast<const char*>(buffer.buffer), sizeof(int64_t));
in WritePatchHeader()
266 stream_.write(reinterpret_cast<const char*>(buffer.buffer), sizeof(int64_t));
in WritePatchHeader()
268 stream_.write(reinterpret_cast<const char*>(buffer.buffer), sizeof(int64_t));
in WritePatchHeader()
270 stream_.seekp(0, std::ios::end);
in WritePatchHeader()
|
| H A D | update_diff.h | 47 Hpackage::PkgManager::StreamPtr stream_ { nullptr };
|
| /base/web/webview/interfaces/kits/napi/webviewcontroller/ |
| H A D | web_scheme_handler_request.cpp | 82 OH_ArkWebResourceRequest_GetHttpBodyStream(request, &stream_); in WebSchemeHandlerRequest()
158 return stream_; in GetHttpBodyStream()
626 stream_ = stream; in WebHttpBodyStream()
627 if (OH_ArkWebHttpBodyStream_SetUserData(stream_, this) != 0) { in WebHttpBodyStream()
631 if (OH_ArkWebHttpBodyStream_SetReadCallback(stream_, in WebHttpBodyStream()
641 if (!stream_) { in ~WebHttpBodyStream()
642 OH_ArkWebResourceRequest_DestroyHttpBodyStream(stream_); in ~WebHttpBodyStream()
643 stream_ = nullptr; in ~WebHttpBodyStream()
685 int ret = OH_ArkWebHttpBodyStream_Init(stream_, in Init()
713 OH_ArkWebHttpBodyStream_Read(stream_, buffe in Read()
[all...] |
| H A D | web_scheme_handler_request.h | 57 ArkWeb_HttpBodyStream* stream_ = nullptr; member in OHOS::NWeb::WebSchemeHandlerRequest
196 ArkWeb_HttpBodyStream* stream_ = nullptr; member in OHOS::NWeb::WebHttpBodyStream
|
| /base/update/updater/services/diffpatch/patch/ |
| H A D | update_patch.cpp | 329 if (!stream_.is_open()) {
in Init()
330 stream_.open(newFileName_, std::ios::out | std::ios::binary);
in Init()
331 if (stream_.fail()) {
in Init()
349 if (!stream_.is_open()) {
in Write()
350 stream_.open(newFileName_, std::ios::out | std::ios::binary);
in Write()
351 if (stream_.fail()) {
in Write()
356 stream_.write(reinterpret_cast<const char*>(buffer.buffer), len);
in Write()
366 PATCH_LOGI("FilePatchWriter %zu", static_cast<size_t>(stream_.tellp()));
in Finish()
367 stream_.close();
in Finish()
|
| H A D | blocks_patch.h | 70 : BlocksPatch(patchInfo), stream_(stream), writer_(writer) {}
in BlocksStreamPatch()
76 Hpackage::PkgManager::StreamPtr stream_ { nullptr };
|
| H A D | blocks_patch.cpp | 246 size_t oldLength = stream_->GetFileLength();
in RestoreDiffData()
248 if (stream_->GetStreamType() == PkgStream::PkgStreamType_MemoryMap ||
in RestoreDiffData()
249 stream_->GetStreamType() == PkgStream::PkgStreamType_Buffer) {
in RestoreDiffData()
250 ret = stream_->GetBuffer(buffer);
in RestoreDiffData()
258 ret = stream_->Read(buffer, oldOffset_, ctrlData.diffLength, readLen);
in RestoreDiffData()
|
| /base/security/security_guard/test/unittest/config_manager/include/ |
| H A D | base_config.h | 32 std::ifstream stream_{};
|
| /base/security/security_guard/test/unittest/risk_classify/include/ |
| H A D | base_config.h | 32 std::ifstream stream_{};
|
| /base/security/security_guard/services/config_manager/include/ |
| H A D | base_config.h | 32 std::ifstream stream_{};
|
| /base/security/security_guard/test/unittest/config_manager/src/ |
| H A D | security_guard_config_manager_test.cpp | 140 config.stream_.close(); in HWTEST_F()
143 config.stream_.open("test.txt"); in HWTEST_F()
146 config.stream_.open("/data/test/unittest/resource/stream_empty.txt"); in HWTEST_F()
149 config.stream_.open("/data/test/unittest/resource/stream_not_empty.txt"); in HWTEST_F()
219 config.stream_.open("/data/test/unittest/resource/security_guard_preset_event.cfg"); in HWTEST_F()
237 config.stream_.open("/data/test/unittest/resource/security_guard_update_event.cfg"); in HWTEST_F()
238 EXPECT_TRUE(config.stream_.is_open()); in HWTEST_F()
273 config.stream_.open("/data/test/unittest/resource/security_guard_preset_model.cfg"); in HWTEST_F()
274 EXPECT_TRUE(config.stream_.is_open()); in HWTEST_F()
292 config.stream_ in HWTEST_F()
[all...] |
| /base/update/updater/services/include/patch/ |
| H A D | update_patch.h | 82 std::ofstream stream_;
member in UpdatePatch::FilePatchWriter
|