Lines Matching refs:stream
93 PkgStreamPtr stream = (*iter1).second;
94 delete stream;
95 stream = nullptr;
172 PkgStreamPtr stream = nullptr;
173 int32_t ret = CreatePkgStream(stream, path, 0, PkgStream::PkgStreamType_Write);
179 PkgFilePtr pkgFile = CreatePackage(PkgStreamImpl::ConvertPkgStream(stream),
183 ClosePkgStream(stream);
191 PKG_LOGE("Create stream fail %s", files[i].first.c_str());
224 PkgFilePtr PkgManagerImpl::CreatePackage(PkgStreamPtr stream, PkgFile::PkgType type, PkgInfoPtr header)
228 std::string pkgName = stream->GetFileName();
235 pkgFile = iter->second(this, stream, header);
252 int32_t PkgManagerImpl::ParsePackage(StreamPtr stream, std::vector<std::string> &fileIds, int32_t type)
254 if (stream == nullptr) {
255 PKG_LOGE("Invalid stream");
258 PkgFilePtr pkgFile = CreatePackage(static_cast<PkgStreamPtr>(stream), static_cast<PkgFile::PkgType>(type), nullptr);
260 PKG_LOGE("Create package fail %s", stream->GetFileName().c_str());
269 PKG_LOGE("Load package fail %s", stream->GetFileName().c_str());
349 PKG_LOGE("Create middle stream fail %s", name.c_str());
353 PkgStreamPtr stream = nullptr;
364 ret = CreatePkgStream(stream, tempPath + name + ".tmp", info->unpackedSize, PkgStream::PkgStreamType_Write);
366 ret = CreatePkgStream(stream, tempPath + name + ".tmp", info->unpackedSize, PkgStream::PkgStreamType_MemoryMap);
369 PKG_LOGE("Create middle stream fail %s", name.c_str());
373 ret = ExtractFile(name, stream);
376 ClosePkgStream(stream);
379 return LoadPackageWithStream(path, fileIds, type, stream);
385 PkgStreamPtr stream = nullptr;
386 int32_t ret = CreatePkgStream(stream, packagePath, 0, PkgStream::PKgStreamType_FileMap);
388 PKG_LOGE("Create input stream fail %s", packagePath.c_str());
392 return LoadPackageWithStream(packagePath, fileIds, type, stream);
396 std::vector<std::string> &fileIds, uint8_t type, StreamPtr stream)
405 static_cast<PkgStreamPtr>(stream));
409 std::vector<std::string> &fileIds, PkgFile::PkgType type, PkgStreamPtr stream)
412 PkgFilePtr pkgFile = CreatePackage(stream, type, nullptr);
415 ClosePkgStream(stream);
437 PKG_LOGE("Invalid stream");
507 int32_t PkgManagerImpl::CreatePkgStream(StreamPtr &stream, const std::string &fileName, const PkgBuffer &buffer)
511 PKG_LOGE("Failed to create stream");
514 stream = pkgStream;
518 int32_t PkgManagerImpl::CreatePkgStream(StreamPtr &stream, const std::string &fileName,
524 PKG_LOGE("Failed to create stream");
527 stream = pkgStream;
531 int32_t PkgManagerImpl::DoCreatePkgStream(PkgStreamPtr &stream, const std::string &fileName, int32_t type)
552 stream = mapStream;
566 stream = new FileStream(this, fileName, file, type);
570 int32_t PkgManagerImpl::CreatePkgStream(PkgStreamPtr &stream, const std::string &fileName, size_t size, int32_t type)
573 stream = nullptr;
575 int32_t ret = DoCreatePkgStream(stream, fileName, type);
603 stream = new MemoryMapStream(this, fileName, buffer);
609 pkgStreams_[fileName] = stream;
613 int32_t PkgManagerImpl::CreatePkgStream(PkgStreamPtr &stream, const std::string &fileName,
616 stream = new ProcessorStream(this, fileName, processor, context);
617 if (stream == nullptr) {
618 PKG_LOGE("Failed to create stream");
624 void PkgManagerImpl::ClosePkgStream(PkgStreamPtr &stream)
626 PkgStreamPtr mapStream = stream;
641 stream = nullptr;
718 int32_t PkgManagerImpl::DoGenerateFileDigest(PkgStreamPtr stream, uint8_t flags, const size_t fileLen,
735 int32_t ret = stream->Read(buff, offset, buffSize, readLen);
737 PKG_LOGE("read buffer fail %s", stream->GetFileName().c_str());
754 int32_t ret = stream->Read(buff, offset, SIGN_TOTAL_LEN, readLen);
756 PKG_LOGE("read buffer failed %s", stream->GetFileName().c_str());
770 int32_t PkgManagerImpl::GenerateFileDigest(PkgStreamPtr stream,
773 size_t fileLen = (hashBufferLen == 0) ? stream->GetFileLength() : hashBufferLen;
779 PKG_LOGE("Invalid file %s", stream->GetFileName().c_str());
786 PKG_LOGE("Invalid file %s", stream->GetFileName().c_str());
793 int32_t ret = DoGenerateFileDigest(stream, flags, fileLen, buff, digestAlgorithm);
831 int32_t PkgManagerImpl::Sign(PkgStreamPtr stream, size_t offset, const PkgInfoPtr &info)
844 int32_t ret = GenerateFileDigest(stream, info->digestMethod, DIGEST_FLAGS_HAS_SIGN, digestInfos);
846 PKG_LOGE("Fail to generate signature %s", stream->GetFileName().c_str());
859 ret = stream->Write(signBuffer, signLen, offset);
865 PKG_LOGE("Fail to SignBuffer %s", stream->GetFileName().c_str());
872 PKG_LOGI("Signature %zu %zu %s", offset, signDataLen, stream->GetFileName().c_str());
873 ret = stream->Write(signBuffer, signDataLen, offset);
874 stream->Flush(offset + signedData.size());
876 PKG_LOGE("Fail to Write signature %s", stream->GetFileName().c_str());
879 PKG_LOGW("Sign file %s success", stream->GetFileName().c_str());
898 int32_t PkgManagerImpl::DecompressBuffer(FileInfoPtr info, const PkgBuffer &buffer, StreamPtr stream) const
900 if (info == nullptr || buffer.buffer == nullptr || stream == nullptr) {
913 PKG_LOGE("DecompressBuffer Can not create stream for %s", info->identity.c_str());
917 int32_t ret = algorithm->Unpack(inStream.get(), PkgStreamImpl::ConvertPkgStream(stream), context);
923 PkgStreamImpl::ConvertPkgStream(stream)->Flush(context.unpackedSize);
930 int32_t PkgManagerImpl::CompressBuffer(FileInfoPtr info, const PkgBuffer &buffer, StreamPtr stream) const
932 if (info == nullptr || buffer.buffer == nullptr || stream == nullptr) {
945 PKG_LOGE("CompressBuffer Can not create stream for %s", info->identity.c_str());
949 int32_t ret = algorithm->Pack(inStream.get(), PkgStreamImpl::ConvertPkgStream(stream), context);
955 PkgStreamImpl::ConvertPkgStream(stream)->Flush(context.packedSize);
1028 PKG_LOGE("create package stream fail %s %s", devRealPath, strerror(errno));
1070 PkgStreamPtr stream = nullptr;
1071 int32_t ret = CreatePkgStream(stream, packagePath, 0, PkgStream::PkgStreamType_Read);
1073 PKG_LOGE("Create input stream fail %s", packagePath.c_str());
1076 size_t fileLen = stream->GetFileLength();
1079 ClosePkgStream(stream);
1088 ClosePkgStream(stream);
1096 ret = GenerateFileDigest(stream, digestMethod, DIGEST_FLAGS_HAS_SIGN, digestInfos);
1102 ClosePkgStream(stream);