Home
last modified time | relevance | path

Searched refs:peer (Results 226 - 250 of 1158) sorted by relevance

12345678910>>...47

/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()
/kernel/linux/linux-6.6/tools/testing/selftests/netfilter/
H A Dipip-conntrack-mtu.sh94 ip link add veth0 netns ${r_a} type veth peer name veth0 netns ${r_w}
95 ip link add veth1 netns ${r_a} type veth peer name veth0 netns ${c_a}
124 ip link add veth0 netns ${r_b} type veth peer name veth1 netns ${r_w}
125 ip link add veth1 netns ${r_b} type veth peer name veth0 netns ${c_b}
/kernel/linux/linux-5.10/drivers/net/ethernet/qlogic/qlcnic/
H A Dqlcnic_dcb.c1019 struct qlcnic_dcb_cee *peer; in qlcnic_dcb_peer_app_info() local
1028 peer = &adapter->dcb->cfg->type[QLC_DCB_PEER_IDX]; in qlcnic_dcb_peer_app_info()
1031 if (peer->app[i].valid) in qlcnic_dcb_peer_app_info()
1042 struct qlcnic_dcb_cee *peer; in qlcnic_dcb_peer_app_table() local
1049 peer = &adapter->dcb->cfg->type[QLC_DCB_PEER_IDX]; in qlcnic_dcb_peer_app_table()
1052 app = &peer->app[i]; in qlcnic_dcb_peer_app_table()
1068 struct qlcnic_dcb_cee *peer; in qlcnic_dcb_cee_peer_get_pg() local
1074 peer = &adapter->dcb->cfg->type[QLC_DCB_PEER_IDX]; in qlcnic_dcb_cee_peer_get_pg()
1077 if (!peer->pg_cfg[i].valid) in qlcnic_dcb_cee_peer_get_pg()
1080 pg->pg_bw[j] = peer in qlcnic_dcb_cee_peer_get_pg()
1101 struct qlcnic_dcb_cee *peer; qlcnic_dcb_cee_peer_get_pfc() local
[all...]
/kernel/linux/linux-6.6/drivers/net/ethernet/qlogic/qlcnic/
H A Dqlcnic_dcb.c1019 struct qlcnic_dcb_cee *peer; in qlcnic_dcb_peer_app_info() local
1028 peer = &adapter->dcb->cfg->type[QLC_DCB_PEER_IDX]; in qlcnic_dcb_peer_app_info()
1031 if (peer->app[i].valid) in qlcnic_dcb_peer_app_info()
1042 struct qlcnic_dcb_cee *peer; in qlcnic_dcb_peer_app_table() local
1049 peer = &adapter->dcb->cfg->type[QLC_DCB_PEER_IDX]; in qlcnic_dcb_peer_app_table()
1052 app = &peer->app[i]; in qlcnic_dcb_peer_app_table()
1068 struct qlcnic_dcb_cee *peer; in qlcnic_dcb_cee_peer_get_pg() local
1074 peer = &adapter->dcb->cfg->type[QLC_DCB_PEER_IDX]; in qlcnic_dcb_cee_peer_get_pg()
1077 if (!peer->pg_cfg[i].valid) in qlcnic_dcb_cee_peer_get_pg()
1080 pg->pg_bw[j] = peer in qlcnic_dcb_cee_peer_get_pg()
1101 struct qlcnic_dcb_cee *peer; qlcnic_dcb_cee_peer_get_pfc() local
[all...]
/kernel/linux/linux-6.6/drivers/net/wireless/ath/ath11k/
H A Ddp_tx.c12 #include "peer.h"
324 struct ath11k_peer *peer; in ath11k_dp_tx_htt_tx_complete_buf() local
366 peer = ath11k_peer_find_by_id(ab, ts->peer_id); in ath11k_dp_tx_htt_tx_complete_buf()
367 if (!peer || !peer->sta) { in ath11k_dp_tx_htt_tx_complete_buf()
369 "dp_tx: failed to find the peer with peer_id %d\n", in ath11k_dp_tx_htt_tx_complete_buf()
377 status.sta = peer->sta; in ath11k_dp_tx_htt_tx_complete_buf()
454 struct ath11k_peer *peer; in ath11k_dp_tx_update_txcompl() local
462 peer = ath11k_peer_find_by_id(ab, ts->peer_id); in ath11k_dp_tx_update_txcompl()
463 if (!peer || !pee in ath11k_dp_tx_update_txcompl()
555 struct ath11k_peer *peer; ath11k_dp_tx_complete_msdu() local
[all...]
/kernel/linux/linux-5.10/drivers/block/drbd/
H A Ddrbd_state.c353 enum drbd_role peer = R_UNKNOWN; in conn_highest_peer() local
360 peer = max_role(peer, device->state.peer); in conn_highest_peer()
364 return peer; in conn_highest_peer()
721 drbd_role_str(ns.peer), in print_st()
754 if (ns.peer != os.peer && flags & CS_DC_PEER) in print_state_change()
755 pbp += sprintf(pbp, "peer( %s -> %s ) ", in print_state_change()
756 drbd_role_str(os.peer), in print_state_change()
[all...]
/kernel/linux/linux-6.6/drivers/block/drbd/
H A Ddrbd_state.c353 enum drbd_role peer = R_UNKNOWN; in conn_highest_peer() local
360 peer = max_role(peer, device->state.peer); in conn_highest_peer()
364 return peer; in conn_highest_peer()
721 drbd_role_str(ns.peer), in print_st()
754 if (ns.peer != os.peer && flags & CS_DC_PEER) in print_state_change()
755 pbp += sprintf(pbp, "peer( %s -> %s ) ", in print_state_change()
756 drbd_role_str(os.peer), in print_state_change()
[all...]
/foundation/communication/bluetooth_service/services/bluetooth/stack/src/smp/
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...]
/kernel/liteos_a/kernel/extended/container/
H A Dlos_net_container.c56 if (netif->peer != NULL) { in FreeNetif()
57 netif_remove(netif->peer); in FreeNetif()
58 (VOID)LOS_MemFree(m_aucSysMem1, netif->peer); in FreeNetif()
94 vethOfNetContainer->peer = vethOfRootNetContainer; in InitVethPair()
95 vethOfRootNetContainer->peer = vethOfNetContainer; in InitVethPair()
/kernel/linux/linux-5.10/drivers/ata/
H A Dpata_amd.c50 struct ata_device *peer = ata_dev_pair(adev); in timing_setup() local
67 if (peer) { in timing_setup()
69 if (peer->dma_mode) { in timing_setup()
70 ata_timing_compute(peer, peer->dma_mode, &apeer, T, UT); in timing_setup()
73 ata_timing_compute(peer, peer->pio_mode, &apeer, T, UT); in timing_setup()
/kernel/linux/linux-5.10/drivers/net/wireless/broadcom/brcm80211/brcmfmac/
H A Dflowring.c432 u8 peer[ETH_ALEN]) in brcmf_flowring_delete_peer()
448 if (memcmp(search->mac, peer, ETH_ALEN) == 0) { in brcmf_flowring_delete_peer()
458 if ((sta || (memcmp(hash[i].mac, peer, ETH_ALEN) == 0)) && in brcmf_flowring_delete_peer()
481 u8 peer[ETH_ALEN]) in brcmf_flowring_add_tdls_peer()
490 memcpy(tdls_entry->mac, peer, ETH_ALEN); in brcmf_flowring_add_tdls_peer()
496 if (memcmp(search->mac, peer, ETH_ALEN) == 0) in brcmf_flowring_add_tdls_peer()
500 if (memcmp(search->mac, peer, ETH_ALEN) == 0) in brcmf_flowring_add_tdls_peer()
431 brcmf_flowring_delete_peer(struct brcmf_flowring *flow, int ifidx, u8 peer[ETH_ALEN]) brcmf_flowring_delete_peer() argument
480 brcmf_flowring_add_tdls_peer(struct brcmf_flowring *flow, int ifidx, u8 peer[ETH_ALEN]) brcmf_flowring_add_tdls_peer() argument
/kernel/linux/linux-5.10/net/smc/
H A Dsmc_cdc.c138 struct smc_cdc_msg *peer; in smcr_cdc_msg_send_validation() local
141 peer = (struct smc_cdc_msg *)wr_buf; in smcr_cdc_msg_send_validation()
142 peer->common.type = local->common.type; in smcr_cdc_msg_send_validation()
143 peer->len = local->len; in smcr_cdc_msg_send_validation()
144 peer->seqno = htons(conn->tx_cdc_seq_fin); /* seqno last compl. tx */ in smcr_cdc_msg_send_validation()
145 peer->token = htonl(local->token); in smcr_cdc_msg_send_validation()
146 peer->prod_flags.failover_validation = 1; in smcr_cdc_msg_send_validation()
223 * Also update the confirmed receive buffer with what was sent to the peer.
351 /* trigger sndbuf consumer: RDMA write into peer RMBE and CDC */ in smc_cdc_msg_recv_action()
359 /* urg data confirmed by peer, indicat in smc_cdc_msg_recv_action()
[all...]
/kernel/linux/linux-6.6/drivers/net/ethernet/mellanox/mlx5/core/steering/
H A Ddr_domain.c564 struct mlx5dr_domain *peer; in mlx5dr_domain_set_peer() local
568 peer = xa_load(&dmn->peer_dmn_xa, peer_vhca_id); in mlx5dr_domain_set_peer()
569 if (peer) in mlx5dr_domain_set_peer()
570 refcount_dec(&peer->refcount); in mlx5dr_domain_set_peer()
574 peer = xa_load(&dmn->peer_dmn_xa, peer_vhca_id); in mlx5dr_domain_set_peer()
575 if (peer) in mlx5dr_domain_set_peer()
576 refcount_inc(&peer->refcount); in mlx5dr_domain_set_peer()
/kernel/linux/linux-6.6/drivers/ata/
H A Dpata_amd.c50 struct ata_device *peer = ata_dev_pair(adev); in timing_setup() local
67 if (peer) { in timing_setup()
69 if (ata_dma_enabled(peer)) { in timing_setup()
70 ata_timing_compute(peer, peer->dma_mode, &apeer, T, UT); in timing_setup()
73 ata_timing_compute(peer, peer->pio_mode, &apeer, T, UT); in timing_setup()
/kernel/linux/linux-6.6/drivers/net/wireless/broadcom/brcm80211/brcmfmac/
H A Dflowring.c431 u8 peer[ETH_ALEN]) in brcmf_flowring_delete_peer()
447 if (memcmp(search->mac, peer, ETH_ALEN) == 0) { in brcmf_flowring_delete_peer()
457 if ((sta || (memcmp(hash[i].mac, peer, ETH_ALEN) == 0)) && in brcmf_flowring_delete_peer()
478 u8 peer[ETH_ALEN]) in brcmf_flowring_add_tdls_peer()
487 memcpy(tdls_entry->mac, peer, ETH_ALEN); in brcmf_flowring_add_tdls_peer()
493 if (memcmp(search->mac, peer, ETH_ALEN) == 0) in brcmf_flowring_add_tdls_peer()
497 if (memcmp(search->mac, peer, ETH_ALEN) == 0) in brcmf_flowring_add_tdls_peer()
430 brcmf_flowring_delete_peer(struct brcmf_flowring *flow, int ifidx, u8 peer[ETH_ALEN]) brcmf_flowring_delete_peer() argument
477 brcmf_flowring_add_tdls_peer(struct brcmf_flowring *flow, int ifidx, u8 peer[ETH_ALEN]) brcmf_flowring_add_tdls_peer() argument
/kernel/linux/linux-6.6/net/smc/
H A Dsmc_cdc.c148 struct smc_cdc_msg *peer; in smcr_cdc_msg_send_validation() local
151 peer = (struct smc_cdc_msg *)wr_buf; in smcr_cdc_msg_send_validation()
152 peer->common.type = local->common.type; in smcr_cdc_msg_send_validation()
153 peer->len = local->len; in smcr_cdc_msg_send_validation()
154 peer->seqno = htons(conn->tx_cdc_seq_fin); /* seqno last compl. tx */ in smcr_cdc_msg_send_validation()
155 peer->token = htonl(local->token); in smcr_cdc_msg_send_validation()
156 peer->prod_flags.failover_validation = 1; in smcr_cdc_msg_send_validation()
234 * Also update the confirmed receive buffer with what was sent to the peer.
362 /* trigger sndbuf consumer: RDMA write into peer RMBE and CDC */ in smc_cdc_msg_recv_action()
374 /* urg data confirmed by peer, indicat in smc_cdc_msg_recv_action()
[all...]
/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 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
/kernel/linux/linux-5.10/drivers/net/wireguard/
H A Dcookie.h44 void wg_cookie_checker_precompute_peer_keys(struct wg_peer *peer);
51 struct wg_peer *peer);
/kernel/linux/linux-6.6/include/soc/tegra/
H A Divc.h17 struct device *peer; member
96 int tegra_ivc_init(struct tegra_ivc *ivc, struct device *peer, const struct iosys_map *rx,
/kernel/linux/linux-6.6/drivers/net/wireguard/
H A Dcookie.h44 void wg_cookie_checker_precompute_peer_keys(struct wg_peer *peer);
51 struct wg_peer *peer);
/kernel/linux/linux-5.10/net/rxrpc/
H A Dconn_client.c126 rxrpc_get_peer(bundle->params.peer); in rxrpc_alloc_bundle()
143 rxrpc_put_peer(bundle->params.peer); in rxrpc_free_bundle()
203 rxrpc_get_peer(conn->params.peer); in rxrpc_alloc_client_connection()
282 cp->peer, key_serial(cp->key), cp->security_level, cp->upgrade); in rxrpc_look_up_bundle()
295 diff = (cmp(peer) ?: in rxrpc_look_up_bundle()
324 diff = (cmp(peer) ?: in rxrpc_look_up_bundle()
372 cp->peer = rxrpc_lookup_peer(rx, cp->local, srx, gfp); in rxrpc_prep_call()
373 if (!cp->peer) in rxrpc_prep_call()
376 call->cong_cwnd = cp->peer->cong_cwnd; in rxrpc_prep_call()
540 call->peer in rxrpc_activate_one_channel()
[all...]
H A Dinput.c94 if (call->peer->rtt_count == 0) in rxrpc_congestion_management()
98 call->peer->srtt_us >> 3))) in rxrpc_congestion_management()
729 struct rxrpc_peer *peer; in rxrpc_input_ackinfo() local
753 peer = call->peer; in rxrpc_input_ackinfo()
754 if (mtu < peer->maxdata) { in rxrpc_input_ackinfo()
755 spin_lock_bh(&peer->lock); in rxrpc_input_ackinfo()
756 peer->maxdata = mtu; in rxrpc_input_ackinfo()
757 peer->mtu = mtu + peer in rxrpc_input_ackinfo()
1221 struct rxrpc_peer *peer = NULL; rxrpc_input_packet() local
[all...]

Completed in 25 milliseconds

12345678910>>...47