Home
last modified time | relevance | path

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

12

/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/include/communicator/
H A Dcommunication_provider.h57 // check peer device pipeInfo Process
58 virtual bool IsSameStartedOnPeer(const PipeInfo &pipeInfo, const DeviceId &peer) const = 0;
/foundation/arkui/napi/sample/native_module_netserver/
H A Dnet_server.h66 static void OnClose(uv_handle_t* peer);
H A Dnetserver.h107 static void OnClose(uv_handle_t* peer);
/foundation/communication/bluetooth_service/services/bluetooth/service/src/gavdp/
H A Da2dp_state_machine.cpp232 A2dpProfilePeer *peer = profile->FindPeerByAddress(addr); in ProcessDiscoverReq() local
233 if (peer == nullptr) { in ProcessDiscoverReq()
239 } else if (peer->GetDisconnectIndication()) { in ProcessDiscoverReq()
241 peer->SetDisconnectIndication(false); in ProcessDiscoverReq()
1227 A2dpProfilePeer *peer = profile->FindOrCreatePeer(addr, role); in ProcessCloseStreamInd() local
1228 if (peer == nullptr) { in ProcessCloseStreamInd()
1232 peer->SetCurrentCmd(EVT_DISCONNECT_IND); in ProcessCloseStreamInd()
1233 peer->SetSignalingTimer(A2DP_ACCEPT_SIGNALLING_TIMEOUT_MS, false); in ProcessCloseStreamInd()
H A Da2dp_profile.h55 * @param[in] addr: The address of peer device
65 * @param[in] addr: The address of peer device
75 * @param[in] addr: The address of peer device
126 * @brief A function used to connect the peer device
128 * @param[in] device The address of peer device
135 * @brief A function used to disconnect the peer device
137 * @param[in] device The address of peer device
258 * @brief A function to process service informaiton of peer
260 * @param[in] addr The address of peer device
283 * @brief A function to delete the profile peer o
[all...]
/foundation/multimedia/media_foundation/engine/pipeline/core/
H A Dfilter_base.cpp95 auto peer = inPort->GetPeerPort(); in UnlinkPrevFilters() local
97 if (peer) { in UnlinkPrevFilters()
98 peer->Disconnect(); in UnlinkPrevFilters()
110 MEDIA_LOG_I("Filter " PUBLIC_LOG_S " outport " PUBLIC_LOG_S " has no peer port (" PUBLIC_LOG_ZU in GetNextFilters()
129 MEDIA_LOG_I("Filter " PUBLIC_LOG_S " inport " PUBLIC_LOG_S " has no peer port (" PUBLIC_LOG_ZU in GetPreFilters()
/foundation/communication/dsoftbus/components/nstackx/nstackx_ctrl/core/
H A Dnstackx_smartgenius.c153 struct sockaddr_nl peer = {AF_NETLINK, 0, 0, 0}; in SmartGeniusCallback() local
159 len = recvfrom(task->taskfd, innerBuf, BUFLEN, 0, (struct sockaddr *)&peer, &socklen); in SmartGeniusCallback()
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/communicator/src/
H A Dsoftbus_adapter.h58 bool IsSameStartedOnPeer(const struct PipeInfo &pipeInfo, const struct DeviceId &peer);
H A Dsoftbus_adapter_standard.cpp401 __attribute__((unused)) const struct DeviceId &peer) in IsSameStartedOnPeer()
404 KvStoreUtils::ToBeAnonymous(peer.deviceId).c_str()); in IsSameStartedOnPeer()
508 ZLOGI("[OnServerBind] socket:%{public}d, peer name:%{public}s, peer devId:%{public}s", socket, info.name, in OnServerBind()
522 ZLOGE("Get peer socket info failed, socket id %{public}d", socket); in OnServerBytesReceived()
526 ZLOGD("[OnBytesReceived] socket:%{public}d, peer name:%{public}s, peer devId:%{public}s, data len:%{public}u", in OnServerBytesReceived()
400 IsSameStartedOnPeer(const struct PipeInfo &pipeInfo, __attribute__((unused)) const struct DeviceId &peer) IsSameStartedOnPeer() argument
/foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/include/communicator/
H A Dsoftbus_adapter.h64 bool IsSameStartedOnPeer(const struct PipeInfo &pipeInfo, const struct DeviceId &peer);
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/app/src/session_manager/
H A Droute_head_handler_impl.cpp52 ZLOGD("init route handler, app:%{public}s, user:%{public}s, peer:%{public}s", appId_.c_str(), userId_.c_str(), in RouteHeadHandlerImpl()
91 ZLOGI("get peer cap failed"); in GetHeadDataSize()
100 ZLOGI("no valid session to peer device"); in GetHeadDataSize()
209 // flip the local and peer ends in ParseHeadData()
211 SessionPoint peer { .deviceId = session_.sourceDeviceId, .userId = session_.sourceUserId, .appId = session_.appId }; in ParseHeadData()
217 if (SessionManager::GetInstance().CheckSession(local, peer)) { in ParseHeadData()
/foundation/communication/bluetooth_service/services/bluetooth/stack/src/smp/
H A Dsmp_def.h172 SMP_PairProcessData peer; member
H A Dsmp_send.c545 (SMP_GetPairMng()->peer.pairParam.authReq & SMP_AUTH_REQ_BONDING))) { in SMP_SendKeysToRemoteCbProcess()
549 } else if (SMP_GetPairMng()->peer.keyDist == 0x00) { in SMP_SendKeysToRemoteCbProcess()
550 LOG_INFO("g_smpPairMng.peer.keyDist is 0."); in SMP_SendKeysToRemoteCbProcess()
H A Dsmp_hci_event.c785 if (SMP_GetPairMng()->peer.keyDistCmdFlag != 0x00) { in SMP_LinkLayerEncCompMaster()
797 LOG_INFO("g_smpPairMng.peer.keyDistCmdFlag is 0."); in SMP_LinkLayerEncCompMaster()
850 if (SMP_GetPairMng()->peer.keyDist == 0x00) { in SMP_LinkLayerEncCompSlave()
851 LOG_INFO("g_smpPairMng.peer.keyDist is 0."); in SMP_LinkLayerEncCompSlave()
/foundation/communication/dsoftbus/components/nstackx/fillp/src/app_lib/src/
H A Dfillp_dfx.c525 struct sockaddr_in *peer = (struct sockaddr_in *)&sock->netconn->pcb->remoteAddr; in DoShowSockList() local
538 (const struct sockaddr *)peer, sizeof(struct sockaddr_in6)); in DoShowSockList()
549 sendPcb->unrecvList.nodeNum, localAddr, FILLP_NTOHS(local->sin_port), peerAddr, FILLP_NTOHS(peer->sin_port), in DoShowSockList()
/foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/src/communicator/
H A Dsoftbus_adapter_standard.cpp526 const struct PipeInfo &pipeInfo, __attribute__((unused)) const struct DeviceId &peer) in IsSameStartedOnPeer()
528 int socket = GetSocket(pipeInfo, peer); in IsSameStartedOnPeer()
611 LOG_INFO("Server on bind, socket: %{public}d, peer networkId: %{public}s", socket, in OnServerBind()
625 LOG_ERROR("Get peer socket info failed, socket: %{public}d", socket); in OnServerBytesReceived()
525 IsSameStartedOnPeer( const struct PipeInfo &pipeInfo, __attribute__((unused)) const struct DeviceId &peer) IsSameStartedOnPeer() argument

Completed in 14 milliseconds

12