Home
last modified time | relevance | path

Searched refs:readLen (Results 1 – 25 of 156) sorted by relevance

1234567

/ohos5.0/foundation/communication/dhcp/services/dhcp_server/src/
H A Ddhcp_server_stub_lite.cpp89 size_t readLen; in OnRegisterCallBack() local
113 size_t readLen; in OnStartDhcpServer() local
131 size_t readLen; in OnStopDhcpServer() local
142 size_t readLen; in OnSetDhcpName() local
155 size_t readLen; in OnSetDhcpRange() local
160 range.strEndip = (char *)ReadString(req, &readLen); in OnSetDhcpRange()
173 size_t readLen; in OnRemoveAllDhcpRange() local
185 size_t readLen; in OnRemoveDhcpRange() local
203 size_t readLen; in OnGetDhcpClientInfos() local
225 size_t readLen; in OnUpdateLeasesTime() local
[all …]
/ohos5.0/drivers/peripheral/bluetooth/hci/hdi_service/implement/
H A Dmct_protocol.cpp60 ssize_t readLen; in ReadEventData() local
63 if (readLen < 0) { in ReadEventData()
67 } else if (readLen == 0) { in ReadEventData()
80 if (readLen < 0) { in ReadEventData()
84 } else if (readLen == 0) { in ReadEventData()
106 ssize_t readLen; in ReadAclData() local
109 if (readLen < 0) { in ReadAclData()
113 } else if (readLen == 0) { in ReadAclData()
118 aclReadLength_ += readLen; in ReadAclData()
126 if (readLen < 0) { in ReadAclData()
[all …]
H A Dh4_protocol.cpp86 ssize_t readLen; in ReadData() local
88 readLen = Read(fd, &packetType_, sizeof(packetType_)); in ReadData()
89 if (readLen < 0) { in ReadData()
92 } else if (readLen == 0) { in ReadData()
101 readLen = Read(fd, hciPacket_.data() + readLength_, hciPacket_.size() - readLength_); in ReadData()
102 if (readLen < 0) { in ReadData()
106 } else if (readLen == 0) { in ReadData()
111 readLength_ += readLen; in ReadData()
121 if (readLen < 0) { in ReadData()
125 } else if (readLen == 0) { in ReadData()
[all …]
/ohos5.0/foundation/communication/dhcp/frameworks/native/src/
H A Ddhcp_client_callback_stub_lite.cpp126 size_t readLen; in RemoteOnIpSuccessChanged() local
129 std::string ifname = (char *)ReadString(data, &readLen); in RemoteOnIpSuccessChanged()
137 result.strYourCli = (char *)ReadString(data, &readLen); in RemoteOnIpSuccessChanged()
138 result.strServer = (char *)ReadString(data, &readLen); in RemoteOnIpSuccessChanged()
139 result.strSubnet = (char *)ReadString(data, &readLen); in RemoteOnIpSuccessChanged()
140 result.strDns1 = (char *)ReadString(data, &readLen); in RemoteOnIpSuccessChanged()
141 result.strDns2 = (char *)ReadString(data, &readLen); in RemoteOnIpSuccessChanged()
142 result.strRouter1 = (char *)ReadString(data, &readLen); in RemoteOnIpSuccessChanged()
143 result.strRouter2 = (char *)ReadString(data, &readLen); in RemoteOnIpSuccessChanged()
144 result.strVendor = (char *)ReadString(data, &readLen); in RemoteOnIpSuccessChanged()
[all …]
/ohos5.0/base/update/updater/services/package/pkg_algorithm/
H A Dpkg_algorithm.cpp26 size_t &remainSize, size_t &readLen) const in ReadData()
38 readLen = readBytes; in ReadData()
74 size_t readLen = 0; in Pack() local
89 srcOffset += readLen; in Pack()
90 destOffset += readLen; in Pack()
120 size_t readLen = 0; in Unpack() local
135 srcOffset += readLen; in Unpack()
136 destOffset += readLen; in Unpack()
167 size_t readLen = 0; in UnpackWithVerify() local
190 srcOffset += readLen; in UnpackWithVerify()
[all …]
H A Dpkg_algo_lz4.cpp66 size_t readLen = 0; in PackCalculate() local
100 srcOffset += readLen; in PackCalculate()
144 size_t readLen = 0; in UnpackCalculate() local
155 if (readLen == 0) { in UnpackCalculate()
188 unpackText.srcOffset += readLen; in UnpackCalculate()
352 size_t readLen = 0; in GetUnpackParam() local
372 if (readLen != nextToRead) { in GetUnpackParam()
376 srcOffset += readLen; in GetUnpackParam()
377 sizeCheck = readLen; in GetUnpackParam()
400 size_t readLen = 0; in UnpackDecode() local
[all …]
H A Dpkg_algo_deflate.cpp74 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() argument
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 = 0; in UnpackCalculate() local
[all …]
/ohos5.0/foundation/communication/netmanager_base/services/netmanagernative/src/netsys/
H A Dclatd.cpp195 ssize_t readLen; in ProcessV6Packet() local
196 if (ReadV6Packet(msgHdr, readLen) != NETMANAGER_SUCCESS) { in ProcessV6Packet()
239 ssize_t readLen; in ProcessV4Packet() local
245 if (readLen < payloadOffset) { in ProcessV4Packet()
250 const int packetLen = readLen - payloadOffset; in ProcessV4Packet()
276 int32_t Clatd::ReadV6Packet(msghdr &msgHdr, ssize_t &readLen) in ReadV6Packet() argument
278 readLen = recvmsg(readSock6_, &msgHdr, 0); in ReadV6Packet()
279 if (readLen < 0) { in ReadV6Packet()
284 } else if (readLen == 0) { in ReadV6Packet()
299 if (readLen < 0) { in ReadV4Packet()
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/common/
H A Ddistributeddb_parcel_unit_test.cpp105 EXPECT_TRUE(readLen == 0);
138 EXPECT_TRUE(readLen == len);
173 EXPECT_TRUE(readLen == len);
208 EXPECT_TRUE(readLen == len);
355 EXPECT_TRUE(readLen == 0);
395 EXPECT_TRUE(readLen == 0);
435 EXPECT_TRUE(readLen != 0);
537 EXPECT_TRUE(readLen != 0);
577 EXPECT_TRUE(readLen == 0);
611 EXPECT_TRUE(readLen != 0);
[all …]
/ohos5.0/base/update/updater/services/package/pkg_manager/
H A Dpkg_stream.cpp88 readLen = 0; in Read()
103 readLen = fread(data.buffer, 1, needRead, stream_); in Read()
104 if (readLen == 0) { in Read()
224 readLen = ((copyLen > needRead) ? needRead : copyLen); in Read()
228 if (memcpy_s(data.buffer, needRead, memMap_ + start, readLen) != EOK) { in Read()
312 readLen = 0; in Read()
314 while (needRead - readLen > 0) { in Read()
328 readLen += readOnce; in Read()
350 readLen = needLen <= avail_ ? needLen : avail_; in ReadFromRingBuf()
351 avail_ -= readLen; in ReadFromRingBuf()
[all …]
H A Dpkg_stream.h33 int32_t Read(PkgBuffer &data, size_t start, size_t needRead, size_t &readLen) override in Read() argument
37 UNUSED(readLen); in Read()
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 in Read() argument
178 UNUSED(readLen); in Read()
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);
/ohos5.0/base/update/updater/services/script/script_interpreter/
H A Dscript_scanner.cpp24 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()
31 currPos += readLen; in LexerInput()
32 return readLen; in LexerInput()
/ohos5.0/base/security/appverify/interfaces/innerkits/appverify_lite/src/
H A Dapp_verify_hap.c73 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 = rawLen; in ComputeDigestsWithOptionalBlock()
141 LOG_INFO("signBuf %0x %d", rawBuf[0], readLen); in ComputeDigestsWithOptionalBlock()
189 int32_t readLenLeft = readLen; in UpdateSmallBlock()
227 ret = UpdateSmallBlock(readLen, fp, mdCtx); in ComputerFileHash()
229 rawBufLen -= readLen; in ComputerFileHash()
[all …]
/ohos5.0/docs/zh-cn/application-dev/file-management/
H A Dapp-file-access.md75 let buf = buffer.from(arrayBuffer, 0, readLen);
108 while (readLen > 0) {
109 readSize += readLen;
111 length: readLen
115 readLen = fs.readSync(srcFile.fd, buf, readOptions);
154 let readLen = await inputStream.read(buf, readOptions);
155 readSize += readLen;
156 while (readLen > 0) {
157 const writeBuf = readLen < bufSize ? buf.slice(0, readLen) : buf;
160 readLen = await inputStream.read(buf, readOptions);
[all …]
/ohos5.0/foundation/communication/dhcp/services/dhcp_client/src/
H A Ddhcp_client_stub_lite.cpp106 size_t readLen; in OnRegisterCallBack() local
107 std::string ifname = (char *)ReadString(req, &readLen); in OnRegisterCallBack()
129 size_t readLen; in OnStartDhcpClient() local
131 std::string ifname = (char *)ReadString(req, &readLen); in OnStartDhcpClient()
154 size_t readLen; in OnSetConfiguration() local
155 std::string ifname = (char *)ReadString(req, &readLen); in OnSetConfiguration()
157 config.bssid = (char *)ReadString(req, &readLen); in OnSetConfiguration()
178 size_t readLen; in OnStopDhcpClient() local
180 std::string ifname = (char *)ReadString(req, &readLen); in OnStopDhcpClient()
/ohos5.0/foundation/communication/ipc/ipc/test/rpc/socket_trans/src/
H A Drpc_socket_trans.c121 ssize_t readLen = read(clientFd, buf, DEFAULT_PACKET_SIZE); in HandleAccept() local
122 if (readLen == 0) { in HandleAccept()
128 if (readLen < 0) { in HandleAccept()
129 RPC_LOG_ERROR("socket read error=%d", readLen); in HandleAccept()
133 ret = g_callback.OnRecieved(clientFd, (void *)buf, (uint32_t)readLen); in HandleAccept()
222 ssize_t readLen = read(fd, buf, DEFAULT_PACKET_SIZE); in HandleSendReply() local
223 if (readLen == 0) { in HandleSendReply()
224 RPC_LOG_INFO("HandleSendReply received len %d", readLen); in HandleSendReply()
229 if (readLen < 0) { in HandleSendReply()
230 RPC_LOG_ERROR("HandleSendReply received len %d", readLen); in HandleSendReply()
[all …]
H A Drpc_mini_socket_trans.c124 ssize_t readLen = read(clientFd, buf, DEFAULT_PACKET_SIZE); in HandleAccept() local
125 if (readLen == 0) { in HandleAccept()
131 if (readLen < 0) { in HandleAccept()
132 RPC_LOG_ERROR("socket read error=%d", readLen); in HandleAccept()
136 ret = g_callback.OnRecieved(clientFd, (void *)buf, (uint32_t)readLen); in HandleAccept()
258 ssize_t readLen = read(fd, buf, DEFAULT_PACKET_SIZE); in HandleSendReply() local
259 if (readLen == 0) { in HandleSendReply()
260 RPC_LOG_INFO("HandleSendReply received len %d", readLen); in HandleSendReply()
265 if (readLen < 0) { in HandleSendReply()
266 RPC_LOG_ERROR("HandleSendReply received len %d", readLen); in HandleSendReply()
[all …]
/ohos5.0/foundation/filemanagement/dfs_service/utils/dentry/src/
H A Dfile_utils.cpp42 size_t readLen = 0; in ReadFile() local
43 while (readLen < size) { in ReadFile()
44 ssize_t ret = read(fd, data, size - readLen); in ReadFile()
51 readLen += ret; in ReadFile()
54 return readLen; in ReadFile()
/ohos5.0/base/update/updater/services/package/pkg_package/
H A Dpkg_zipfile.cpp207 size_t readLen = 0; in LoadPackage() local
515 size_t readLen = buffer.length; in DecodeCentralDirEntry() local
516 if (readLen < sizeof(CentralDirEntry)) { in DecodeCentralDirEntry()
554 size_t readLen = 0; in DecodeLocalFileHeaderCheck() local
562 if (readLen < sizeof(DataDescriptor)) { in DecodeLocalFileHeaderCheck()
587 size_t readLen = 0; in DecodeLocalFileHeader() local
593 if (readLen < sizeof(LocalFileHeader)) { in DecodeLocalFileHeader()
656 startWrite += readLen; in Stored()
657 remainSize -= readLen; in Stored()
733 size_t readLen = 0; in DecodeHeader() local
[all …]
/ohos5.0/foundation/communication/ipc/ipc/test/serializer/
H A Dutils_serializer_test.cpp551 size_t readLen = 0; variable
553 EXPECT_EQ(readLen, sizeBool);
600 size_t readLen = 0; variable
602 EXPECT_EQ(readLen, sizeInt8);
608 EXPECT_EQ(readLen, sizeInt16);
656 size_t readLen = 0; variable
659 EXPECT_EQ(readLen, sizeInt32);
665 EXPECT_EQ(readLen, sizeInt64);
709 size_t readLen = 0; variable
712 EXPECT_EQ(readLen, sizeUint8);
[all …]
/ohos5.0/foundation/multimedia/media_lite/services/recorder_lite/impl/src/
H A Drecorder_audio_source.cpp106 int32_t readLen = audioCap_->Read(buffer_, framesize_, isBlocking); in AcquireBuffer() local
107 if (readLen <= SUCCESS || readLen > static_cast<int32_t>(framesize_)) { in AcquireBuffer()
108 MEDIA_ERR_LOG("AudioCapturerImpl Read failed ret:0x%x", readLen); in AcquireBuffer()
114 buffer.dataLen = readLen; in AcquireBuffer()
/ohos5.0/foundation/communication/wifi/wifi/frameworks/native/src/
H A Dwifi_device_callback_stub_lite.cpp177 size_t readLen; in RemoteOnWifiConnectionChanged() local
182 info.ssid = (char *)ReadString(data, &readLen); in RemoteOnWifiConnectionChanged()
183 info.bssid = (char *)ReadString(data, &readLen); in RemoteOnWifiConnectionChanged()
188 info.macAddress = (char *)ReadString(data, &readLen); in RemoteOnWifiConnectionChanged()
203 info.portalUrl = (char *)ReadString(data, &readLen); in RemoteOnWifiConnectionChanged()
235 size_t readLen; in RemoteOnWifiWpsStateChanged() local
238 std::string pinCode = (char *)ReadString(data, &readLen); in RemoteOnWifiWpsStateChanged()
/ohos5.0/foundation/multimedia/audio_lite/services/impl/
H A Daudio_capturer_impl.cpp213 int32_t readLen = ERR_INVALID_READ; in Read() local
218 readLen = audioSource_->ReadFrame(frame, isBlockingRead); in Read()
219 if (readLen == ERR_INVALID_READ) { in Read()
220 MEDIA_ERR_LOG("audioSource_ ReadFrame fail,ret:0x%x", readLen); in Read()
235 readLen = audioEncoder_->ReadStream(stream, isBlockingRead); in Read()
236 if (readLen == ERR_INVALID_READ) { in Read()
237 MEDIA_ERR_LOG("audioEncoder_ ReadStream fail,ret:0x%x", readLen); in Read()
244 return readLen; in Read()
/ohos5.0/docs/en/application-dev/file-management/
H A Dapp-file-access.md72 let buf = buffer.from(arrayBuffer, 0, readLen);
105 while (readLen > 0) {
106 readSize += readLen;
108 length: readLen
112 readLen = fs.readSync(srcFile.fd, buf, readOptions);
149 let readLen = await inputStream.read(buf, readOptions);
150 readSize += readLen;
151 while (readLen > 0) {
152 const writeBuf = readLen < bufSize ? buf.slice(0, readLen) : buf;
155 readLen = await inputStream.read(buf, readOptions);
[all …]
/ohos5.0/base/update/updater/services/package/pkg_verify/
H A Dopenssl_util.cpp212 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()

1234567