/base/update/updater/services/script/script_interpreter/ |
H A D | script_scanner.cpp | 24 size_t readLen = 0; in LexerInput() local 26 if (pkgStream_->Read(data, currPos, maxSize, readLen) != PKG_SUCCESS) { in LexerInput() 28 return readLen; in LexerInput() 30 memcpy_s(reinterpret_cast<uint8_t*>(buf), maxSize, data.buffer, readLen); in LexerInput() local 31 currPos += readLen; in LexerInput() 32 return readLen; in LexerInput()
|
/base/update/updater/services/package/pkg_algorithm/ |
H A D | pkg_algorithm.cpp | 26 size_t &remainSize, size_t &readLen) const
in ReadData() 38 readLen = readBytes;
in ReadData() 74 size_t readLen = 0;
in Pack() local 76 ret = ReadData(inStream, srcOffset, buffer, remainSize, readLen);
in Pack() 82 ret = outStream->Write(buffer, readLen, destOffset);
in Pack() 88 algorithm->Update(buffer, readLen);
in Pack() 89 srcOffset += readLen;
in Pack() 90 destOffset += readLen;
in Pack() 120 size_t readLen = 0;
in Unpack() local 122 ret = ReadData(inStream, srcOffset, buffer, remainSize, readLen);
in Unpack() 167 size_t readLen = 0; UnpackWithVerify() local [all...] |
H A D | pkg_algo_lz4.cpp | 66 size_t readLen = 0;
in PackCalculate() local 77 ret = ReadData(inStream, srcOffset, inBuffer, remainSize, readLen);
in PackCalculate() 85 outBuffer.buffer + LZ4B_REVERSED_LEN, readLen, outBuffer.length - LZ4B_REVERSED_LEN);
in PackCalculate() 100 srcOffset += readLen;
in PackCalculate() 144 size_t readLen = 0;
in UnpackCalculate() local 150 int32_t ret = ReadData(inStream, unpackText.srcOffset, inBuffer, unpackText.packedSize, readLen);
in UnpackCalculate() 155 if (readLen == 0) {
in UnpackCalculate() 167 ret = ReadData(inStream, unpackText.srcOffset, inBuffer, unpackText.packedSize, readLen);
in UnpackCalculate() 175 outBuffer.buffer, readLen, LZ4B_BLOCK_SIZE);
in UnpackCalculate() 188 unpackText.srcOffset += readLen;
in UnpackCalculate() 352 size_t readLen = 0; GetUnpackParam() local 400 size_t readLen = 0; UnpackDecode() local [all...] |
H A D | pkg_algo_deflate.cpp | 74 size_t readLen = 0;
in PackCalculate() local 76 ret = ReadData(inStream, srcOffset, inBuffer, remainSize, readLen);
in PackCalculate() 82 zstream.avail_in = readLen;
in PackCalculate() 83 srcOffset += readLen;
in PackCalculate() 85 algorithm->Calculate(crcResult, inBuffer, readLen);
in PackCalculate() 123 z_stream &zstream, PkgAlgorithmContext &context, size_t &readLen)
in ReadUnpackData() 126 int32_t ret = ReadData(inStream, context.srcOffset, inBuffer, context.packedSize, readLen);
in ReadUnpackData() 132 zstream.avail_in = readLen;
in ReadUnpackData() 133 context.srcOffset += readLen;
in ReadUnpackData() 168 size_t readLen in UnpackCalculate() local 122 ReadUnpackData(const PkgStreamPtr inStream, PkgBuffer &inBuffer, z_stream &zstream, PkgAlgorithmContext &context, size_t &readLen) ReadUnpackData() argument [all...] |
/base/update/updater/services/package/pkg_manager/ |
H A D | pkg_stream.cpp | 75 int32_t FileStream::Read(PkgBuffer &data, size_t start, size_t needRead, size_t &readLen) in Read() argument 88 readLen = 0; in Read() 103 readLen = fread(data.buffer, 1, needRead, stream_); in Read() 104 if (readLen == 0) { in Read() 209 int32_t MemoryMapStream::Read(PkgBuffer &data, size_t start, size_t needRead, size_t &readLen) in Read() argument 224 readLen = ((copyLen > needRead) ? needRead : copyLen); in Read() 228 if (memcpy_s(data.buffer, needRead, memMap_ + start, readLen) != EOK) { in Read() 229 PKG_LOGE("Memcpy failed size:%zu, start:%zu copyLen:%zu %zu", needRead, start, copyLen, readLen); in Read() 295 int32_t FlowDataStream::Read(PkgBuffer &data, size_t start, size_t needRead, size_t &readLen) in Read() argument 312 readLen in Read() 334 ReadFromRingBuf(uint8_t *&buff, const uint32_t needLen, uint32_t &readLen) ReadFromRingBuf() argument [all...] |
H A D | pkg_stream.h | 33 int32_t Read(PkgBuffer &data, size_t start, size_t needRead, size_t &readLen) override 37 UNUSED(readLen); variable 96 int32_t Read(PkgBuffer &data, size_t start, size_t needRead, size_t &readLen) override; 124 int32_t Read(PkgBuffer &data, size_t start, size_t needRead, size_t &readLen) override; 174 int32_t Read(PkgBuffer &data, size_t start, size_t needRead, size_t &readLen) override 178 UNUSED(readLen); variable 237 int32_t Read(Hpackage::PkgBuffer &data, size_t start, size_t needRead, size_t &readLen) override; 272 int32_t ReadFromRingBuf(uint8_t *&buff, const uint32_t needLen, uint32_t &readLen);
|
/base/security/appverify/interfaces/innerkits/appverify_lite/src/ |
H A D | app_verify_hap.c | 54 int32_t readLen = (rawBufLen > HASH_BLOB_LEN) ? HASH_BLOB_LEN : rawBufLen; in ComputeBlockHash() local 64 if (memcpy_s((chunkContentPrefix + 1), HAP_DIGEST_PRIFIX_LEN - 1, (&readLen), sizeof(int)) != EOK) { in ComputeBlockHash() 71 ret = mbedtls_md_update(mdCtx, (unsigned char *)block + pos, readLen); in ComputeBlockHash() 73 rawBufLen -= readLen; in ComputeBlockHash() 74 pos += readLen; in ComputeBlockHash() 133 int32_t readLen = chunkDigest->len; in ComputeDigestsWithOptionalBlock() local 134 LOG_INFO("readLen %d", readLen); in ComputeDigestsWithOptionalBlock() 135 ret = mbedtls_md_update(mdCtx, chunkDigest->buffer, readLen); in ComputeDigestsWithOptionalBlock() 140 readLen in ComputeDigestsWithOptionalBlock() 159 HapUpdateDigistHead( int32_t digestAlgorithm, mbedtls_md_context_t *mdCtx, const mbedtls_md_info_t *mdInfo, int32_t readLen, size_t *hlen) HapUpdateDigistHead() argument 187 UpdateSmallBlock(int32_t readLen, const int32_t fp, mbedtls_md_context_t *mdCtx) UpdateSmallBlock() argument 218 int32_t readLen = (rawBufLen > HASH_BLOB_LEN) ? HASH_BLOB_LEN : rawBufLen; ComputerFileHash() local [all...] |
/base/hiviewdfx/hichecker/interfaces/js/kits/napi/js_leak_watcher/ |
H A D | js_leak_watcher.js | 78 let readLen = fs.readSync(heapDumpFile.fd, buf, readOptions); 80 while (readLen > 0) { 81 md.updateSync({ data: new Uint8Array(buf.slice(0, readLen)) }); 82 readSize += readLen; 84 readLen = fs.readSync(heapDumpFile.fd, buf, readOptions);
|
/base/security/access_token/services/accesstokenmanager/main/cpp/src/permission/ |
H A D | dlp_permission_set_parser.cpp | 109 ssize_t readLen = 0; in ReadCfgFile() local 110 while ((readLen = read(fd, buff, MAX_BUFFER_SIZE)) > 0) { in ReadCfgFile() 111 dlpPermsRawData.append(buff, readLen); in ReadCfgFile() 115 if (readLen == 0) { in ReadCfgFile()
|
/base/security/access_token/frameworks/common/src/ |
H A D | json_parser.cpp | 105 ssize_t readLen = 0; in ReadCfgFile() local 106 while ((readLen = read(fd, buff, BUFFER_SIZE)) > 0) { in ReadCfgFile() 107 rawData.append(buff, readLen); in ReadCfgFile() 110 if (readLen == 0) { in ReadCfgFile()
|
/base/update/updater/services/package/pkg_package/ |
H A D | pkg_zipfile.cpp | 121 uint32_t endDirLen, size_t endDirPos, size_t &readLen)
in LoadPackage() 147 sizeof(Zip64EndCentralDirLocator), readLen);
in LoadPackage() 153 ret = pkgStream_->Read(buffer, currentPos, sizeof(Zip64EndCentralDirRecord), readLen);
in LoadPackage() 207 size_t readLen = 0;
in LoadPackage() local 209 ret = pkgStream_->Read(buffer, endDirPos, sizeof(EndCentralDir), readLen);
in LoadPackage() 228 ret = pkgStream_->Read(buffer, endDirPos, sizeof(EndCentralDir), readLen);
in LoadPackage() 236 return LoadPackage(fileNames, buffer, endDirLen, endDirPos, readLen);
in LoadPackage() 515 size_t readLen = buffer.length;
in DecodeCentralDirEntry() local 516 if (readLen < sizeof(CentralDirEntry)) {
in DecodeCentralDirEntry() 517 PKG_LOGE("data not not enough %zu", readLen);
in DecodeCentralDirEntry() 120 LoadPackage(std::vector<std::string> &fileNames, PkgBuffer &buffer, uint32_t endDirLen, size_t endDirPos, size_t &readLen) LoadPackage() argument 554 size_t readLen = 0; DecodeLocalFileHeaderCheck() local 587 size_t readLen = 0; DecodeLocalFileHeader() local 645 size_t readLen = (remainSize > buffer.length) ? buffer.length : remainSize; Stored() local 733 size_t readLen = 0; DecodeHeader() local [all...] |
H A D | pkg_gzipfile.cpp | 173 size_t readLen = 0;
in CheckFileInfo() local 176 int32_t ret = inStream->Read(buffer, context.packedSize + fileInfo_.fileInfo.dataOffset, BLOCK_SIZE, readLen);
in CheckFileInfo() 293 size_t readLen = 0;
in DecodeHeader() local 295 int32_t ret = inStream->Read(buffer, blockOffset, buffer.length, readLen);
in DecodeHeader() 365 size_t readLen = 0;
in LoadPackage() local 367 int32_t ret = pkgStream_->Read(buffer, srcOffset, buffer.length, readLen);
in LoadPackage() 394 ret = entry->DecodeHeader(buffer, srcOffset, srcOffset, readLen);
in LoadPackage() 395 srcOffset += readLen;
in LoadPackage()
|
/base/update/updater/services/package/pkg_verify/ |
H A D | openssl_util.cpp | 212 size_t readLen = 0; in CalcSha256Digest() local 215 ret = srcData->Read(buffer, offset, blockLen, readLen); in CalcSha256Digest() 222 offset += readLen; in CalcSha256Digest() 223 remainLen -= readLen; in CalcSha256Digest() 226 ret = srcData->Read(buffer, offset, remainLen, readLen); in CalcSha256Digest() 232 SHA256_Update(&ctx, buffer.buffer, readLen); in CalcSha256Digest()
|
H A D | pkg_verify_util.cpp | 70 size_t readLen = 0; in VerifyAccPackageSign() local 73 pkgStream->Read(digest, 0, srcDataLen, readLen); in VerifyAccPackageSign() 74 sourceDigest.assign(digest.buffer, digest.buffer + readLen); in VerifyAccPackageSign() 142 size_t readLen = 0; in GetSignature() local 143 ret = pkgStream->Read(signData, signatureStart, signDataLen, readLen); in GetSignature() 149 signature.assign(signData.buffer, signData.buffer + readLen); in GetSignature()
|
H A D | zip_pkg_parse.cpp | 52 size_t &readLen, const uint16_t &signCommentAppendLen, uint16_t &signCommentTotalLen) const in DoParseZipPkg() 64 int32_t ret = pkgStream->Read(zipEocd, zipEocdStart, eocdTotalLen, readLen); in DoParseZipPkg() 103 size_t readLen = 0; in ParseZipPkg() local 105 int32_t ret = pkgStream->Read(footer, footerStart, footerSize, readLen); in ParseZipPkg() 120 return DoParseZipPkg(pkgStream, pkgSignComment, readLen, signCommentAppendLen, signCommentTotalLen); in ParseZipPkg() 51 DoParseZipPkg(PkgStreamPtr pkgStream, PkgSignComment &pkgSignComment, size_t &readLen, const uint16_t &signCommentAppendLen, uint16_t &signCommentTotalLen) const DoParseZipPkg() argument
|
/base/update/updater/test/fuzztest/UpdaterStartUpdaterProc_fuzzer/ |
H A D | UpdaterStartUpdaterProc_fuzzer.cpp | 82 size_t readLen = 0; in BuildFileDigest() local 84 ret = stream->Read(buff, offset, buffSize, readLen); in BuildFileDigest() 91 algorithm->Update(buff, readLen); in BuildFileDigest() 93 offset += readLen; in BuildFileDigest() 94 readLen = 0; in BuildFileDigest()
|
/base/update/updater/test/fuzztest/package_fuzzer/ |
H A D | pkg_fuzz_test.h | 121 size_t readLen = 0; in BuildFileDigest() local 123 ret = stream->Read(buff, offset, bufSize, readLen); in BuildFileDigest() 129 alg->Update(buff, readLen); in BuildFileDigest() 131 offset += readLen; in BuildFileDigest() 132 readLen = 0; in BuildFileDigest()
|
/base/update/updater/test/unittest/package/ |
H A D | pkg_test.h | 98 size_t readLen = 0; in BuildFileDigest() local 100 ret = stream->Read(buff, offset, buffSize, readLen); in BuildFileDigest() 106 algorithm->Update(buff, readLen); in BuildFileDigest() 108 offset += readLen; in BuildFileDigest() 109 readLen = 0; in BuildFileDigest()
|
/base/update/updater/test/unittest/updater_binary/ |
H A D | updater_binary_unittest.cpp | 103 size_t readLen = 0; in BuildFileDigest() local 105 ret = stream->Read(buff, offset, buffSize, readLen); in BuildFileDigest() 112 algorithm->Update(buff, readLen); in BuildFileDigest() 113 offset += readLen; in BuildFileDigest() 114 readLen = 0; in BuildFileDigest()
|
/base/startup/init/services/modules/bootchart/ |
H A D | bootchart.c | 49 ssize_t readLen = 0; in ReadFileToBuffer() local 55 readLen = read(fd, buffer, bufferSize - 1); in ReadFileToBuffer() 57 PLUGIN_CHECK(readLen >= 0, break, "Failed to read data for %s %d readLen %d", fileName, errno, readLen); in ReadFileToBuffer() 58 buffer[readLen] = '\0'; in ReadFileToBuffer() 63 return (readLen > 0) ? buffer : NULL; in ReadFileToBuffer()
|
/base/security/appverify/interfaces/innerkits/appverify/src/init/ |
H A D | hap_crl_manager.cpp | 126 long long readLen = crlRandomAccess.ReadFileFullyFromOffset(crlsBuffer, 0);
in ReadCrls() local 127 if (readLen != fileLen) {
in ReadCrls() 128 HAPVERIFY_LOG_ERROR("read file len: %{public}lld is not same as %{public}lld", readLen, fileLen);
in ReadCrls()
|
/base/hiviewdfx/hiview_lite/ |
H A D | hiview_file.c | 175 int32 ReadFromFile(HiviewFile *fp, uint8 *data, uint32 readLen) in ReadFromFile() argument 177 if (fp == NULL || data == NULL || fp->fhandle < 0 || readLen == 0) { in ReadFromFile() 184 if (wCursor < readLen) { in ReadFromFile() 187 int32 rLen = (readLen <= (wCursor - rCursor)) ? readLen : (wCursor - rCursor); in ReadFromFile()
|
/base/update/updater/test/fuzztest/extractandexecutescript_fuzzer/ |
H A D | extractandexecutescript_fuzzer.cpp | 219 size_t readLen = 0; in BuildFileDigest() local 221 ret = stream->Read(buff, offset, buffSize, readLen); in BuildFileDigest() 227 algorithm->Update(buff, readLen); in BuildFileDigest() 229 offset += readLen; in BuildFileDigest() 230 readLen = 0; in BuildFileDigest()
|
/base/update/updater/services/diffpatch/bzip2/ |
H A D | bzip2_adapter.cpp | 231 size_t readLen = 0;
in ReadData() local 237 readLen = info.length - stream_.avail_out;
in ReadData() 245 readLen = info.length;
in ReadData() 253 if (readLen < info.length) {
in ReadData() 254 PATCH_LOGE("Failed to read mem ret %zu length %zu", readLen, info.length);
in ReadData()
|
/base/startup/init/services/loopevent/task/ |
H A D | le_streamtask.c | 59 int readLen = 0;
in HandleRecvMsg_() local 62 readLen = handleRecvMsg(taskHandle, buffer->data, LOOP_DEFAULT_BUFFER, 0);
in HandleRecvMsg_() 64 readLen = recv(GetSocketFd(taskHandle), buffer->data, LOOP_DEFAULT_BUFFER, 0);
in HandleRecvMsg_() 66 LE_LOGV("HandleRecvMsg fd:%d read msg len %d", GetSocketFd(taskHandle), readLen);
in HandleRecvMsg_() 67 if (readLen < 0) {
in HandleRecvMsg_() 73 } else if (readLen == 0) {
in HandleRecvMsg_() 86 recvMessage(taskHandle, buffer->data, readLen);
in HandleRecvMsg_()
|