| /foundation/communication/bluetooth_service/services/bluetooth/stack/src/hci/evt/ |
| D | hci_evt.c | 66 static void HciEventOnInquiryCompleteEvent(Packet *packet) in HciEventOnInquiryCompleteEvent()
85 static void HciEventOnInquiryResultEvent(Packet *packet) in HciEventOnInquiryResultEvent()
146 static void HciEventOnCommandStatusEvent(Packet *packet) in HciEventOnCommandStatusEvent()
174 static void HciEventOnConnectionCompleteEvent(Packet *packet) in HciEventOnConnectionCompleteEvent()
201 static void HciEventOnConnectionRequestEvent(Packet *packet) in HciEventOnConnectionRequestEvent()
224 static void HciEventOnRemoteNameRequestCompleteEvent(Packet *packet) in HciEventOnRemoteNameRequestCompleteEvent()
247 static void HciEventOnEncryptionChangeEvent(Packet *packet) in HciEventOnEncryptionChangeEvent()
270 static void HciEventOnReadRemoteSupportedFeaturesCompleteEvent(Packet *packet) in HciEventOnReadRemoteSupportedFeaturesCompleteEvent()
294 static void HciEventOnReadRemoteVersionInformationCompleteEvent(Packet *packet) in HciEventOnReadRemoteVersionInformationCompleteEvent()
318 static void HciEventOnRemoteHostSupportedFeaturesNotificationEvent(Packet *packet) in HciEventOnRemoteHostSupportedFeaturesNotificationEvent()
[all …]
|
| /foundation/communication/dhcp/test/unittest/services/dhcp_client/ |
| D | dhcp_options_test.cpp | 60 struct DhcpPacket packet; variable
92 struct DhcpPacket packet; variable
121 struct DhcpPacket packet; variable
145 struct DhcpPacket packet; variable
177 struct DhcpPacket packet; variable
217 struct DhcpPacket packet; variable
250 struct DhcpPacket packet; variable
279 struct DhcpPacket packet; variable
305 struct DhcpPacket packet; variable
327 struct DhcpPacket packet; variable
[all …]
|
| D | dhcp_client_state_machine_test.cpp | 160 struct DhcpPacket *packet = nullptr; variable
172 struct DhcpPacket packet; variable
184 struct DhcpPacket *packet = nullptr; variable
197 struct DhcpPacket packet; variable
219 struct DhcpPacket packet; variable
245 struct DhcpPacket *packet = nullptr; variable
258 struct DhcpPacket packet; variable
271 struct DhcpPacket *packet = nullptr; variable
284 struct DhcpPacket packet; variable
322 struct DhcpPacket packet; variable
[all …]
|
| D | dhcp_socket_test.cpp | 117 struct DhcpPacket packet; variable
151 struct DhcpPacket packet; variable
179 struct UdpDhcpPacket packet; variable
210 struct UdpDhcpPacket packet; variable
229 struct UdpDhcpPacket packet; variable
244 struct DhcpPacket packet; variable
258 struct DhcpPacket packet; variable
|
| /foundation/multimodalinput/input/intention/cooperate/plugin/src/ |
| D | dsoftbus_handler.cpp | 120 NetPacket packet(MessageId::DSOFTBUS_START_COOPERATE); in StartCooperate() local
137 NetPacket packet(MessageId::DSOFTBUS_STOP_COOPERATE); in StopCooperate() local
148 NetPacket packet(MessageId::DSOFTBUS_COME_BACK); in ComeBack() local
164 NetPacket packet(MessageId::DSOFTBUS_RELAY_COOPERATE); in RelayCooperate() local
180 NetPacket packet(MessageId::DSOFTBUS_RELAY_COOPERATE_FINISHED); in RelayCooperateFinish() local
228 bool DSoftbusHandler::OnPacket(const std::string &networkId, NetPacket &packet) in OnPacket()
262 void DSoftbusHandler::OnStartCooperate(const std::string &networkId, NetPacket &packet) in OnStartCooperate()
283 void DSoftbusHandler::OnStopCooperate(const std::string &networkId, NetPacket &packet) in OnStopCooperate()
295 void DSoftbusHandler::OnComeBack(const std::string &networkId, NetPacket &packet) in OnComeBack()
316 void DSoftbusHandler::OnRelayCooperate(const std::string &networkId, NetPacket &packet) in OnRelayCooperate()
[all …]
|
| D | mouse_location.cpp | 226 NetPacket packet(MessageId::DSOFTBUS_REPLY_SUBSCRIBE_MOUSE_LOCATION); in ReplySubscribeMouseLocation() local
242 NetPacket packet(MessageId::DSOFTBUS_REPLY_UNSUBSCRIBE_MOUSE_LOCATION); in ReplyUnSubscribeMouseLocation() local
258 NetPacket packet(MessageId::DSOFTBUS_SUBSCRIBE_MOUSE_LOCATION); in SubscribeMouseLocation() local
274 NetPacket packet(MessageId::DSOFTBUS_UNSUBSCRIBE_MOUSE_LOCATION); in UnSubscribeMouseLocation() local
290 NetPacket packet(MessageId::DSOFTBUS_MOUSE_LOCATION); in SyncMouseLocation() local
355 int32_t MouseLocation::SendPacket(const std::string &remoteNetworkId, NetPacket &packet) in SendPacket()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/ |
| D | single_ver_serialize_manager.cpp | 201 …erializeManager::DataPacketSyncerPartSerialization(Parcel &parcel, const DataRequestPacket *packet) in DataPacketSyncerPartSerialization()
225 auto packet = inMsg->GetObject<DataRequestPacket>(); in DataPacketSerialization() local
269 …SerializeManager::DataPacketQuerySyncSerialization(Parcel &parcel, const DataRequestPacket *packet) in DataPacketQuerySyncSerialization()
294 const DataRequestPacket *packet = inMsg->GetObject<DataRequestPacket>(); in DataPacketCalculateLen() local
305 const DataAckPacket *packet = inMsg->GetObject<DataAckPacket>(); in AckPacketCalculateLen() local
330 const DataAckPacket *packet = inMsg->GetObject<DataAckPacket>(); in AckPacketSerialization() local
344 …erSerializeManager::AckPacketSyncerPartSerializationV1(Parcel &parcel, const DataAckPacket *packet) in AckPacketSyncerPartSerializationV1()
375 auto packet = new (std::nothrow) DataRequestPacket(); in DataPacketDeSerialization() local
407 …eVerSerializeManager::DataPacketQuerySyncDeSerialization(Parcel &parcel, DataRequestPacket *packet) in DataPacketQuerySyncDeSerialization()
436 …rSerializeManager::DataPacketCompressDataDeSerialization(Parcel &parcel, DataRequestPacket *packet) in DataPacketCompressDataDeSerialization()
[all …]
|
| D | single_ver_data_sync.cpp | 160 const DataAckPacket *packet = message->GetObject<DataAckPacket>(); in TryContinueSync() local
555 const DataRequestPacket *packet = message->GetObject<DataRequestPacket>(); in RemoveDeviceDataHandle() local
660 void SingleVerDataSync::FillDataRequestPacket(DataRequestPacket *packet, SingleVerSyncTaskContext *… in FillDataRequestPacket()
733 DataRequestPacket *packet = new (std::nothrow) DataRequestPacket; in RequestStart() local
797 DataRequestPacket *packet = new (std::nothrow) DataRequestPacket; in PullRequestStart() local
946 auto *packet = message->GetObject<DataRequestPacket>(); in DataRequestRecvPre() local
993 const DataRequestPacket *packet = message->GetObject<DataRequestPacket>(); in DataRequestRecv() local
1040 int SingleVerDataSync::SendDataPacket(SyncType syncType, DataRequestPacket *packet, in SendDataPacket()
1081 DataRequestPacket *packet = new (std::nothrow) DataRequestPacket; in SendPullResponseDataPkt() local
1124 const DataRequestPacket *packet = message->GetObject<DataRequestPacket>(); in SendDataAck() local
[all …]
|
| D | single_ver_data_sync_utils.cpp | 93 int SingleVerDataSyncUtils::RequestQueryCheck(const DataRequestPacket *packet, SyncGenericInterface… in RequestQueryCheck()
201 const std::string &label, const DataRequestPacket *packet) in RunPermissionCheck()
267 void SingleVerDataSyncUtils::SetPacketId(DataRequestPacket *packet, SingleVerSyncTaskContext *conte… in SetPacketId()
312 void SingleVerDataSyncUtils::FillControlRequestPacket(ControlRequestPacket *packet, SingleVerSyncTa… in FillControlRequestPacket()
351 const ControlRequestPacket *packet = inMsg->GetObject<ControlRequestPacket>(); in IsNeedTriggerQueryAutoSync() local
490 …const SyncGenericInterface* storage, const std::string &label, const DataRequestPacket *packet, in… in RunPermissionCheckInner()
511 const DataRequestPacket *packet = message->GetObject<DataRequestPacket>(); in GetTimeOffsetFromRequestMsg() local
540 …const SyncGenericInterface &storage, DataRequestPacket &packet, std::shared_ptr<Metadata> &metadat… in SetDataRequestCommonInfo()
566 const DataRequestPacket &packet, std::shared_ptr<Metadata> &metadata) in SchemaVersionMatchCheck()
|
| /foundation/communication/bluetooth_service/services/bluetooth/service/src/avrcp_ct/ |
| D | avrcp_ct_profile.cpp | 330 …std::shared_ptr<AvrcCtPassPacket> packet = std::make_shared<AvrcCtPassPacket>(button, AVRC_KEY_STA… in SendPressButtonCmd() local
340 …std::shared_ptr<AvrcCtPassPacket> packet = std::make_shared<AvrcCtPassPacket>(button, AVRC_KEY_STA… in SendReleaseButtonCmd() local
394 std::shared_ptr<AvrcCtPassPacket> packet = cnManager->PopPassQueue(rawAddr); in SendNextPassCmd() local
405 AvrcCtPassPacket packet(pkt); in ReceivePassRsp() local
542 std::shared_ptr<AvrcCtUnitPacket> packet = cnManager->PopUnitQueue(rawAddr); in SendNextUnitCmd() local
569 AvrcCtUnitPacket packet(pkt); in ReceiveUnitRsp() local
579 AvrcCtSubUnitPacket packet(pkt); in ReceiveSubUnitRsp() local
588 …std::shared_ptr<AvrcCtUnitPacket> packet = AvrcCtConnectManager::GetInstance()->GetUnitPacket(rawA… in ProcessUnitTimeout() local
666 std::shared_ptr<AvrcCtVendorPacket> packet = cnManager->PopVendorQueue(rawAddr); in SendNextVendorCmd() local
681 std::shared_ptr<AvrcCtVendorPacket> packet = std::make_shared<AvrcCtRcrPacket>(pduId); in SendVendorContinueCmd() local
[all …]
|
| /foundation/communication/bluetooth_service/services/bluetooth/service/src/avrcp_tg/ |
| D | avrcp_tg_profile.cpp | 342 …std::shared_ptr<AvrcTgPassPacket> packet = std::make_shared<AvrcTgPassPacket>(button, AVRC_KEY_STA… in SendPressButtonRsp() local
353 std::shared_ptr<AvrcTgPassPacket> packet = in SendReleaseButtonRsp() local
374 …std::shared_ptr<AvrcTgPassPacket> packet = AvrcTgConnectManager::GetInstance()->GetPassPacket(rawA… in IsSamePassPressCommand() local
401 std::shared_ptr<AvrcTgPassPacket> packet = cnManager->GetPassPacket(rawAddr); in IsIgnorePassReleaseCommand() local
458 std::shared_ptr<AvrcTgPassPacket> packet = std::make_shared<AvrcTgPassPacket>(pkt, label); in ReceivePassCmd() local
559 std::shared_ptr<AvrcTgUnitPacket> packet = std::make_shared<AvrcTgUnitPacket>(pkt, label); in ReceiveUnitCmd() local
568 std::shared_ptr<AvrcTgUnitPacket> packet = std::make_shared<AvrcTgSubUnitPacket>(pkt, label); in ReceiveSubUnitCmd() local
595 std::shared_ptr<AvrcTgVendorPacket> packet = in SendGetCapabilitiesRsp() local
605 std::shared_ptr<AvrcTgVendorPacket> packet = in SendGetCapabilitiesRsp() local
629 std::shared_ptr<AvrcTgVendorPacket> packet = gcPkt; in ReceiveGetCapabilitiesCmd() local
[all …]
|
| /foundation/communication/bluetooth_service/services/bluetooth/stack/src/hci/ |
| D | hci.c | 64 static void HciFreePacket(void *packet) in HciFreePacket()
198 HciPacket *packet = QueueTryDequeue(g_hciTxQueue); in CleanTxPacket() local
209 HciPacket *packet = QueueTryDequeue(g_hciRxQueue); in CleanRxPacket() local
325 HciPacket *packet = QueueTryDequeue(g_hciTxQueue); in HciSendPacketCallback() local
370 HciPacket *packet = QueueTryDequeue(g_hciRxQueue); in HciRecvPacketCallback() local
389 void HciPushToTxQueue(HciPacket *packet) in HciPushToTxQueue()
|
| /foundation/communication/dhcp/services/dhcp_client/src/ |
| D | dhcp_options.cpp | 27 static bool CheckOptSoverloaded(const struct DhcpPacket *packet, int code, int maxLen, int *over, i… in CheckOptSoverloaded()
46 static int CheckOptionsData(const struct DhcpPacket *packet, int code, int index, int maxLen) in CheckOptionsData()
153 const uint8_t *GetDhcpOption(const struct DhcpPacket *packet, int code, size_t *length) in GetDhcpOption()
206 bool GetDhcpOptionUint8(const struct DhcpPacket *packet, int code, uint8_t *data) in GetDhcpOptionUint8()
226 bool GetDhcpOptionUint32(const struct DhcpPacket *packet, int code, uint32_t *data) in GetDhcpOptionUint32()
250 bool GetDhcpOptionUint32n(const struct DhcpPacket *packet, int code, uint32_t *data1, uint32_t *dat… in GetDhcpOptionUint32n()
284 char *GetDhcpOptionString(const struct DhcpPacket *packet, int code) in GetDhcpOptionString()
|
| D | dhcp_client_state_machine.cpp | 534 void DhcpClientStateMachine::AddParamaterRequestList(struct DhcpPacket *packet) in AddParamaterRequestList()
618 void DhcpClientStateMachine::AddParamaterRebootList(struct DhcpPacket *packet) in AddParamaterRebootList()
652 struct DhcpPacket packet; in DhcpReboot() local
854 void DhcpClientStateMachine::DhcpOfferPacketHandle(uint8_t type, const struct DhcpPacket *packet, t… in DhcpOfferPacketHandle()
901 void DhcpClientStateMachine::ParseNetworkServerIdInfo(const struct DhcpPacket *packet, struct DhcpI… in ParseNetworkServerIdInfo()
946 void DhcpClientStateMachine::ParseNetworkDnsInfo(const struct DhcpPacket *packet, struct DhcpIpResu… in ParseNetworkDnsInfo()
1054 void DhcpClientStateMachine::ParseNetworkInfo(const struct DhcpPacket *packet, struct DhcpIpResult … in ParseNetworkInfo()
1183 int DhcpClientStateMachine::GetDHCPServerHostName(const struct DhcpPacket *packet, struct DhcpIpRes… in GetDHCPServerHostName()
1219 int DhcpClientStateMachine::ParseNetworkVendorInfo(const struct DhcpPacket *packet, struct DhcpIpRe… in ParseNetworkVendorInfo()
1248 void DhcpClientStateMachine::DhcpAckOrNakPacketHandle(uint8_t type, struct DhcpPacket *packet, time… in DhcpAckOrNakPacketHandle()
[all …]
|
| /foundation/communication/dsoftbus/tests/core/discovery/ble/softbus_ble_mock/ |
| D | ble_mock.cpp | 84 int32_t UpdateBroadcasting(int32_t bcId, const BroadcastParam *param, const BroadcastPacket *packet) in UpdateBroadcasting()
94 int32_t SetBroadcastingData(int32_t bcId, const BroadcastPacket *packet) in SetBroadcastingData()
99 int32_t StartBroadcasting(int32_t bcId, const BroadcastParam *param, const BroadcastPacket *packet) in StartBroadcasting()
215 …ActionOfStartBroadcasting(int32_t bcId, const BroadcastParam *param, const BroadcastPacket *packet) in ActionOfStartBroadcasting()
259 void BleMock::ShowAdvData(int32_t bcId, const BroadcastPacket *packet) in ShowAdvData()
269 int32_t BleMock::ActionOfSetAdvDataForActiveDiscovery(int32_t bcId, const BroadcastPacket *packet) in ActionOfSetAdvDataForActiveDiscovery()
291 const BroadcastPacket *packet) in ActionOfUpdateAdvForActiveDiscovery()
312 int32_t BleMock::ActionOfSetAdvDataForActivePublish(int32_t bcId, const BroadcastPacket *packet) in ActionOfSetAdvDataForActivePublish()
334 const BroadcastPacket *packet) in ActionOfUpdateAdvForActivePublish()
355 int32_t BleMock::ActionOfSetAdvDataForPassivePublish(int32_t bcId, const BroadcastPacket *packet) in ActionOfSetAdvDataForPassivePublish()
[all …]
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/multiver/ |
| D | value_slice_sync.cpp | 237 const ValueSliceHashPacket *packet = message->GetObject<ValueSliceHashPacket>(); in RequestRecvCallback() local
273 const ValueSlicePacket *packet = message->GetObject<ValueSlicePacket>(); in AckRecvCallback() local
306 ValueSliceHashPacket *packet = new (std::nothrow) ValueSliceHashPacket(); in SendFinishedRequest() local
343 const ValueSliceHashPacket *packet = inMsg->GetObject<ValueSliceHashPacket>(); in RequestPacketCalculateLen() local
354 const ValueSliceHashPacket *packet = inMsg->GetObject<ValueSliceHashPacket>(); in RequestPacketSerialization() local
397 ValueSliceHashPacket *packet = new (std::nothrow) ValueSliceHashPacket(); in RequestPacketDeSerialization() local
414 const ValueSlicePacket *packet = inMsg->GetObject<ValueSlicePacket>(); in AckPacketCalculateLen() local
427 const ValueSlicePacket *packet = inMsg->GetObject<ValueSlicePacket>(); in AckPacketSerialization() local
474 ValueSlicePacket *packet = new (std::nothrow) ValueSlicePacket(); in AckPacketDeSerialization() local
540 ValueSliceHashPacket *packet = new (std::nothrow) ValueSliceHashPacket(); in SendRequestPacket() local
[all …]
|
| D | multi_ver_data_sync.cpp | 220 const MultiVerRequestPacket *packet = message->GetObject<MultiVerRequestPacket>(); in RequestRecvCallback() local
261 const MultiVerAckPacket *packet = message->GetObject<MultiVerAckPacket>(); in AckRecvCallback() local
323 MultiVerRequestPacket *packet = new (std::nothrow) MultiVerRequestPacket(); in SendFinishedRequest() local
364 const MultiVerRequestPacket *packet = inMsg->GetObject<MultiVerRequestPacket>(); in RequestPacketCalculateLen() local
378 const MultiVerRequestPacket *packet = inMsg->GetObject<MultiVerRequestPacket>(); in RequestPacketSerialization() local
423 MultiVerRequestPacket *packet = new (std::nothrow) MultiVerRequestPacket(); in RequestPacketDeSerialization() local
444 const MultiVerAckPacket *packet = inMsg->GetObject<MultiVerAckPacket>(); in AckPacketCalculateLen() local
457 const MultiVerAckPacket *packet = inMsg->GetObject<MultiVerAckPacket>(); in AckPacketSerialization() local
514 MultiVerAckPacket *packet = new (std::nothrow) MultiVerAckPacket(); in AckPacketDeSerialization() local
591 MultiVerRequestPacket *packet = new (std::nothrow) MultiVerRequestPacket(); in SendRequestPacket() local
[all …]
|
| /foundation/communication/bluetooth_service/services/bluetooth/stack/src/hci/acl/ |
| D | hci_acl.c | 144 static void FreeTxPacketsEntity(void *packet) in FreeTxPacketsEntity()
309 static uint16_t HciGetAclHandleFromPacket(const Packet *packet) in HciGetAclHandleFromPacket()
387 static int HciAclPushToTxQueue(Packet *packet) in HciAclPushToTxQueue()
401 static Packet **HciFargment(uint16_t handle, uint8_t flushable, Packet *packet, uint16_t frameLengt… in HciFargment()
444 static int HciSendSinglePacket(uint16_t connectionHandle, Packet *packet) in HciSendSinglePacket()
461 static int HciFargmentAndSendData(uint16_t handle, uint8_t flushable, Packet *packet) in HciFargmentAndSendData()
499 static int HciSendLeSinglePacket(uint16_t connectionHandle, Packet *packet) in HciSendLeSinglePacket()
516 static int HciFargmentAndSendLeData(uint16_t handle, uint8_t flushable, Packet *packet) in HciFargmentAndSendLeData()
554 int HCI_SendAclData(uint16_t handle, uint8_t flushable, Packet *packet) in HCI_SendAclData()
590 void HciOnAclData(Packet *packet) in HciOnAclData()
[all …]
|
| /foundation/communication/bluetooth_service/services/bluetooth/stack/src/att/ |
| D | att_send_request.c | 192 Packet *packet = NULL; in AttExchangeMTURequestAsync() local
281 Packet *packet = NULL; in AttFindInformationRequestAsync() local
371 Packet *packet = NULL; in AttFindByTypeValueRequestAsync() local
479 Packet *packet = NULL; in AttReadByTypeRequestAsync() local
599 Packet *packet = NULL; in AttReadRequestAsync() local
683 Packet *packet = NULL; in AttReadBlobRequestAsync() local
769 Packet *packet = NULL; in AttReadMultipleRequestAsync() local
901 Packet *packet = NULL; in AttReadByGroupTypeRequestAsync() local
1018 Packet *packet = NULL; in AttWriteRequestAsync() local
1118 Packet *packet = NULL; in AttWriteCommandAsync() local
[all …]
|
| D | att_send_response.c | 127 Packet *packet = NULL; in AttErrorResponseAsync() local
233 Packet *packet = NULL; in AttExchangeMTUResponseAsync() local
367 Packet *packet = NULL; in AttFindInformationResponseAsync() local
507 Packet *packet = PacketMalloc(0, 0, sizeof(uint8_t) + handlesInforLen); in AttFindByTypeValueResponseAsync() local
626 Packet *packet = PacketMalloc(0, 0, sizeof(uint8_t) + sizeof(len)); in AttReadByTypeResponseAsync() local
737 Packet *packet = NULL; in AttReadResponseAsync() local
839 Packet *packet = NULL; in AttReadBlobResponseAsync() local
936 Packet *packet = NULL; in AttReadMultipleResponseAsync() local
1075 Packet *packet = PacketMalloc(0, 0, sizeof(uint8_t) + sizeof(len)); in AttReadByGroupTypeResponseAsync() local
1183 Packet *packet = NULL; in AttWriteResponseAsync() local
[all …]
|
| /foundation/multimodalinput/input/intention/cooperate/plugin/src/input_event_transmission/ |
| D | input_event_builder.cpp | 102 bool InputEventBuilder::OnPacket(const std::string &networkId, Msdp::NetPacket &packet) in OnPacket()
126 void InputEventBuilder::OnPointerEvent(Msdp::NetPacket &packet) in OnPointerEvent()
146 void InputEventBuilder::OnKeyEvent(Msdp::NetPacket &packet) in OnKeyEvent()
|
| /foundation/communication/dsoftbus/tests/adapter/bluetooth/broadcast/ |
| D | softbus_broadcast_mgr_test.cpp | 78 static void BuildBroadcastPacketExceptPayload(BroadcastPacket *packet) in BuildBroadcastPacketExceptPayload()
279 BroadcastPacket packet = {}; variable
323 BroadcastPacket packet = {}; variable
465 BroadcastPacket packet = {}; variable
626 BroadcastPacket packet = {}; variable
666 BroadcastPacket packet = {}; variable
702 BroadcastPacket packet = {}; variable
736 BroadcastPacket packet = {}; variable
763 BroadcastPacket packet = {}; variable
795 BroadcastPacket packet = {}; variable
[all …]
|
| /foundation/multimodalinput/input/intention/adapters/dsoftbus_adapter/src/ |
| D | dsoftbus_adapter.cpp | 58 int32_t DSoftbusAdapter::SendPacket(const std::string &networkId, NetPacket &packet) in SendPacket()
68 int32_t DSoftbusAdapter::BroadcastPacket(NetPacket &packet) in BroadcastPacket()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/ |
| D | commit_history_sync.cpp | 256 …const CommitHistorySyncRequestPacket *packet = message->GetObject<CommitHistorySyncRequestPacket>(… in RequestRecvCallback() local
303 const CommitHistorySyncAckPacket *packet = message->GetObject<CommitHistorySyncAckPacket>(); in AckRecvCallback() local
327 … const CommitHistorySyncRequestPacket *packet = inMsg->GetObject<CommitHistorySyncRequestPacket>(); in RequestPacketCalculateLen() local
344 … const CommitHistorySyncRequestPacket *packet = inMsg->GetObject<CommitHistorySyncRequestPacket>(); in RequestPacketSerialization() local
420 CommitHistorySyncRequestPacket *packet = new (std::nothrow) CommitHistorySyncRequestPacket(); in RequestPacketDeSerialization() local
441 const CommitHistorySyncAckPacket *packet = inMsg->GetObject<CommitHistorySyncAckPacket>(); in AckPacketCalculateLen() local
458 const CommitHistorySyncAckPacket *packet = inMsg->GetObject<CommitHistorySyncAckPacket>(); in AckPacketSerialization() local
518 CommitHistorySyncAckPacket *packet = new (std::nothrow) CommitHistorySyncAckPacket(); in AckPacketDeSerialization() local
619 CommitHistorySyncRequestPacket *packet = new (std::nothrow) CommitHistorySyncRequestPacket(); in SendRequestPacket() local
667 CommitHistorySyncAckPacket *packet = new (std::nothrow) CommitHistorySyncAckPacket(); in SendAckPacket() local
|
| D | ability_sync.cpp | 383 AbilitySyncRequestPacket packet; in SyncStart() local
420 const AbilitySyncAckPacket *packet = message->GetObject<AbilitySyncAckPacket>(); in AckRecv() local
448 const AbilitySyncRequestPacket *packet = message->GetObject<AbilitySyncRequestPacket>(); in RequestRecv() local
480 const AbilitySyncAckPacket *packet = message->GetObject<AbilitySyncAckPacket>(); in AckNotifyRecv() local
563 void AbilitySync::HandleVersionV3RequestParam(const AbilitySyncRequestPacket *packet, ISyncTaskCont… in HandleVersionV3RequestParam()
575 void AbilitySync::HandleVersionV3AckSecOptionParam(const AbilitySyncAckPacket *packet, in HandleVersionV3AckSecOptionParam()
696 const AbilitySyncRequestPacket *packet = inMsg->GetObject<AbilitySyncRequestPacket>(); in RequestPacketCalculateLen() local
707 const AbilitySyncAckPacket *packet = inMsg->GetObject<AbilitySyncAckPacket>(); in AckPacketCalculateLen() local
718 const AbilitySyncRequestPacket *packet = inMsg->GetObject<AbilitySyncRequestPacket>(); in RequestPacketSerialization() local
742 const AbilitySyncAckPacket *packet = inMsg->GetObject<AbilitySyncAckPacket>(); in AckPacketSerialization() local
[all …]
|