Home
last modified time | relevance | path

Searched refs:peer (Results 1 – 25 of 408) sorted by relevance

12345678910>>...17

/linux/drivers/net/wireguard/
A Dtimers.c43 struct wg_peer *peer = from_timer(peer, timer, in wg_expired_retransmit_handshake() local
48 peer->device->dev->name, peer->internal_id, in wg_expired_retransmit_handshake()
61 mod_peer_timer(peer, &peer->timer_zero_key_material, in wg_expired_retransmit_handshake()
66 peer->device->dev->name, peer->internal_id, in wg_expired_retransmit_handshake()
86 mod_peer_timer(peer, &peer->timer_send_keepalive, in wg_expired_send_keepalive()
96 peer->device->dev->name, peer->internal_id, in wg_expired_new_handshake()
128 peer->device->dev->name, peer->internal_id, in wg_queued_expired_zero_key_material()
137 struct wg_peer *peer = from_timer(peer, timer, in wg_expired_send_persistent_keepalive() local
148 mod_peer_timer(peer, &peer->timer_new_handshake, in wg_timers_data_sent()
158 mod_peer_timer(peer, &peer->timer_send_keepalive, in wg_timers_data_received()
[all …]
A Dpeer.c25 struct wg_peer *peer; in wg_peer_create() local
34 if (unlikely(!peer)) in wg_peer_create()
39 peer->device = wg; in wg_peer_create()
45 wg_timers_init(peer); in wg_peer_create()
65 return peer; in wg_peer_create()
76 if (unlikely(!peer || !kref_get_unless_zero(&peer->refcount))) in wg_peer_get_maybe_zero()
78 return peer; in wg_peer_get_maybe_zero()
85 wg_allowedips_remove_by_peer(&peer->device->peer_allowedips, peer, in peer_make_dead()
87 wg_pubkey_hashtable_remove(peer->device->peer_hashtable, peer); in peer_make_dead()
197 memzero_explicit(peer, sizeof(*peer)); in rcu_release()
[all …]
A Dsend.c31 peer->device->dev->name, peer->internal_id, in wg_packet_send_handshake_initiation()
32 &peer->endpoint.addr); in wg_packet_send_handshake_initiation()
52 wg_peer_put(peer); in wg_packet_handshake_send_worker()
71 wg_peer_get(peer); in wg_packet_send_queued_handshake_initiation()
80 wg_peer_put(peer); in wg_packet_send_queued_handshake_initiation()
91 peer->device->dev->name, peer->internal_id, in wg_packet_send_handshake_response()
235 peer->device->dev->name, peer->internal_id, in wg_packet_send_keepalive()
259 keep_key_fresh(peer); in wg_packet_create_data_done()
281 wg_peer_put(peer); in wg_packet_tx_worker()
329 wg_peer_put(peer); in wg_packet_create_data()
[all …]
A Dnetlink.c275 next_peer_cursor = peer; in wg_get_device_dump()
316 struct wg_peer *peer; in set_port() local
413 if (IS_ERR(peer)) { in set_peer()
414 ret = PTR_ERR(peer); in set_peer()
415 peer = NULL; in set_peer()
421 wg_peer_get(peer); in set_peer()
425 wg_peer_remove(peer); in set_peer()
487 wg_peer_put(peer); in set_peer()
527 struct wg_peer *peer; in wg_set_device() local
561 if (peer) { in wg_set_device()
[all …]
A Dreceive.c28 peer->rx_bytes += len; in update_rx_stats()
152 if (unlikely(!peer)) { in wg_receive_handshake_packet()
174 if (unlikely(!peer)) { in wg_receive_handshake_packet()
199 if (unlikely(!peer)) { in wg_receive_handshake_packet()
210 wg_peer_put(peer); in wg_receive_handshake_packet()
358 keep_key_fresh(peer); in wg_packet_consume_data_done()
431 dev->name, peer->internal_id, &peer->endpoint.addr); in wg_packet_consume_data_done()
437 dev->name, peer->internal_id, &peer->endpoint.addr); in wg_packet_consume_data_done()
486 wg_peer_put(peer); in wg_packet_rx_poll()
526 &peer); in wg_packet_consume_data()
[all …]
A Dcookie.c157 struct wg_peer *peer) in wg_cookie_add_mac_to_packet() argument
167 up_write(&peer->latest_cookie.lock); in wg_cookie_add_mac_to_packet()
169 down_read(&peer->latest_cookie.lock); in wg_cookie_add_mac_to_packet()
170 if (peer->latest_cookie.is_valid && in wg_cookie_add_mac_to_packet()
174 peer->latest_cookie.cookie); in wg_cookie_add_mac_to_packet()
177 up_read(&peer->latest_cookie.lock); in wg_cookie_add_mac_to_packet()
201 struct wg_peer *peer = NULL; in wg_cookie_message_consume() local
208 src->receiver_index, &peer))) in wg_cookie_message_consume()
213 up_read(&peer->latest_cookie.lock); in wg_cookie_message_consume()
220 up_read(&peer->latest_cookie.lock); in wg_cookie_message_consume()
[all …]
A Ddevice.c34 struct wg_peer *peer; in wg_open() local
53 wg_packet_send_staged_packets(peer); in wg_open()
55 wg_packet_send_keepalive(peer); in wg_open()
67 struct wg_peer *peer; in wg_pm_notification() local
100 struct wg_peer *peer; in wg_stop() local
106 wg_timers_stop(peer); in wg_stop()
123 struct wg_peer *peer; in wg_xmit() local
136 if (unlikely(!peer)) { in wg_xmit()
202 wg_peer_put(peer); in wg_xmit()
206 wg_peer_put(peer); in wg_xmit()
[all …]
A Dtimers.h13 void wg_timers_init(struct wg_peer *peer);
14 void wg_timers_stop(struct wg_peer *peer);
15 void wg_timers_data_sent(struct wg_peer *peer);
16 void wg_timers_data_received(struct wg_peer *peer);
17 void wg_timers_any_authenticated_packet_sent(struct wg_peer *peer);
18 void wg_timers_any_authenticated_packet_received(struct wg_peer *peer);
19 void wg_timers_handshake_initiated(struct wg_peer *peer);
20 void wg_timers_handshake_complete(struct wg_peer *peer);
21 void wg_timers_session_derived(struct wg_peer *peer);
22 void wg_timers_any_authenticated_packet_traversal(struct wg_peer *peer);
/linux/net/rxrpc/
A Dpeer_object.c141 if (peer) { in rxrpc_lookup_peer_rcu()
145 return peer; in rxrpc_lookup_peer_rcu()
218 if (peer) { in rxrpc_alloc_peer()
251 peer->mtu = peer->if_mtu; in rxrpc_init_peer()
276 peer->maxdata = peer->mtu - peer->hdrsize; in rxrpc_init_peer()
293 if (peer) { in rxrpc_create_peer()
344 if (peer && !rxrpc_get_peer_maybe(peer)) in rxrpc_lookup_peer()
362 if (peer && !rxrpc_get_peer_maybe(peer)) in rxrpc_lookup_peer()
373 if (peer) in rxrpc_lookup_peer()
405 if (peer) { in rxrpc_get_peer_maybe()
[all …]
A Drtt.c25 return usecs_to_jiffies((peer->srtt_us >> 3) + peer->rttvar_us); in __rxrpc_set_rto()
85 if (peer->mdev_us > peer->mdev_max_us) { in rxrpc_rtt_estimator()
86 peer->mdev_max_us = peer->mdev_us; in rxrpc_rtt_estimator()
87 if (peer->mdev_max_us > peer->rttvar_us) in rxrpc_rtt_estimator()
88 peer->rttvar_us = peer->mdev_max_us; in rxrpc_rtt_estimator()
94 peer->rttvar_us = max(peer->mdev_us, rxrpc_rto_min_us(peer)); in rxrpc_rtt_estimator()
95 peer->mdev_max_us = peer->rttvar_us; in rxrpc_rtt_estimator()
140 peer->backoff = 0; in rxrpc_ack_update_rtt()
152 struct rxrpc_peer *peer = call->peer; in rxrpc_peer_add_rtt() local
166 peer->srtt_us >> 3, peer->rto_j); in rxrpc_peer_add_rtt()
[all …]
A Dpeer_event.c114 if (mtu > 0 && peer->if_mtu == 65535 && mtu < peer->if_mtu) { in rxrpc_adjust_mtu()
115 peer->if_mtu = mtu; in rxrpc_adjust_mtu()
121 mtu = peer->if_mtu; in rxrpc_adjust_mtu()
135 peer->mtu = mtu; in rxrpc_adjust_mtu()
136 peer->maxdata = peer->mtu - peer->hdrsize; in rxrpc_adjust_mtu()
139 peer->mtu, peer->maxdata); in rxrpc_adjust_mtu()
183 if (peer && !rxrpc_get_peer_maybe(peer)) in rxrpc_error_report()
184 peer = NULL; in rxrpc_error_report()
185 if (!peer) { in rxrpc_error_report()
208 rxrpc_put_peer(peer); in rxrpc_error_report()
[all …]
A Dconn_service.c44 read_seqbegin_or_lock(&peer->service_conn_lock, &seq); in rxrpc_find_service_conn_rcu()
46 p = rcu_dereference_raw(peer->service_conns.rb_node); in rxrpc_find_service_conn_rcu()
60 done_seqretry(&peer->service_conn_lock, seq); in rxrpc_find_service_conn_rcu()
76 write_seqlock_bh(&peer->service_conn_lock); in rxrpc_publish_service_conn()
78 pp = &peer->service_conns.rb_node; in rxrpc_publish_service_conn()
97 write_sequnlock_bh(&peer->service_conn_lock); in rxrpc_publish_service_conn()
104 write_sequnlock_bh(&peer->service_conn_lock); in rxrpc_publish_service_conn()
116 &peer->service_conns); in rxrpc_publish_service_conn()
197 struct rxrpc_peer *peer = conn->params.peer; in rxrpc_unpublish_service_conn() local
199 write_seqlock_bh(&peer->service_conn_lock); in rxrpc_unpublish_service_conn()
[all …]
/linux/drivers/net/wireless/ath/ath11k/
A Dpeer.c23 return peer; in ath11k_peer_find()
42 return peer; in ath11k_peer_find_by_pdev_idx()
59 return peer; in ath11k_peer_find_by_addr()
74 return peer; in ath11k_peer_find_by_id()
103 if (!peer) { in ath11k_peer_unmap_event()
110 peer->vdev_id, peer->addr, peer_id); in ath11k_peer_unmap_event()
113 kfree(peer); in ath11k_peer_unmap_event()
127 if (!peer) { in ath11k_peer_map_event()
128 peer = kzalloc(sizeof(*peer), GFP_ATOMIC); in ath11k_peer_map_event()
129 if (!peer) in ath11k_peer_map_event()
[all …]
/linux/drivers/ntb/test/
A Dntb_perf.c534 (void)ntb_peer_mw_clear_trans(peer->perf->ntb, peer->pidx, peer->gidx); in perf_free_outbuf()
544 peer->outbuf_xlat, peer->outbuf_size); in perf_setup_outbuf()
562 (void)ntb_mw_clear_trans(peer->perf->ntb, peer->pidx, peer->gidx); in perf_free_inbuf()
564 peer->inbuf, peer->inbuf_xlat); in perf_free_inbuf()
593 peer->inbuf_size, &peer->inbuf_xlat, in perf_setup_inbuf()
607 peer->inbuf_xlat, peer->inbuf_size); in perf_setup_inbuf()
633 perf_cmd_send(peer, PERF_CMD_SSIZE, peer->outbuf_size); in perf_service_work()
639 perf_cmd_send(peer, PERF_CMD_SXLAT, peer->inbuf_xlat); in perf_service_work()
648 peer == peer->perf->test_peer) { in perf_service_work()
897 peer->out_phys_addr, peer->outbuf_size, in perf_init_test()
[all …]
A Dntb_msi_test.c144 irq_count, peer); in ntb_msit_copy_peer_desc()
155 int peer; in ntb_msit_db_event() local
159 for (peer = 0; peer < sizeof(peer_mask) * 8; peer++) { in ntb_msit_db_event()
160 if (!(peer_mask & BIT(peer))) in ntb_msit_db_event()
171 kfree(nm->peers[peer].msi_desc); in ntb_msit_db_event()
188 if (idx >= peer->num_irqs) in ntb_msit_dbgfs_trigger()
192 idx, peer->pidx); in ntb_msit_dbgfs_trigger()
194 return ntb_msi_peer_trigger(peer->nm->ntb, peer->pidx, in ntb_msit_dbgfs_trigger()
195 &peer->msi_desc[idx]); in ntb_msit_dbgfs_trigger()
205 *port = ntb_peer_port_number(peer->nm->ntb, peer->pidx); in ntb_msit_dbgfs_port_get()
[all …]
/linux/drivers/net/can/
A Dvxcan.c48 peer = rcu_dereference(priv->peer); in vxcan_xmit()
83 struct net_device *peer = rtnl_dereference(priv->peer); in vxcan_open() local
85 if (!peer) in vxcan_open()
98 struct net_device *peer = rtnl_dereference(priv->peer); in vxcan_close() local
101 if (peer) in vxcan_close()
114 peer = rcu_dereference(priv->peer); in vxcan_get_iflink()
115 iflink = peer ? peer->ifindex : 0; in vxcan_get_iflink()
244 rcu_assign_pointer(priv->peer, peer); in vxcan_newlink()
262 peer = rtnl_dereference(priv->peer); in vxcan_dellink()
271 if (peer) { in vxcan_dellink()
[all …]
/linux/net/tipc/
A Dmonitor.c179 peer = peer_prev(peer); in peer_head()
180 return peer; in peer_head()
289 peer = peer_nxt(peer); in mon_update_local_domain()
316 peer = peer_prev(peer); in mon_update_neighbors()
330 for (; peer != self; peer = peer_nxt(peer)) { in mon_assign_roles()
364 if (!peer) in tipc_mon_remove_peer()
397 *peer = p; in tipc_mon_add_peer()
430 if (!peer && !tipc_mon_add_peer(mon, addr, &peer)) in tipc_mon_peer_up()
522 if (!peer || !peer->is_up) in tipc_mon_rcv()
618 if (peer) { in tipc_mon_get_state()
[all …]
/linux/net/sctp/
A Dassociola.c497 if (asoc->peer.retran_path == peer) in sctp_assoc_rm_peer()
510 if (asoc->peer.primary_path == peer) in sctp_assoc_rm_peer()
512 if (asoc->peer.active_path == peer) in sctp_assoc_rm_peer()
514 if (asoc->peer.retran_path == peer) in sctp_assoc_rm_peer()
516 if (asoc->peer.last_data_from == peer) in sctp_assoc_rm_peer()
730 asoc->peer.retran_path = peer; in sctp_assoc_add_peer()
735 asoc->peer.retran_path = peer; in sctp_assoc_add_peer()
1113 asoc->peer.rwnd = new->peer.rwnd; in sctp_assoc_update()
1114 asoc->peer.sack_needed = new->peer.sack_needed; in sctp_assoc_update()
1116 asoc->peer.i = new->peer.i; in sctp_assoc_update()
[all …]
/linux/drivers/staging/fwserial/
A Dfwserial.c418 peer = rcu_dereference(port->peer); in __fwtty_write_port_status()
419 if (peer) { in __fwtty_write_port_status()
614 if (!peer || peer != rcu_access_pointer(port->peer)) { in fwtty_port_handler()
711 peer = rcu_dereference(port->peer); in fwtty_tx()
809 peer = rcu_dereference(port->peer); in fwtty_write_xchar()
1691 rcu_assign_pointer(port->peer, peer); in fwserial_claim_port()
1720 rcu_assign_pointer(ports[i]->peer, peer); in fwserial_find_port()
2001 peer = kzalloc(sizeof(*peer), GFP_KERNEL); in fwserial_add_peer()
2100 if (peer == peer->serial->self) in fwserial_remove_peer()
2510 if (peer->serial->card->guid > peer->guid) in fwserial_handle_plug_req()
[all …]
/linux/drivers/net/wireless/ath/ath10k/
A Dtxrx.c142 struct ath10k_peer *peer; in ath10k_peer_find() local
152 return peer; in ath10k_peer_find()
160 struct ath10k_peer *peer; in ath10k_peer_find_by_id() local
169 return peer; in ath10k_peer_find_by_id()
221 if (!peer) { in ath10k_peer_map_event()
222 peer = kzalloc(sizeof(*peer), GFP_ATOMIC); in ath10k_peer_map_event()
223 if (!peer) in ath10k_peer_map_event()
257 if (!peer) { in ath10k_peer_unmap_event()
264 peer->vdev_id, peer->addr, ev->peer_id); in ath10k_peer_unmap_event()
270 list_del(&peer->list); in ath10k_peer_unmap_event()
[all …]
/linux/net/bluetooth/
A D6lowpan.c113 return peer; in __peer_lookup_chan()
126 return peer; in __peer_lookup_conn()
171 &peer->chan->dst, peer->chan->dst_type, in peer_lookup_dst()
207 if (peer) in lookup_peer()
213 return peer; in lookup_peer()
351 if (!peer) in chan_recv_cb()
639 peer = kzalloc(sizeof(*peer), GFP_ATOMIC); in add_peer_chan()
640 if (!peer) in add_peer_chan()
912 if (!peer) in bt_6lowpan_disconnect()
915 BT_DBG("peer %p chan %p", peer, peer->chan); in bt_6lowpan_disconnect()
[all …]
/linux/net/smc/
A Dsmc_cdc.h201 peer->count = htonl(save->count); in smc_host_cursor_to_cdc()
202 peer->wrap = htons(save->wrap); in smc_host_cursor_to_cdc()
213 peer->len = local->len; in smc_host_msg_to_cdc()
223 union smc_cdc_cursor *peer, in smc_cdc_cursor_to_host() argument
242 struct smc_cdc_msg *peer, in smcr_cdc_msg_to_host() argument
246 local->len = peer->len; in smcr_cdc_msg_to_host()
256 struct smcd_cdc_msg *peer, in smcd_cdc_msg_to_host() argument
261 temp.wrap = peer->prod.wrap; in smcd_cdc_msg_to_host()
262 temp.count = peer->prod.count; in smcd_cdc_msg_to_host()
265 temp.wrap = peer->cons.wrap; in smcd_cdc_msg_to_host()
[all …]
/linux/drivers/net/
A Dveth.c183 data[0] = peer ? peer->ifindex : 0; in veth_get_ethtool_stats()
423 peer = rcu_dereference(priv->peer); in veth_get_stats64()
1204 peer = rtnl_dereference(priv->peer); in veth_set_channels()
1382 peer = rcu_dereference(priv->peer); in veth_get_iflink()
1383 iflink = peer ? peer->ifindex : 0; in veth_get_iflink()
1395 peer = rtnl_dereference(priv->peer); in veth_fix_features()
1437 peer = rcu_dereference(priv->peer); in veth_set_rx_headroom()
1462 peer = rtnl_dereference(priv->peer); in veth_xdp_set()
1741 rcu_assign_pointer(priv->peer, peer); in veth_newlink()
1774 peer = rtnl_dereference(priv->peer); in veth_dellink()
[all …]
/linux/drivers/usb/core/
A Dport.c198 struct usb_port *peer = port_dev->peer; in usb_port_runtime_resume() local
256 struct usb_port *peer = port_dev->peer; in usb_port_runtime_suspend() local
326 if (left->peer == right && right->peer == left) in link_peers()
329 if (left->peer || right->peer) { in link_peers()
373 left->peer = right; in link_peers()
409 WARN(right->peer != left || left->peer != right, in unlink_peers()
431 left->peer = NULL; in unlink_peers()
464 if (peer && peer->location == port_dev->location) { in match_location()
527 if (peer && peer->location == 0) in find_and_link_peer()
619 peer = port_dev->peer; in usb_hub_remove_port_device()
[all …]
/linux/drivers/ntb/
A Dmsi.c101 int peer, peer_widx; in ntb_msi_setup_mws() local
114 for (peer = 0; peer < ntb_peer_port_count(ntb); peer++) { in ntb_msi_setup_mws()
115 peer_widx = ntb_peer_highest_mw_idx(ntb, peer); in ntb_msi_setup_mws()
127 for (peer = 0; peer < ntb_peer_port_count(ntb); peer++) { in ntb_msi_setup_mws()
128 peer_widx = ntb_peer_highest_mw_idx(ntb, peer); in ntb_msi_setup_mws()
144 ret = ntb_mw_set_trans(ntb, peer, peer_widx, in ntb_msi_setup_mws()
156 for (i = 0; i < peer; i++) { in ntb_msi_setup_mws()
157 peer_widx = ntb_peer_highest_mw_idx(ntb, peer); in ntb_msi_setup_mws()
176 int peer; in ntb_msi_clear_mws() local
179 for (peer = 0; peer < ntb_peer_port_count(ntb); peer++) { in ntb_msi_clear_mws()
[all …]

Completed in 80 milliseconds

12345678910>>...17