Lines Matching refs:stream
93 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()
224 PkgFilePtr PkgManagerImpl::CreatePackage(PkgStreamPtr stream, PkgFile::PkgType type, PkgInfoPtr hea… in CreatePackage() argument
228 std::string pkgName = stream->GetFileName(); in CreatePackage()
235 pkgFile = iter->second(this, stream, header); in CreatePackage()
252 int32_t PkgManagerImpl::ParsePackage(StreamPtr stream, std::vector<std::string> &fileIds, int32_t t… in ParsePackage() argument
254 if (stream == nullptr) { in ParsePackage()
258 …PkgFilePtr pkgFile = CreatePackage(static_cast<PkgStreamPtr>(stream), static_cast<PkgFile::PkgType… in ParsePackage()
260 PKG_LOGE("Create package fail %s", stream->GetFileName().c_str()); in ParsePackage()
269 PKG_LOGE("Load package fail %s", stream->GetFileName().c_str()); in ParsePackage()
353 PkgStreamPtr stream = nullptr; in ExtraAndLoadPackage() local
364 …ret = CreatePkgStream(stream, tempPath + name + ".tmp", info->unpackedSize, PkgStream::PkgStreamTy… in ExtraAndLoadPackage()
366 …ret = CreatePkgStream(stream, tempPath + name + ".tmp", info->unpackedSize, PkgStream::PkgStreamTy… in ExtraAndLoadPackage()
373 ret = ExtractFile(name, stream); in ExtraAndLoadPackage()
376 ClosePkgStream(stream); in ExtraAndLoadPackage()
379 return LoadPackageWithStream(path, fileIds, type, stream); in ExtraAndLoadPackage()
385 PkgStreamPtr stream = nullptr; in LoadPackage() local
386 int32_t ret = CreatePkgStream(stream, packagePath, 0, PkgStream::PKgStreamType_FileMap); in LoadPackage()
392 return LoadPackageWithStream(packagePath, fileIds, type, stream); in LoadPackage()
396 std::vector<std::string> &fileIds, uint8_t type, StreamPtr stream) in LoadPackageWithStream() argument
405 static_cast<PkgStreamPtr>(stream)); in LoadPackageWithStream()
409 std::vector<std::string> &fileIds, PkgFile::PkgType type, PkgStreamPtr stream) in LoadPackageWithStream() argument
412 PkgFilePtr pkgFile = CreatePackage(stream, type, nullptr); in LoadPackageWithStream()
415 ClosePkgStream(stream); in LoadPackageWithStream()
507 int32_t PkgManagerImpl::CreatePkgStream(StreamPtr &stream, const std::string &fileName, const PkgBu… in CreatePkgStream() argument
514 stream = pkgStream; in CreatePkgStream()
518 int32_t PkgManagerImpl::CreatePkgStream(StreamPtr &stream, const std::string &fileName, in CreatePkgStream() argument
527 stream = pkgStream; in CreatePkgStream()
531 int32_t PkgManagerImpl::DoCreatePkgStream(PkgStreamPtr &stream, const std::string &fileName, int32_… in DoCreatePkgStream() argument
552 stream = mapStream; in DoCreatePkgStream()
566 stream = new FileStream(this, fileName, file, type); in DoCreatePkgStream()
570 int32_t PkgManagerImpl::CreatePkgStream(PkgStreamPtr &stream, const std::string &fileName, size_t s… in DoCreatePkgStream() argument
573 stream = nullptr; in DoCreatePkgStream()
575 int32_t ret = DoCreatePkgStream(stream, fileName, type); in DoCreatePkgStream()
603 stream = new MemoryMapStream(this, fileName, buffer); in DoCreatePkgStream()
609 pkgStreams_[fileName] = stream; in DoCreatePkgStream()
613 int32_t PkgManagerImpl::CreatePkgStream(PkgStreamPtr &stream, const std::string &fileName, in DoCreatePkgStream() argument
616 stream = new ProcessorStream(this, fileName, processor, context); in DoCreatePkgStream()
617 if (stream == nullptr) { in DoCreatePkgStream()
624 void PkgManagerImpl::ClosePkgStream(PkgStreamPtr &stream) in DoCreatePkgStream() argument
626 PkgStreamPtr mapStream = stream; in DoCreatePkgStream()
641 stream = nullptr; in DoCreatePkgStream()
718 int32_t PkgManagerImpl::DoGenerateFileDigest(PkgStreamPtr stream, uint8_t flags, const size_t fileL… in DoCreatePkgStream() argument
735 int32_t ret = stream->Read(buff, offset, buffSize, readLen); in DoCreatePkgStream()
737 PKG_LOGE("read buffer fail %s", stream->GetFileName().c_str()); in DoCreatePkgStream()
754 int32_t ret = stream->Read(buff, offset, SIGN_TOTAL_LEN, readLen); in DoCreatePkgStream()
756 PKG_LOGE("read buffer failed %s", stream->GetFileName().c_str()); in DoCreatePkgStream()
770 int32_t PkgManagerImpl::GenerateFileDigest(PkgStreamPtr stream, in DoCreatePkgStream() argument
773 size_t fileLen = (hashBufferLen == 0) ? stream->GetFileLength() : hashBufferLen; in DoCreatePkgStream()
779 PKG_LOGE("Invalid file %s", stream->GetFileName().c_str()); in DoCreatePkgStream()
786 PKG_LOGE("Invalid file %s", stream->GetFileName().c_str()); in DoCreatePkgStream()
793 int32_t ret = DoGenerateFileDigest(stream, flags, fileLen, buff, digestAlgorithm); in DoCreatePkgStream()
831 int32_t PkgManagerImpl::Sign(PkgStreamPtr stream, size_t offset, const PkgInfoPtr &info) in DoCreatePkgStream() argument
844 … int32_t ret = GenerateFileDigest(stream, info->digestMethod, DIGEST_FLAGS_HAS_SIGN, digestInfos); in DoCreatePkgStream()
846 PKG_LOGE("Fail to generate signature %s", stream->GetFileName().c_str()); in DoCreatePkgStream()
859 ret = stream->Write(signBuffer, signLen, offset); in DoCreatePkgStream()
865 PKG_LOGE("Fail to SignBuffer %s", stream->GetFileName().c_str()); in DoCreatePkgStream()
872 PKG_LOGI("Signature %zu %zu %s", offset, signDataLen, stream->GetFileName().c_str()); in DoCreatePkgStream()
873 ret = stream->Write(signBuffer, signDataLen, offset); in DoCreatePkgStream()
874 stream->Flush(offset + signedData.size()); in DoCreatePkgStream()
876 PKG_LOGE("Fail to Write signature %s", stream->GetFileName().c_str()); in DoCreatePkgStream()
879 PKG_LOGW("Sign file %s success", stream->GetFileName().c_str()); in DoCreatePkgStream()
898 …PkgManagerImpl::DecompressBuffer(FileInfoPtr info, const PkgBuffer &buffer, StreamPtr stream) const in DoCreatePkgStream()
900 if (info == nullptr || buffer.buffer == nullptr || stream == nullptr) { in DoCreatePkgStream()
917 … int32_t ret = algorithm->Unpack(inStream.get(), PkgStreamImpl::ConvertPkgStream(stream), context); in DoCreatePkgStream()
923 PkgStreamImpl::ConvertPkgStream(stream)->Flush(context.unpackedSize); in DoCreatePkgStream()
930 int32_t PkgManagerImpl::CompressBuffer(FileInfoPtr info, const PkgBuffer &buffer, StreamPtr stream)… in DoCreatePkgStream()
932 if (info == nullptr || buffer.buffer == nullptr || stream == nullptr) { in DoCreatePkgStream()
949 int32_t ret = algorithm->Pack(inStream.get(), PkgStreamImpl::ConvertPkgStream(stream), context); in DoCreatePkgStream()
955 PkgStreamImpl::ConvertPkgStream(stream)->Flush(context.packedSize); in DoCreatePkgStream()
1070 PkgStreamPtr stream = nullptr; in DoCreatePkgStream() local
1071 int32_t ret = CreatePkgStream(stream, packagePath, 0, PkgStream::PkgStreamType_Read); in DoCreatePkgStream()
1076 size_t fileLen = stream->GetFileLength(); in DoCreatePkgStream()
1079 ClosePkgStream(stream); in DoCreatePkgStream()
1088 ClosePkgStream(stream); in DoCreatePkgStream()
1096 ret = GenerateFileDigest(stream, digestMethod, DIGEST_FLAGS_HAS_SIGN, digestInfos); in DoCreatePkgStream()
1102 ClosePkgStream(stream); in DoCreatePkgStream()