| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/ |
| H A D | single_ver_data_packet.cpp | 154 uint64_t totalLen = GenericSingleVerKvEntry::CalculateLens( in CalculateLen() local
156 if (totalLen == 0) { in CalculateLen()
159 totalLen += Parcel::GetUInt64Len(); // endWaterMark in CalculateLen()
160 totalLen += Parcel::GetUInt64Len(); // localWaterMark in CalculateLen()
161 totalLen += Parcel::GetUInt64Len(); // peerWaterMark in CalculateLen()
162 totalLen += Parcel::GetIntLen(); // sendCode in CalculateLen()
163 totalLen += Parcel::GetIntLen(); // mode in CalculateLen()
164 totalLen += Parcel::GetUInt32Len(); // sessionId in CalculateLen()
165 totalLen += Parcel::GetUInt32Len(); // version in CalculateLen()
166 totalLen in CalculateLen()
503 uint64_t totalLen = ControlRequestPacket::CalculateLen(); CalculateLen() local
[all...] |
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/app/src/session_manager/ |
| H A D | route_head_handler_impl.h | 63 DBStatus FillHeadData(uint8_t *data, uint32_t headSize, uint32_t totalLen) override;
68 bool PackData(uint8_t *data, uint32_t totalLen);
69 bool PackDataHead(uint8_t *data, uint32_t totalLen);
70 bool PackDataBody(uint8_t *data, uint32_t totalLen);
71 bool UnPackData(const uint8_t *data, uint32_t totalLen, uint32_t &unpackedSize);
72 bool UnPackDataHead(const uint8_t *data, uint32_t totalLen, RouteHead &routeHead);
73 bool UnPackDataBody(const uint8_t *data, uint32_t totalLen);
|
| H A D | route_head_handler_impl.cpp | 115 DistributedDB::DBStatus RouteHeadHandlerImpl::FillHeadData(uint8_t *data, uint32_t headSize, uint32_t totalLen)
in FillHeadData() argument
131 bool RouteHeadHandlerImpl::PackData(uint8_t *data, uint32_t totalLen)
in PackData() argument
133 if (headSize_ > totalLen) {
in PackData()
135 headSize_, totalLen);
in PackData()
146 bool RouteHeadHandlerImpl::PackDataHead(uint8_t *data, uint32_t totalLen)
in PackDataHead() argument
156 head->dataLen = HostToNet(uint32_t(totalLen - sizeof(RouteHead)));
in PackDataHead()
160 bool RouteHeadHandlerImpl::PackDataBody(uint8_t *data, uint32_t totalLen)
in PackDataBody() argument
187 uint8_t *end = data + totalLen;
in PackDataBody()
224 bool RouteHeadHandlerImpl::UnPackData(const uint8_t *data, uint32_t totalLen, uint32_t &unpackedSize)
in UnPackData() argument
226 if (data == nullptr || totalLen < sizeo in UnPackData()
243 UnPackDataHead(const uint8_t *data, uint32_t totalLen, RouteHead &routeHead) UnPackDataHead() argument
265 UnPackDataBody(const uint8_t *data, uint32_t totalLen) UnPackDataBody() argument
[all...] |
| /foundation/filemanagement/dfs_service/services/cloudsyncservice/src/transport/ |
| H A D | message_handler.cpp | 41 bool MessageHandler::PackData(uint8_t *data, uint32_t totalLen) in PackData() argument
43 if (!data || totalLen < dataSize_) { in PackData()
44 LOGE("Invalid param, totalLen:%{public}d, dataSize:%{public}d", totalLen, dataSize_); in PackData()
53 head->dataLen = htole32(totalLen - sizeof(MessageHeader)); in PackData()
77 uint8_t *end = data + totalLen; in PackData()
86 bool MessageHandler::UnPackData(uint8_t *data, uint32_t totalLen) in UnPackData() argument
88 if (!data || totalLen < sizeof(MessageHeader)) { in UnPackData()
89 LOGE("invalid input data, totalLen:%{public}d", totalLen); in UnPackData()
[all...] |
| /foundation/distributedhardware/distributed_camera/services/channel/src/ |
| H A D | dcamera_softbus_session.cpp | 144 if (buffer->Size() != (headerPara.dataLen + BINARY_HEADER_FRAG_LEN) || headerPara.dataLen > headerPara.totalLen || in PackRecvData()
145 headerPara.dataLen > BINARY_DATA_MAX_LEN || headerPara.totalLen > BINARY_DATA_MAX_TOTAL_LEN) { in PackRecvData()
147 DHLOGE("pack recv data failed, size: %{public}" PRIu64", dataLen: %{public}d, totalLen: %{public}d sess: " in PackRecvData()
148 "%{public}s peerSess: %{public}s", bufferSize, headerPara.dataLen, headerPara.totalLen, in PackRecvData()
153 DHLOGD("pack recv data Assemble, size: %{public}" PRIu64", dataLen: %{public}d, totalLen: %{public}d, nowTime: " in PackRecvData()
154 "%{public}" PRId64" start", bufferSize, headerPara.dataLen, headerPara.totalLen, GetNowTimeStampUs()); in PackRecvData()
161 DHLOGD("pack recv data Assemble, size: %{public}" PRIu64", dataLen: %{public}d, totalLen: %{public}d, nowTime: " in PackRecvData()
162 "%{public}" PRId64" end", bufferSize, headerPara.dataLen, headerPara.totalLen, GetNowTimeStampUs()); in PackRecvData()
167 if (headerPara.dataLen != headerPara.totalLen) { in AssembleNoFrag()
168 DHLOGE("DCameraSoftbusSession PackRecvData failed, dataLen: %{public}d, totalLen in AssembleNoFrag()
359 uint32_t totalLen = buffer->Size(); UnPackSendData() local
406 SetHeadParaDataLen(SessionDataHeader& headPara, const uint32_t totalLen, const uint32_t offset) SetHeadParaDataLen() argument
[all...] |
| /foundation/ability/dmsfwk/services/dtbschedmgr/src/softbus_adapter/transport/ |
| H A D | dsched_softbus_session.cpp | 118 if (buffer->Size() != (headerPara.dataLen + BINARY_HEADER_FRAG_LEN) || headerPara.dataLen > headerPara.totalLen || in PackRecvData()
119 headerPara.dataLen > BINARY_DATA_MAX_LEN || headerPara.totalLen > BINARY_DATA_MAX_TOTAL_LEN) { in PackRecvData()
121 HILOGE("pack recv data failed, size: %" PRIu64", dataLen: %{public}d, totalLen: %{public}d session id:" in PackRecvData()
122 " %{public}d", bufferSize, headerPara.dataLen, headerPara.totalLen, sessionId_); in PackRecvData()
126 HILOGD("pack recv data Assemble, size: %" PRIu64", dataLen: %{public}d, totalLen: %{public}d, nowTime: " in PackRecvData()
127 "%" PRId64" start", bufferSize, headerPara.dataLen, headerPara.totalLen, GetNowTimeStampUs()); in PackRecvData()
134 HILOGD("pack recv data Assemble, size: %" PRIu64", dataLen: %{public}d, totalLen: %{public}d, nowTime: " in PackRecvData()
135 "%" PRId64" end", bufferSize, headerPara.dataLen, headerPara.totalLen, GetNowTimeStampUs()); in PackRecvData()
190 ret = memcpy_s(&headerPara.totalLen, sizeof(headerPara.totalLen), pt in ReadTlvToHeader()
328 uint32_t totalLen = buffer->Size(); UnPackSendData() local
396 SetHeadParaDataLen(SessionDataHeader& headPara, const uint32_t totalLen, const uint32_t offset, const uint32_t maxSendSize) SetHeadParaDataLen() argument
447 TlvItem totalLen = { TLV_TYPE_TOTAL_LEN, sizeof(uint32_t), headPara.totalLen }; MakeFragDataHeader() local
[all...] |
| /foundation/ability/ability_lite/frameworks/want_lite/src/ |
| H A D | want.cpp | 103 uint8_t totalLen = valueLen + 2;
104 entity = AdapterMalloc(totalLen);
109 if (memcpy_s((unsigned char *)entity, totalLen, &type, 1) != 0 ||
110 memcpy_s((unsigned char *)entity + 1, totalLen - 1, &length, 1) != 0 ||
124 newTlv->totalLen = totalLen;
136 uint8_t newTlvValueLen = keyTlv->totalLen + valueTlv->totalLen;
141 if (memcpy_s((unsigned char *)newTlvValue, keyTlv->totalLen, keyTlv->entity, keyTlv->totalLen) !
[all...] |
| /foundation/arkui/ui_lite/interfaces/kits/events/ |
| H A D | drag_event.h | 53 * @param totalLen Indicates the distance that the view has been dragged, including the movement on the x-axis
58 DragEvent(const Point& newPos, const Point& lastPos, const Point& totalLen) : Event(newPos) in DragEvent() argument
61 startPos_.x = newPos.x - totalLen.x; in DragEvent()
62 startPos_.y = newPos.y - totalLen.y; in DragEvent()
|
| /foundation/communication/netstack/frameworks/cj/http/include/ |
| H A D | net_http_request_context.h | 41 LoadBytes(curl_off_t nowLen, curl_off_t totalLen): nLen(nowLen), tLen(totalLen) {}; in LoadBytes()
91 void SetDlLen(curl_off_t nowLen, curl_off_t totalLen);
95 void SetUlLen(curl_off_t nowLen, curl_off_t totalLen);
99 bool CompareWithLastElement(curl_off_t nowLen, curl_off_t totalLen);
|
| /foundation/communication/netstack/frameworks/js/napi/http/async_context/include/ |
| H A D | request_context.h | 36 LoadBytes(curl_off_t nowLen, curl_off_t totalLen) in LoadBytes()
39 tLen = totalLen; in LoadBytes()
89 void SetDlLen(curl_off_t nowLen, curl_off_t totalLen);
93 void SetUlLen(curl_off_t nowLen, curl_off_t totalLen);
97 bool CompareWithLastElement(curl_off_t nowLen, curl_off_t totalLen);
|
| /foundation/arkui/ui_lite/frameworks/components/ |
| H A D | ui_scroll_view.cpp | 264 int16_t totalLen = childrenRect.GetHeight() + 2 * scrollBlankSize_; // 2: two blank space on both sizes in RefreshScrollBar() local
267 yScrollBar_->SetForegroundProportion(static_cast<float>(len) / totalLen); in RefreshScrollBar()
269 yScrollBar_->SetScrollProgress(static_cast<float>(scrollBlankSize_ - childrenRect.GetTop()) / (totalLen - len)); in RefreshScrollBar()
273 totalLen = childrenRect.GetWidth() + 2 * scrollBlankSize_; // 2: two blank space on both sizes in RefreshScrollBar()
275 xScrollBar_->SetForegroundProportion(static_cast<float>(len) / totalLen); in RefreshScrollBar()
277 (totalLen - len)); in RefreshScrollBar()
|
| /foundation/multimedia/image_framework/plugins/common/libs/image/libextplugin/src/hardware/ |
| H A D | jpeg_hw_decoder.cpp | 343 unsigned int totalLen, uint16_t marker) in JumpOverCurrentJpegMarker()
346 if (curPos + JpegMarker::MARKER_LEN > totalLen) { in JumpOverCurrentJpegMarker()
348 curPos, totalLen, marker); in JumpOverCurrentJpegMarker()
356 if (curPos > totalLen) { in JumpOverCurrentJpegMarker()
358 "for marker(%{public}u)", curPos, totalLen, marker); in JumpOverCurrentJpegMarker()
374 unsigned int totalLen = static_cast<unsigned int>(inputBufferHandle->size); in GetCompressedDataStart() local
377 while (curPos + JpegMarker::MARKER_LEN <= totalLen) { in GetCompressedDataStart()
383 if (!JumpOverCurrentJpegMarker(data, curPos, totalLen, potentialMarker)) { in GetCompressedDataStart()
342 JumpOverCurrentJpegMarker(const uint8_t* data, unsigned int& curPos, unsigned int totalLen, uint16_t marker) JumpOverCurrentJpegMarker() argument
|
| /foundation/graphic/graphic_2d/frameworks/bootanimation/src/ |
| H A D | util.cpp | 270 int totalLen = 0; in ReadImageFile() local
285 if (memcpy_s(imageStruct->memPtr.memBuffer + totalLen, size - totalLen, \ in ReadImageFile()
287 totalLen += readLen; in ReadImageFile()
291 if (totalLen > 0) { in ReadImageFile()
292 LOGD("fileName: %{public}s, fileSize: %{public}d, totalLen: %{public}d", fileName.c_str(), size, totalLen); in ReadImageFile()
294 ParseImageConfig(imageStruct->memPtr.memBuffer, totalLen, frameConfig); in ReadImageFile()
296 CheckImageData(fileName, imageStruct, totalLen, imgVec); in ReadImageFile()
|
| /foundation/filemanagement/dfs_service/services/cloudsyncservice/include/transport/ |
| H A D | message_handler.h | 73 bool PackData(uint8_t *data, uint32_t totalLen);
74 bool UnPackData(uint8_t *data, uint32_t totalLen);
|
| /foundation/distributedhardware/distributed_camera/services/channel/test/unittest/common/channel/ |
| H A D | dcamera_softbus_session_test.cpp | 195 headerPara.totalLen = 2; in HWTEST_F()
197 headerPara.totalLen = 1; in HWTEST_F()
216 headerPara.totalLen = 2; in HWTEST_F()
228 headerPara.totalLen = 10; in HWTEST_F()
245 headerPara.totalLen = 2; in HWTEST_F()
276 headerPara.totalLen = 2; in HWTEST_F()
341 headerPara.totalLen = 2; in HWTEST_F()
|
| /foundation/ability/ability_lite/frameworks/want_lite/include/ |
| H A D | want_utils.h | 24 uint8_t totalLen = 0; member
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/include/communicator/ |
| H A D | route_head_handler.h | 29 const uint8_t *data, uint32_t totalLen, uint32_t &headSize, std::vector<std::string> &users) = 0;
|
| /foundation/ability/dmsfwk/services/dtbschedmgr/include/softbus_adapter/transport/ |
| H A D | dsched_softbus_session.h | 90 uint32_t totalLen; member
115 void SetHeadParaDataLen(SessionDataHeader& headPara, const uint32_t totalLen, const uint32_t offset,
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/include/ |
| H A D | iprocess_communicator.h | 54 virtual DBStatus FillHeadData(uint8_t *data, uint32_t headSize, uint32_t totalLen) in FillHeadData() argument
162 virtual DBStatus CheckAndGetDataHeadInfo(const uint8_t *data, uint32_t totalLen, uint32_t &headLength, in CheckAndGetDataHeadInfo() argument
|
| /foundation/arkui/ace_engine/frameworks/core/components/form/resource/ |
| H A D | form_manager_resource.cpp | 116 size_t totalLen = param.length(); in ParseMapFromString() local
119 while (index < totalLen) { in ParseMapFromString()
122 end = totalLen; in ParseMapFromString()
|
| /foundation/arkui/ace_engine/frameworks/core/components/plugin/resource/ |
| H A D | plugin_manager_resource.cpp | 114 size_t totalLen = param.length(); in ParseMapFromString() local
117 while (index < totalLen) { in ParseMapFromString()
120 end = totalLen; in ParseMapFromString()
|
| /foundation/bundlemanager/bundle_framework/services/bundlemgr/src/ |
| H A D | bundle_parser.cpp | 40 bool ParseStr(const char *buf, const int itemLen, int totalLen, std::vector<std::string> &sysCaps) in ParseStr() argument
42 APP_LOGD("Parse rpcid output start, itemLen:%{public}d totalLen:%{public}d", itemLen, totalLen); in ParseStr()
43 if (buf == nullptr || itemLen <= 0 || totalLen <= 0) { in ParseStr()
49 while (index + itemLen <= totalLen) { in ParseStr()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/communicator/ |
| H A D | distributeddb_communicator_common.h | 97 DistributedDB::DBStatus FillHeadData(uint8_t *data, uint32_t headSize, uint32_t totalLen) override
106 auto errCode = memcpy_s(data, totalLen, &info, sizeof(ExtendHeadInfo));
|
| /foundation/distributedhardware/distributed_camera/services/channel/include/ |
| H A D | dcamera_softbus_session.h | 58 uint32_t totalLen; member
78 void SetHeadParaDataLen(SessionDataHeader& headPara, const uint32_t totalLen, const uint32_t offset);
|
| /foundation/communication/netstack/frameworks/cj/http/src/ |
| H A D | net_http_request_context.cpp | 184 void RequestContext::SetDlLen(curl_off_t nowLen, curl_off_t totalLen) in SetDlLen() argument
187 LoadBytes dlBytes{nowLen, totalLen}; in SetDlLen()
191 void RequestContext::SetUlLen(curl_off_t nowLen, curl_off_t totalLen) in SetUlLen() argument
197 LoadBytes ulBytes{nowLen, totalLen}; in SetUlLen()
224 bool RequestContext::CompareWithLastElement(curl_off_t nowLen, curl_off_t totalLen) in CompareWithLastElement() argument
231 return nowLen == lastElement.nLen && totalLen == lastElement.tLen; in CompareWithLastElement()
|