Home
last modified time | relevance | path

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

12345678910>>...26

/openbmc/linux/drivers/net/wireguard/
H 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 …]
H 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()
64 return peer; in wg_peer_create()
75 if (unlikely(!peer || !kref_get_unless_zero(&peer->refcount))) in wg_peer_get_maybe_zero()
77 return peer; in wg_peer_get_maybe_zero()
84 wg_allowedips_remove_by_peer(&peer->device->peer_allowedips, peer, in peer_make_dead()
86 wg_pubkey_hashtable_remove(peer->device->peer_hashtable, peer); in peer_make_dead()
196 memzero_explicit(peer, sizeof(*peer)); in rcu_release()
[all …]
H 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()
92 &peer->endpoint.addr); 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()
[all …]
H 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()
486 wg_peer_put(peer); in set_peer()
526 struct wg_peer *peer; in wg_set_device() local
561 if (peer) { in wg_set_device()
[all …]
H A Dreceive.c23 peer->rx_bytes += len; in update_rx_stats()
145 if (unlikely(!peer)) { in wg_receive_handshake_packet()
167 if (unlikely(!peer)) { in wg_receive_handshake_packet()
192 if (unlikely(!peer)) { in wg_receive_handshake_packet()
203 wg_peer_put(peer); in wg_receive_handshake_packet()
351 keep_key_fresh(peer); in wg_packet_consume_data_done()
424 dev->name, peer->internal_id, &peer->endpoint.addr); in wg_packet_consume_data_done()
430 dev->name, peer->internal_id, &peer->endpoint.addr); in wg_packet_consume_data_done()
479 wg_peer_put(peer); in wg_packet_rx_poll()
519 &peer); in wg_packet_consume_data()
[all …]
H 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 …]
H 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);
H A Ddevice.c36 struct wg_peer *peer; in wg_open() local
57 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_vm_notification() local
118 struct wg_peer *peer; in wg_stop() local
124 wg_timers_stop(peer); in wg_stop()
141 struct wg_peer *peer; in wg_xmit() local
154 if (unlikely(!peer)) { in wg_xmit()
220 wg_peer_put(peer); in wg_xmit()
224 wg_peer_put(peer); in wg_xmit()
[all …]
/openbmc/linux/net/rxrpc/
H A Dpeer_object.c141 if (peer) in rxrpc_lookup_peer_rcu()
143 return peer; in rxrpc_lookup_peer_rcu()
216 if (peer) { in rxrpc_alloc_peer()
233 return peer; in rxrpc_alloc_peer()
244 peer->mtu = peer->if_mtu; in rxrpc_init_peer()
269 peer->maxdata = peer->mtu - peer->hdrsize; in rxrpc_init_peer()
285 if (peer) { in rxrpc_create_peer()
364 if (peer) in rxrpc_lookup_peer()
394 if (peer) { in rxrpc_get_peer_maybe()
429 if (peer) { in rxrpc_put_peer()
[all …]
H 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 …]
H A Dpeer_event.c106 if (mtu > 0 && peer->if_mtu == 65535 && mtu < peer->if_mtu) in rxrpc_adjust_mtu()
107 peer->if_mtu = mtu; in rxrpc_adjust_mtu()
111 mtu = peer->if_mtu; in rxrpc_adjust_mtu()
123 if (mtu < peer->mtu) { in rxrpc_adjust_mtu()
125 peer->mtu = mtu; in rxrpc_adjust_mtu()
126 peer->maxdata = peer->mtu - peer->hdrsize; in rxrpc_adjust_mtu()
149 if (peer && !rxrpc_get_peer_maybe(peer, rxrpc_peer_get_input_error)) in rxrpc_input_error()
150 peer = NULL; in rxrpc_input_error()
152 if (!peer) in rxrpc_input_error()
208 spin_lock(&peer->lock); in rxrpc_distribute_error()
[all …]
H A Dconn_service.c41 p = rcu_dereference_raw(peer->service_conns.rb_node); in rxrpc_find_service_conn_rcu()
55 done_seqretry(&peer->service_conn_lock, seq); in rxrpc_find_service_conn_rcu()
71 write_seqlock(&peer->service_conn_lock); in rxrpc_publish_service_conn()
73 pp = &peer->service_conns.rb_node; in rxrpc_publish_service_conn()
92 write_sequnlock(&peer->service_conn_lock); in rxrpc_publish_service_conn()
99 write_sequnlock(&peer->service_conn_lock); in rxrpc_publish_service_conn()
111 &peer->service_conns); in rxrpc_publish_service_conn()
180 rxrpc_publish_service_conn(conn->peer, conn); in rxrpc_new_incoming_connection()
189 struct rxrpc_peer *peer = conn->peer; in rxrpc_unpublish_service_conn() local
191 write_seqlock(&peer->service_conn_lock); in rxrpc_unpublish_service_conn()
[all …]
/openbmc/linux/drivers/net/wireless/ath/ath12k/
H A Dpeer.c24 return peer; in ath12k_peer_find()
43 return peer; in ath12k_peer_find_by_pdev_idx()
60 return peer; in ath12k_peer_find_by_addr()
75 return peer; in ath12k_peer_find_by_id()
117 if (!peer) { in ath12k_peer_unmap_event()
124 peer->vdev_id, peer->addr, peer_id); in ath12k_peer_unmap_event()
127 kfree(peer); in ath12k_peer_unmap_event()
141 if (!peer) { in ath12k_peer_map_event()
142 peer = kzalloc(sizeof(*peer), GFP_ATOMIC); in ath12k_peer_map_event()
143 if (!peer) in ath12k_peer_map_event()
[all …]
/openbmc/qemu/contrib/ivshmem-client/
H A Divshmem-client.c86 g_free(peer); in ivshmem_client_free_peer()
108 if (peer == NULL || peer == &client->local) { in ivshmem_client_handle_server_msg()
120 if (peer == NULL) { in ivshmem_client_handle_server_msg()
121 peer = g_malloc0(sizeof(*peer)); in ivshmem_client_handle_server_msg()
122 peer->id = peer_id; in ivshmem_client_handle_server_msg()
130 PRId64 "\n", peer->vectors_count, fd, peer->id); in ivshmem_client_handle_server_msg()
131 if (peer->vectors_count >= G_N_ELEMENTS(peer->vectors)) { in ivshmem_client_handle_server_msg()
136 peer->vectors[peer->vectors_count] = fd; in ivshmem_client_handle_server_msg()
137 peer->vectors_count++; in ivshmem_client_handle_server_msg()
303 if (peer->vectors[i] >= maxfd || !FD_ISSET(peer->vectors[i], cur)) { in ivshmem_client_handle_event()
[all …]
/openbmc/linux/drivers/net/can/
H A Dvxcan.c49 peer = rcu_dereference(priv->peer); in vxcan_xmit()
90 struct net_device *peer = rtnl_dereference(priv->peer); in vxcan_open() local
92 if (!peer) in vxcan_open()
105 struct net_device *peer = rtnl_dereference(priv->peer); in vxcan_close() local
108 if (peer) in vxcan_close()
121 peer = rcu_dereference(priv->peer); in vxcan_get_iflink()
122 iflink = peer ? peer->ifindex : 0; in vxcan_get_iflink()
252 rcu_assign_pointer(priv->peer, peer); in vxcan_newlink()
270 peer = rtnl_dereference(priv->peer); in vxcan_dellink()
279 if (peer) { in vxcan_dellink()
[all …]
/openbmc/qemu/contrib/ivshmem-server/
H A Divshmem-server.c80 close(peer->sock_fd); in ivshmem_server_free_peer()
92 g_free(peer); in ivshmem_server_free_peer()
111 ret = ivshmem_server_send_one_msg(peer->sock_fd, peer->id, -1); in ivshmem_server_send_initial_info()
153 peer = g_malloc0(sizeof(*peer)); in ivshmem_server_handle_new_conn()
154 peer->sock_fd = newfd; in ivshmem_server_handle_new_conn()
168 g_free(peer); in ivshmem_server_handle_new_conn()
206 ivshmem_server_send_one_msg(peer->sock_fd, peer->id, in ivshmem_server_handle_new_conn()
220 g_free(peer); in ivshmem_server_handle_new_conn()
389 IvshmemServerPeer *peer; in ivshmem_server_get_fds() local
424 if (peer->sock_fd < maxfd && FD_ISSET(peer->sock_fd, fds)) { in ivshmem_server_handle_fds()
[all …]
/openbmc/linux/drivers/net/wireless/ath/ath11k/
H A Dpeer.c22 return peer; in ath11k_peer_find_list_by_id()
41 return peer; in ath11k_peer_find()
60 return peer; in ath11k_peer_find_by_addr()
76 return peer; in ath11k_peer_find_by_id()
110 peer->vdev_id, peer->addr, peer_id); in ath11k_peer_unmap_event()
128 peer = kzalloc(sizeof(*peer), GFP_ATOMIC); in ath11k_peer_map_event()
220 peer->addr, peer->peer_id, ret); in ath11k_peer_rhash_add()
228 peer->addr, peer->peer_id, ret); in ath11k_peer_rhash_add()
310 if (peer && peer->vdev_id == vdev_id) in __ath11k_peer_delete()
488 peer->addr, peer->peer_id, ret); in ath11k_peer_rhash_delete()
[all …]
/openbmc/linux/drivers/ntb/test/
H 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 …]
H 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 …]
/openbmc/linux/net/tipc/
H 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()
524 if (!peer || !peer->is_up) in tipc_mon_rcv()
620 if (peer) { in tipc_mon_get_state()
[all …]
/openbmc/linux/net/sctp/
H A Dassociola.c494 if (asoc->peer.retran_path == peer) in sctp_assoc_rm_peer()
507 if (asoc->peer.primary_path == peer) in sctp_assoc_rm_peer()
509 if (asoc->peer.active_path == peer) in sctp_assoc_rm_peer()
511 if (asoc->peer.retran_path == peer) in sctp_assoc_rm_peer()
513 if (asoc->peer.last_data_from == peer) in sctp_assoc_rm_peer()
727 asoc->peer.retran_path = peer; in sctp_assoc_add_peer()
732 asoc->peer.retran_path = peer; in sctp_assoc_add_peer()
1110 asoc->peer.rwnd = new->peer.rwnd; in sctp_assoc_update()
1111 asoc->peer.sack_needed = new->peer.sack_needed; in sctp_assoc_update()
1113 asoc->peer.i = new->peer.i; in sctp_assoc_update()
[all …]
/openbmc/qemu/net/
H A Dclients.h30 NetClientState *peer, Error **errp);
34 NetClientState *peer, Error **errp);
38 NetClientState *peer, Error **errp);
41 NetClientState *peer, Error **errp);
44 NetClientState *peer, Error **errp);
47 NetClientState *peer, Error **errp);
50 NetClientState *peer, Error **errp);
53 NetClientState *peer, Error **errp);
56 NetClientState *peer, Error **errp);
59 NetClientState *peer, Error **errp);
[all …]
/openbmc/linux/drivers/net/wireless/ath/ath10k/
H A Dtxrx.c153 struct ath10k_peer *peer; in ath10k_peer_find() local
163 return peer; in ath10k_peer_find()
171 struct ath10k_peer *peer; in ath10k_peer_find_by_id() local
180 return peer; in ath10k_peer_find_by_id()
232 if (!peer) { in ath10k_peer_map_event()
233 peer = kzalloc(sizeof(*peer), GFP_ATOMIC); in ath10k_peer_map_event()
234 if (!peer) in ath10k_peer_map_event()
268 if (!peer) { in ath10k_peer_unmap_event()
275 peer->vdev_id, peer->addr, ev->peer_id); in ath10k_peer_unmap_event()
281 list_del(&peer->list); in ath10k_peer_unmap_event()
[all …]
/openbmc/linux/net/smc/
H 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 …]
/openbmc/linux/net/bluetooth/
H 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()
911 if (!peer) in bt_6lowpan_disconnect()
914 BT_DBG("peer %p chan %p", peer, peer->chan); in bt_6lowpan_disconnect()
[all …]

12345678910>>...26