Lines Matching refs:stream
90 PkgStreamPtr stream = (*iter1).second; in ClearPkgFile() local
91 delete stream; in ClearPkgFile()
92 stream = nullptr; in ClearPkgFile()
169 PkgStreamPtr stream = nullptr; in CreatePackage() local
170 int32_t ret = CreatePkgStream(stream, path, 0, PkgStream::PkgStreamType_Write); in CreatePackage()
176 PkgFilePtr pkgFile = CreatePackage(PkgStreamImpl::ConvertPkgStream(stream), in CreatePackage()
180 ClosePkgStream(stream); in CreatePackage()
221 PkgFilePtr PkgManagerImpl::CreatePackage(PkgStreamPtr stream, PkgFile::PkgType type, PkgInfoPtr hea… in CreatePackage() argument
225 std::string pkgName = stream->GetFileName(); in CreatePackage()
232 pkgFile = iter->second(this, stream, header); in CreatePackage()
249 int32_t PkgManagerImpl::ParsePackage(StreamPtr stream, std::vector<std::string> &fileIds, int32_t t… in ParsePackage() argument
251 if (stream == nullptr) { in ParsePackage()
255 …PkgFilePtr pkgFile = CreatePackage(static_cast<PkgStreamPtr>(stream), static_cast<PkgFile::PkgType… in ParsePackage()
257 PKG_LOGE("Create package fail %s", stream->GetFileName().c_str()); in ParsePackage()
266 PKG_LOGE("Load package fail %s", stream->GetFileName().c_str()); in ParsePackage()
339 PkgStreamPtr stream = nullptr; in ExtraAndLoadPackage() local
352 …ret = CreatePkgStream(stream, tempPath + name + ".tmp", info->unpackedSize, PkgStream::PkgStreamTy… in ExtraAndLoadPackage()
354 …ret = CreatePkgStream(stream, tempPath + name + ".tmp", info->unpackedSize, PkgStream::PkgStreamTy… in ExtraAndLoadPackage()
361 ret = ExtractFile(name, stream); in ExtraAndLoadPackage()
364 ClosePkgStream(stream); in ExtraAndLoadPackage()
367 return LoadPackageWithStream(path, fileIds, type, stream); in ExtraAndLoadPackage()
373 PkgStreamPtr stream = nullptr; in LoadPackage() local
374 int32_t ret = CreatePkgStream(stream, packagePath, 0, PkgStream::PKgStreamType_FileMap); in LoadPackage()
380 return LoadPackageWithStream(packagePath, fileIds, type, stream); in LoadPackage()
384 std::vector<std::string> &fileIds, uint8_t type, StreamPtr stream) in LoadPackageWithStream() argument
393 static_cast<PkgStreamPtr>(stream)); in LoadPackageWithStream()
397 std::vector<std::string> &fileIds, PkgFile::PkgType type, PkgStreamPtr stream) in LoadPackageWithStream() argument
400 PkgFilePtr pkgFile = CreatePackage(stream, type, nullptr); in LoadPackageWithStream()
403 ClosePkgStream(stream); in LoadPackageWithStream()
495 int32_t PkgManagerImpl::CreatePkgStream(StreamPtr &stream, const std::string &fileName, const PkgBu… in CreatePkgStream() argument
502 stream = pkgStream; in CreatePkgStream()
506 int32_t PkgManagerImpl::CreatePkgStream(StreamPtr &stream, const std::string &fileName, RingBuffer … in CreatePkgStream() argument
520 stream = pkgStream; in CreatePkgStream()
524 int32_t PkgManagerImpl::DoCreatePkgStream(PkgStreamPtr &stream, const std::string &fileName, int32_… in DoCreatePkgStream() argument
545 stream = mapStream; in DoCreatePkgStream()
559 stream = new FileStream(this, fileName, file, type); in DoCreatePkgStream()
563 int32_t PkgManagerImpl::CreatePkgStream(PkgStreamPtr &stream, const std::string &fileName, size_t s… in DoCreatePkgStream() argument
566 stream = nullptr; in DoCreatePkgStream()
568 int32_t ret = DoCreatePkgStream(stream, fileName, type); in DoCreatePkgStream()
596 stream = new MemoryMapStream(this, fileName, buffer); in DoCreatePkgStream()
602 pkgStreams_[fileName] = stream; in DoCreatePkgStream()
606 int32_t PkgManagerImpl::CreatePkgStream(PkgStreamPtr &stream, const std::string &fileName, in DoCreatePkgStream() argument
609 stream = new ProcessorStream(this, fileName, processor, context); in DoCreatePkgStream()
610 if (stream == nullptr) { in DoCreatePkgStream()
617 void PkgManagerImpl::ClosePkgStream(PkgStreamPtr &stream) in DoCreatePkgStream() argument
619 PkgStreamPtr mapStream = stream; in DoCreatePkgStream()
634 stream = nullptr; in DoCreatePkgStream()
711 int32_t PkgManagerImpl::DoGenerateFileDigest(PkgStreamPtr stream, uint8_t flags, const size_t fileL… in DoCreatePkgStream() argument
728 int32_t ret = stream->Read(buff, offset, buffSize, readLen); in DoCreatePkgStream()
730 PKG_LOGE("read buffer fail %s", stream->GetFileName().c_str()); in DoCreatePkgStream()
747 int32_t ret = stream->Read(buff, offset, SIGN_TOTAL_LEN, readLen); in DoCreatePkgStream()
749 PKG_LOGE("read buffer failed %s", stream->GetFileName().c_str()); in DoCreatePkgStream()
763 int32_t PkgManagerImpl::GenerateFileDigest(PkgStreamPtr stream, in DoCreatePkgStream() argument
766 size_t fileLen = (hashBufferLen == 0) ? stream->GetFileLength() : hashBufferLen; in DoCreatePkgStream()
772 PKG_LOGE("Invalid file %s", stream->GetFileName().c_str()); in DoCreatePkgStream()
779 PKG_LOGE("Invalid file %s", stream->GetFileName().c_str()); in DoCreatePkgStream()
786 int32_t ret = DoGenerateFileDigest(stream, flags, fileLen, buff, digestAlgorithm); in DoCreatePkgStream()
824 int32_t PkgManagerImpl::Sign(PkgStreamPtr stream, size_t offset, const PkgInfoPtr &info) in DoCreatePkgStream() argument
837 … int32_t ret = GenerateFileDigest(stream, info->digestMethod, DIGEST_FLAGS_HAS_SIGN, digestInfos); in DoCreatePkgStream()
839 PKG_LOGE("Fail to generate signature %s", stream->GetFileName().c_str()); in DoCreatePkgStream()
852 ret = stream->Write(signBuffer, signLen, offset); in DoCreatePkgStream()
858 PKG_LOGE("Fail to SignBuffer %s", stream->GetFileName().c_str()); in DoCreatePkgStream()
865 PKG_LOGI("Signature %zu %zu %s", offset, signDataLen, stream->GetFileName().c_str()); in DoCreatePkgStream()
866 ret = stream->Write(signBuffer, signDataLen, offset); in DoCreatePkgStream()
867 stream->Flush(offset + signedData.size()); in DoCreatePkgStream()
869 PKG_LOGE("Fail to Write signature %s", stream->GetFileName().c_str()); in DoCreatePkgStream()
872 PKG_LOGW("Sign file %s success", stream->GetFileName().c_str()); in DoCreatePkgStream()
888 …PkgManagerImpl::DecompressBuffer(FileInfoPtr info, const PkgBuffer &buffer, StreamPtr stream) const in DoCreatePkgStream()
890 if (info == nullptr || buffer.buffer == nullptr || stream == nullptr) { in DoCreatePkgStream()
907 … int32_t ret = algorithm->Unpack(inStream.get(), PkgStreamImpl::ConvertPkgStream(stream), context); in DoCreatePkgStream()
913 PkgStreamImpl::ConvertPkgStream(stream)->Flush(context.unpackedSize); in DoCreatePkgStream()
920 int32_t PkgManagerImpl::CompressBuffer(FileInfoPtr info, const PkgBuffer &buffer, StreamPtr stream)… in DoCreatePkgStream()
922 if (info == nullptr || buffer.buffer == nullptr || stream == nullptr) { in DoCreatePkgStream()
939 int32_t ret = algorithm->Pack(inStream.get(), PkgStreamImpl::ConvertPkgStream(stream), context); in DoCreatePkgStream()
945 PkgStreamImpl::ConvertPkgStream(stream)->Flush(context.packedSize); in DoCreatePkgStream()
984 PkgStreamPtr stream = nullptr; in DoCreatePkgStream() local
985 int32_t ret = CreatePkgStream(stream, packagePath, 0, PkgStream::PkgStreamType_Read); in DoCreatePkgStream()
990 size_t fileLen = stream->GetFileLength(); in DoCreatePkgStream()
993 ClosePkgStream(stream); in DoCreatePkgStream()
1002 ClosePkgStream(stream); in DoCreatePkgStream()
1010 ret = GenerateFileDigest(stream, digestMethod, DIGEST_FLAGS_HAS_SIGN, digestInfos); in DoCreatePkgStream()
1016 ClosePkgStream(stream); in DoCreatePkgStream()