/foundation/distributeddatamgr/distributeddatamgr/services/distributeddataservice/libs/distributeddb/syncer/src/ |
D | single_ver_serialize_manager.cpp | 180 …erializeManager::DataPacketSyncerPartSerialization(Parcel &parcel, const DataRequestPacket *packet) in DataPacketSyncerPartSerialization() argument 182 parcel.WriteUInt64(packet->GetEndWaterMark()); in DataPacketSyncerPartSerialization() 183 parcel.WriteUInt64(packet->GetLocalWaterMark()); in DataPacketSyncerPartSerialization() 184 parcel.WriteUInt64(packet->GetPeerWaterMark()); in DataPacketSyncerPartSerialization() 185 parcel.WriteInt(packet->GetSendCode()); in DataPacketSyncerPartSerialization() 186 parcel.WriteInt(packet->GetMode()); in DataPacketSyncerPartSerialization() 187 parcel.WriteUInt32(packet->GetSessionId()); in DataPacketSyncerPartSerialization() 188 parcel.WriteVector<uint64_t>(packet->GetReserved()); in DataPacketSyncerPartSerialization() 192 if (packet->GetVersion() > SOFTWARE_VERSION_RELEASE_2_0) { in DataPacketSyncerPartSerialization() 193 parcel.WriteUInt32(packet->GetFlag()); in DataPacketSyncerPartSerialization() [all …]
|
D | ability_sync.cpp | 359 AbilitySyncRequestPacket packet; in SyncStart() local 360 int errCode = SetAbilityRequestBodyInfo(packet, remoteCommunicatorVersion); in SyncStart() 369 errCode = message->SetCopiedObject<>(packet); in SyncStart() 396 const AbilitySyncAckPacket *packet = message->GetObject<AbilitySyncAckPacket>(); in AckRecv() local 397 if (packet == nullptr) { in AckRecv() 400 uint32_t remoteSoftwareVersion = packet->GetSoftwareVersion(); in AckRecv() 403 errCode = AckRecvWithHighVersion(message, context, packet); in AckRecv() 405 std::string schema = packet->GetSchema(); in AckRecv() 423 const AbilitySyncRequestPacket *packet = message->GetObject<AbilitySyncRequestPacket>(); in RequestRecv() local 424 if (packet == nullptr) { in RequestRecv() [all …]
|
D | value_slice_sync.cpp | 235 const ValueSliceHashPacket *packet = message->GetObject<ValueSliceHashPacket>(); in RequestRecvCallback() local 236 if (packet == nullptr) { in RequestRecvCallback() 240 packet->GetValueSliceHash(valueSliceHashNode); in RequestRecvCallback() 241 if ((packet->GetErrCode() == -E_LAST_SYNC_FRAME) && valueSliceHashNode.empty()) { in RequestRecvCallback() 259 if (packet->GetErrCode() == -E_LAST_SYNC_FRAME) { in RequestRecvCallback() 271 const ValueSlicePacket *packet = message->GetObject<ValueSlicePacket>(); in AckRecvCallback() local 272 if (packet == nullptr) { in AckRecvCallback() 276 packet->GetErrorCode(errCode); in AckRecvCallback() 278 packet->GetData(valueSlice); in AckRecvCallback() 307 ValueSliceHashPacket *packet = new (std::nothrow) ValueSliceHashPacket(); in SendFinishedRequest() local [all …]
|
D | multi_ver_data_sync.cpp | 218 const MultiVerRequestPacket *packet = message->GetObject<MultiVerRequestPacket>(); in RequestRecvCallback() local 219 if (packet == nullptr) { in RequestRecvCallback() 222 if (packet->GetErrCode() == -E_LAST_SYNC_FRAME) { in RequestRecvCallback() 226 packet->GetCommit(commit); in RequestRecvCallback() 259 const MultiVerAckPacket *packet = message->GetObject<MultiVerAckPacket>(); in AckRecvCallback() local 260 if (packet == nullptr) { in AckRecvCallback() 264 packet->GetErrorCode(errCode); in AckRecvCallback() 273 packet->GetData(dataEntries); in AckRecvCallback() 321 MultiVerRequestPacket *packet = new (std::nothrow) MultiVerRequestPacket(); in SendFinishedRequest() local 322 if (packet == nullptr) { in SendFinishedRequest() [all …]
|
D | commit_history_sync.cpp | 254 …const CommitHistorySyncRequestPacket *packet = message->GetObject<CommitHistorySyncRequestPacket>(… in RequestRecvCallback() local 255 if (packet == nullptr) { in RequestRecvCallback() 266 packet->GetCommitMap(commitMap); in RequestRecvCallback() 267 uint32_t ver = packet->GetVersion(); in RequestRecvCallback() 301 const CommitHistorySyncAckPacket *packet = message->GetObject<CommitHistorySyncAckPacket>(); in AckRecvCallback() local 302 if (packet == nullptr) { in AckRecvCallback() 305 packet->GetErrorCode(errCode); in AckRecvCallback() 310 packet->GetData(commits); in AckRecvCallback() 311 uint32_t ver = packet->GetVersion(); in AckRecvCallback() 325 … const CommitHistorySyncRequestPacket *packet = inMsg->GetObject<CommitHistorySyncRequestPacket>(); in RequestPacketCalculateLen() local [all …]
|
D | single_ver_data_sync.cpp | 154 const DataAckPacket *packet = message->GetObject<DataAckPacket>(); in TryContinueSync() local 155 if (packet == nullptr) { in TryContinueSync() 158 …uint64_t packetId = packet->GetPacketId(); // above 102 version data request reserve[0] store pack… in TryContinueSync() 515 const DataRequestPacket *packet = message->GetObject<DataRequestPacket>(); in RemoveDeviceDataHandle() local 516 if (packet == nullptr) { in RemoveDeviceDataHandle() 520 SyncType curType = SyncOperation::GetSyncType(packet->GetMode()); in RemoveDeviceDataHandle() 521 WaterMark packetLocalMark = packet->GetLocalWaterMark(); in RemoveDeviceDataHandle() 619 void SingleVerDataSync::FillDataRequestPacket(DataRequestPacket *packet, SingleVerSyncTaskContext *… in FillDataRequestPacket() argument 636 packet->SetLastSequence(); in FillDataRequestPacket() 642 packet->SetData(syncData.entries); in FillDataRequestPacket() [all …]
|
D | single_ver_serialize_manager.h | 51 static int DataPacketSyncerPartSerialization(Parcel &parcel, const DataRequestPacket *packet); 52 static int DataPacketQuerySyncSerialization(Parcel &parcel, const DataRequestPacket *packet); 55 static int DataPacketQuerySyncDeSerialization(Parcel &parcel, DataRequestPacket *packet); 56 static int DataPacketCompressDataDeSerialization(Parcel &parcel, DataRequestPacket *packet); 58 …static int DataPacketSyncerPartDeSerialization(Parcel &parcel, DataRequestPacket *packet, uint32_t… 63 static int AckPacketSyncerPartSerializationV1(Parcel &parcel, const DataAckPacket *packet); 65 static int AckPacketSyncerPartDeSerializationV1(Parcel &parcel, DataAckPacket &packet); 77 static int ControlRequestDeSerialization(Parcel &parcel, ControlRequestPacket &packet);
|
D | time_sync.cpp | 196 TimeSyncPacket packet; in SyncStart() local 198 packet.SetSourceTimeBegin(startTime); in SyncStart() 209 int errCode = message->SetCopiedObject<>(packet); in SyncStart() 230 const TimeSyncPacket *packet = const_cast<TimeSyncPacket *>(inMsg->GetObject<TimeSyncPacket>()); in CalculateLen() local 231 if (packet == nullptr) { in CalculateLen() 243 const TimeSyncPacket *packet = inMsg->GetObject<TimeSyncPacket>(); in Serialization() local 244 if ((packet == nullptr) || (length != TimeSyncPacket::CalculateLen())) { in Serialization() 249 TimeStamp srcBegin = packet->GetSourceTimeBegin(); in Serialization() 250 TimeStamp srcEnd = packet->GetSourceTimeEnd(); in Serialization() 251 TimeStamp targetBegin = packet->GetTargetTimeBegin(); in Serialization() [all …]
|
/foundation/communication/wifi/tests/wifi_standard/wifi_framework/dhcp_manage/dhcp_client/ |
D | dhcp_socket_test.cpp | 118 struct DhcpPacket packet; variable 119 packet.xid = 123456; 120 … EXPECT_EQ(SendToDhcpPacket(&packet, 0, 0, ifindex, (uint8_t *)MAC_BCAST_ADDR), SOCKET_OPT_FAILED); 121 …EXPECT_EQ(SendToDhcpPacket(&packet, INADDR_ANY, INADDR_BROADCAST, ifindex, (uint8_t *)MAC_BCAST_AD… 140 struct DhcpPacket packet; variable 141 packet.xid = 123456; 142 EXPECT_EQ(SendDhcpPacket(&packet, INADDR_ANY, INADDR_BROADCAST), SOCKET_OPT_FAILED); 143 EXPECT_EQ(SendDhcpPacket(&packet, INADDR_ANY, INADDR_BROADCAST), SOCKET_OPT_SUCCESS); 169 struct UdpDhcpPacket packet; variable 171 EXPECT_EQ(CheckUdpPacket(&packet, total), SOCKET_OPT_FAILED); [all …]
|
D | dhcp_options_test.cpp | 55 struct DhcpPacket packet; variable 56 ASSERT_TRUE(memset_s(&packet, sizeof(struct DhcpPacket), 0, sizeof(struct DhcpPacket)) == EOK); 59 uint8_t *pOption = packet.options; 79 EXPECT_NE(GetDhcpOption(&packet, DHCP_MESSAGE_TYPE_OPTION, &len), nullptr); 87 struct DhcpPacket packet; variable 88 ASSERT_TRUE(memset_s(&packet, sizeof(struct DhcpPacket), 0, sizeof(struct DhcpPacket)) == EOK); 91 uint8_t *pOption = packet.options; 111 EXPECT_EQ(GetDhcpOption(&packet, DHCP_MESSAGE_TYPE_OPTION, &len), nullptr); 116 struct DhcpPacket packet; variable 117 ASSERT_TRUE(memset_s(&packet, sizeof(struct DhcpPacket), 0, sizeof(struct DhcpPacket)) == EOK); [all …]
|
/foundation/communication/bluetooth/services/bluetooth_standard/stack/src/hci/ |
D | hci.c | 63 static void HciFreePacket(void *packet) in HciFreePacket() argument 65 HciPacket *hciPacket = packet; in HciFreePacket() 67 PacketFree(hciPacket->packet); in HciFreePacket() 69 MEM_MALLOC.free(packet); in HciFreePacket() 201 HciPacket *packet = QueueTryDequeue(g_hciTxQueue); in CleanTxPacket() local 202 while (packet != NULL) { in CleanTxPacket() 203 HciFreePacket(packet); in CleanTxPacket() 204 packet = QueueTryDequeue(g_hciTxQueue); in CleanTxPacket() 212 HciPacket *packet = QueueTryDequeue(g_hciRxQueue); in CleanRxPacket() local 213 while (packet != NULL) { in CleanRxPacket() [all …]
|
/foundation/communication/bluetooth/services/bluetooth_standard/stack/src/hci/evt/ |
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 [all …]
|
/foundation/communication/wifi/services/wifi_standard/wifi_framework/dhcp_manage/dhcp_client/src/ |
D | dhcp_ipv4.c | 171 static void AddParamaterRequestList(struct DhcpPacket *packet) in AddParamaterRequestList() argument 173 int end = GetEndOptionIndex(packet->options); in AddParamaterRequestList() 183 packet->options[end + DHCP_OPT_CODE_INDEX] = PARAMETER_REQUEST_LIST_OPTION; in AddParamaterRequestList() 186 packet->options[end + DHCP_OPT_DATA_INDEX + len++] = arrReqCode[i]; in AddParamaterRequestList() 189 packet->options[end + DHCP_OPT_LEN_INDEX] = len; in AddParamaterRequestList() 190 packet->options[end + DHCP_OPT_DATA_INDEX + len] = END_OPTION; in AddParamaterRequestList() 334 static void AddParamaterRebootList(struct DhcpPacket *packet) in AddParamaterRebootList() argument 336 int end = GetEndOptionIndex(packet->options); in AddParamaterRebootList() 347 packet->options[end + DHCP_OPT_CODE_INDEX] = PARAMETER_REQUEST_LIST_OPTION; in AddParamaterRebootList() 350 packet->options[end + DHCP_OPT_DATA_INDEX + len++] = arrReqCode[i]; in AddParamaterRebootList() [all …]
|
D | dhcp_options.c | 27 static bool CheckOptSoverloaded(const struct DhcpPacket *packet, int code, int maxLen, int *over, i… in CheckOptSoverloaded() argument 29 if (packet == NULL) { in CheckOptSoverloaded() 34 const uint8_t *pOption = packet->options; in CheckOptSoverloaded() 46 static int CheckOptionsData(const struct DhcpPacket *packet, int code, int index, int maxLen) in CheckOptionsData() argument 48 if (packet == NULL) { in CheckOptionsData() 59 const uint8_t *pOption = packet->options; in CheckOptionsData() 153 const uint8_t *GetDhcpOption(const struct DhcpPacket *packet, int code, size_t *length) in GetDhcpOption() argument 156 if (packet == NULL) { in GetDhcpOption() 161 const uint8_t *pOption = packet->options; in GetDhcpOption() 164 int nRet = CheckOptionsData(packet, code, nIndex, maxLen); in GetDhcpOption() [all …]
|
/foundation/communication/bluetooth/services/bluetooth_standard/service/src/avrcp_ct/ |
D | avrcp_ct_profile.cpp | 328 …std::shared_ptr<AvrcCtPassPacket> packet = std::make_shared<AvrcCtPassPacket>(button, AVRC_KEY_STA… in SendPressButtonCmd() local 330 SendPassCmd(rawAddr, packet); in SendPressButtonCmd() 338 …std::shared_ptr<AvrcCtPassPacket> packet = std::make_shared<AvrcCtPassPacket>(button, AVRC_KEY_STA… in SendReleaseButtonCmd() local 340 SendPassCmd(rawAddr, packet); in SendReleaseButtonCmd() 393 std::shared_ptr<AvrcCtPassPacket> packet = cnManager->PopPassQueue(rawAddr); in SendNextPassCmd() local 394 SendPassCmd(rawAddr, packet); in SendNextPassCmd() 404 AvrcCtPassPacket packet(pkt); in ReceivePassRsp() local 407 packet.GetKeyOperation(), in ReceivePassRsp() 408 packet.GetKeyState()); in ReceivePassRsp() 411 …rawAddr, packet.GetKeyOperation(), packet.GetKeyState(), ExpainPassCrCodeToResult(packet.GetCrCode… in ReceivePassRsp() [all …]
|
/foundation/communication/bluetooth/services/bluetooth_standard/stack/src/hci/acl/ |
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 frameLengt… in HciFargment() argument 407 size_t totalLength = PacketSize(packet); in HciFargment() 420 PacketFragment(packet, fargmented, frameLength); in HciFargment() 444 static int HciSendSinglePacket(uint16_t connectionHandle, Packet *packet) in HciSendSinglePacket() argument [all …]
|
/foundation/communication/bluetooth/services/bluetooth_standard/stack/src/att/ |
D | att_send_response.c | 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() 232 Packet *packet = NULL; in AttExchangeMTUResponseAsync() local 242 packet = PacketMalloc(0, 0, sizeof(uint8_t) + sizeof(exchangeMtuResPtr->mtu)); in AttExchangeMTUResponseAsync() 243 if (packet == NULL) { in AttExchangeMTUResponseAsync() 247 data = BufferPtr(PacketContinuousPayload(packet)); in AttExchangeMTUResponseAsync() [all …]
|
D | att_send_request.c | 42 AttConnectInfo *connect, uint8_t *data, Packet *packet, uint16_t bufferSize); 44 const AttConnectInfo *connect, int ret, Buffer *sigedWriteBuffPtr, Packet *packet); 113 …ponseSendData(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; in AttFindInformationRequestAsync() local [all …]
|
/foundation/communication/bluetooth/services/bluetooth_standard/service/src/avrcp_tg/ |
D | avrcp_tg_profile.cpp | 335 …std::shared_ptr<AvrcTgPassPacket> packet = std::make_shared<AvrcTgPassPacket>(button, AVRC_KEY_STA… in SendPressButtonRsp() local 336 packet->SetCrCode(ExplainResultToPassCrCode(result)); in SendPressButtonRsp() 338 SendPassRsp(rawAddr, packet); in SendPressButtonRsp() 346 std::shared_ptr<AvrcTgPassPacket> packet = in SendReleaseButtonRsp() local 348 packet->SetCrCode(ExplainResultToPassCrCode(result)); in SendReleaseButtonRsp() 350 SendPassRsp(rawAddr, packet); in SendReleaseButtonRsp() 367 …std::shared_ptr<AvrcTgPassPacket> packet = AvrcTgConnectManager::GetInstance()->GetPassPacket(rawA… in IsSamePassPressCommand() local 369 if (packet == nullptr) { in IsSamePassPressCommand() 373 if (packet->GetKeyOperation() != button) { in IsSamePassPressCommand() 377 if (packet->GetKeyState() != AVRC_KEY_STATE_PRESS) { in IsSamePassPressCommand() [all …]
|
/foundation/communication/wifi/services/wifi_standard/wifi_framework/dhcp_manage/dhcp_client/include/ |
D | dhcp_options.h | 29 const uint8_t *GetDhcpOption(const struct DhcpPacket *packet, int code, size_t *length); 30 bool GetDhcpOptionUint8(const struct DhcpPacket *packet, int code, uint8_t *data); 31 bool GetDhcpOptionUint32(const struct DhcpPacket *packet, int code, uint32_t *data); 32 bool GetDhcpOptionUint32n(const struct DhcpPacket *packet, int code, uint32_t *data1, uint32_t *dat… 33 char *GetDhcpOptionString(const struct DhcpPacket *packet, int code);
|
/foundation/distributeddatamgr/distributeddatamgr/services/distributeddataservice/libs/distributeddb/test/unittest/common/syncer/ |
D | distributeddb_anti_dos_sync_test.cpp | 171 DataRequestPacket *packet = new (std::nothrow) DataRequestPacket; variable 172 ASSERT_TRUE(packet != nullptr); 179 packet->SetData(outData); 180 packet->SetSendCode(E_OK); 181 packet->SetVersion(SOFTWARE_VERSION_CURRENT); 186 int errCode = message->SetExternalObject(packet); 222 DataRequestPacket *packet = new (std::nothrow) DataRequestPacket; variable 223 ASSERT_TRUE(packet != nullptr); 230 packet->SetData(outData); 231 packet->SetSendCode(E_OK); [all …]
|
/foundation/communication/wifi/services/wifi_standard/wifi_framework/dhcp_manage/dhcp_server/src/ |
D | dhcp_server.c | 277 if (memcpy_s(&msgInfo->packet, sizeof(DhcpMessage), recvBuffer, rsize) != EOK) { in ReceiveDhcpMessage() 280 if (msgInfo->packet.op != BOOTREQUEST) { in ReceiveDhcpMessage() 284 if (msgInfo->packet.hlen > DHCP_HWADDR_LENGTH) { in ReceiveDhcpMessage() 288 if (IsEmptyHWAddr(msgInfo->packet.chaddr)) { in ReceiveDhcpMessage() 292 if (IsReserved(msgInfo->packet.chaddr)) { in ReceiveDhcpMessage() 293 LOGD("ignore client, %s", ParseLogMac(msgInfo->packet.chaddr)); in ReceiveDhcpMessage() 305 reply->packet.op = BOOTREPLY; in InitReply() 306 reply->packet.htype = ETHERNET; in InitReply() 307 reply->packet.hlen = OPT_MAC_ADDR_LENGTH; in InitReply() 308 reply->packet.secs = 0; in InitReply() [all …]
|
/foundation/communication/bluetooth/services/bluetooth_standard/stack/src/hci/cmd/ |
D | hci_cmd.c | 99 hciPacket->packet = cmd->packet; in HciCmdPushToTxQueue() 100 cmd->packet = NULL; in HciCmdPushToTxQueue() 177 Packet *packet = PacketMalloc(sizeof(HciCmdHeader), 0, 0); in HciCreateCmdPacket() local 178 Buffer *headerBuffer = PacketHead(packet); in HciCreateCmdPacket() 185 return packet; in HciCreateCmdPacket() 190 Packet *packet = PacketMalloc(sizeof(HciCmdHeader), 0, paramLength); in HciCreateCmdPacketWithParam() local 191 Buffer *headerBuffer = PacketHead(packet); in HciCreateCmdPacketWithParam() 197 PacketPayloadWrite(packet, param, 0, paramLength); in HciCreateCmdPacketWithParam() 198 return packet; in HciCreateCmdPacketWithParam() 211 cmd->packet = HciCreateCmdPacketWithParam(opCode, param, paramLength); in HciAllocCmd() [all …]
|
/foundation/communication/bluetooth/services/bluetooth_standard/stack/src/sdp/ |
D | sdp_connect.c | 43 Packet *packet; /// Fragment packet member 59 static void SdpReceiveData(uint16_t lcid, Packet *packet, void *context); 96 if (connect->packet != NULL) { in SdpFreeConnectInfo() 97 PacketFree(connect->packet); in SdpFreeConnectInfo() 98 connect->packet = NULL; in SdpFreeConnectInfo() 484 SdpSendRequest(lcid, request->transactionId, 0, NULL, request->packet); in SdpConfigRspCallbackTask() 857 SdpSendRequest(connect->lcid, request->transactionId, 0, NULL, request->packet); in SdpReceiveConfigResponseTask() 1108 Packet *packet; member 1119 static void SdpReceiveDataTask(uint16_t lcid, const Packet *packet, void *context) in SdpReceiveDataTask() argument 1137 SdpParseServerResponse(&connect->addr, lcid, packet); in SdpReceiveDataTask() [all …]
|
D | sdp_client_parse.c | 38 const BtAddr *addr, uint16_t transactionId, uint16_t parameterLength, const Packet *packet); 39 … SdpParseSearchResponse(const BtAddr *addr, uint16_t lcid, uint16_t transactionId, Packet *packet); 40 …pParseAttributeResponse(const BtAddr *addr, uint16_t lcid, uint16_t transactionId, Packet *packet); 41 …SearchAttributeResponse(const BtAddr *addr, uint16_t lcid, uint16_t transactionId, Packet *packet); 59 if (request->packet != NULL) { in SdpFreeClientRequest() 60 PacketFree(request->packet); in SdpFreeClientRequest() 61 request->packet = NULL; in SdpFreeClientRequest() 248 static void SdpSendRequestForAssemblePacket(uint16_t lcid, uint16_t transactionId, Packet *packet, in SdpSendRequestForAssemblePacket() argument 258 request->assemblePacket = PacketRefMalloc(packet); in SdpSendRequestForAssemblePacket() 264 PacketAssemble(request->assemblePacket, packet); in SdpSendRequestForAssemblePacket() [all …]
|