Home
last modified time | relevance | path

Searched refs:peer (Results 1 - 25 of 41) sorted by relevance

12

/foundation/communication/bluetooth_service/services/bluetooth/service/src/gavdp/
H A Da2dp_avdtp.cpp317 A2dpProfilePeer *peer = profile->FindPeerByAddress(bdAddr); in ParseAvdtpDisconnectInd() local
318 if (peer == nullptr) { in ParseAvdtpDisconnectInd()
319 LOG_ERROR("[A2dpAvdtp] %{public}s Failed to get peer instance \n", __func__); in ParseAvdtpDisconnectInd()
322 peer->StopSignalingTimer(); in ParseAvdtpDisconnectInd()
341 A2dpProfilePeer *peer = profile->FindPeerByAddress(bdAddr); in ParseAvdtpConfigureInd() local
342 if (peer == nullptr) { in ParseAvdtpConfigureInd()
343 LOG_ERROR("[A2dpAvdtp] %{public}s Failed to get peer instance \n", __func__); in ParseAvdtpConfigureInd()
346 if (peer->GetInitSide()) { in ParseAvdtpConfigureInd()
359 peer->SetCurrentCmd(EVT_SETCONFIG_IND); in ParseAvdtpConfigureInd()
360 peer in ParseAvdtpConfigureInd()
384 A2dpProfilePeer *peer = profile->FindPeerByAddress(bdAddr); ParseAvdtpReconfigureInd() local
432 A2dpProfilePeer *peer = profile->FindPeerByAddress(bdAddr); ParseAvdtpOpenInd() local
480 A2dpProfilePeer *peer = profile->FindPeerByAddress(bdAddr); ParseAvdtpCloseChannelInd() local
505 A2dpProfilePeer *peer = profile->FindPeerByAddress(bdAddr); ParseAvdtpStartInd() local
548 A2dpProfilePeer *peer = profile->FindOrCreatePeer(bdAddr, role); ParseAvdtpConnectCFM() local
575 A2dpProfilePeer *peer = profile->FindPeerByAddress(bdAddr); ParseAvdtpDisconnectCFM() local
596 A2dpProfilePeer *peer = profile->FindPeerByAddress(bdAddr); ParseAvdtpDiscoverCFM() local
631 A2dpProfilePeer *peer = profile->FindPeerByAddress(bdAddr); ParseAvdtpGetCapabilityCFM() local
675 A2dpProfilePeer *peer = profile->FindPeerByAddress(bdAddr); ParseAvdtpGetALLCapCFM() local
718 A2dpProfilePeer *peer = profile->FindPeerByAddress(bdAddr); ParseAvdtpConfigureCFM() local
749 A2dpProfilePeer *peer = profile->FindPeerByAddress(bdAddr); ParseAvdtpGetConfigureCFM() local
768 A2dpProfilePeer *peer = profile->FindPeerByAddress(bdAddr); ParseAvdtpReconfigureCFM() local
809 A2dpProfilePeer *peer = profile->FindPeerByAddress(bdAddr); ParseAvdtpOpenCFM() local
832 A2dpProfilePeer *peer = profile->FindPeerByAddress(bdAddr); ParseAvdtpStartCFM() local
853 A2dpProfilePeer *peer = profile->FindPeerByAddress(bdAddr); ParseAvdtpSuspendCFM() local
874 A2dpProfilePeer *peer = profile->FindPeerByAddress(bdAddr); ParseAvdtpStreamCloseCFM() local
895 A2dpProfilePeer *peer = profile->FindPeerByAddress(bdAddr); ParseAvdtpAbortCFM() local
915 A2dpProfilePeer *peer = profile->FindPeerByAddress(bdAddr); ParseAvdtpWriteCFM() local
[all...]
H A Da2dp_profile.cpp119 void A2dpProfile::SetActivePeer(const BtAddr &peer) in SetActivePeer() argument
123 activePeer_ = peer; in SetActivePeer()
175 A2dpProfilePeer *peer = FindOrCreatePeer(addr, role); in ProcessAvdtpCallback() local
176 if (peer == nullptr) { in ProcessAvdtpCallback()
177 LOG_ERROR("[A2dpService] %{public}s Failed to get peer instance\n", __func__); in ProcessAvdtpCallback()
188 peer->GetStateMachine()->ProcessMessage(data); in ProcessAvdtpCallback()
243 A2dpProfilePeer *peer = FindPeerByAddress(addr); in CodecChangedNotify() local
245 if (a2dpSvcCBack_ != nullptr && peer != nullptr) { in CodecChangedNotify()
246 a2dpSvcCBack_->OnCodecStateChanged(addr, peer->GetCodecStatus(), context); in CodecChangedNotify()
264 A2dpProfilePeer *peer in SetUserCodecConfigure() local
302 A2dpProfilePeer *peer = FindPeerByAddress(addr); EnableOptionalCodec() local
316 A2dpProfilePeer *peer = FindPeerByAddress(addr); NotifyEncoder() local
328 A2dpProfilePeer *peer = FindPeerByAddress(addr); NotifyDecoder() local
375 A2dpProfilePeer *peer = FindOrCreatePeer(activePeer_, A2DP_ROLE_SOURCE); DequeuePacket() local
533 A2dpProfilePeer *peer = nullptr; Disable() local
583 A2dpProfilePeer *peer = FindPeerByAddress(addr); SetConfigure() local
626 A2dpProfilePeer *peer = FindOrCreatePeer(addr, role); ProcessSDPCallback() local
648 A2dpProfilePeer *peer = nullptr; Disconnect() local
675 A2dpProfilePeer *peer = nullptr; Stop() local
710 A2dpProfilePeer *peer = nullptr; Start() local
765 A2dpProfilePeer *peer = nullptr; Close() local
792 A2dpProfilePeer *peer = nullptr; HasStreaming() local
808 A2dpProfilePeer *peer = nullptr; HasOpen() local
890 A2dpProfilePeer *peer = nullptr; Reconfigure() local
925 A2dpProfilePeer *peer = nullptr; DelayReportNotify() local
939 A2dpProfilePeer *peer = nullptr; ResetDelayValue() local
966 A2dpProfilePeer *peer = nullptr; FindPeerByAddress() local
982 A2dpProfilePeer *peer = nullptr; FindPeerByHandle() local
996 A2dpProfilePeer *peer = nullptr; FindOrCreatePeer() local
1100 A2dpProfilePeer *peer = FindPeerByAddress(addr); ProcessSignalingTimeoutCallback() local
1115 A2dpProfilePeer *peer = profile->FindPeerByHandle(handle); ProcessSinkStream() local
[all...]
/foundation/communication/bluetooth_service/services/bluetooth/stack/src/smp/
H A Dsmp_tool.c243 param->pres[PAIR_RES_5] = SMP_GetPairMng()->peer.pairParam.ioCapability; in SMP_ConstituteC1Step1Param()
244 param->pres[PAIR_RES_4] = SMP_GetPairMng()->peer.pairParam.oobDataFlag; in SMP_ConstituteC1Step1Param()
245 param->pres[PAIR_RES_3] = SMP_GetPairMng()->peer.pairParam.authReq; in SMP_ConstituteC1Step1Param()
246 param->pres[PAIR_RES_2] = SMP_GetPairMng()->peer.pairParam.maxEncKeySize; in SMP_ConstituteC1Step1Param()
247 param->pres[PAIR_RES_1] = SMP_GetPairMng()->peer.pairParam.initKeyDist; in SMP_ConstituteC1Step1Param()
248 param->pres[PAIR_RES_0] = SMP_GetPairMng()->peer.pairParam.respKeyDist; in SMP_ConstituteC1Step1Param()
250 param->rat = SMP_GetPairMng()->peer.addr.type; in SMP_ConstituteC1Step1Param()
253 param->preq[PAIR_REQ_5] = SMP_GetPairMng()->peer.pairParam.ioCapability; in SMP_ConstituteC1Step1Param()
254 param->preq[PAIR_REQ_4] = SMP_GetPairMng()->peer.pairParam.oobDataFlag; in SMP_ConstituteC1Step1Param()
255 param->preq[PAIR_REQ_3] = SMP_GetPairMng()->peer in SMP_ConstituteC1Step1Param()
[all...]
H A Dsmp_receive.c215 (void)memcpy_s(&SMP_GetPairMng()->peer.pairParam, sizeof(SMP_PairParam), &pairParamTemp, sizeof(SMP_PairParam)); in SMP_ReceivePairingRequest()
269 if (memcpy_s(&SMP_GetPairMng()->peer.pairParam, in SMP_ReceivePairingResponse()
271 LOG_ERROR("[%{public}s][%{public}d] peer.pairParam memcpy_s fail.", __FUNCTION__, __LINE__); in SMP_ReceivePairingResponse()
647 if (memcpy_s(SMP_GetPairMng()->peer.LTK, SMP_LTK_LEN, (uint8_t *)BufferPtr(buffer), SMP_LTK_LEN) != EOK) { in SMP_RecvEncInfoProcessMaster()
651 SMP_GetPairMng()->peer.keyDistCmdFlag = in SMP_RecvEncInfoProcessMaster()
652 SMP_GetPairMng()->peer.keyDistCmdFlag & (~SMP_KEY_DIST_CMD_FLAG_BIT_ENC_INFO); in SMP_RecvEncInfoProcessMaster()
653 if ((SMP_GetPairMng()->peer.keyDistCmdFlag != 0x00) || in SMP_RecvEncInfoProcessMaster()
657 LOG_INFO("g_smpPairMng.peer.keyDistCmdFlag is 0"); in SMP_RecvEncInfoProcessMaster()
697 if (memcpy_s(SMP_GetPairMng()->peer.LTK, SMP_LTK_LEN, (uint8_t *)BufferPtr(buffer), SMP_LTK_LEN) != EOK) { in SMP_RecvEncInfoProcessSlave()
701 SMP_GetPairMng()->peer in SMP_RecvEncInfoProcessSlave()
[all...]
H A Dsmp_sc_initiator.c65 (void)memcpy_s(SMP_GetPairMng()->peer.publicKey, SMP_PUBLICKEY_LEN, (uint8_t *)param->data, SMP_PUBLICKEY_LEN); in SMP_ScPairJustworkOrNumericMasterStep2()
68 DHKeyParam.remoteP256PublicKey, SMP_PUBLICKEY_LEN, SMP_GetPairMng()->peer.publicKey, SMP_PUBLICKEY_LEN); in SMP_ScPairJustworkOrNumericMasterStep2()
89 SMP_MemoryReverseCopy(SMP_GetPairMng()->peer.confirm, (uint8_t *)param->data, SMP_CONFIRM_DATA_LEN); in SMP_ScPairJustworkOrNumericMasterStep3()
102 SMP_MemoryReverseCopy(SMP_GetPairMng()->peer.confirm, (uint8_t *)param->data, SMP_CONFIRM_DATA_LEN); in SMP_ScPairJustworkOrNumericMasterStep4()
164 SMP_MemoryReverseCopy(SMP_GetPairMng()->peer.random, (uint8_t *)param->data, SMP_RANDOM_DATA_LEN); in SMP_ScPairJustworkOrNumericMasterStep7()
165 SMP_MemoryReverseCopy(encryptParam.key, SMP_GetPairMng()->peer.random, SMP_RANDOM_DATA_LEN); in SMP_ScPairJustworkOrNumericMasterStep7()
190 SMP_GetPublicKeyX(SMP_GetPairMng()->peer.publicKey, cryptF4Param.U, sizeof(cryptF4Param.U)); in SMP_ScPairJustworkOrNumericMasterStep8()
242 if (memcmp(confirmTemp, SMP_GetPairMng()->peer.confirm, SMP_CONFIRM_DATA_LEN) != 0x00) { in SMP_ScPairJustworkOrNumericMasterStep10()
284 SMP_GetPublicKeyX(SMP_GetPairMng()->peer.publicKey, cryptG2Param.V, sizeof(cryptG2Param.V)); in SMP_ScPairJustworkOrNumericMasterStep11()
285 (void)memcpy_s(cryptG2Param.Y, sizeof(cryptG2Param.Y), SMP_GetPairMng()->peer in SMP_ScPairJustworkOrNumericMasterStep11()
[all...]
H A Dsmp_sc_accepter.c38 (void)memcpy_s(SMP_GetPairMng()->peer.publicKey, SMP_PUBLICKEY_LEN, (uint8_t *)param->data, SMP_PUBLICKEY_LEN); in SMP_ScPairJustworkOrNumericSlaveStep1()
67 DHKeyParam.remoteP256PublicKey, SMP_PUBLICKEY_LEN, SMP_GetPairMng()->peer.publicKey, SMP_PUBLICKEY_LEN); in SMP_ScPairJustworkOrNumericSlaveStep2()
163 SMP_GetPublicKeyX(SMP_GetPairMng()->peer.publicKey, cryptF4Param.V, sizeof(cryptF4Param.V)); in SMP_ScPairJustworkOrNumericSlaveStep6()
236 SMP_MemoryReverseCopy(SMP_GetPairMng()->peer.random, (uint8_t *)param->data, SMP_RANDOM_DATA_LEN); in SMP_ScPairJustworkOrNumericSlaveStep9()
253 SMP_MemoryReverseCopy(encryptParam.key, SMP_GetPairMng()->peer.random, sizeof(encryptParam.key)); in SMP_ScPairJustworkOrNumericSlaveStep9()
280 SMP_GetPublicKeyX(SMP_GetPairMng()->peer.publicKey, cryptG2Param.U, sizeof(cryptG2Param.U)); in SMP_ScPairJustworkOrNumericSlaveStep10()
358 (void)memcpy_s(SMP_GetPairMng()->peer.DHKeyCheck, SMP_DHKEY_CHECK_LEN, (uint8_t *)param->data, SMP_DHKEY_CHECK_LEN); in SMP_ScPairJustworkOrNumericSlaveStep13()
369 (void)memcpy_s(SMP_GetPairMng()->peer.publicKey, SMP_PUBLICKEY_LEN, (uint8_t *)param->data, SMP_PUBLICKEY_LEN); in SMP_ScPairPasskeyEntrySlaveStep1()
398 DHKeyParam.remoteP256PublicKey, SMP_PUBLICKEY_LEN, SMP_GetPairMng()->peer.publicKey, SMP_PUBLICKEY_LEN); in SMP_ScPairPasskeyEntrySlaveStep2()
475 SMP_MemoryReverseCopy(SMP_GetPairMng()->peer in SMP_ScPairPasskeyEntrySlaveStep5()
[all...]
H A Dsmp_legacy.c143 SMP_MemoryReverseCopy(SMP_GetPairMng()->peer.confirm, (uint8_t *)param->data, SMP_CONFIRM_DATA_LEN); in SMP_LegacyPairMasterStep6()
165 SMP_MemoryReverseCopy(SMP_GetPairMng()->peer.random, (uint8_t *)param->data, SMP_RANDOM_DATA_LEN); in SMP_LegacyPairMasterStep7()
166 SMP_ConstituteC1Step1Param(SMP_ROLE_MASTER, SMP_GetPairMng()->peer.random, SMP_RANDOM_DATA_LEN, &cryptC1Step1Param); in SMP_LegacyPairMasterStep7()
211 if (memcmp(confirmTemp, SMP_GetPairMng()->peer.confirm, SMP_CONFIRM_DATA_LEN) != 0x00) { in SMP_LegacyPairMasterStep9()
218 cryptS1Param.r1, sizeof(cryptS1Param.r1), SMP_GetPairMng()->peer.random, sizeof(cryptS1Param.r1)); in SMP_LegacyPairMasterStep9()
420 SMP_MemoryReverseCopy(SMP_GetPairMng()->peer.confirm, (uint8_t *)param->data, SMP_CONFIRM_DATA_LEN); in SMP_LegacyPairSlaveStep2()
431 SMP_MemoryReverseCopy(SMP_GetPairMng()->peer.confirm, (uint8_t *)param->data, SMP_CONFIRM_DATA_LEN); in SMP_LegacyPairSlaveStep3()
537 SMP_MemoryReverseCopy(SMP_GetPairMng()->peer.random, (uint8_t *)param->data, SMP_RANDOM_DATA_LEN); in SMP_LegacyPairSlaveStep8()
538 SMP_ConstituteC1Step1Param(SMP_ROLE_SLAVE, SMP_GetPairMng()->peer.random, SMP_RANDOM_DATA_LEN, &cryptC1Step1Param); in SMP_LegacyPairSlaveStep8()
585 if (memcmp(confirm, SMP_GetPairMng()->peer in SMP_LegacyPairSlaveStep10()
[all...]
H A Dsmp.c328 g_smpPairMng.peer.addr.type = param->peerAddr.type; in SMP_StartPairTask()
331 SMP_MemoryReverseCopy(g_smpPairMng.peer.addr.addr, param->peerAddr.addr, sizeof(g_smpPairMng.peer.addr.addr)); in SMP_StartPairTask()
479 g_smpPairMng.peer.addr.type = param->peerAddr.type; in SMP_RemotePairReqReplyTask()
482 SMP_MemoryReverseCopy(g_smpPairMng.peer.addr.addr, param->peerAddr.addr, sizeof(g_smpPairMng.peer.addr.addr)); in SMP_RemotePairReqReplyTask()
1245 DHKeyParam.remoteP256PublicKey, SMP_PUBLICKEY_LEN, g_smpPairMng.peer.publicKey, SMP_PUBLICKEY_LEN); in SMP_AuthReqReplyOobSlave()
1279 SMP_MemoryReverseCopy(g_smpPairMng.peer.addr.addr, entryValue, sizeof(g_smpPairMng.peer.addr.addr)); in SMP_AuthReqReplyObtainEntryValue()
1280 (void)memcpy_s(g_smpPairMng.peer in SMP_AuthReqReplyObtainEntryValue()
[all...]
/foundation/arkui/ace_engine/frameworks/core/interfaces/native/node/
H A Dextension_companion_node.h28 ExtensionCompanionNode(int peerId, int flags, void* peer) in ExtensionCompanionNode() argument
29 : peerId_(peerId), flags_(flags), peer_(peer) in ExtensionCompanionNode()
57 void SetPeer(void* peer) in SetPeer() argument
59 peer_ = peer; in SetPeer()
/foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/src/communicator/
H A Dapp_pipe_handler.cpp55 const struct PipeInfo &pipeInfo, __attribute__((unused)) const struct DeviceId &peer) in IsSameStartedOnPeer()
57 return softbusAdapter_->IsSameStartedOnPeer(pipeInfo, peer); in IsSameStartedOnPeer()
54 IsSameStartedOnPeer( const struct PipeInfo &pipeInfo, __attribute__((unused)) const struct DeviceId &peer) IsSameStartedOnPeer() argument
H A Dcommunication_provider_impl.cpp87 bool CommunicationProviderImpl::IsSameStartedOnPeer(const PipeInfo &pipeInfo, const DeviceId &peer) const in IsSameStartedOnPeer()
89 return appPipeMgr_.IsSameStartedOnPeer(pipeInfo, peer); in IsSameStartedOnPeer()
H A Dapp_pipe_mgr.cpp127 bool AppPipeMgr::IsSameStartedOnPeer(const struct PipeInfo &pipeInfo, const struct DeviceId &peer) in IsSameStartedOnPeer() argument
130 if (pipeInfo.pipeId.empty() || peer.deviceId.empty()) { in IsSameStartedOnPeer()
145 return appPipeHandler->IsSameStartedOnPeer(pipeInfo, peer); in IsSameStartedOnPeer()
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/communicator/src/
H A Dapp_pipe_handler.cpp64 __attribute__((unused))const struct DeviceId &peer) in IsSameStartedOnPeer()
66 return softbusAdapter_->IsSameStartedOnPeer(pipeInfo, peer); in IsSameStartedOnPeer()
63 IsSameStartedOnPeer(const struct PipeInfo &pipeInfo, __attribute__((unused))const struct DeviceId &peer) IsSameStartedOnPeer() argument
H A Dcommunication_provider_impl.cpp67 bool CommunicationProviderImpl::IsSameStartedOnPeer(const PipeInfo &pipeInfo, const DeviceId &peer) const in IsSameStartedOnPeer()
69 return appPipeMgr_.IsSameStartedOnPeer(pipeInfo, peer); in IsSameStartedOnPeer()
H A Dapp_pipe_mgr.cpp127 bool AppPipeMgr::IsSameStartedOnPeer(const struct PipeInfo &pipeInfo, const struct DeviceId &peer) in IsSameStartedOnPeer() argument
130 if (pipeInfo.pipeId.empty() || peer.deviceId.empty()) { in IsSameStartedOnPeer()
145 return appPipeHandler->IsSameStartedOnPeer(pipeInfo, peer); in IsSameStartedOnPeer()
H A Dapp_pipe_handler.h47 bool IsSameStartedOnPeer(const struct PipeInfo &pipeInfo, const struct DeviceId &peer);
H A Dapp_pipe_mgr.h46 bool IsSameStartedOnPeer(const struct PipeInfo &pipeInfo, const struct DeviceId &peer);
H A Dcommunication_provider_impl.h48 bool IsSameStartedOnPeer(const PipeInfo &pipeInfo, const DeviceId &peer) const override;
/foundation/arkui/napi/sample/native_module_netserver/
H A Dnet_server.cpp73 void NetServer::OnClose(uv_handle_t* peer) in OnClose() argument
75 if (peer == nullptr) { in OnClose()
76 HILOG_ERROR("peer is null"); in OnClose()
80 NetServer* that = static_cast<NetServer*>(peer->data); in OnClose()
82 free(peer); in OnClose()
H A Dnetserver.cpp72 void NetServer::OnClose(uv_handle_t* peer) in OnClose() argument
74 if (peer == nullptr) { in OnClose()
75 HILOG_ERROR("peer is null"); in OnClose()
79 NetServer* that = (NetServer*)peer->data; in OnClose()
81 free(peer); in OnClose()
/foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/include/communicator/
H A Dapp_pipe_mgr.h51 bool IsSameStartedOnPeer(const struct PipeInfo &pipeInfo, const struct DeviceId &peer);
H A Dapp_pipe_handler.h43 bool IsSameStartedOnPeer(const struct PipeInfo &pipeInfo, const struct DeviceId &peer);
H A Dcommunication_provider_impl.h61 bool IsSameStartedOnPeer(const PipeInfo &pipeInfo, const DeviceId &peer) const override;
H A Dcommunication_provider.h71 // check peer device pipeInfo Process
72 KVSTORE_API virtual bool IsSameStartedOnPeer(const PipeInfo &pipeInfo, const DeviceId &peer) const = 0;
/foundation/communication/wifi/wifi/services/wifi_standard/wifi_framework/wifi_manage/wifi_p2p/
H A Dp2p_idle_state.cpp401 WIFI_LOGW("Failed to get the peer information."); in ProcessInvitationReceivedEvt()
406 const WifiP2pDevice peer = deviceManager.GetDevices(owner.GetDeviceAddress()); in ProcessInvitationReceivedEvt() local
407 if (!peer.IsValid()) { in ProcessInvitationReceivedEvt()
412 deviceManager.UpdateDeviceGroupCap(peer.GetDeviceAddress(), static_cast<size_t>(peer.GetGroupCapabilitys()) | 0x01); in ProcessInvitationReceivedEvt()
415 if (peer.WpsPbcSupported()) { in ProcessInvitationReceivedEvt()
417 } else if (peer.WpsDisplaySupported()) { in ProcessInvitationReceivedEvt()
419 } else if (peer.WpKeypadSupported()) { in ProcessInvitationReceivedEvt()

Completed in 17 milliseconds

12