| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/src/ |
| H A D | serial_buffer.cpp | 54 totalLen_ = BYTE_8_ALIGN(payloadLen_ + headerLen_); in AllocBufferByPayloadLength()
55 paddingLen_ = totalLen_ - payloadLen_ - headerLen_; in AllocBufferByPayloadLength()
56 if (totalLen_ == 0 || totalLen_ > MAX_TOTAL_LEN) { in AllocBufferByPayloadLength()
59 oringinalBytes_ = new (std::nothrow) uint8_t[totalLen_ + extendHeadLen_](); in AllocBufferByPayloadLength()
77 totalLen_ = inTotalLen; in AllocBufferByTotalLength()
79 payloadLen_ = totalLen_ - headerLen_; in AllocBufferByTotalLength()
99 totalLen_ = inTotalLen; in SetExternalBuff()
101 payloadLen_ = totalLen_ - headerLen_; in SetExternalBuff()
110 if (totalLen_ in Clone()
[all...] |
| H A D | serial_buffer.h | 69 uint32_t totalLen_ = 0; member in DistributedDB::SerialBuffer
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/ |
| H A D | parcel.cpp | 30 totalLen_(len) in Parcel()
85 if (isError_ || parcelLen_ + sizeof(double) > totalLen_) { in WriteDouble()
89 errno_t errCode = memcpy_s(bufPtr_, totalLen_ - parcelLen_, &inData, sizeof(double)); in WriteDouble()
101 if (isError_ || bufPtr_ == nullptr || parcelLen_ + sizeof(double) > totalLen_) { in ReadDouble()
165 if (stepLen > INT32_MAX || parcelLen_ + BYTE_8_ALIGN(stepLen) > totalLen_) { in WriteString()
166 LOGE("[WriteString] stepLen:%" PRIu64 ", totalLen:%" PRIu64 ", parcelLen:%" PRIu64, stepLen, totalLen_, in WriteString()
171 errno_t errCode = memcpy_s(bufPtr_, totalLen_ - parcelLen_, &len, sizeof(uint32_t)); in WriteString()
173 LOGE("[WriteString] bufPtr:%d, totalLen:%" PRIu64 ", parcelLen:%" PRIu64, bufPtr_ != nullptr, totalLen_, in WriteString()
184 errCode = memcpy_s(bufPtr_, totalLen_ - parcelLen_ - sizeof(uint32_t), inVal.c_str(), inVal.size()); in WriteString()
187 totalLen_, parcelLen in WriteString()
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/include/ |
| H A D | parcel.h | 80 if (bufPtr_ == nullptr || stepLen > INT32_MAX || parcelLen_ + BYTE_8_ALIGN(stepLen) > totalLen_) { in WriteVector()
82 bufPtr_ != nullptr, ULL(stepLen), ULL(totalLen_), ULL(parcelLen_)); in WriteVector()
86 errno_t errCode = memcpy_s(bufPtr_, totalLen_ - parcelLen_, &len, sizeof(uint32_t)); in WriteVector()
88 LOGE("[ReadVector] totalLen:%llu, parcelLen:%llu", ULL(totalLen_), ULL(parcelLen_)); in WriteVector()
109 if (bufPtr_ == nullptr || parcelLen_ + sizeof(uint32_t) > totalLen_ || sizeof(T) > INT32_MAX) { in ReadVector()
111 bufPtr_ != nullptr, ULL(totalLen_), ULL(parcelLen_), sizeof(T)); in ReadVector()
123 if (stepLen > INT32_MAX || parcelLen_ + BYTE_8_ALIGN(stepLen) > totalLen_) { in ReadVector()
124 LOGE("[ReadVector] stepLen:%llu, totalLen:%llu, parcelLen:%llu", ULL(stepLen), ULL(totalLen_), in ReadVector()
185 uint64_t totalLen_ = 0; member in DistributedDB::Parcel
194 if (bufPtr_ == nullptr || parcelLen_ + sizeof(T) > totalLen_) { in ReadInteger()
[all...] |
| /foundation/ability/dmsfwk/services/dtbschedmgr/src/softbus_adapter/transport/ |
| H A D | dsched_softbus_session.cpp | 235 totalLen_ = headerPara.totalLen; in AssembleFrag()
293 if (totalLen_ < headerPara.dataLen + offset_) { in CheckUnPackBuffer()
295 " peerNetworkId: %{public}s.", totalLen_, offset_, headerPara.dataLen, sessionId_, in CheckUnPackBuffer()
308 totalLen_ = 0; in ResetAssembleFrag()
|
| /foundation/distributedhardware/distributed_camera/services/channel/src/ |
| H A D | dcamera_softbus_session.cpp | 199 totalLen_ = headerPara.totalLen; in AssembleFrag()
259 if (totalLen_ < headerPara.dataLen + offset_) { in CheckUnPackBuffer()
261 "%{public}d sess: %{public}s peerSess: %{public}s", totalLen_, offset_, headerPara.dataLen, in CheckUnPackBuffer()
274 totalLen_ = 0; in ResetAssembleFrag()
|
| /foundation/ability/dmsfwk/services/dtbschedmgr/include/softbus_adapter/transport/ |
| H A D | dsched_softbus_session.h | 124 uint32_t totalLen_; member in OHOS::DistributedSchedule::DSchedSoftbusSession
|
| /foundation/distributedhardware/distributed_camera/services/channel/include/ |
| H A D | dcamera_softbus_session.h | 110 uint32_t totalLen_; member in OHOS::DistributedHardware::DCameraSoftbusSession
|
| /foundation/multimedia/av_codec/services/media_engine/plugins/source/http_source/hls/ |
| H A D | hls_media_downloader.h | 178 uint64_t totalLen_ = 0; member in OHOS::Media::Plugins::HttpPlugin::HlsMediaDownloader
|
| H A D | hls_media_downloader.cpp | 778 totalLen_ += realLen; in SaveEncryptData()
|
| /foundation/distributedhardware/distributed_camera/services/channel/test/unittest/common/channel/ |
| H A D | dcamera_softbus_session_test.cpp | 258 softbusSession_->totalLen_ = 2; in HWTEST_F()
|
| /foundation/ability/dmsfwk/services/dtbschedmgr/test/unittest/softbus_adapter/ |
| H A D | softbus_transport_test.cpp | 363 softbusSessionTest_->totalLen_ = TOTALLEN_2; in HWTEST_F()
|