| /kernel/linux/linux-6.6/drivers/ntb/ |
| H A D | msi.c | 24 * the peer memory windows.
89 * inbound memory windows for each peer (where N is the number of peers).
99 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()
119 ret = ntb_mw_get_align(ntb, peer, peer_widx, &addr_align, in ntb_msi_setup_mws()
127 for (peer = 0; peer < ntb_peer_port_coun in ntb_msi_setup_mws()
176 int peer; ntb_msi_clear_mws() local
367 ntb_msi_peer_trigger(struct ntb_dev *ntb, int peer, struct ntb_msi_desc *desc) ntb_msi_peer_trigger() argument
397 ntb_msi_peer_addr(struct ntb_dev *ntb, int peer, struct ntb_msi_desc *desc, phys_addr_t *msi_addr) ntb_msi_peer_addr() argument
[all...] |
| /kernel/linux/linux-5.10/drivers/net/wireguard/ |
| H A D | peerlookup.c | 7 #include "peer.h"
36 struct wg_peer *peer) in wg_pubkey_hashtable_add()
39 hlist_add_head_rcu(&peer->pubkey_hash, in wg_pubkey_hashtable_add()
40 pubkey_bucket(table, peer->handshake.remote_static)); in wg_pubkey_hashtable_add()
45 struct wg_peer *peer) in wg_pubkey_hashtable_remove()
48 hlist_del_init_rcu(&peer->pubkey_hash); in wg_pubkey_hashtable_remove()
52 /* Returns a strong reference to a peer */
57 struct wg_peer *iter_peer, *peer = NULL; in wg_pubkey_hashtable_lookup() local
64 peer = iter_peer; in wg_pubkey_hashtable_lookup()
68 peer in wg_pubkey_hashtable_lookup()
35 wg_pubkey_hashtable_add(struct pubkey_hashtable *table, struct wg_peer *peer) wg_pubkey_hashtable_add() argument
44 wg_pubkey_hashtable_remove(struct pubkey_hashtable *table, struct wg_peer *peer) wg_pubkey_hashtable_remove() argument
202 wg_index_hashtable_lookup(struct index_hashtable *table, const enum index_hashtable_type type_mask, const __le32 index, struct wg_peer **peer) wg_index_hashtable_lookup() argument
[all...] |
| H A D | device.c | 11 #include "peer.h"
35 struct wg_peer *peer; in wg_open() local
53 list_for_each_entry(peer, &wg->peer_list, peer_list) { in wg_open()
54 wg_packet_send_staged_packets(peer); in wg_open()
55 if (peer->persistent_keepalive_interval) in wg_open()
56 wg_packet_send_keepalive(peer); in wg_open()
68 struct wg_peer *peer; in wg_pm_notification() local
83 list_for_each_entry(peer, &wg->peer_list, peer_list) { in wg_pm_notification()
84 del_timer(&peer->timer_zero_key_material); in wg_pm_notification()
85 wg_noise_handshake_clear(&peer in wg_pm_notification()
101 struct wg_peer *peer; wg_stop() local
124 struct wg_peer *peer; wg_xmit() local
402 struct wg_peer *peer; wg_netns_pre_exit() local
[all...] |
| H A D | socket.c | 7 #include "peer.h"
168 int wg_socket_send_skb_to_peer(struct wg_peer *peer, struct sk_buff *skb, u8 ds) in wg_socket_send_skb_to_peer() argument
173 read_lock_bh(&peer->endpoint_lock); in wg_socket_send_skb_to_peer()
174 if (peer->endpoint.addr.sa_family == AF_INET) in wg_socket_send_skb_to_peer()
175 ret = send4(peer->device, skb, &peer->endpoint, ds, in wg_socket_send_skb_to_peer()
176 &peer->endpoint_cache); in wg_socket_send_skb_to_peer()
177 else if (peer->endpoint.addr.sa_family == AF_INET6) in wg_socket_send_skb_to_peer()
178 ret = send6(peer->device, skb, &peer in wg_socket_send_skb_to_peer()
189 wg_socket_send_buffer_to_peer(struct wg_peer *peer, void *buffer, size_t len, u8 ds) wg_socket_send_buffer_to_peer() argument
273 wg_socket_set_peer_endpoint(struct wg_peer *peer, const struct endpoint *endpoint) wg_socket_set_peer_endpoint() argument
299 wg_socket_set_peer_endpoint_from_skb(struct wg_peer *peer, const struct sk_buff *skb) wg_socket_set_peer_endpoint_from_skb() argument
308 wg_socket_clear_peer_endpoint_src(struct wg_peer *peer) wg_socket_clear_peer_endpoint_src() argument
[all...] |
| H A D | noise.c | 8 #include "peer.h"
46 /* Must hold peer->handshake.static_identity->lock */
47 void wg_noise_precompute_static_static(struct wg_peer *peer) in wg_noise_precompute_static_static() argument
49 down_write(&peer->handshake.lock); in wg_noise_precompute_static_static()
50 if (!peer->handshake.static_identity->has_identity || in wg_noise_precompute_static_static()
51 !curve25519(peer->handshake.precomputed_static_static, in wg_noise_precompute_static_static()
52 peer->handshake.static_identity->static_private, in wg_noise_precompute_static_static()
53 peer->handshake.remote_static)) in wg_noise_precompute_static_static()
54 memset(peer->handshake.precomputed_static_static, 0, in wg_noise_precompute_static_static()
56 up_write(&peer in wg_noise_precompute_static_static()
59 wg_noise_handshake_init(struct noise_handshake *handshake, struct noise_static_identity *static_identity, const u8 peer_public_key[NOISE_PUBLIC_KEY_LEN], const u8 peer_preshared_key[NOISE_SYMMETRIC_KEY_LEN], struct wg_peer *peer) wg_noise_handshake_init() argument
98 keypair_create(struct wg_peer *peer) keypair_create() argument
179 wg_noise_expire_current_peer_keypairs(struct wg_peer *peer) wg_noise_expire_current_peer_keypairs() argument
587 struct wg_peer *peer = NULL, *ret_peer = NULL; wg_noise_handshake_consume_initiation() local
732 struct wg_peer *peer = NULL, *ret_peer = NULL; wg_noise_handshake_consume_response() local
[all...] |
| H A D | allowedips.c | 7 #include "peer.h"
77 if (rcu_access_pointer(node->peer)) in root_remove_peer_lists()
117 if (rcu_access_pointer(node->peer)) in find_node()
126 /* Returns a strong reference to a peer */
133 struct wg_peer *peer = NULL; in lookup() local
141 peer = wg_peer_get_maybe_zero(rcu_dereference_bh(node->peer)); in lookup()
142 if (!peer) in lookup()
146 return peer; in lookup()
182 u8 cidr, struct wg_peer *peer, struc in add()
181 add(struct allowedips_node __rcu **trie, u8 bits, const u8 *key, u8 cidr, struct wg_peer *peer, struct mutex *lock) add() argument
281 wg_allowedips_insert_v4(struct allowedips *table, const struct in_addr *ip, u8 cidr, struct wg_peer *peer, struct mutex *lock) wg_allowedips_insert_v4() argument
292 wg_allowedips_insert_v6(struct allowedips *table, const struct in6_addr *ip, u8 cidr, struct wg_peer *peer, struct mutex *lock) wg_allowedips_insert_v6() argument
303 wg_allowedips_remove_by_peer(struct allowedips *table, struct wg_peer *peer, struct mutex *lock) wg_allowedips_remove_by_peer() argument
[all...] |
| H A D | queueing.h | 9 #include "peer.h"
39 void wg_packet_send_queued_handshake_initiation(struct wg_peer *peer,
41 void wg_packet_send_handshake_response(struct wg_peer *peer);
45 void wg_packet_send_keepalive(struct wg_peer *peer);
46 void wg_packet_purge_staged_packets(struct wg_peer *peer);
47 void wg_packet_send_staged_packets(struct wg_peer *peer);
68 #define PACKET_PEER(skb) (PACKET_CB(skb)->keypair->entry.peer)
166 /* We first queue this up for the peer ingestion, but the consumer in wg_queue_enqueue_per_device_and_peer()
185 * peer can be freed from below us. in wg_queue_enqueue_per_peer_tx()
187 struct wg_peer *peer in wg_queue_enqueue_per_peer_tx() local
200 struct wg_peer *peer = wg_peer_get(PACKET_PEER(skb)); wg_queue_enqueue_per_peer_rx() local
[all...] |
| /kernel/linux/linux-6.6/drivers/net/wireguard/ |
| H A D | peerlookup.c | 7 #include "peer.h"
36 struct wg_peer *peer) in wg_pubkey_hashtable_add()
39 hlist_add_head_rcu(&peer->pubkey_hash, in wg_pubkey_hashtable_add()
40 pubkey_bucket(table, peer->handshake.remote_static)); in wg_pubkey_hashtable_add()
45 struct wg_peer *peer) in wg_pubkey_hashtable_remove()
48 hlist_del_init_rcu(&peer->pubkey_hash); in wg_pubkey_hashtable_remove()
52 /* Returns a strong reference to a peer */
57 struct wg_peer *iter_peer, *peer = NULL; in wg_pubkey_hashtable_lookup() local
64 peer = iter_peer; in wg_pubkey_hashtable_lookup()
68 peer in wg_pubkey_hashtable_lookup()
35 wg_pubkey_hashtable_add(struct pubkey_hashtable *table, struct wg_peer *peer) wg_pubkey_hashtable_add() argument
44 wg_pubkey_hashtable_remove(struct pubkey_hashtable *table, struct wg_peer *peer) wg_pubkey_hashtable_remove() argument
202 wg_index_hashtable_lookup(struct index_hashtable *table, const enum index_hashtable_type type_mask, const __le32 index, struct wg_peer **peer) wg_index_hashtable_lookup() argument
[all...] |
| H A D | socket.c | 7 #include "peer.h"
168 int wg_socket_send_skb_to_peer(struct wg_peer *peer, struct sk_buff *skb, u8 ds) in wg_socket_send_skb_to_peer() argument
173 read_lock_bh(&peer->endpoint_lock); in wg_socket_send_skb_to_peer()
174 if (peer->endpoint.addr.sa_family == AF_INET) in wg_socket_send_skb_to_peer()
175 ret = send4(peer->device, skb, &peer->endpoint, ds, in wg_socket_send_skb_to_peer()
176 &peer->endpoint_cache); in wg_socket_send_skb_to_peer()
177 else if (peer->endpoint.addr.sa_family == AF_INET6) in wg_socket_send_skb_to_peer()
178 ret = send6(peer->device, skb, &peer in wg_socket_send_skb_to_peer()
189 wg_socket_send_buffer_to_peer(struct wg_peer *peer, void *buffer, size_t len, u8 ds) wg_socket_send_buffer_to_peer() argument
273 wg_socket_set_peer_endpoint(struct wg_peer *peer, const struct endpoint *endpoint) wg_socket_set_peer_endpoint() argument
299 wg_socket_set_peer_endpoint_from_skb(struct wg_peer *peer, const struct sk_buff *skb) wg_socket_set_peer_endpoint_from_skb() argument
308 wg_socket_clear_peer_endpoint_src(struct wg_peer *peer) wg_socket_clear_peer_endpoint_src() argument
[all...] |
| H A D | noise.c | 8 #include "peer.h"
46 /* Must hold peer->handshake.static_identity->lock */
47 void wg_noise_precompute_static_static(struct wg_peer *peer) in wg_noise_precompute_static_static() argument
49 down_write(&peer->handshake.lock); in wg_noise_precompute_static_static()
50 if (!peer->handshake.static_identity->has_identity || in wg_noise_precompute_static_static()
51 !curve25519(peer->handshake.precomputed_static_static, in wg_noise_precompute_static_static()
52 peer->handshake.static_identity->static_private, in wg_noise_precompute_static_static()
53 peer->handshake.remote_static)) in wg_noise_precompute_static_static()
54 memset(peer->handshake.precomputed_static_static, 0, in wg_noise_precompute_static_static()
56 up_write(&peer in wg_noise_precompute_static_static()
59 wg_noise_handshake_init(struct noise_handshake *handshake, struct noise_static_identity *static_identity, const u8 peer_public_key[NOISE_PUBLIC_KEY_LEN], const u8 peer_preshared_key[NOISE_SYMMETRIC_KEY_LEN], struct wg_peer *peer) wg_noise_handshake_init() argument
98 keypair_create(struct wg_peer *peer) keypair_create() argument
179 wg_noise_expire_current_peer_keypairs(struct wg_peer *peer) wg_noise_expire_current_peer_keypairs() argument
587 struct wg_peer *peer = NULL, *ret_peer = NULL; wg_noise_handshake_consume_initiation() local
732 struct wg_peer *peer = NULL, *ret_peer = NULL; wg_noise_handshake_consume_response() local
[all...] |
| H A D | allowedips.c | 7 #include "peer.h"
77 if (rcu_access_pointer(node->peer)) in root_remove_peer_lists()
117 if (rcu_access_pointer(node->peer)) in find_node()
126 /* Returns a strong reference to a peer */
133 struct wg_peer *peer = NULL; in lookup() local
141 peer = wg_peer_get_maybe_zero(rcu_dereference_bh(node->peer)); in lookup()
142 if (!peer) in lookup()
146 return peer; in lookup()
182 u8 cidr, struct wg_peer *peer, struc in add()
181 add(struct allowedips_node __rcu **trie, u8 bits, const u8 *key, u8 cidr, struct wg_peer *peer, struct mutex *lock) add() argument
281 wg_allowedips_insert_v4(struct allowedips *table, const struct in_addr *ip, u8 cidr, struct wg_peer *peer, struct mutex *lock) wg_allowedips_insert_v4() argument
292 wg_allowedips_insert_v6(struct allowedips *table, const struct in6_addr *ip, u8 cidr, struct wg_peer *peer, struct mutex *lock) wg_allowedips_insert_v6() argument
303 wg_allowedips_remove_by_peer(struct allowedips *table, struct wg_peer *peer, struct mutex *lock) wg_allowedips_remove_by_peer() argument
[all...] |
| H A D | queueing.h | 9 #include "peer.h"
39 void wg_packet_send_queued_handshake_initiation(struct wg_peer *peer,
41 void wg_packet_send_handshake_response(struct wg_peer *peer);
45 void wg_packet_send_keepalive(struct wg_peer *peer);
46 void wg_packet_purge_staged_packets(struct wg_peer *peer);
47 void wg_packet_send_staged_packets(struct wg_peer *peer);
68 #define PACKET_PEER(skb) (PACKET_CB(skb)->keypair->entry.peer)
164 /* We first queue this up for the peer ingestion, but the consumer in wg_queue_enqueue_per_device_and_peer()
183 * peer can be freed from below us. in wg_queue_enqueue_per_peer_tx()
185 struct wg_peer *peer in wg_queue_enqueue_per_peer_tx() local
198 struct wg_peer *peer = wg_peer_get(PACKET_PEER(skb)); wg_queue_enqueue_per_peer_rx() local
[all...] |
| /kernel/linux/linux-6.6/drivers/net/wireless/intel/iwlwifi/mvm/ |
| H A D | ftm-initiator.c | 311 struct cfg80211_pmsr_request_peer *peer, in iwl_mvm_ftm_target_chandef_v1()
315 u32 freq = peer->chandef.chan->center_freq; in iwl_mvm_ftm_target_chandef_v1()
319 switch (peer->chandef.width) { in iwl_mvm_ftm_target_chandef_v1()
334 peer->chandef.width); in iwl_mvm_ftm_target_chandef_v1()
338 *ctrl_ch_position = (peer->chandef.width > NL80211_CHAN_WIDTH_20) ? in iwl_mvm_ftm_target_chandef_v1()
339 iwl_mvm_get_ctrl_pos(&peer->chandef) : 0; in iwl_mvm_ftm_target_chandef_v1()
346 struct cfg80211_pmsr_request_peer *peer, in iwl_mvm_ftm_target_chandef_v2()
350 u32 freq = peer->chandef.chan->center_freq; in iwl_mvm_ftm_target_chandef_v2()
355 switch (peer->chandef.width) { in iwl_mvm_ftm_target_chandef_v2()
385 peer in iwl_mvm_ftm_target_chandef_v2()
310 iwl_mvm_ftm_target_chandef_v1(struct iwl_mvm *mvm, struct cfg80211_pmsr_request_peer *peer, u8 *channel, u8 *bandwidth, u8 *ctrl_ch_position) iwl_mvm_ftm_target_chandef_v1() argument
345 iwl_mvm_ftm_target_chandef_v2(struct iwl_mvm *mvm, struct cfg80211_pmsr_request_peer *peer, u8 *channel, u8 *format_bw, u8 *ctrl_ch_position) iwl_mvm_ftm_target_chandef_v2() argument
400 iwl_mvm_ftm_put_target_v2(struct iwl_mvm *mvm, struct cfg80211_pmsr_request_peer *peer, struct iwl_tof_range_req_ap_entry_v2 *target) iwl_mvm_ftm_put_target_v2() argument
436 iwl_mvm_ftm_put_target_common(struct iwl_mvm *mvm, struct cfg80211_pmsr_request_peer *peer, struct iwl_tof_range_req_ap_entry_v6 *target) iwl_mvm_ftm_put_target_common() argument
476 iwl_mvm_ftm_put_target_v3(struct iwl_mvm *mvm, struct cfg80211_pmsr_request_peer *peer, struct iwl_tof_range_req_ap_entry_v3 *target) iwl_mvm_ftm_put_target_v3() argument
498 iwl_mvm_ftm_put_target_v4(struct iwl_mvm *mvm, struct cfg80211_pmsr_request_peer *peer, struct iwl_tof_range_req_ap_entry_v4 *target) iwl_mvm_ftm_put_target_v4() argument
516 iwl_mvm_ftm_put_target(struct iwl_mvm *mvm, struct ieee80211_vif *vif, struct cfg80211_pmsr_request_peer *peer, struct iwl_tof_range_req_ap_entry_v6 *target) iwl_mvm_ftm_put_target() argument
596 struct cfg80211_pmsr_request_peer *peer = &req->peers[i]; iwl_mvm_ftm_start_v5() local
626 struct cfg80211_pmsr_request_peer *peer = &req->peers[i]; iwl_mvm_ftm_start_v7() local
652 struct cfg80211_pmsr_request_peer *peer = &req->peers[i]; iwl_mvm_ftm_start_v8() local
678 struct cfg80211_pmsr_request_peer *peer = &req->peers[i]; iwl_mvm_ftm_start_v9() local
751 iwl_mvm_ftm_put_target_v7(struct iwl_mvm *mvm, struct ieee80211_vif *vif, struct cfg80211_pmsr_request_peer *peer, struct iwl_tof_range_req_ap_entry_v7 *target) iwl_mvm_ftm_put_target_v7() argument
780 struct cfg80211_pmsr_request_peer *peer = &req->peers[i]; iwl_mvm_ftm_start_v11() local
808 iwl_mvm_ftm_put_target_v8(struct iwl_mvm *mvm, struct ieee80211_vif *vif, struct cfg80211_pmsr_request_peer *peer, struct iwl_tof_range_req_ap_entry_v8 *target) iwl_mvm_ftm_put_target_v8() argument
851 struct cfg80211_pmsr_request_peer *peer = &req->peers[i]; iwl_mvm_ftm_start_v12() local
879 struct cfg80211_pmsr_request_peer *peer = &req->peers[i]; iwl_mvm_ftm_start_v13() local
979 struct cfg80211_pmsr_request_peer *peer = &req->peers[i]; iwl_mvm_ftm_find_peer() local
[all...] |
| /kernel/linux/linux-5.10/drivers/ntb/test/ |
| H A D | ntb_msi_test.c | 131 static void ntb_msit_copy_peer_desc(struct ntb_msit_ctx *nm, int peer) in ntb_msit_copy_peer_desc() argument
134 struct ntb_msi_desc *desc = nm->peers[peer].msi_desc; in ntb_msit_copy_peer_desc()
135 int irq_count = nm->peers[peer].num_irqs; in ntb_msit_copy_peer_desc()
138 desc[i].addr_offset = ntb_peer_spad_read(nm->ntb, peer, in ntb_msit_copy_peer_desc()
140 desc[i].data = ntb_peer_spad_read(nm->ntb, peer, 2 * i + 2); in ntb_msit_copy_peer_desc()
143 dev_info(&nm->ntb->dev, "Found %d interrupts on peer %d\n", in ntb_msit_copy_peer_desc()
144 irq_count, peer); in ntb_msit_copy_peer_desc()
146 complete_all(&nm->peers[peer].init_comp); in ntb_msit_copy_peer_desc()
155 int peer; in ntb_msit_db_event() local
159 for (peer in ntb_msit_db_event()
186 struct ntb_msit_peer *peer = data; ntb_msit_dbgfs_trigger() local
203 struct ntb_msit_peer *peer = data; ntb_msit_dbgfs_port_get() local
215 struct ntb_msit_peer *peer = data; ntb_msit_dbgfs_count_get() local
227 struct ntb_msit_peer *peer = data; ntb_msit_dbgfs_ready_get() local
236 struct ntb_msit_peer *peer = data; ntb_msit_dbgfs_ready_set() local
[all...] |
| /kernel/linux/linux-6.6/drivers/ntb/test/ |
| H A D | ntb_msi_test.c | 131 static void ntb_msit_copy_peer_desc(struct ntb_msit_ctx *nm, int peer) in ntb_msit_copy_peer_desc() argument
134 struct ntb_msi_desc *desc = nm->peers[peer].msi_desc; in ntb_msit_copy_peer_desc()
135 int irq_count = nm->peers[peer].num_irqs; in ntb_msit_copy_peer_desc()
138 desc[i].addr_offset = ntb_peer_spad_read(nm->ntb, peer, in ntb_msit_copy_peer_desc()
140 desc[i].data = ntb_peer_spad_read(nm->ntb, peer, 2 * i + 2); in ntb_msit_copy_peer_desc()
143 dev_info(&nm->ntb->dev, "Found %d interrupts on peer %d\n", in ntb_msit_copy_peer_desc()
144 irq_count, peer); in ntb_msit_copy_peer_desc()
146 complete_all(&nm->peers[peer].init_comp); in ntb_msit_copy_peer_desc()
155 int peer; in ntb_msit_db_event() local
159 for (peer in ntb_msit_db_event()
186 struct ntb_msit_peer *peer = data; ntb_msit_dbgfs_trigger() local
203 struct ntb_msit_peer *peer = data; ntb_msit_dbgfs_port_get() local
215 struct ntb_msit_peer *peer = data; ntb_msit_dbgfs_count_get() local
227 struct ntb_msit_peer *peer = data; ntb_msit_dbgfs_ready_get() local
236 struct ntb_msit_peer *peer = data; ntb_msit_dbgfs_ready_set() local
[all...] |
| /kernel/linux/linux-5.10/net/rxrpc/ |
| H A D | conn_service.c | 22 * the hash function. So, instead, we use a hash table for the peer and from
27 struct rxrpc_connection *rxrpc_find_service_conn_rcu(struct rxrpc_peer *peer, in rxrpc_find_service_conn_rcu() argument
45 read_seqbegin_or_lock(&peer->service_conn_lock, &seq); in rxrpc_find_service_conn_rcu()
47 p = rcu_dereference_raw(peer->service_conns.rb_node); in rxrpc_find_service_conn_rcu()
59 } while (need_seqretry(&peer->service_conn_lock, seq)); in rxrpc_find_service_conn_rcu()
61 done_seqretry(&peer->service_conn_lock, seq); in rxrpc_find_service_conn_rcu()
67 * Insert a service connection into a peer's tree, thereby making it a target
70 static void rxrpc_publish_service_conn(struct rxrpc_peer *peer, in rxrpc_publish_service_conn() argument
77 write_seqlock_bh(&peer->service_conn_lock); in rxrpc_publish_service_conn()
79 pp = &peer in rxrpc_publish_service_conn()
200 struct rxrpc_peer *peer = conn->params.peer; rxrpc_unpublish_service_conn() local
[all...] |
| /kernel/linux/linux-5.10/fs/hmdfs/ |
| H A D | inode.c | 62 /* The peer of remote inode */
63 struct hmdfs_peer *peer; member
105 res = (ia->peer == hii->conn && in iget_test()
133 hii->conn = ia->peer; in iget_set()
171 .peer = NULL, in hmdfs_iget5_locked_merge()
197 .peer = NULL, in hmdfs_iget5_locked_cloud_merge()
232 .peer = NULL, in hmdfs_iget5_locked_local()
252 * @peer: corresponding device node
258 * ino. Thus the combination of the peer's unique dev_id and the remote_ino
262 struct hmdfs_peer *peer, in hmdfs_iget5_locked_remote()
261 hmdfs_iget5_locked_remote(struct super_block *sb, struct hmdfs_peer *peer, uint64_t remote_ino) hmdfs_iget5_locked_remote() argument
297 hmdfs_iget5_locked_cloud(struct super_block *sb, struct hmdfs_peer *peer, struct hmdfs_lookup_cloud_ret *res) hmdfs_iget5_locked_cloud() argument
321 hmdfs_iget_locked_root(struct super_block *sb, uint64_t root_ino, struct inode *lo_i, struct hmdfs_peer *peer) hmdfs_iget_locked_root() argument
[all...] |
| /kernel/linux/linux-6.6/fs/hmdfs/ |
| H A D | inode.c | 62 /* The peer of remote inode */
63 struct hmdfs_peer *peer; member
105 res = (ia->peer == hii->conn && in iget_test()
133 hii->conn = ia->peer; in iget_set()
171 .peer = NULL, in hmdfs_iget5_locked_merge()
197 .peer = NULL, in hmdfs_iget5_locked_cloud_merge()
232 .peer = NULL, in hmdfs_iget5_locked_local()
252 * @peer: corresponding device node
258 * ino. Thus the combination of the peer's unique dev_id and the remote_ino
262 struct hmdfs_peer *peer, in hmdfs_iget5_locked_remote()
261 hmdfs_iget5_locked_remote(struct super_block *sb, struct hmdfs_peer *peer, uint64_t remote_ino) hmdfs_iget5_locked_remote() argument
297 hmdfs_iget5_locked_cloud(struct super_block *sb, struct hmdfs_peer *peer, struct hmdfs_lookup_cloud_ret *res) hmdfs_iget5_locked_cloud() argument
321 hmdfs_iget_locked_root(struct super_block *sb, uint64_t root_ino, struct inode *lo_i, struct hmdfs_peer *peer) hmdfs_iget_locked_root() argument
[all...] |
| /kernel/linux/linux-6.6/drivers/usb/core/ |
| H A D | port.c | 321 struct usb_port *peer = port_dev->peer; in usb_port_runtime_resume() local
333 * Power on our usb3 peer before this usb2 port to prevent a usb3 in usb_port_runtime_resume()
336 if (!port_dev->is_superspeed && peer) in usb_port_runtime_resume()
337 pm_runtime_get_sync(&peer->dev); in usb_port_runtime_resume()
379 struct usb_port *peer = port_dev->peer; in usb_port_runtime_suspend() local
406 * Our peer usb3 port may now be able to suspend, so in usb_port_runtime_suspend()
410 if (!port_dev->is_superspeed && peer) in usb_port_runtime_suspend()
411 pm_runtime_put(&peer in usb_port_runtime_suspend()
572 struct usb_port *port_dev = p, *peer; match_location() local
603 struct usb_port *port_dev = hub->ports[port1 - 1], *peer; find_and_link_peer() local
785 struct usb_port *peer; usb_hub_remove_port_device() local
[all...] |
| /kernel/liteos_a/testsuites/unittest/container/smoke/ |
| H A D | It_net_container_009.cpp | 51 int peer; in TcpClient() local
56 peer = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP); in TcpClient()
57 if (peer < 0) { in TcpClient()
68 ret = connect(peer, const_cast<struct sockaddr *>(reinterpret_cast<struct sockaddr *>(&server_addr)), in TcpClient()
73 (void)close(peer); in TcpClient()
78 ret = send(peer, PEER_MSG, strlen(PEER_MSG) + 1, 0); in TcpClient()
80 (void)close(peer); in TcpClient()
85 ret = recv(peer, recv_data, sizeof(recv_data), 0); in TcpClient()
87 (void)close(peer); in TcpClient()
91 (void)close(peer); in TcpClient()
104 int peer; TcpServer() local
[all...] |
| /third_party/wpa_supplicant/wpa_supplicant-2.9/src/pae/ |
| H A D | ieee802_1x_kay.c | 193 mi = body->peer + i; in ieee802_1x_mka_dump_peer_body()
321 struct ieee802_1x_kay_peer *peer; in get_peer_mi() local
323 dl_list_for_each(peer, peers, struct ieee802_1x_kay_peer, list) { in get_peer_mi()
324 if (os_memcmp(peer->mi, mi, MI_LEN) == 0) in get_peer_mi()
325 return peer; in get_peer_mi()
383 struct ieee802_1x_kay_peer *peer; in ieee802_1x_kay_get_peer() local
385 peer = ieee802_1x_kay_get_live_peer(participant, mi); in ieee802_1x_kay_get_peer()
386 if (peer) in ieee802_1x_kay_get_peer()
387 return peer; in ieee802_1x_kay_get_peer()
443 struct ieee802_1x_kay_peer *peer; in ieee802_1x_kay_get_peer_sci() local
576 ieee802_1x_kay_dump_peer(struct ieee802_1x_kay_peer *peer) ieee802_1x_kay_dump_peer() argument
586 struct ieee802_1x_kay_peer *peer; ieee802_1x_kay_create_peer() local
611 struct ieee802_1x_kay_peer *peer; ieee802_1x_kay_create_live_peer() local
649 struct ieee802_1x_kay_peer *peer; ieee802_1x_kay_create_potential_peer() local
671 struct ieee802_1x_kay_peer *peer; ieee802_1x_kay_move_live_peer() local
797 struct ieee802_1x_kay_peer *peer; ieee802_1x_mka_decode_basic_body() local
928 struct ieee802_1x_kay_peer *peer; ieee802_1x_mka_get_live_peer_length() local
947 struct ieee802_1x_kay_peer *peer; ieee802_1x_mka_encode_live_peer_body() local
988 struct ieee802_1x_kay_peer *peer; ieee802_1x_mka_get_potential_peer_length() local
1007 struct ieee802_1x_kay_peer *peer; ieee802_1x_mka_encode_potential_peer_body() local
1116 struct ieee802_1x_kay_peer *peer; ieee802_1x_mka_decode_live_peer_body() local
1370 struct ieee802_1x_kay_peer *peer; ieee802_1x_mka_decode_sak_use_body() local
1648 struct ieee802_1x_kay_peer *peer; ieee802_1x_mka_decode_dist_sak_body() local
2081 struct ieee802_1x_kay_peer *peer; ieee802_1x_kay_generate_new_sak() local
2213 compare_priorities(const struct ieee802_1x_kay_peer *peer, const struct ieee802_1x_kay_peer *other) compare_priorities() argument
2232 struct ieee802_1x_kay_peer *peer; ieee802_1x_kay_elect_key_server() local
2334 struct ieee802_1x_kay_peer *peer; ieee802_1x_kay_decide_macsec_use() local
2505 struct ieee802_1x_kay_peer *peer, *pre_peer; ieee802_1x_participant_timer() local
3168 struct ieee802_1x_kay_peer *peer; ieee802_1x_kay_decode_mkpdu() local
3761 struct ieee802_1x_kay_peer *peer; ieee802_1x_kay_delete_mka() local
[all...] |
| /third_party/wpa_supplicant/wpa_supplicant-2.9_standard/src/pae/ |
| H A D | ieee802_1x_kay.c | 193 mi = body->peer + i; in ieee802_1x_mka_dump_peer_body()
321 struct ieee802_1x_kay_peer *peer; in get_peer_mi() local
323 dl_list_for_each(peer, peers, struct ieee802_1x_kay_peer, list) { in get_peer_mi()
324 if (os_memcmp(peer->mi, mi, MI_LEN) == 0) in get_peer_mi()
325 return peer; in get_peer_mi()
383 struct ieee802_1x_kay_peer *peer; in ieee802_1x_kay_get_peer() local
385 peer = ieee802_1x_kay_get_live_peer(participant, mi); in ieee802_1x_kay_get_peer()
386 if (peer) in ieee802_1x_kay_get_peer()
387 return peer; in ieee802_1x_kay_get_peer()
443 struct ieee802_1x_kay_peer *peer; in ieee802_1x_kay_get_peer_sci() local
576 ieee802_1x_kay_dump_peer(struct ieee802_1x_kay_peer *peer) ieee802_1x_kay_dump_peer() argument
586 struct ieee802_1x_kay_peer *peer; ieee802_1x_kay_create_peer() local
611 struct ieee802_1x_kay_peer *peer; ieee802_1x_kay_create_live_peer() local
649 struct ieee802_1x_kay_peer *peer; ieee802_1x_kay_create_potential_peer() local
671 struct ieee802_1x_kay_peer *peer; ieee802_1x_kay_move_live_peer() local
797 struct ieee802_1x_kay_peer *peer; ieee802_1x_mka_decode_basic_body() local
928 struct ieee802_1x_kay_peer *peer; ieee802_1x_mka_get_live_peer_length() local
947 struct ieee802_1x_kay_peer *peer; ieee802_1x_mka_encode_live_peer_body() local
988 struct ieee802_1x_kay_peer *peer; ieee802_1x_mka_get_potential_peer_length() local
1007 struct ieee802_1x_kay_peer *peer; ieee802_1x_mka_encode_potential_peer_body() local
1116 struct ieee802_1x_kay_peer *peer; ieee802_1x_mka_decode_live_peer_body() local
1383 struct ieee802_1x_kay_peer *peer; ieee802_1x_mka_decode_sak_use_body() local
1685 struct ieee802_1x_kay_peer *peer; ieee802_1x_mka_decode_dist_sak_body() local
2118 struct ieee802_1x_kay_peer *peer; ieee802_1x_kay_generate_new_sak() local
2250 compare_priorities(const struct ieee802_1x_kay_peer *peer, const struct ieee802_1x_kay_peer *other) compare_priorities() argument
2269 struct ieee802_1x_kay_peer *peer; ieee802_1x_kay_elect_key_server() local
2371 struct ieee802_1x_kay_peer *peer; ieee802_1x_kay_decide_macsec_use() local
2542 struct ieee802_1x_kay_peer *peer, *pre_peer; ieee802_1x_participant_timer() local
3205 struct ieee802_1x_kay_peer *peer; ieee802_1x_kay_decode_mkpdu() local
3798 struct ieee802_1x_kay_peer *peer; ieee802_1x_kay_delete_mka() local
[all...] |
| /kernel/linux/linux-5.10/tools/testing/selftests/wireguard/ |
| H A D | netns.sh | 101 peer "$pub2" \
107 peer "$pub1" \
163 n1 wg set wg0 peer "$pub2" endpoint 127.0.0.1:2
164 n2 wg set wg0 peer "$pub1" endpoint 127.0.0.1:1
187 n1 wg set wg0 peer "$pub2" endpoint [::1]:2
188 n2 wg set wg0 peer "$pub1" endpoint [::1]:1
197 n1 wg set wg0 peer "$pub2" endpoint 127.0.0.1:2
198 n2 wg set wg0 peer "$pub1" endpoint 127.0.0.1:1
214 n1 wg set wg0 peer "$pub2" endpoint 127.0.0.1:2
220 n1 wg set wg0 peer "
[all...] |
| /kernel/linux/linux-6.6/tools/testing/selftests/wireguard/ |
| H A D | netns.sh | 103 peer "$pub2" \
109 peer "$pub1" \
163 n1 wg set wg0 peer "$pub2" endpoint 127.0.0.1:2
164 n2 wg set wg0 peer "$pub1" endpoint 127.0.0.1:1
187 n1 wg set wg0 peer "$pub2" endpoint [::1]:2
188 n2 wg set wg0 peer "$pub1" endpoint [::1]:1
197 n1 wg set wg0 peer "$pub2" endpoint 127.0.0.1:2
198 n2 wg set wg0 peer "$pub1" endpoint 127.0.0.1:1
214 n1 wg set wg0 peer "$pub2" endpoint 127.0.0.1:2
220 n1 wg set wg0 peer "
[all...] |
| /kernel/linux/linux-5.10/fs/hmdfs/comm/ |
| H A D | connection.c | 580 void peer_online(struct hmdfs_peer *peer) in peer_online() argument
582 // To evaluate if someone else has made the peer online in peer_online()
583 u8 prev_stat = xchg(&peer->status, NODE_STAT_ONLINE); in peer_online()
588 WRITE_ONCE(peer->conn_time, jif_tmp); in peer_online()
589 WRITE_ONCE(peer->sbi->connections.recent_ol, jif_tmp); in peer_online()
590 hmdfs_queue_raw_node_evt(peer, RAW_NODE_EVT_ON); in peer_online()
783 struct hmdfs_peer *peer = container_of(ref, struct hmdfs_peer, ref_cnt); in hmdfs_peer_release() local
784 struct mutex *lock = &peer->sbi->connections.node_lock; in hmdfs_peer_release()
786 if (!list_empty(&peer->list)) in hmdfs_peer_release()
787 hmdfs_info("releasing a on-sbi peer in hmdfs_peer_release()
816 peer_put(struct hmdfs_peer *peer) peer_put() argument
1046 struct hmdfs_peer *peer; add_peer_unsafe() local
1182 struct hmdfs_peer *peer = NULL, *on_sbi_peer = NULL; hmdfs_get_peer() local
1239 hmdfs_find_msg_head(struct hmdfs_peer *peer, int id, struct hmdfs_cmd operations) hmdfs_find_msg_head() argument
1255 hmdfs_alloc_msg_idr(struct hmdfs_peer *peer, enum MSG_IDR_TYPE type, void *ptr, struct hmdfs_cmd operations) hmdfs_alloc_msg_idr() argument
[all...] |