| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/src/ |
| H A D | send_task_scheduler.cpp | 55 uint32_t totalLength = 0; in Finalize() local
56 int errCode = ScheduleOutSendTask(task, taskInfo, totalLength); in Finalize()
92 int SendTaskScheduler::ScheduleOutSendTask(SendTask &outTask, uint32_t &totalLength) in ScheduleOutSendTask() argument
95 int errCode = ScheduleOutSendTask(outTask, taskInfo, totalLength); in ScheduleOutSendTask()
103 int SendTaskScheduler::ScheduleOutSendTask(SendTask &outTask, SendTaskInfo &outTaskInfo, uint32_t &totalLength) in ScheduleOutSendTask() argument
115 totalLength = totalBytesByTarget_[outTask.dstTarget]; in ScheduleOutSendTask()
126 totalLength = totalBytesByTarget_[outTask.dstTarget]; in ScheduleOutSendTask()
|
| /foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/src/communicator/ |
| H A D | app_pipe_handler.cpp | 38 uint32_t totalLength, const MessageInfo &info)
in SendData()
40 return softbusAdapter_->SendData(pipeInfo, deviceId, dataInfo, totalLength, info);
in SendData()
37 SendData(const PipeInfo &pipeInfo, const DeviceId &deviceId, const DataInfo &dataInfo, uint32_t totalLength, const MessageInfo &info) SendData() argument
|
| H A D | process_communicator_impl.cpp | 109 uint32_t totalLength = 0;
in SendData() local
110 return SendData(dstDevInfo, data, length, totalLength);
in SendData()
114 const DeviceInfos &dstDevInfo, const uint8_t *data, uint32_t length, uint32_t totalLength)
in SendData()
120 Status errCode = CommunicationProvider::GetInstance().SendData(pi, destination, dataInfo, totalLength);
in SendData()
113 SendData( const DeviceInfos &dstDevInfo, const uint8_t *data, uint32_t length, uint32_t totalLength) SendData() argument
|
| H A D | communication_provider_impl.cpp | 72 const DataInfo &dataInfo, uint32_t totalLength, const MessageInfo &info)
in SendData()
74 return appPipeMgr_.SendData(pipeInfo, deviceId, dataInfo, totalLength, info);
in SendData()
71 SendData(const PipeInfo &pipeInfo, const DeviceId &deviceId, const DataInfo &dataInfo, uint32_t totalLength, const MessageInfo &info) SendData() argument
|
| H A D | app_pipe_mgr.cpp | 58 uint32_t totalLength, const MessageInfo &info)
in SendData()
76 return appPipeHandler->SendData(pipeInfo, deviceId, dataInfo, totalLength, info);
in SendData()
57 SendData(const PipeInfo &pipeInfo, const DeviceId &deviceId, const DataInfo &dataInfo, uint32_t totalLength, const MessageInfo &info) SendData() argument
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/communicator/src/ |
| H A D | app_pipe_handler.cpp | 47 uint32_t totalLength, const MessageInfo &info) in SendData()
49 return softbusAdapter_->SendData(pipeInfo, deviceId, dataInfo, totalLength, info); in SendData()
46 SendData(const PipeInfo &pipeInfo, const DeviceId &deviceId, const DataInfo &dataInfo, uint32_t totalLength, const MessageInfo &info) SendData() argument
|
| H A D | communication_provider_impl.cpp | 52 uint32_t totalLength, const MessageInfo &info) in SendData()
54 return appPipeMgr_.SendData(pipeInfo, deviceId, dataInfo, totalLength, info); in SendData()
51 SendData(const PipeInfo &pipeInfo, const DeviceId &deviceId, const DataInfo &dataInfo, uint32_t totalLength, const MessageInfo &info) SendData() argument
|
| H A D | app_pipe_mgr.cpp | 62 uint32_t totalLength, const MessageInfo &info) in SendData()
69 ZLOGD("pipeInfo:%s ,size:%u, total length:%u", pipeInfo.pipeId.c_str(), dataInfo.length, totalLength); in SendData()
80 return appPipeHandler->SendData(pipeInfo, deviceId, dataInfo, totalLength, info); in SendData()
61 SendData(const PipeInfo &pipeInfo, const DeviceId &deviceId, const DataInfo &dataInfo, uint32_t totalLength, const MessageInfo &info) SendData() argument
|
| H A D | process_communicator_impl.cpp | 131 uint32_t totalLength = 0; in SendData() local
132 return SendData(dstDevInfo, data, length, totalLength); in SendData()
136 uint32_t totalLength) in SendData()
142 Status errCode = CommunicationProvider::GetInstance().SendData(pi, destination, dataInfo, totalLength); in SendData()
135 SendData(const DeviceInfos &dstDevInfo, const uint8_t *data, uint32_t length, uint32_t totalLength) SendData() argument
|
| H A D | app_pipe_handler.h | 46 uint32_t totalLength, const MessageInfo &info);
|
| H A D | app_pipe_mgr.h | 40 uint32_t totalLength, const MessageInfo &info);
|
| H A D | communication_provider_impl.h | 40 uint32_t totalLength, const MessageInfo &info) override;
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/ |
| H A D | data_transformer.cpp | 285 uint64_t totalLength = Parcel::GetUInt64Len(); // first record field count in SerializeValue() local
288 totalLength += Parcel::GetUInt32Len(); // For save the dataValue's type. in SerializeValue()
290 totalLength += dataLength; in SerializeValue()
291 if (totalLength > static_cast<uint64_t>(INT32_MAX)) { in SerializeValue()
296 value.resize(static_cast<uint32_t>(totalLength)); in SerializeValue()
297 if (value.size() != static_cast<uint32_t>(totalLength)) { in SerializeValue()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/include/ |
| H A D | send_task_scheduler.h | 67 int ScheduleOutSendTask(SendTask &outTask, uint32_t &totalLength);
68 int ScheduleOutSendTask(SendTask &outTask, SendTaskInfo &outTaskInfo, uint32_t &totalLength);
|
| H A D | iadapter.h | 58 uint32_t totalLength) = 0;
|
| /foundation/communication/bluetooth_service/services/bluetooth/service/src/avrcp_tg/ |
| H A D | avrcp_tg_vendor.cpp | 1219 uint16_t totalLength = 0x00; in GetNumberOfPackets() local
1224 if (totalLength + attributeName_[i].length() + AVRC_TG_GPASAT_PARAMETER_EXCEPT_ATTRIBUTE_NUM < in GetNumberOfPackets()
1226 totalLength += (attributeName_[i].length() + AVRC_TG_GPASAT_PARAMETER_EXCEPT_ATTRIBUTE_NUM); in GetNumberOfPackets()
1231 tem = std::make_pair(totalNumber, totalLength); in GetNumberOfPackets()
1233 totalLength = 0x00; in GetNumberOfPackets()
1238 tem = std::make_pair(totalNumber, totalLength); in GetNumberOfPackets()
1395 uint16_t totalLength = 0x00; in GetNumberOfPackets() local
1400 if (totalLength + valueName_[i].length() + AVRC_TG_GPASVT_PARAMETER_EXCEPT_ATTRIBUTE_NUM < in GetNumberOfPackets()
1402 totalLength += (valueName_[i].length() + AVRC_TG_GPASVT_PARAMETER_EXCEPT_ATTRIBUTE_NUM); in GetNumberOfPackets()
1407 tem = std::make_pair(totalNumber, totalLength); in GetNumberOfPackets()
1619 uint16_t totalLength = 0x00; GetNumberOfPackets() local
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/include/ |
| H A D | iprocess_communicator.h | 99 virtual DBStatus SendData(const DeviceInfos &dstDevInfo, const uint8_t *data, uint32_t length, uint32_t totalLength) in SendData() argument
101 (void)totalLength; in SendData()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/multiver/ |
| H A D | multi_ver_value_object.cpp | 54 size_t totalLength = Parcel::GetIntLen() * serialIntNum + Parcel::GetVectorCharLen(valueHashVector_); in GetSerialData() local
55 data.resize(totalLength); in GetSerialData()
|
| H A D | generic_multi_ver_kv_entry.cpp | 40 size_t totalLength = Parcel::GetVectorCharLen(key_) + Parcel::GetVectorCharLen(valueObjectSerial) + in GetSerialData() local
43 data.resize(totalLength); in GetSerialData()
|
| /foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/include/communicator/ |
| H A D | app_pipe_mgr.h | 44 Status SendData(const PipeInfo &pipeInfo, const DeviceId &deviceId, const DataInfo &dataInfo, uint32_t totalLength,
|
| H A D | app_pipe_handler.h | 41 Status SendData(const PipeInfo &pipeInfo, const DeviceId &deviceId, const DataInfo &dataInfo, uint32_t totalLength,
|
| H A D | communication_provider_impl.h | 46 Status SendData(const PipeInfo &pipeInfo, const DeviceId &deviceId, const DataInfo &DataInfo, uint32_t totalLength,
|
| H A D | communication_provider.h | 54 uint32_t totalLength, const MessageInfo &info = { MessageType::DEFAULT }) = 0;
|
| /foundation/communication/bluetooth_service/services/bluetooth/stack/src/hci/acl/ |
| H A D | hci_acl.c | 407 size_t totalLength = PacketSize(packet); in HciFargment() local
409 int count = (totalLength / frameLength) + ((totalLength % frameLength) ? 1 : 0); in HciFargment()
465 size_t totalLength = PacketSize(packet); in HciFargmentAndSendData() local
466 if (totalLength > g_aclDataPacketLength) { in HciFargmentAndSendData()
520 size_t totalLength = PacketSize(packet); in HciFargmentAndSendLeData() local
521 if (totalLength > g_leAclDataPacketLength) { in HciFargmentAndSendLeData()
|
| /foundation/communication/bluetooth_service/services/bluetooth/stack/src/sdp/ |
| H A D | sdp_client_parse.c | 555 uint32_t totalLength; in SdpParseAttributeListArray() local
568 totalLength = PacketSize(packet); in SdpParseAttributeListArray()
569 uint8_t *buffer = MEM_MALLOC.alloc(totalLength); in SdpParseAttributeListArray()
574 (void)memset_s(buffer, totalLength, 0, totalLength); in SdpParseAttributeListArray()
575 PacketRead(packet, buffer, 0, totalLength); in SdpParseAttributeListArray()
591 if (length != (totalLength - offset)) { in SdpParseAttributeListArray()
593 __FUNCTION__, __LINE__, totalLength, length, offset); in SdpParseAttributeListArray()
598 while (offset < totalLength) { in SdpParseAttributeListArray()
604 bufferInfo.length = totalLength; in SdpParseAttributeListArray()
1026 uint32_t totalLength = 0; SdpGetCommonProtocolDescriptorList() local
[all...] |