| /foundation/multimodalinput/input/intention/cooperate/plugin/src/ |
| H A D | dsoftbus_handler.cpp | 40 [this] (const std::string &networkId, NetPacket &packet) { in DSoftbusHandler()
41 this->OnStartCooperate(networkId, packet);}}, in DSoftbusHandler()
43 [this] (const std::string &networkId, NetPacket &packet) { in DSoftbusHandler()
44 this->OnStopCooperate(networkId, packet);}}, in DSoftbusHandler()
46 [this] (const std::string &networkId, NetPacket &packet) { in DSoftbusHandler()
47 this->OnComeBack(networkId, packet);}}, in DSoftbusHandler()
49 [this] (const std::string &networkId, NetPacket &packet) { in DSoftbusHandler()
50 this->OnRelayCooperate(networkId, packet);}}, in DSoftbusHandler()
52 [this] (const std::string &networkId, NetPacket &packet) { in DSoftbusHandler()
53 this->OnRelayCooperateFinish(networkId, packet);}}, in DSoftbusHandler()
228 OnPacket(const std::string &networkId, NetPacket &packet) OnPacket() argument
262 OnStartCooperate(const std::string &networkId, NetPacket &packet) OnStartCooperate() argument
283 OnStopCooperate(const std::string &networkId, NetPacket &packet) OnStopCooperate() argument
295 OnComeBack(const std::string &networkId, NetPacket &packet) OnComeBack() argument
316 OnRelayCooperate(const std::string &networkId, NetPacket &packet) OnRelayCooperate() argument
333 OnRelayCooperateFinish(const std::string &networkId, NetPacket &packet) OnRelayCooperateFinish() argument
349 OnSubscribeMouseLocation(const std::string &networKId, NetPacket &packet) OnSubscribeMouseLocation() argument
363 OnUnSubscribeMouseLocation(const std::string& networKId, NetPacket &packet) OnUnSubscribeMouseLocation() argument
377 OnReplySubscribeLocation(const std::string& networKId, NetPacket &packet) OnReplySubscribeLocation() argument
391 OnReplyUnSubscribeLocation(const std::string& networKId, NetPacket &packet) OnReplyUnSubscribeLocation() argument
405 OnRemoteMouseLocation(const std::string& networKId, NetPacket &packet) OnRemoteMouseLocation() argument
420 OnRemoteInputDevice(const std::string& networkId, NetPacket &packet) OnRemoteInputDevice() argument
445 OnRemoteHotPlug(const std::string &networkId, NetPacket &packet) OnRemoteHotPlug() argument
462 DeserializeDevice(std::shared_ptr<IDevice> device, NetPacket &packet) DeserializeDevice() argument
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/ |
| H A D | single_ver_serialize_manager.cpp | 154 LOGE("[CalculateDataLen] calculate data request packet len failed, errCode=%d", errCode); in CalculateDataLen()
162 LOGE("[CalculateDataLen] calculate data notify packet len failed errCode=%d", errCode); in CalculateDataLen()
179 LOGE("[CalculateControlLen] calculate control request packet len failed, errCode=%d", errCode); in CalculateControlLen()
187 LOGE("[CalculateControlLen] calculate control request packet len failed, errCode=%d", errCode); in CalculateControlLen()
202 int SingleVerSerializeManager::DataPacketSyncerPartSerialization(Parcel &parcel, const DataRequestPacket *packet) in DataPacketSyncerPartSerialization() argument
204 parcel.WriteUInt64(packet->GetEndWaterMark()); in DataPacketSyncerPartSerialization()
205 parcel.WriteUInt64(packet->GetLocalWaterMark()); in DataPacketSyncerPartSerialization()
206 parcel.WriteUInt64(packet->GetPeerWaterMark()); in DataPacketSyncerPartSerialization()
207 parcel.WriteInt(packet->GetSendCode()); in DataPacketSyncerPartSerialization()
208 parcel.WriteInt(packet in DataPacketSyncerPartSerialization()
226 auto packet = inMsg->GetObject<DataRequestPacket>(); DataPacketSerialization() local
270 DataPacketQuerySyncSerialization(Parcel &parcel, const DataRequestPacket *packet) DataPacketQuerySyncSerialization() argument
295 const DataRequestPacket *packet = inMsg->GetObject<DataRequestPacket>(); DataPacketCalculateLen() local
306 const DataAckPacket *packet = inMsg->GetObject<DataAckPacket>(); AckPacketCalculateLen() local
331 const DataAckPacket *packet = inMsg->GetObject<DataAckPacket>(); AckPacketSerialization() local
345 AckPacketSyncerPartSerializationV1(Parcel &parcel, const DataAckPacket *packet) AckPacketSyncerPartSerializationV1() argument
376 auto packet = new (std::nothrow) DataRequestPacket(); DataPacketDeSerialization() local
408 DataPacketQuerySyncDeSerialization(Parcel &parcel, DataRequestPacket *packet) DataPacketQuerySyncDeSerialization() argument
437 DataPacketCompressDataDeSerialization(Parcel &parcel, DataRequestPacket *packet) DataPacketCompressDataDeSerialization() argument
449 DataPacketSyncerPartDeSerialization(Parcel &parcel, DataRequestPacket *packet, uint32_t packLen, uint32_t length, uint32_t version) DataPacketSyncerPartDeSerialization() argument
497 DataAckPacket packet; AckPacketDeSerialization() local
520 AckPacketSyncerPartDeSerializationV1(Parcel &parcel, DataAckPacket &packet) AckPacketSyncerPartDeSerializationV1() argument
541 auto packet = inMsg->GetObject<ControlRequestPacket>(); ControlPacketCalculateLen() local
554 auto packet = inMsg->GetObject<ControlRequestPacket>(); ControlPacketSerialization() local
568 ControlRequestPacket packet; ControlPacketDeSerialization() local
581 auto packet = inMsg->GetObject<ControlAckPacket>(); AckControlPacketCalculateLen() local
592 auto packet = inMsg->GetObject<ControlAckPacket>(); AckControlPacketSerialization() local
611 auto packet = new (std::nothrow) ControlAckPacket(); AckControlPacketDeSerialization() local
644 auto packet = inMsg->GetObject<ControlRequestPacket>(); ControlRequestSerialization() local
660 ControlRequestDeSerialization(Parcel &parcel, ControlRequestPacket &packet) ControlRequestDeSerialization() argument
683 auto packet = inMsg->GetObject<SubscribeRequest>(); SubscribeCalculateLen() local
693 auto packet = inMsg->GetObject<SubscribeRequest>(); SubscribeSerialization() local
715 auto packet = new (std::nothrow) SubscribeRequest(); SubscribeDeSerialization() local
784 const auto packet = inMsg->GetObject<ISyncPacket>(); ISyncPacketCalculateLen() local
799 auto packet = inMsg->GetObject<ISyncPacket>(); ISyncPacketSerialization() local
812 ISyncPacket *packet = nullptr; ISyncPacketDeSerialization() local
832 BuildISyncPacket(Message *inMsg, ISyncPacket *&packet) BuildISyncPacket() argument
855 DataPacketExtraConditionsSerialization(Parcel &parcel, const DataRequestPacket *packet) DataPacketExtraConditionsSerialization() argument
877 DataPacketExtraConditionsDeserialization(Parcel &parcel, DataRequestPacket *packet) DataPacketExtraConditionsDeserialization() argument
907 DataPacketInnerDeSerialization(DataRequestPacket *packet, Parcel &parcel) DataPacketInnerDeSerialization() argument
951 DataPacketInnerSerialization(const DataRequestPacket *packet, Parcel &parcel) DataPacketInnerSerialization() argument
[all...] |
| H A D | single_ver_data_sync_extend.cpp | 44 const ControlAckPacket *packet = message->GetObject<ControlAckPacket>(); in ControlCmdAckRecv() local
45 if (packet == nullptr) { in ControlCmdAckRecv()
48 int32_t recvCode = packet->GetRecvCode(); in ControlCmdAckRecv()
49 uint32_t cmdType = packet->GetcontrolCmdType(); in ControlCmdAckRecv()
93 int SingleVerDataSync::SendControlPacket(ControlRequestPacket *packet, SingleVerSyncTaskContext *context) in SendControlPacket() argument
98 delete packet; in SendControlPacket()
99 packet = nullptr; in SendControlPacket()
102 uint32_t packetLen = packet->CalculateLen(); in SendControlPacket()
103 int errCode = message->SetExternalObject(packet); in SendControlPacket()
105 delete packet; in SendControlPacket()
158 const ControlRequestPacket *packet = message->GetObject<ControlRequestPacket>(); ControlCmdRequestRecvPre() local
173 SubscribeRequestRecvPre(SingleVerSyncTaskContext *context, const SubscribeRequest *packet, const Message *message) SubscribeRequestRecvPre() argument
207 const SubscribeRequest *packet = message->GetObject<SubscribeRequest>(); SubscribeRequestRecv() local
254 const SubscribeRequest *packet = message->GetObject<SubscribeRequest>(); UnsubscribeRequestRecv() local
[all...] |
| H A D | single_ver_data_sync.cpp | 161 const DataAckPacket *packet = message->GetObject<DataAckPacket>(); in TryContinueSync() local
162 if (packet == nullptr) { in TryContinueSync()
165 uint64_t packetId = packet->GetPacketId(); // above 102 version data request reserve[0] store packetId value in TryContinueSync()
424 // query only support prefix key and don't have query in packet in 104 version in SaveData()
556 const DataRequestPacket *packet = message->GetObject<DataRequestPacket>(); in RemoveDeviceDataHandle() local
557 if (packet == nullptr) { in RemoveDeviceDataHandle()
558 LOGE("[RemoveDeviceDataHandle] get packet object failed"); in RemoveDeviceDataHandle()
561 SyncType curType = SyncOperation::GetSyncType(packet->GetMode()); in RemoveDeviceDataHandle()
562 WaterMark packetLocalMark = packet->GetLocalWaterMark(); in RemoveDeviceDataHandle()
661 void SingleVerDataSync::FillDataRequestPacket(DataRequestPacket *packet, SingleVerSyncTaskContex argument
734 DataRequestPacket *packet = new (std::nothrow) DataRequestPacket; RequestStart() local
798 DataRequestPacket *packet = new (std::nothrow) DataRequestPacket; PullRequestStart() local
947 auto *packet = message->GetObject<DataRequestPacket>(); DataRequestRecvPre() local
994 const DataRequestPacket *packet = message->GetObject<DataRequestPacket>(); DataRequestRecv() local
1043 SendDataPacket(SyncType syncType, DataRequestPacket *packet, SingleVerSyncTaskContext *context) SendDataPacket() argument
1084 DataRequestPacket *packet = new (std::nothrow) DataRequestPacket; SendPullResponseDataPkt() local
1135 const DataRequestPacket *packet = message->GetObject<DataRequestPacket>(); SendDataAck() local
1173 const DataAckPacket *packet = message->GetObject<DataAckPacket>(); AckPacketIdCheck() local
1197 const DataAckPacket *packet = message->GetObject<DataAckPacket>(); AckRecv() local
1280 GetPullEndWatermark(const SingleVerSyncTaskContext *context, const DataRequestPacket *packet, WaterMark &pullEndWatermark) const GetPullEndWatermark() argument
1329 RunPermissionCheck(SingleVerSyncTaskContext *context, const Message *message, const DataRequestPacket *packet) RunPermissionCheck() argument
1419 DataRequestPacket *packet = new (std::nothrow) DataRequestPacket; ReSend() local
1447 SendReSendPacket(DataRequestPacket *packet, SingleVerSyncTaskContext *context, uint32_t sessionId, uint32_t sequenceId) SendReSendPacket() argument
1530 const DataRequestPacket *packet = message->GetObject<DataRequestPacket>(); WaterMarkErrHandle() local
1562 auto *packet = message->GetObject<DataRequestPacket>(); CheckSchemaStrategy() local
1597 SetAckPacket(DataAckPacket &ackPacket, SingleVerSyncTaskContext *context, const DataRequestPacket *packet, int32_t recvCode, WaterMark maxSendDataTime) SetAckPacket() argument
1720 FillRequestReSendPacket(SingleVerSyncTaskContext *context, DataRequestPacket *packet, DataSyncReSendInfo reSendInfo, SyncEntry &syncData, int sendCode) FillRequestReSendPacket() argument
1770 FillRequestReSendPacketV2(const SingleVerSyncTaskContext *context, DataRequestPacket *packet) FillRequestReSendPacketV2() argument
1816 ControlRequestPacket* packet = new (std::nothrow) SubscribeRequest(); ControlCmdStart() local
1840 const ControlRequestPacket *packet = message->GetObject<ControlRequestPacket>(); ControlCmdRequestRecv() local
[all...] |
| H A D | single_ver_serialize_manager.h | 54 static int DataPacketSyncerPartSerialization(Parcel &parcel, const DataRequestPacket *packet);
55 static int DataPacketQuerySyncSerialization(Parcel &parcel, const DataRequestPacket *packet);
56 static int DataPacketExtraConditionsSerialization(Parcel &parcel, const DataRequestPacket *packet);
58 static int DataPacketInnerSerialization(const DataRequestPacket *packet, Parcel &parcel);
60 static int DataPacketQuerySyncDeSerialization(Parcel &parcel, DataRequestPacket *packet);
61 static int DataPacketCompressDataDeSerialization(Parcel &parcel, DataRequestPacket *packet);
63 static int DataPacketSyncerPartDeSerialization(Parcel &parcel, DataRequestPacket *packet, uint32_t packLen,
65 static int DataPacketExtraConditionsDeserialization(Parcel &parcel, DataRequestPacket *packet);
66 static int DataPacketInnerDeSerialization(DataRequestPacket *packet, Parcel &parcel);
70 static int AckPacketSyncerPartSerializationV1(Parcel &parcel, const DataAckPacket *packet);
[all...] |
| /foundation/communication/dsoftbus/tests/core/discovery/ble/softbus_ble_mock/ |
| H A D | ble_mock.cpp | 85 int32_t UpdateBroadcasting(int32_t bcId, const BroadcastParam *param, const BroadcastPacket *packet) in UpdateBroadcasting() argument
87 return BleMock::GetMock()->UpdateBroadcasting(bcId, param, packet); in UpdateBroadcasting()
95 int32_t SetBroadcastingData(int32_t bcId, const BroadcastPacket *packet) in SetBroadcastingData() argument
97 return BleMock::GetMock()->SetBroadcastingData(bcId, packet); in SetBroadcastingData()
100 int32_t StartBroadcasting(int32_t bcId, const BroadcastParam *param, const BroadcastPacket *packet) in StartBroadcasting() argument
102 return BleMock::GetMock()->StartBroadcasting(bcId, param, packet); in StartBroadcasting()
216 int32_t BleMock::ActionOfStartBroadcasting(int32_t bcId, const BroadcastParam *param, const BroadcastPacket *packet) in ActionOfStartBroadcasting() argument
218 ShowAdvData(bcId, packet); in ActionOfStartBroadcasting()
260 void BleMock::ShowAdvData(int32_t bcId, const BroadcastPacket *packet) in ShowAdvData() argument
262 DISC_LOGI(DISC_TEST, "bcId=%{public}d, advLen=%{public}d, rspLen=%{public}d", bcId, packet in ShowAdvData()
270 ActionOfSetAdvDataForActiveDiscovery(int32_t bcId, const BroadcastPacket *packet) ActionOfSetAdvDataForActiveDiscovery() argument
291 ActionOfUpdateAdvForActiveDiscovery(int32_t bcId, const BroadcastParam *param, const BroadcastPacket *packet) ActionOfUpdateAdvForActiveDiscovery() argument
313 ActionOfSetAdvDataForActivePublish(int32_t bcId, const BroadcastPacket *packet) ActionOfSetAdvDataForActivePublish() argument
334 ActionOfUpdateAdvForActivePublish(int32_t bcId, const BroadcastParam *param, const BroadcastPacket *packet) ActionOfUpdateAdvForActivePublish() argument
356 ActionOfSetAdvDataForPassivePublish(int32_t bcId, const BroadcastPacket *packet) ActionOfSetAdvDataForPassivePublish() argument
378 ActionOfUpdateAdvForPassivePublish( int32_t bcId, const BroadcastParam *param, const BroadcastPacket *packet) ActionOfUpdateAdvForPassivePublish() argument
[all...] |
| /foundation/communication/dhcp/test/unittest/services/dhcp_client/ |
| H A D | dhcp_socket_test.cpp | 117 struct DhcpPacket packet; in HWTEST_F() local
118 ASSERT_TRUE(memset_s(&packet, sizeof(struct DhcpPacket), 0, sizeof(struct DhcpPacket)) == EOK); in HWTEST_F()
121 uint8_t *pOption = packet.options; in HWTEST_F()
134 int result = SendToDhcpPacket(&packet, srcIp, destIp, destIndex, destHwaddr); in HWTEST_F()
151 struct DhcpPacket packet; in HWTEST_F() local
152 packet.xid = 123456; in HWTEST_F()
153 EXPECT_EQ(SendDhcpPacket(&packet, INADDR_ANY, INADDR_BROADCAST), SOCKET_OPT_SUCCESS); in HWTEST_F()
178 struct UdpDhcpPacket packet; in HWTEST_F() local
180 EXPECT_EQ(CheckUdpPacket(&packet, total), SOCKET_OPT_FAILED); in HWTEST_F()
183 packet in HWTEST_F()
209 struct UdpDhcpPacket packet; HWTEST_F() local
228 struct UdpDhcpPacket packet; HWTEST_F() local
243 struct DhcpPacket packet; HWTEST_F() local
256 struct DhcpPacket packet; HWTEST_F() local
[all...] |
| H A D | dhcp_options_test.cpp | 60 struct DhcpPacket packet; in HWTEST_F() local
61 ASSERT_TRUE(memset_s(&packet, sizeof(struct DhcpPacket), 0, sizeof(struct DhcpPacket)) == EOK); in HWTEST_F()
64 uint8_t *pOption = packet.options; in HWTEST_F()
84 EXPECT_NE(GetDhcpOption(&packet, DHCP_MESSAGE_TYPE_OPTION, &len), nullptr); in HWTEST_F()
92 struct DhcpPacket packet; in HWTEST_F() local
93 ASSERT_TRUE(memset_s(&packet, sizeof(struct DhcpPacket), 0, sizeof(struct DhcpPacket)) == EOK); in HWTEST_F()
96 uint8_t *pOption = packet.options; in HWTEST_F()
116 EXPECT_EQ(GetDhcpOption(&packet, DHCP_MESSAGE_TYPE_OPTION, &len), nullptr); in HWTEST_F()
121 struct DhcpPacket packet; in HWTEST_F() local
122 ASSERT_TRUE(memset_s(&packet, sizeo in HWTEST_F()
145 struct DhcpPacket packet; HWTEST_F() local
177 struct DhcpPacket packet; HWTEST_F() local
217 struct DhcpPacket packet; HWTEST_F() local
250 struct DhcpPacket packet; HWTEST_F() local
279 struct DhcpPacket packet; HWTEST_F() local
305 struct DhcpPacket packet; HWTEST_F() local
327 struct DhcpPacket packet; HWTEST_F() local
343 struct DhcpPacket packet; HWTEST_F() local
363 struct DhcpPacket packet; HWTEST_F() local
377 struct DhcpPacket packet; HWTEST_F() local
[all...] |
| H A D | dhcp_client_state_machine_test.cpp | 164 struct DhcpPacket *packet = nullptr; in HWTEST_F() local
166 EXPECT_EQ(DHCP_OPT_FAILED, dhcpClient->ParseNetworkVendorInfo(packet, &result)); in HWTEST_F()
176 struct DhcpPacket packet; in HWTEST_F() local
178 EXPECT_EQ(DHCP_OPT_FAILED, dhcpClient->ParseNetworkVendorInfo(&packet, result)); in HWTEST_F()
188 struct DhcpPacket *packet = nullptr; in HWTEST_F() local
190 EXPECT_EQ(DHCP_OPT_FAILED, dhcpClient->ParseNetworkVendorInfo(packet, result)); in HWTEST_F()
201 struct DhcpPacket packet; in HWTEST_F() local
203 strcpy_s((char*)packet.sname, sizeof(packet.sname), "testcode"); in HWTEST_F()
204 EXPECT_EQ(DHCP_OPT_SUCCESS, dhcpClient->ParseNetworkVendorInfo(&packet, in HWTEST_F()
223 struct DhcpPacket packet; HWTEST_F() local
249 struct DhcpPacket *packet = nullptr; HWTEST_F() local
262 struct DhcpPacket packet; HWTEST_F() local
275 struct DhcpPacket *packet = nullptr; HWTEST_F() local
288 struct DhcpPacket packet; HWTEST_F() local
329 struct DhcpPacket packet; HWTEST_F() local
426 struct DhcpPacket *packet = nullptr; HWTEST_F() local
449 struct DhcpPacket *packet = nullptr; HWTEST_F() local
460 struct DhcpPacket *packet = nullptr; HWTEST_F() local
480 struct DhcpPacket *packet = nullptr; HWTEST_F() local
500 struct DhcpPacket *packet = nullptr; HWTEST_F() local
634 struct DhcpPacket packet; HWTEST_F() local
646 struct DhcpPacket packet; HWTEST_F() local
668 struct DhcpPacket packet; HWTEST_F() local
678 struct DhcpPacket *packet = nullptr; HWTEST_F() local
691 struct DhcpPacket *packet = nullptr; HWTEST_F() local
1004 DhcpPacket packet; HWTEST_F() local
1014 DhcpPacket packet; HWTEST_F() local
[all...] |
| /foundation/communication/dsoftbus/tests/adapter/fuzztest/softbusbroadcast_fuzzer/ |
| H A D | softbusbroadcast_fuzzer.cpp | 80 static void DestroyBleConfigAdvData(BroadcastPacket *packet) in DestroyBleConfigAdvData() argument
82 SoftBusFree(packet->bcData.payload); in DestroyBleConfigAdvData()
83 SoftBusFree(packet->rspData.payload); in DestroyBleConfigAdvData()
84 packet->bcData.payload = nullptr; in DestroyBleConfigAdvData()
85 packet->rspData.payload = nullptr; in DestroyBleConfigAdvData()
88 static int32_t BuildBroadcastPacket(const uint8_t* data, size_t size, BroadcastPacket *packet) in BuildBroadcastPacket() argument
90 packet->isSupportFlag = true; in BuildBroadcastPacket()
91 packet->flag = BC_ADV_FLAG; in BuildBroadcastPacket()
92 packet->bcData.type = BC_DATA_TYPE_SERVICE; in BuildBroadcastPacket()
93 packet in BuildBroadcastPacket()
222 BroadcastPacket packet; StartBroadcastingFuzzTest() local
233 BroadcastPacket packet; UpdateBroadcastingFuzzTest() local
242 BroadcastPacket packet; SetBroadcastingDataFuzzTest() local
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/ |
| H A D | ability_sync.cpp | 383 AbilitySyncRequestPacket packet; in SyncStart() local
384 int errCode = SetAbilityRequestBodyInfo(remoteCommunicatorVersion, context, packet); in SyncStart()
393 errCode = message->SetCopiedObject<>(packet); in SyncStart()
420 const AbilitySyncAckPacket *packet = message->GetObject<AbilitySyncAckPacket>(); in AckRecv() local
421 if (packet == nullptr) { in AckRecv()
424 uint32_t remoteSoftwareVersion = packet->GetSoftwareVersion(); in AckRecv()
427 errCode = AckRecvWithHighVersion(message, context, packet); in AckRecv()
429 std::string schema = packet->GetSchema(); in AckRecv()
430 uint8_t schemaType = packet->GetSchemaType(); in AckRecv()
448 const AbilitySyncRequestPacket *packet in RequestRecv() local
480 const AbilitySyncAckPacket *packet = message->GetObject<AbilitySyncAckPacket>(); AckNotifyRecv() local
563 HandleVersionV3RequestParam(const AbilitySyncRequestPacket *packet, ISyncTaskContext *context) HandleVersionV3RequestParam() argument
575 HandleVersionV3AckSecOptionParam(const AbilitySyncAckPacket *packet, ISyncTaskContext *context) HandleVersionV3AckSecOptionParam() argument
696 const AbilitySyncRequestPacket *packet = inMsg->GetObject<AbilitySyncRequestPacket>(); RequestPacketCalculateLen() local
707 const AbilitySyncAckPacket *packet = inMsg->GetObject<AbilitySyncAckPacket>(); AckPacketCalculateLen() local
718 const AbilitySyncRequestPacket *packet = inMsg->GetObject<AbilitySyncRequestPacket>(); RequestPacketSerialization() local
742 const AbilitySyncAckPacket *packet = inMsg->GetObject<AbilitySyncAckPacket>(); AckPacketSerialization() local
776 auto *packet = new (std::nothrow) AbilitySyncRequestPacket(); RequestPacketDeSerialization() local
822 RequestPacketDeSerializationTailPart(Parcel &parcel, AbilitySyncRequestPacket *packet, uint32_t version) RequestPacketDeSerializationTailPart() argument
860 AckPacketDeSerializationTailPart(Parcel &parcel, AbilitySyncAckPacket *packet, uint32_t version) AckPacketDeSerializationTailPart() argument
912 auto *packet = new (std::nothrow) AbilitySyncAckPacket(); AckPacketDeSerialization() local
1090 const AbilitySyncAckPacket *packet = message->GetObject<AbilitySyncAckPacket>(); AckMsgCheck() local
1118 const AbilitySyncRequestPacket *packet = message->GetObject<AbilitySyncRequestPacket>(); HandleRequestRecv() local
1212 MakeKvSyncOpinion(const AbilitySyncRequestPacket *packet, const std::string &remoteSchema, ISyncTaskContext *context) MakeKvSyncOpinion() argument
1229 MakeRelationSyncOpinion(const AbilitySyncRequestPacket *packet, const std::string &remoteSchema) const MakeRelationSyncOpinion() argument
1306 AckRecvWithHighVersion(const Message *message, ISyncTaskContext *context, const AbilitySyncAckPacket *packet) AckRecvWithHighVersion() argument
[all...] |
| H A D | commit_history_sync.cpp | 256 const CommitHistorySyncRequestPacket *packet = message->GetObject<CommitHistorySyncRequestPacket>(); in RequestRecvCallback() local
257 if (packet == nullptr) { in RequestRecvCallback()
268 packet->GetCommitMap(commitMap); in RequestRecvCallback()
269 uint32_t ver = packet->GetVersion(); in RequestRecvCallback()
303 const CommitHistorySyncAckPacket *packet = message->GetObject<CommitHistorySyncAckPacket>(); in AckRecvCallback() local
304 if (packet == nullptr) { in AckRecvCallback()
307 packet->GetErrorCode(errCode); in AckRecvCallback()
312 packet->GetData(commits); in AckRecvCallback()
313 uint32_t ver = packet->GetVersion(); in AckRecvCallback()
327 const CommitHistorySyncRequestPacket *packet in RequestPacketCalculateLen() local
344 const CommitHistorySyncRequestPacket *packet = inMsg->GetObject<CommitHistorySyncRequestPacket>(); RequestPacketSerialization() local
420 CommitHistorySyncRequestPacket *packet = new (std::nothrow) CommitHistorySyncRequestPacket(); RequestPacketDeSerialization() local
441 const CommitHistorySyncAckPacket *packet = inMsg->GetObject<CommitHistorySyncAckPacket>(); AckPacketCalculateLen() local
458 const CommitHistorySyncAckPacket *packet = inMsg->GetObject<CommitHistorySyncAckPacket>(); AckPacketSerialization() local
518 CommitHistorySyncAckPacket *packet = new (std::nothrow) CommitHistorySyncAckPacket(); AckPacketDeSerialization() local
619 CommitHistorySyncRequestPacket *packet = new (std::nothrow) CommitHistorySyncRequestPacket(); SendRequestPacket() local
667 CommitHistorySyncAckPacket *packet = new (std::nothrow) CommitHistorySyncAckPacket(); SendAckPacket() local
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/multiver/ |
| H A D | value_slice_sync.cpp | 203 LOGD("ValueSliceSync::SyncStart send request packet dst=%s{private}, errCode = %d", in SyncStart()
237 const ValueSliceHashPacket *packet = message->GetObject<ValueSliceHashPacket>(); in RequestRecvCallback() local
238 if (packet == nullptr) { in RequestRecvCallback()
242 packet->GetValueSliceHash(valueSliceHashNode); in RequestRecvCallback()
243 if ((packet->GetErrCode() == -E_LAST_SYNC_FRAME) && valueSliceHashNode.empty()) { in RequestRecvCallback()
261 if (packet->GetErrCode() == -E_LAST_SYNC_FRAME) { in RequestRecvCallback()
273 const ValueSlicePacket *packet = message->GetObject<ValueSlicePacket>(); in AckRecvCallback() local
274 if (packet == nullptr) { in AckRecvCallback()
278 packet->GetErrorCode(errCode); in AckRecvCallback()
280 packet in AckRecvCallback()
306 ValueSliceHashPacket *packet = new (std::nothrow) ValueSliceHashPacket(); SendFinishedRequest() local
343 const ValueSliceHashPacket *packet = inMsg->GetObject<ValueSliceHashPacket>(); RequestPacketCalculateLen() local
354 const ValueSliceHashPacket *packet = inMsg->GetObject<ValueSliceHashPacket>(); RequestPacketSerialization() local
397 ValueSliceHashPacket *packet = new (std::nothrow) ValueSliceHashPacket(); RequestPacketDeSerialization() local
414 const ValueSlicePacket *packet = inMsg->GetObject<ValueSlicePacket>(); AckPacketCalculateLen() local
427 const ValueSlicePacket *packet = inMsg->GetObject<ValueSlicePacket>(); AckPacketSerialization() local
474 ValueSlicePacket *packet = new (std::nothrow) ValueSlicePacket(); AckPacketDeSerialization() local
540 ValueSliceHashPacket *packet = new (std::nothrow) ValueSliceHashPacket(); SendRequestPacket() local
583 ValueSlicePacket *packet = new (std::nothrow) ValueSlicePacket(); SendAckPacket() local
[all...] |
| H A D | multi_ver_data_sync.cpp | 220 const MultiVerRequestPacket *packet = message->GetObject<MultiVerRequestPacket>(); in RequestRecvCallback() local
221 if (packet == nullptr) { in RequestRecvCallback()
224 if (packet->GetErrCode() == -E_LAST_SYNC_FRAME) { in RequestRecvCallback()
228 packet->GetCommit(commit); in RequestRecvCallback()
261 const MultiVerAckPacket *packet = message->GetObject<MultiVerAckPacket>(); in AckRecvCallback() local
262 if (packet == nullptr) { in AckRecvCallback()
266 packet->GetErrorCode(errCode); in AckRecvCallback()
275 packet->GetData(dataEntries); in AckRecvCallback()
323 MultiVerRequestPacket *packet = new (std::nothrow) MultiVerRequestPacket(); in SendFinishedRequest() local
324 if (packet in SendFinishedRequest()
364 const MultiVerRequestPacket *packet = inMsg->GetObject<MultiVerRequestPacket>(); RequestPacketCalculateLen() local
378 const MultiVerRequestPacket *packet = inMsg->GetObject<MultiVerRequestPacket>(); RequestPacketSerialization() local
423 MultiVerRequestPacket *packet = new (std::nothrow) MultiVerRequestPacket(); RequestPacketDeSerialization() local
444 const MultiVerAckPacket *packet = inMsg->GetObject<MultiVerAckPacket>(); AckPacketCalculateLen() local
457 const MultiVerAckPacket *packet = inMsg->GetObject<MultiVerAckPacket>(); AckPacketSerialization() local
514 MultiVerAckPacket *packet = new (std::nothrow) MultiVerAckPacket(); AckPacketDeSerialization() local
591 MultiVerRequestPacket *packet = new (std::nothrow) MultiVerRequestPacket(); SendRequestPacket() local
639 MultiVerAckPacket *packet = new (std::nothrow) MultiVerAckPacket(); SendAckPacket() local
[all...] |
| /foundation/communication/bluetooth_service/services/bluetooth/stack/src/hci/ |
| H A D | hci.c | 21 #include "packet.h"
71 static void HciFreePacket(void *packet) in HciFreePacket() argument
73 HciPacket *hciPacket = packet; in HciFreePacket()
75 PacketFree(hciPacket->packet); in HciFreePacket()
77 MEM_MALLOC.free(packet); in HciFreePacket()
226 HciPacket *packet = QueueTryDequeue(g_hciTxQueue); in CleanTxPacket() local
227 while (packet != NULL) { in CleanTxPacket()
228 HciFreePacket(packet); in CleanTxPacket()
229 packet = QueueTryDequeue(g_hciTxQueue); in CleanTxPacket()
237 HciPacket *packet in CleanRxPacket() local
364 HciPacket *packet = QueueTryDequeue(g_hciTxQueue); HciSendPacketCallback() local
409 HciPacket *packet = QueueTryDequeue(g_hciRxQueue); HciRecvPacketCallback() local
428 HciPushToTxQueue(HciPacket *packet) HciPushToTxQueue() argument
[all...] |
| /foundation/communication/dsoftbus/tests/core/discovery/ble/softbus_ble/ |
| H A D | disc_ble_utils_test.cpp | 364 reportInfo.packet.bcData.id = SERVICE_UUID; in HWTEST_F()
365 reportInfo.packet.bcData.type = BC_DATA_TYPE_SERVICE; in HWTEST_F()
366 reportInfo.packet.rspData.id = MANU_COMPANY_ID; in HWTEST_F()
367 reportInfo.packet.rspData.type = BC_DATA_TYPE_MANUFACTURER; in HWTEST_F()
368 reportInfo.packet.bcData.payload = &g_invalidAdvData[0]; in HWTEST_F()
369 reportInfo.packet.bcData.payloadLen = ADV_DATA_MAX_LEN + 1; // bcLen > ADV_DATA_MAX_LEN in HWTEST_F()
370 reportInfo.packet.rspData.payload = &g_invalidRspData[0]; in HWTEST_F()
371 reportInfo.packet.rspData.payloadLen = REAL_RESP_DATA_MAX_LEN; in HWTEST_F()
393 reportInfo.packet.bcData.id = SERVICE_UUID; in HWTEST_F()
394 reportInfo.packet in HWTEST_F()
[all...] |
| /foundation/communication/bluetooth_service/services/bluetooth/stack/src/hci/acl/ |
| H A D | hci_acl.c | 144 static void FreeTxPacketsEntity(void *packet) in FreeTxPacketsEntity() argument
146 MEM_CALLOC.free(packet); in FreeTxPacketsEntity()
309 static uint16_t HciGetAclHandleFromPacket(const Packet *packet) in HciGetAclHandleFromPacket() argument
312 Buffer *headerBuffer = PacketHead(packet); in HciGetAclHandleFromPacket()
387 static int HciAclPushToTxQueue(Packet *packet) in HciAclPushToTxQueue() argument
393 hciPacket->packet = packet; in HciAclPushToTxQueue()
401 static Packet **HciFargment(uint16_t handle, uint8_t flushable, Packet *packet, uint16_t frameLength, int *frameCount) in HciFargment() argument
407 size_t totalLength = PacketSize(packet); in HciFargment()
420 PacketFragment(packet, fargmente in HciFargment()
444 HciSendSinglePacket(uint16_t connectionHandle, Packet *packet) HciSendSinglePacket() argument
461 HciFargmentAndSendData(uint16_t handle, uint8_t flushable, Packet *packet) HciFargmentAndSendData() argument
499 HciSendLeSinglePacket(uint16_t connectionHandle, Packet *packet) HciSendLeSinglePacket() argument
516 HciFargmentAndSendLeData(uint16_t handle, uint8_t flushable, Packet *packet) HciFargmentAndSendLeData() argument
554 HCI_SendAclData(uint16_t handle, uint8_t flushable, Packet *packet) HCI_SendAclData() argument
590 HciOnAclData(Packet *packet) HciOnAclData() argument
614 Packet *packet = NULL; HciSendCachedAclPackets() local
655 Packet *packet = NULL; HciSendCachedLePackets() local
727 Packet *packet = NULL; HciCleanupCacheByAclHandle() local
753 Packet *packet = NULL; HciCleanupLeCacheByAclHandle() local
[all...] |
| /foundation/communication/bluetooth_service/services/bluetooth/service/src/avrcp_ct/ |
| H A D | avrcp_ct_profile.cpp | 330 std::shared_ptr<AvrcCtPassPacket> packet = std::make_shared<AvrcCtPassPacket>(button, AVRC_KEY_STATE_PRESS); in SendPressButtonCmd() local
332 SendPassCmd(rawAddr, packet); in SendPressButtonCmd()
340 std::shared_ptr<AvrcCtPassPacket> packet = std::make_shared<AvrcCtPassPacket>(button, AVRC_KEY_STATE_RELEASE); in SendReleaseButtonCmd() local
342 SendPassCmd(rawAddr, packet); in SendReleaseButtonCmd()
394 std::shared_ptr<AvrcCtPassPacket> packet = cnManager->PopPassQueue(rawAddr); in SendNextPassCmd() local
395 SendPassCmd(rawAddr, packet); in SendNextPassCmd()
405 AvrcCtPassPacket packet(pkt); in ReceivePassRsp()
407 packet.GetKeyOperation(), packet.GetKeyState()); in ReceivePassRsp()
410 rawAddr, packet in ReceivePassRsp()
542 std::shared_ptr<AvrcCtUnitPacket> packet = cnManager->PopUnitQueue(rawAddr); SendNextUnitCmd() local
588 std::shared_ptr<AvrcCtUnitPacket> packet = AvrcCtConnectManager::GetInstance()->GetUnitPacket(rawAddr); ProcessUnitTimeout() local
666 std::shared_ptr<AvrcCtVendorPacket> packet = cnManager->PopVendorQueue(rawAddr); SendNextVendorCmd() local
681 std::shared_ptr<AvrcCtVendorPacket> packet = std::make_shared<AvrcCtRcrPacket>(pduId); SendVendorContinueCmd() local
700 std::shared_ptr<AvrcCtVendorPacket> packet = std::make_shared<AvrcCtAcrPacket>(pduId); SendVendorAbortCmd() local
719 std::shared_ptr<AvrcCtVendorPacket> packet = std::make_shared<AvrcCtGcPacket>(capabilityId); SendGetCapabilitiesCmd() local
743 std::shared_ptr<AvrcCtVendorPacket> packet = std::make_shared<AvrcCtLpasaPacket>(); SendListPlayerApplicationSettingAttributesCmd() local
764 std::shared_ptr<AvrcCtVendorPacket> packet = std::make_shared<AvrcCtLpasvPacket>(attribute); SendListPlayerApplicationSettingValuesCmd() local
776 std::shared_ptr<AvrcCtVendorPacket> packet = cnManager->GetVendorContinuePacket(rawAddr); ReceiveListPlayerApplicationSettingValuesRsp() local
827 std::shared_ptr<AvrcCtVendorPacket> packet = std::make_shared<AvrcCtGcpasvPacket>(attributes); SendGetCurrentPlayerApplicationSettingValueCmd() local
839 std::shared_ptr<AvrcCtVendorPacket> packet = cnManager->GetVendorContinuePacket(rawAddr); ReceiveGetCurrentPlayerApplicationSettingValueRsp() local
895 std::shared_ptr<AvrcCtVendorPacket> packet = std::make_shared<AvrcCtSpasvPacket>(attributes, values); SendSetPlayerApplicationSettingValueCmd() local
916 std::shared_ptr<AvrcCtVendorPacket> packet = std::make_shared<AvrcCtGpasatPacket>(attributes); SendGetPlayerApplicationSettingAttributeTextCmd() local
928 std::shared_ptr<AvrcCtVendorPacket> packet = cnManager->GetVendorContinuePacket(rawAddr); ReceiveGetPlayerApplicationSettingAttributeTextRsp() local
984 std::shared_ptr<AvrcCtVendorPacket> packet = std::make_shared<AvrcCtGpasvtPacket>(attributeId, values); SendGetPlayerApplicationSettingValueTextCmd() local
996 std::shared_ptr<AvrcCtVendorPacket> packet = cnManager->GetVendorContinuePacket(rawAddr); ReceiveGetPlayerApplicationSettingValueTextRsp() local
1051 std::shared_ptr<AvrcCtVendorPacket> packet = std::make_shared<AvrcCtGeaPacket>(identifier, attributes); SendGetElementAttributesCmd() local
1063 std::shared_ptr<AvrcCtVendorPacket> packet = cnManager->GetVendorContinuePacket(rawAddr); ReceiveGetElementAttributesRsp() local
1112 std::shared_ptr<AvrcCtVendorPacket> packet = std::make_shared<AvrcCtGpsPacket>(); SendGetPlayStatusCmd() local
1136 std::shared_ptr<AvrcCtVendorPacket> packet = std::make_shared<AvrcCtRcrPacket>(pduId); SendRequestContinuingResponseCmd() local
1146 std::shared_ptr<AvrcCtVendorPacket> packet = std::make_shared<AvrcCtAcrPacket>(pduId); SendAbortContinuingResponseCmd() local
1158 std::shared_ptr<AvrcCtVendorPacket> packet = AvrcCtConnectManager::GetInstance()->GetVendorContinuePacket(rawAddr); ReceiveAbortContinuingResponseRsp() local
1175 std::shared_ptr<AvrcCtVendorPacket> packet = std::make_shared<AvrcCtSapPacket>(playerId); SendSetAddressedPlayerCmd() local
1202 std::shared_ptr<AvrcCtVendorPacket> packet = std::make_shared<AvrcCtPiPacket>(scope, uid, uidCounter); SendPlayItemCmd() local
1229 std::shared_ptr<AvrcCtVendorPacket> packet = std::make_shared<AvrcCtAtnpPacket>(scope, uid, uidCounter); SendAddToNowPlayingCmd() local
1255 std::shared_ptr<AvrcCtVendorPacket> packet = std::make_shared<AvrcCtSavPacket>(volume); SendSetAbsoluteVolumeCmd() local
1279 std::shared_ptr<AvrcCtVendorPacket> packet = std::make_shared<AvrcCtNotifyPacket>(event); EnableNotification() local
1324 std::shared_ptr<AvrcCtVendorPacket> packet = std::make_shared<AvrcCtNotifyPacket>(notifyPkt->GetEventId()); ReceiveRegisterNotificationRsp() local
1388 std::shared_ptr<AvrcCtVendorPacket> packet = cnManager->GetVendorContinuePacket(rawAddr); InformPlayerApplicationSettingChanged() local
1509 std::shared_ptr<AvrcCtVendorPacket> packet = std::make_shared<AvrcCtNotifyPacket>(event); ProcessVendorNotificationTimeout() local
1514 ProcessVendorAvcControlTimeout(RawAddress rawAddr, const std::shared_ptr<AvrcCtVendorPacket> &packet) ProcessVendorAvcControlTimeout() argument
1553 ProcessVendorAvcStatus1Timeout(RawAddress rawAddr, const std::shared_ptr<AvrcCtVendorPacket> &packet) ProcessVendorAvcStatus1Timeout() argument
1584 ProcessVendorAvcStatus2Timeout(RawAddress rawAddr, const std::shared_ptr<AvrcCtVendorPacket> &packet) ProcessVendorAvcStatus2Timeout() argument
1622 std::shared_ptr<AvrcCtVendorPacket> packet = cnManager->GetVendorPacket(rawAddr); ProcessVendorTimeout() local
1715 std::shared_ptr<AvrcCtBrowsePacket> packet = cnManager->PopBrowseQueue(rawAddr); SendNextBrowseCmd() local
1750 std::shared_ptr<AvrcCtBrowsePacket> packet = std::make_shared<AvrcCtSbpPacket>(playerId); SendSetBrowsedPlayerCmd() local
1780 std::shared_ptr<AvrcCtBrowsePacket> packet = std::make_shared<AvrcCtCpPacket>(uidCounter, direction, folderUid); SendChangePathCmd() local
1806 std::shared_ptr<AvrcCtBrowsePacket> packet = SendGetFolderItemsCmd() local
1839 std::shared_ptr<AvrcCtBrowsePacket> packet = std::make_shared<AvrcCtGiaPacket>(scope, uid, uidCounter, attributes); SendGetItemAttributesCmd() local
1863 std::shared_ptr<AvrcCtBrowsePacket> packet = std::make_shared<AvrcCtGtnoiPacket>(scope); SendGetTotalNumberOfItemsCmd() local
1921 std::shared_ptr<AvrcCtBrowsePacket> packet = AvrcCtConnectManager::GetInstance()->GetBrowsePacket(rawAddr); ProcessBrowseTimeout() local
[all...] |
| /foundation/communication/dhcp/services/dhcp_client/src/ |
| H A D | dhcp_client_state_machine.cpp | 293 DHCP_LOGI("StartIpv4 send packet timed out, now break!"); in StartIpv4()
314 DHCP_LOGI("StartIpv4 already timed out, need send or resend packet..."); in StartIpv4()
491 /* Set socket mode, send unicast packet. */ in ExecDhcpRenew()
497 /* Set dhcp ipv4 state, send request packet. */ in ExecDhcpRenew()
513 /* Ensure that we've received dhcp ack packet completely. */ in ExecDhcpRelease()
516 /* Unicast dhcp release packet. */ in ExecDhcpRelease()
530 void DhcpClientStateMachine::AddParamaterRequestList(struct DhcpPacket *packet) in AddParamaterRequestList() argument
532 int end = GetEndOptionIndex(packet->options); in AddParamaterRequestList()
550 packet->options[end + DHCP_OPT_CODE_INDEX] = PARAMETER_REQUEST_LIST_OPTION; in AddParamaterRequestList()
553 packet in AddParamaterRequestList()
617 AddParamaterRebootList(struct DhcpPacket *packet) AddParamaterRebootList() argument
651 struct DhcpPacket packet; DhcpReboot() local
873 DhcpOfferPacketHandle(uint8_t type, const struct DhcpPacket *packet, time_t timestamp) DhcpOfferPacketHandle() argument
917 ParseNetworkServerIdInfo(const struct DhcpPacket *packet, struct DhcpIpResult *result) ParseNetworkServerIdInfo() argument
959 ParseNetworkDnsInfo(const struct DhcpPacket *packet, struct DhcpIpResult *result) ParseNetworkDnsInfo() argument
1061 ParseNetworkInfo(const struct DhcpPacket *packet, struct DhcpIpResult *result) ParseNetworkInfo() argument
1177 GetDHCPServerHostName(const struct DhcpPacket *packet, struct DhcpIpResult *result) GetDHCPServerHostName() argument
1213 ParseNetworkVendorInfo(const struct DhcpPacket *packet, struct DhcpIpResult *result) ParseNetworkVendorInfo() argument
1242 DhcpAckOrNakPacketHandle(uint8_t type, struct DhcpPacket *packet, time_t timestamp) DhcpAckOrNakPacketHandle() argument
1290 ParseDhcpAckPacket(const struct DhcpPacket *packet, time_t timestamp) ParseDhcpAckPacket() argument
1317 ParseDhcpNakPacket(const struct DhcpPacket *packet, time_t timestamp) ParseDhcpNakPacket() argument
1344 GetDhcpOffer(DhcpPacket *packet, int64_t timestamp) GetDhcpOffer() argument
1380 struct DhcpPacket packet; DhcpResponseHandle() local
1497 GetPacketHeaderInfo(struct DhcpPacket *packet, uint8_t type) GetPacketHeaderInfo() argument
1529 GetPacketCommonInfo(struct DhcpPacket *packet) GetPacketCommonInfo() argument
1546 AddClientIdToOpts(struct DhcpPacket *packet) AddClientIdToOpts() argument
1569 AddHostNameToOpts(struct DhcpPacket *packet) AddHostNameToOpts() argument
1587 AddStrToOpts(struct DhcpPacket *packet, int option, std::string &value) AddStrToOpts() argument
1619 struct DhcpPacket packet; DhcpDiscover() local
1653 struct DhcpPacket packet; DhcpRequest() local
1688 struct DhcpPacket packet; DhcpRenew() local
1725 struct DhcpPacket packet; DhcpRelease() local
1749 struct DhcpPacket packet; DhcpDecline() local
[all...] |
| /foundation/multimodalinput/input/intention/cooperate/plugin/include/ |
| H A D | dsoftbus_handler.h | 50 bool OnPacket(const std::string &networkId, NetPacket &packet) override
52 return parent_.OnPacket(networkId, packet);
85 bool OnPacket(const std::string &networkId, NetPacket &packet);
88 void OnStartCooperate(const std::string &networkId, NetPacket &packet);
89 void OnStopCooperate(const std::string &networkId, NetPacket &packet);
90 void OnComeBack(const std::string &networkId, NetPacket &packet);
91 void OnRelayCooperate(const std::string &networkId, NetPacket &packet);
92 void OnRelayCooperateFinish(const std::string &networkId, NetPacket &packet);
93 void OnSubscribeMouseLocation(const std::string& networKId, NetPacket &packet);
94 void OnUnSubscribeMouseLocation(const std::string& networKId, NetPacket &packet);
[all...] |
| /foundation/communication/bluetooth_service/services/bluetooth/stack/src/hci/evt/ |
| H A D | hci_evt.c | 42 typedef void (*HciEventFunc)(Packet *packet);
66 static void HciEventOnInquiryCompleteEvent(Packet *packet) in HciEventOnInquiryCompleteEvent() argument
68 Buffer *payloadBuffer = PacketContinuousPayload(packet); in HciEventOnInquiryCompleteEvent()
85 static void HciEventOnInquiryResultEvent(Packet *packet) in HciEventOnInquiryResultEvent() argument
87 Buffer *payloadBuffer = PacketContinuousPayload(packet); in HciEventOnInquiryResultEvent()
146 static void HciEventOnCommandStatusEvent(Packet *packet) in HciEventOnCommandStatusEvent() argument
148 Buffer *payloadBuffer = PacketContinuousPayload(packet); in HciEventOnCommandStatusEvent()
174 static void HciEventOnConnectionCompleteEvent(Packet *packet) in HciEventOnConnectionCompleteEvent() argument
176 Buffer *payloadBuffer = PacketContinuousPayload(packet); in HciEventOnConnectionCompleteEvent()
201 static void HciEventOnConnectionRequestEvent(Packet *packet) in HciEventOnConnectionRequestEvent() argument
224 HciEventOnRemoteNameRequestCompleteEvent(Packet *packet) HciEventOnRemoteNameRequestCompleteEvent() argument
247 HciEventOnEncryptionChangeEvent(Packet *packet) HciEventOnEncryptionChangeEvent() argument
270 HciEventOnReadRemoteSupportedFeaturesCompleteEvent(Packet *packet) HciEventOnReadRemoteSupportedFeaturesCompleteEvent() argument
294 HciEventOnReadRemoteVersionInformationCompleteEvent(Packet *packet) HciEventOnReadRemoteVersionInformationCompleteEvent() argument
318 HciEventOnRemoteHostSupportedFeaturesNotificationEvent(Packet *packet) HciEventOnRemoteHostSupportedFeaturesNotificationEvent() argument
342 HciEventOnNumberOfCompletedPacketsEvent(Packet *packet) HciEventOnNumberOfCompletedPacketsEvent() argument
382 HciEventOnModeChangeEvent(Packet *packet) HciEventOnModeChangeEvent() argument
405 HciEventOnPINCodeRequestEvent(Packet *packet) HciEventOnPINCodeRequestEvent() argument
429 HciEventOnLinkKeyRequestEvent(Packet *packet) HciEventOnLinkKeyRequestEvent() argument
452 HciEventOnLinkKeyNotificationEvent(Packet *packet) HciEventOnLinkKeyNotificationEvent() argument
475 HciEventOnSynchronousConnectionCompleteEvent(Packet *packet) HciEventOnSynchronousConnectionCompleteEvent() argument
499 HciEventOnSynchronousConnectionChangedEvent(Packet *packet) HciEventOnSynchronousConnectionChangedEvent() argument
523 HciEventOnDisconnectCompeteEvent(Packet *packet) HciEventOnDisconnectCompeteEvent() argument
550 HciEventOnAuthencationCompleteEvent(Packet *packet) HciEventOnAuthencationCompleteEvent() argument
573 HciEventOnInquiryResultWithRSSIEvent(Packet *packet) HciEventOnInquiryResultWithRSSIEvent() argument
634 HciEventOnReadRemoteExtendedFeaturesCompleteEvent(Packet *packet) HciEventOnReadRemoteExtendedFeaturesCompleteEvent() argument
658 HciEventOnExtendedInquiryResultEvent(Packet *packet) HciEventOnExtendedInquiryResultEvent() argument
682 HciEventOnEncryptionKeyRefreshCompleteEvent(Packet *packet) HciEventOnEncryptionKeyRefreshCompleteEvent() argument
707 HciEventOnIOCapabilityRequestEvent(Packet *packet) HciEventOnIOCapabilityRequestEvent() argument
731 HciEventOnIOCapabilityResponseEvent(Packet *packet) HciEventOnIOCapabilityResponseEvent() argument
755 HciEventOnUserConfirmationRequestEvent(Packet *packet) HciEventOnUserConfirmationRequestEvent() argument
779 HciEventOnUserPasskeyRequestEvent(Packet *packet) HciEventOnUserPasskeyRequestEvent() argument
803 HciEventOnRemoteOOBDataRequestEvent(Packet *packet) HciEventOnRemoteOOBDataRequestEvent() argument
827 HciEventOnSimplePairingCompleteEvent(Packet *packet) HciEventOnSimplePairingCompleteEvent() argument
851 HciEventOnUserPasskeyNotificationEvent(Packet *packet) HciEventOnUserPasskeyNotificationEvent() argument
875 HciEventOnKeypressNotificationEvent(Packet *packet) HciEventOnKeypressNotificationEvent() argument
899 HciEventOnAuthenticatedPayloadTimeoutExpiredEvent(Packet *packet) HciEventOnAuthenticatedPayloadTimeoutExpiredEvent() argument
923 HciEventOnChangeConnectionLinkKeyCompleteEvent(Packet *packet) HciEventOnChangeConnectionLinkKeyCompleteEvent() argument
948 HciEventOnMasterLinkKeyCompleteEvent(Packet *packet) HciEventOnMasterLinkKeyCompleteEvent() argument
972 HciEventOnQoSSetupCompleteEvent(Packet *packet) HciEventOnQoSSetupCompleteEvent() argument
996 HciEventOnHardwareErrorEvent(Packet *packet) HciEventOnHardwareErrorEvent() argument
1020 HciEventOnFlushOccurredEvent(Packet *packet) HciEventOnFlushOccurredEvent() argument
1044 HciEventOnRoleChangeEvent(Packet *packet) HciEventOnRoleChangeEvent() argument
1068 HciEventOnReturnLinkKeysEvent(Packet *packet) HciEventOnReturnLinkKeysEvent() argument
1092 HciEventOnDataBufferOverflowEvent(Packet *packet) HciEventOnDataBufferOverflowEvent() argument
1116 HciEventOnMaxSlotsChangeEvent(Packet *packet) HciEventOnMaxSlotsChangeEvent() argument
1140 HciEventOnReadClockOffsetCompleteEvent(Packet *packet) HciEventOnReadClockOffsetCompleteEvent() argument
1164 HciEventOnConnectionPacketTypeChangedEvent(Packet *packet) HciEventOnConnectionPacketTypeChangedEvent() argument
1189 HciEventOnQoSViolationEvent(Packet *packet) HciEventOnQoSViolationEvent() argument
1213 HciEventOnPageScanRepetitionModeChangeEvent(Packet *packet) HciEventOnPageScanRepetitionModeChangeEvent() argument
1238 HciEventOnFlowSpecificationCompleteEvent(Packet *packet) HciEventOnFlowSpecificationCompleteEvent() argument
1262 HciEventOnSniffSubratingEvent(Packet *packet) HciEventOnSniffSubratingEvent() argument
1286 HciEventOnLinkSupervisionTimeoutChangedEvent(Packet *packet) HciEventOnLinkSupervisionTimeoutChangedEvent() argument
1311 HciEventOnEnhancedFlushCompleteEvent(Packet *packet) HciEventOnEnhancedFlushCompleteEvent() argument
1335 HciEventOnPhysicalLinkCompleteEvent(Packet *packet) HciEventOnPhysicalLinkCompleteEvent() argument
1359 HciEventOnChannelSelectedEvent(Packet *packet) HciEventOnChannelSelectedEvent() argument
1383 HciEventOnDisconnectionPhysicalLinkCompleteEvent(Packet *packet) HciEventOnDisconnectionPhysicalLinkCompleteEvent() argument
1408 HciEventOnPhysicalLinkLossEarlyWarningEvent(Packet *packet) HciEventOnPhysicalLinkLossEarlyWarningEvent() argument
1433 HciEventOnPhysicalLinkRecoveryEvent(Packet *packet) HciEventOnPhysicalLinkRecoveryEvent() argument
1457 HciEventOnLogicalLinkCompleteEvent(Packet *packet) HciEventOnLogicalLinkCompleteEvent() argument
1481 HciEventOnDisconnectionLogicalLinkCompleteEvent(Packet *packet) HciEventOnDisconnectionLogicalLinkCompleteEvent() argument
1506 HciEventOnFlowSpecModifyCompleteEvent(Packet *packet) HciEventOnFlowSpecModifyCompleteEvent() argument
1530 HciEventOnNumberOfCompletedDataBlocksEvent(Packet *packet) HciEventOnNumberOfCompletedDataBlocksEvent() argument
1555 HciEventOnShortRangeModeChangeCompleteEvent(Packet *packet) HciEventOnShortRangeModeChangeCompleteEvent() argument
1580 HciEventOnAMPStatusChangeEvent(Packet *packet) HciEventOnAMPStatusChangeEvent() argument
1604 HciEventOnAMPStartTestEvent(Packet *packet) HciEventOnAMPStartTestEvent() argument
1628 HciEventOnAMPTestEndEvent(Packet *packet) HciEventOnAMPTestEndEvent() argument
1652 HciEventOnAMPReceiverReportEvent(Packet *packet) HciEventOnAMPReceiverReportEvent() argument
1676 HciEventOnTriggeredClockCaptureEvent(Packet *packet) HciEventOnTriggeredClockCaptureEvent() argument
1700 HciEventOnSynchronizationTrainCompleteEvent(Packet *packet) HciEventOnSynchronizationTrainCompleteEvent() argument
1725 HciEventOnSynchronizationTrainReceivedEvent(Packet *packet) HciEventOnSynchronizationTrainReceivedEvent() argument
1750 HciEventOnConnectionlessSlaveBroadcastReceiveEvent(Packet *packet) HciEventOnConnectionlessSlaveBroadcastReceiveEvent() argument
1775 HciEventOnConnectionlessSlaveBroadcastTimeoutEvent(Packet *packet) HciEventOnConnectionlessSlaveBroadcastTimeoutEvent() argument
1800 HciEventOnTruncatedPageCompleteEvent(Packet *packet) HciEventOnTruncatedPageCompleteEvent() argument
1824 HciEventOnConnectionlessSlaveBroadcastChannelMapChangeEvent(Packet *packet) HciEventOnConnectionlessSlaveBroadcastChannelMapChangeEvent() argument
1849 HciEventOnInquiryResponseNotificationEvent(Packet *packet) HciEventOnInquiryResponseNotificationEvent() argument
1874 HciEventOnSAMStatusChangeEvent(Packet *packet) HciEventOnSAMStatusChangeEvent() argument
1992 HciOnEvent(Packet *packet) HciOnEvent() argument
[all...] |
| /foundation/communication/bluetooth_service/services/bluetooth/stack/src/att/ |
| H A D | att_send_response.c | 30 #include "packet.h"
127 Packet *packet = NULL; in AttErrorResponseAsync() local
140 packet = PacketMalloc(0, 0, sizeof(uint8_t) + STEP_FOUR); in AttErrorResponseAsync()
141 if (packet == NULL) { in AttErrorResponseAsync()
145 data = BufferPtr(PacketContinuousPayload(packet)); in AttErrorResponseAsync()
151 ret = AttResponseSendData(connect, packet); in AttErrorResponseAsync()
153 PacketFree(packet); in AttErrorResponseAsync()
233 Packet *packet = NULL; in AttExchangeMTUResponseAsync() local
243 packet = PacketMalloc(0, 0, sizeof(uint8_t) + sizeof(exchangeMtuResPtr->mtu)); in AttExchangeMTUResponseAsync()
244 if (packet in AttExchangeMTUResponseAsync()
367 Packet *packet = NULL; AttFindInformationResponseAsync() local
507 Packet *packet = PacketMalloc(0, 0, sizeof(uint8_t) + handlesInforLen); AttFindByTypeValueResponseAsync() local
626 Packet *packet = PacketMalloc(0, 0, sizeof(uint8_t) + sizeof(len)); AttReadByTypeResponseAsync() local
737 Packet *packet = NULL; AttReadResponseAsync() local
839 Packet *packet = NULL; AttReadBlobResponseAsync() local
936 Packet *packet = NULL; AttReadMultipleResponseAsync() local
1075 Packet *packet = PacketMalloc(0, 0, sizeof(uint8_t) + sizeof(len)); AttReadByGroupTypeResponseAsync() local
1183 Packet *packet = NULL; AttWriteResponseAsync() local
1267 Packet *packet = NULL; AttPrepareWriteResponseAsync() local
1379 Packet *packet = NULL; AttExecuteWriteResponseAsync() local
1460 Packet *packet = NULL; AttHandleValueNotificationAsync() local
1565 Packet *packet = NULL; AttHandleValueIndicationAsync() local
[all...] |
| H A D | att_send_request.c | 30 #include "packet.h"
42 AttConnectInfo *connect, uint8_t *data, Packet *packet, uint16_t bufferSize);
44 const AttConnectInfo *connect, int ret, Buffer *sigedWriteBuffPtr, Packet *packet);
113 AttResponseSendData(sigedWriteCommandGenerContextPtr->connect, sigedWriteCommandGenerContextPtr->packet); in AttGapSignatureGenerationResultAsync()
115 PacketFree(sigedWriteCommandGenerContextPtr->packet); in AttGapSignatureGenerationResultAsync()
192 Packet *packet = NULL; in AttExchangeMTURequestAsync() local
210 packet = PacketMalloc(0, 0, sizeof(uint8_t) + sizeof(exchangeMtuReqPtr->mtu)); in AttExchangeMTURequestAsync()
211 if (packet == NULL) { in AttExchangeMTURequestAsync()
215 data = BufferPtr(PacketContinuousPayload(packet)); in AttExchangeMTURequestAsync()
219 ListAddLast(connect->instruct, packet); in AttExchangeMTURequestAsync()
281 Packet *packet = NULL; AttFindInformationRequestAsync() local
371 Packet *packet = NULL; AttFindByTypeValueRequestAsync() local
479 Packet *packet = NULL; AttReadByTypeRequestAsync() local
599 Packet *packet = NULL; AttReadRequestAsync() local
683 Packet *packet = NULL; AttReadBlobRequestAsync() local
769 Packet *packet = NULL; AttReadMultipleRequestAsync() local
901 Packet *packet = NULL; AttReadByGroupTypeRequestAsync() local
1018 Packet *packet = NULL; AttWriteRequestAsync() local
1118 Packet *packet = NULL; AttWriteCommandAsync() local
1213 AttSignedWriteCommandErrorFree( const AttConnectInfo *connect, int ret, Buffer *sigedWriteBuffPtr, Packet *packet) AttSignedWriteCommandErrorFree() argument
1276 Packet *packet = PacketMalloc(0, 0, sizeof(uint8_t) + sizeof(uint16_t) + bufferSize + sizeof(signature)); AttSignedWriteCommandAsync() local
1363 Packet *packet = NULL; AttPrepareWriteRequestAsync() local
1469 Packet *packet = NULL; AttExecuteWriteRequestAsync() local
1558 Packet *packet = NULL; AttHandleValueConfirmationAsync() local
1739 AttSingedWriteCommandContextAssign(SigedWriteCommandGenerationContext *sigedWriteCommandGenerContextPtr, AttConnectInfo *connect, uint8_t *data, Packet *packet, uint16_t bufferSize) AttSingedWriteCommandContextAssign() argument
[all...] |
| /foundation/graphic/graphic_2d/rosen/modules/render_service_profiler/ |
| H A D | rs_profiler_network.cpp | 109 void Network::SendPacket(const Packet& packet) in SendPacket() argument
113 outgoing_.emplace(const_cast<Packet&>(packet).Release()); in SendPacket()
175 Packet packet { Packet::BINARY }; in SendRSTreeDumpJSON()
176 packet.Write(static_cast<char>(PackageID::RS_PROFILER_RSTREE_DUMP_JSON)); in SendRSTreeDumpJSON()
177 packet.Write(jsonstr); in SendRSTreeDumpJSON()
178 SendPacket(packet); in SendRSTreeDumpJSON()
183 Packet packet { Packet::BINARY }; in SendRSTreePerfNodeList()
184 packet.Write(static_cast<char>(PackageID::RS_PROFILER_RSTREE_PERF_NODE_LIST)); in SendRSTreePerfNodeList()
185 packet.Write(perfNodesList); in SendRSTreePerfNodeList()
186 SendPacket(packet); in SendRSTreePerfNodeList()
[all...] |
| /foundation/communication/dsoftbus/tests/adapter/bluetooth/broadcast/ |
| H A D | softbus_broadcast_mgr_test.cpp | 78 static void BuildBroadcastPacketExceptPayload(BroadcastPacket *packet) in BuildBroadcastPacketExceptPayload() argument
80 packet->bcData.type = BC_DATA_TYPE_SERVICE; in BuildBroadcastPacketExceptPayload()
81 packet->bcData.id = SERVICE_UUID; in BuildBroadcastPacketExceptPayload()
82 packet->rspData.type = BC_DATA_TYPE_MANUFACTURER; in BuildBroadcastPacketExceptPayload()
83 packet->rspData.id = MANUFACTURE_COMPANY_ID; in BuildBroadcastPacketExceptPayload()
84 packet->isSupportFlag = true; in BuildBroadcastPacketExceptPayload()
85 packet->flag = BC_ADV_FLAG; in BuildBroadcastPacketExceptPayload()
279 BroadcastPacket packet = {}; in HWTEST_F() local
281 BuildBroadcastPacketExceptPayload(&packet); in HWTEST_F()
283 packet in HWTEST_F()
323 BroadcastPacket packet = {}; HWTEST_F() local
465 BroadcastPacket packet = {}; HWTEST_F() local
626 BroadcastPacket packet = {}; HWTEST_F() local
666 BroadcastPacket packet = {}; HWTEST_F() local
702 BroadcastPacket packet = {}; HWTEST_F() local
736 BroadcastPacket packet = {}; HWTEST_F() local
763 BroadcastPacket packet = {}; HWTEST_F() local
795 BroadcastPacket packet = {}; HWTEST_F() local
824 BroadcastPacket packet = {}; HWTEST_F() local
851 BroadcastPacket packet = {}; HWTEST_F() local
[all...] |