| /linux/drivers/net/wireguard/ |
| H A D | timers.c | 30 static inline void mod_peer_timer(struct wg_peer *peer, in mod_peer_timer() argument
35 if (likely(netif_running(peer->device->dev) && in mod_peer_timer()
36 !READ_ONCE(peer->is_dead))) in mod_peer_timer()
43 struct wg_peer *peer = timer_container_of(peer, timer, in wg_expired_retransmit_handshake() local
46 if (peer->timer_handshake_attempts > MAX_TIMER_HANDSHAKES) { in wg_expired_retransmit_handshake()
48 peer->device->dev->name, peer->internal_id, in wg_expired_retransmit_handshake()
49 &peer->endpoint.addr, (int)MAX_TIMER_HANDSHAKES + 2); in wg_expired_retransmit_handshake()
51 timer_delete(&peer->timer_send_keepalive); in wg_expired_retransmit_handshake()
55 wg_packet_purge_staged_packets(peer); in wg_expired_retransmit_handshake()
60 if (!timer_pending(&peer->timer_zero_key_material)) in wg_expired_retransmit_handshake()
[all …]
|
| H A D | peer.c | 25 struct wg_peer *peer; in wg_peer_create() local
33 peer = kmem_cache_zalloc(peer_cache, GFP_KERNEL); in wg_peer_create()
34 if (unlikely(!peer)) in wg_peer_create()
36 if (unlikely(dst_cache_init(&peer->endpoint_cache, GFP_KERNEL))) in wg_peer_create()
39 peer->device = wg; in wg_peer_create()
40 wg_noise_handshake_init(&peer->handshake, &wg->static_identity, in wg_peer_create()
41 public_key, preshared_key, peer); in wg_peer_create()
42 peer->internal_id = atomic64_inc_return(&peer_counter); in wg_peer_create()
43 peer->serial_work_cpu = nr_cpumask_bits; in wg_peer_create()
44 wg_cookie_init(&peer->latest_cookie); in wg_peer_create()
[all …]
|
| H A D | send.c | 21 static void wg_packet_send_handshake_initiation(struct wg_peer *peer) in wg_packet_send_handshake_initiation() argument
25 if (!wg_birthdate_has_expired(atomic64_read(&peer->last_sent_handshake), in wg_packet_send_handshake_initiation()
29 atomic64_set(&peer->last_sent_handshake, ktime_get_coarse_boottime_ns()); in wg_packet_send_handshake_initiation()
31 peer->device->dev->name, peer->internal_id, in wg_packet_send_handshake_initiation()
32 &peer->endpoint.addr); in wg_packet_send_handshake_initiation()
34 if (wg_noise_handshake_create_initiation(&packet, &peer->handshake)) { in wg_packet_send_handshake_initiation()
35 wg_cookie_add_mac_to_packet(&packet, sizeof(packet), peer); in wg_packet_send_handshake_initiation()
36 wg_timers_any_authenticated_packet_traversal(peer); in wg_packet_send_handshake_initiation()
37 wg_timers_any_authenticated_packet_sent(peer); in wg_packet_send_handshake_initiation()
38 atomic64_set(&peer->last_sent_handshake, in wg_packet_send_handshake_initiation()
[all …]
|
| H A D | receive.c | 20 static void update_rx_stats(struct wg_peer *peer, size_t len) in update_rx_stats() argument
22 dev_sw_netstats_rx_add(peer->device->dev, len); in update_rx_stats()
23 peer->rx_bytes += len; in update_rx_stats()
96 struct wg_peer *peer = NULL; in wg_receive_handshake_packet() local
144 peer = wg_noise_handshake_consume_initiation(message, wg); in wg_receive_handshake_packet()
145 if (unlikely(!peer)) { in wg_receive_handshake_packet()
150 wg_socket_set_peer_endpoint_from_skb(peer, skb); in wg_receive_handshake_packet()
152 wg->dev->name, peer->internal_id, in wg_receive_handshake_packet()
153 &peer->endpoint.addr); in wg_receive_handshake_packet()
154 wg_packet_send_handshake_response(peer); in wg_receive_handshake_packet()
[all …]
|
| H A D | cookie.c | 61 void wg_cookie_checker_precompute_peer_keys(struct wg_peer *peer) in wg_cookie_checker_precompute_peer_keys() argument
63 precompute_key(peer->latest_cookie.cookie_decryption_key, in wg_cookie_checker_precompute_peer_keys()
64 peer->handshake.remote_static, cookie_key_label); in wg_cookie_checker_precompute_peer_keys()
65 precompute_key(peer->latest_cookie.message_mac1_key, in wg_cookie_checker_precompute_peer_keys()
66 peer->handshake.remote_static, mac1_key_label); in wg_cookie_checker_precompute_peer_keys()
157 struct wg_peer *peer) in wg_cookie_add_mac_to_packet() argument
162 down_write(&peer->latest_cookie.lock); in wg_cookie_add_mac_to_packet()
164 peer->latest_cookie.message_mac1_key); in wg_cookie_add_mac_to_packet()
165 memcpy(peer->latest_cookie.last_mac1_sent, macs->mac1, COOKIE_LEN); in wg_cookie_add_mac_to_packet()
166 peer->latest_cookie.have_sent_mac1 = true; in wg_cookie_add_mac_to_packet()
[all …]
|
| H A D | timers.h | 13 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/ |
| H A D | peer_object.c | 78 static long rxrpc_peer_cmp_key(const struct rxrpc_peer *peer, in rxrpc_peer_cmp_key() argument
85 diff = ((peer->hash_key - hash_key) ?: in rxrpc_peer_cmp_key()
86 ((unsigned long)peer->local - (unsigned long)local) ?: in rxrpc_peer_cmp_key()
87 (peer->srx.transport_type - srx->transport_type) ?: in rxrpc_peer_cmp_key()
88 (peer->srx.transport_len - srx->transport_len) ?: in rxrpc_peer_cmp_key()
89 (peer->srx.transport.family - srx->transport.family)); in rxrpc_peer_cmp_key()
95 return ((u16 __force)peer->srx.transport.sin.sin_port - in rxrpc_peer_cmp_key()
97 memcmp(&peer->srx.transport.sin.sin_addr, in rxrpc_peer_cmp_key()
102 return ((u16 __force)peer->srx.transport.sin6.sin6_port - in rxrpc_peer_cmp_key()
104 memcmp(&peer->srx.transport.sin6.sin6_addr, in rxrpc_peer_cmp_key()
[all …]
|
| H A D | peer_event.c | 103 static void rxrpc_adjust_mtu(struct rxrpc_peer *peer, unsigned int mtu) in rxrpc_adjust_mtu() argument
108 if (mtu > 0 && peer->if_mtu == 65535 && mtu < peer->if_mtu) in rxrpc_adjust_mtu()
109 peer->if_mtu = mtu; in rxrpc_adjust_mtu()
113 mtu = peer->if_mtu; in rxrpc_adjust_mtu()
120 if (mtu < peer->hdrsize) in rxrpc_adjust_mtu()
121 mtu = peer->hdrsize + 4; in rxrpc_adjust_mtu()
125 max_data = max_t(int, mtu - peer->hdrsize, 500); in rxrpc_adjust_mtu()
126 if (max_data < peer->max_data) { in rxrpc_adjust_mtu()
127 if (peer->pmtud_good > max_data) in rxrpc_adjust_mtu()
128 peer->pmtud_good = max_data; in rxrpc_adjust_mtu()
[all …]
|
| H A D | conn_service.c | 21 struct rxrpc_connection *rxrpc_find_service_conn_rcu(struct rxrpc_peer *peer, in rxrpc_find_service_conn_rcu() argument
39 read_seqbegin_or_lock(&peer->service_conn_lock, &seq); in rxrpc_find_service_conn_rcu()
41 p = rcu_dereference_raw(peer->service_conns.rb_node); in rxrpc_find_service_conn_rcu()
53 } while (need_seqretry(&peer->service_conn_lock, seq)); in rxrpc_find_service_conn_rcu()
55 done_seqretry(&peer->service_conn_lock, seq); in rxrpc_find_service_conn_rcu()
64 static void rxrpc_publish_service_conn(struct rxrpc_peer *peer, in rxrpc_publish_service_conn() argument
71 write_seqlock(&peer->service_conn_lock); in rxrpc_publish_service_conn()
73 pp = &peer->service_conns.rb_node; in rxrpc_publish_service_conn()
89 rb_insert_color(&conn->service_node, &peer->service_conns); in rxrpc_publish_service_conn()
92 write_sequnlock(&peer->service_conn_lock); in rxrpc_publish_service_conn()
[all …]
|
| /linux/drivers/net/ovpn/ |
| H A D | peer.c | 29 struct ovpn_peer *peer; in unlock_ovpn() local
33 llist_for_each_entry(peer, release_list->first, release_entry) { in unlock_ovpn()
34 ovpn_socket_release(peer); in unlock_ovpn()
35 ovpn_peer_put(peer); in unlock_ovpn()
45 void ovpn_peer_keepalive_set(struct ovpn_peer *peer, u32 interval, u32 timeout) in ovpn_peer_keepalive_set() argument
49 netdev_dbg(peer->ovpn->dev, in ovpn_peer_keepalive_set()
51 peer->id, interval, timeout); in ovpn_peer_keepalive_set()
53 peer->keepalive_interval = interval; in ovpn_peer_keepalive_set()
54 WRITE_ONCE(peer->last_sent, now); in ovpn_peer_keepalive_set()
55 peer->keepalive_xmit_exp = now + interval; in ovpn_peer_keepalive_set()
[all …]
|
| H A D | tcp.c | 64 static void ovpn_tcp_to_userspace(struct ovpn_peer *peer, struct sock *sk, in ovpn_tcp_to_userspace() argument
69 skb_queue_tail(&peer->tcp.user_queue, skb); in ovpn_tcp_to_userspace()
70 peer->tcp.sk_cb.sk_data_ready(sk); in ovpn_tcp_to_userspace()
75 struct ovpn_peer *peer = container_of(strp, struct ovpn_peer, tcp.strp); in ovpn_tcp_rcv() local
84 netdev_name(peer->ovpn->dev), peer->id); in ovpn_tcp_rcv()
91 netdev_name(peer->ovpn->dev), peer->id); in ovpn_tcp_rcv()
100 netdev_name(peer->ovpn->dev), peer->id); in ovpn_tcp_rcv()
109 netdev_name(peer->ovpn->dev)); in ovpn_tcp_rcv()
117 ovpn_tcp_to_userspace(peer, strp->sk, skb); in ovpn_tcp_rcv()
126 if (WARN_ON(!ovpn_peer_hold(peer))) in ovpn_tcp_rcv()
[all …]
|
| H A D | io.c | 60 static void ovpn_netdev_write(struct ovpn_peer *peer, struct sk_buff *skb) in ovpn_netdev_write() argument
83 skb->dev = peer->ovpn->dev; in ovpn_netdev_write()
93 ret = gro_cells_receive(&peer->ovpn->gro_cells, skb); in ovpn_netdev_write()
96 ovpn_peer_stats_increment_rx(&peer->vpn_stats, pkt_len); in ovpn_netdev_write()
97 dev_dstats_rx_add(peer->ovpn->dev, pkt_len); in ovpn_netdev_write()
107 struct ovpn_peer *peer; in ovpn_decrypt_post() local
119 peer = ovpn_skb_cb(skb)->peer; in ovpn_decrypt_post()
134 netdev_name(peer->ovpn->dev), peer->id, in ovpn_decrypt_post()
140 WRITE_ONCE(peer->last_recv, ktime_get_real_seconds()); in ovpn_decrypt_post()
143 sock = rcu_dereference(peer->sock); in ovpn_decrypt_post()
[all …]
|
| H A D | netlink.c | 279 static int ovpn_nl_peer_modify(struct ovpn_peer *peer, struct genl_info *info, in ovpn_nl_peer_modify() argument
288 spin_lock_bh(&peer->lock); in ovpn_nl_peer_modify()
298 ret = ovpn_peer_reset_sockaddr(peer, &ss, local_ip); in ovpn_nl_peer_modify()
305 dst_cache_reset(&peer->dst_cache); in ovpn_nl_peer_modify()
310 peer->vpn_addrs.ipv4.s_addr = in ovpn_nl_peer_modify()
316 peer->vpn_addrs.ipv6 = in ovpn_nl_peer_modify()
325 ovpn_peer_keepalive_set(peer, interv, timeout); in ovpn_nl_peer_modify()
328 netdev_dbg(peer->ovpn->dev, in ovpn_nl_peer_modify()
330 peer->id, &ss, in ovpn_nl_peer_modify()
331 &peer->vpn_addrs.ipv4.s_addr, &peer->vpn_addrs.ipv6); in ovpn_nl_peer_modify()
[all …]
|
| H A D | socket.c | 43 static bool ovpn_socket_put(struct ovpn_peer *peer, struct ovpn_socket *sock) in ovpn_socket_put() argument
66 void ovpn_socket_release(struct ovpn_peer *peer) in ovpn_socket_release() argument
73 sock = rcu_replace_pointer(peer->sock, NULL, true); in ovpn_socket_release()
86 released = ovpn_socket_put(peer, sock); in ovpn_socket_release()
99 ovpn_peer_put(sock->peer); in ovpn_socket_release()
117 struct ovpn_peer *peer) in ovpn_socket_attach() argument
120 return ovpn_udp_socket_attach(ovpn_sock, sock, peer->ovpn); in ovpn_socket_attach()
122 return ovpn_tcp_socket_attach(ovpn_sock, peer); in ovpn_socket_attach()
134 struct ovpn_socket *ovpn_socket_new(struct socket *sock, struct ovpn_peer *peer) in ovpn_socket_new() argument
166 if (ovpn_sock->ovpn != peer->ovpn) { in ovpn_socket_new()
[all …]
|
| H A D | udp.c | 72 struct ovpn_peer *peer; in ovpn_udp_encap_recv() local
116 peer = ovpn_peer_get_by_transp_addr(ovpn, skb); in ovpn_udp_encap_recv()
118 peer = ovpn_peer_get_by_id(ovpn, peer_id); in ovpn_udp_encap_recv()
120 if (unlikely(!peer)) in ovpn_udp_encap_recv()
125 ovpn_recv(peer, skb); in ovpn_udp_encap_recv()
145 static int ovpn_udp4_output(struct ovpn_peer *peer, struct ovpn_bind *bind, in ovpn_udp4_output() argument
172 spin_lock_bh(&peer->lock); in ovpn_udp4_output()
174 spin_unlock_bh(&peer->lock); in ovpn_udp4_output()
181 spin_lock_bh(&peer->lock); in ovpn_udp4_output()
183 spin_unlock_bh(&peer->lock); in ovpn_udp4_output()
[all …]
|
| /linux/drivers/ntb/test/ |
| H A D | ntb_perf.c | 204 int (*cmd_send)(struct perf_peer *peer, enum perf_cmd cmd, u64 data);
249 static inline bool perf_link_is_up(struct perf_peer *peer) in perf_link_is_up() argument
253 link = ntb_link_is_up(peer->perf->ntb, NULL, NULL); in perf_link_is_up()
254 return !!(link & BIT_ULL_MASK(peer->pidx)); in perf_link_is_up()
257 static int perf_spad_cmd_send(struct perf_peer *peer, enum perf_cmd cmd, in perf_spad_cmd_send() argument
260 struct perf_ctx *perf = peer->perf; in perf_spad_cmd_send()
274 if (!perf_link_is_up(peer)) in perf_spad_cmd_send()
277 sts = ntb_peer_spad_read(perf->ntb, peer->pidx, in perf_spad_cmd_send()
284 ntb_peer_spad_write(perf->ntb, peer->pidx, in perf_spad_cmd_send()
287 ntb_peer_spad_write(perf->ntb, peer->pidx, in perf_spad_cmd_send()
[all …]
|
| 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()
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 = 0; peer < sizeof(peer_mask) * 8; peer++) { in ntb_msit_db_event()
160 if (!(peer_mask & BIT(peer))) in ntb_msit_db_event()
[all …]
|
| /linux/drivers/net/wireless/ath/ath11k/ |
| H A D | peer.c | 14 struct ath11k_peer *peer; in ath11k_peer_find_list_by_id() local
18 list_for_each_entry(peer, &ab->peers, list) { in ath11k_peer_find_list_by_id()
19 if (peer->peer_id != peer_id) in ath11k_peer_find_list_by_id()
22 return peer; in ath11k_peer_find_list_by_id()
31 struct ath11k_peer *peer; in ath11k_peer_find() local
35 list_for_each_entry(peer, &ab->peers, list) { in ath11k_peer_find()
36 if (peer->vdev_id != vdev_id) in ath11k_peer_find()
38 if (!ether_addr_equal(peer->addr, addr)) in ath11k_peer_find()
41 return peer; in ath11k_peer_find()
50 struct ath11k_peer *peer; in ath11k_peer_find_by_addr() local
[all …]
|
| /linux/net/tipc/ |
| H A D | monitor.c | 166 static struct tipc_peer *peer_prev(struct tipc_peer *peer) in peer_prev() argument
168 return list_last_entry(&peer->list, struct tipc_peer, list); in peer_prev()
171 static struct tipc_peer *peer_nxt(struct tipc_peer *peer) in peer_nxt() argument
173 return list_first_entry(&peer->list, struct tipc_peer, list); in peer_nxt()
176 static struct tipc_peer *peer_head(struct tipc_peer *peer) in peer_head() argument
178 while (!peer->is_head) in peer_head()
179 peer = peer_prev(peer); in peer_head()
180 return peer; in peer_head()
185 struct tipc_peer *peer; in get_peer() local
188 hlist_for_each_entry(peer, &mon->peers[thash], hash) { in get_peer()
[all …]
|
| /linux/drivers/net/wireless/ath/ath12k/ |
| H A D | peer.c | 30 struct ath12k_peer *peer; in ath12k_peer_find() local
34 list_for_each_entry(peer, &ab->peers, list) { in ath12k_peer_find()
35 if (peer->vdev_id != vdev_id) in ath12k_peer_find()
37 if (!ether_addr_equal(peer->addr, addr)) in ath12k_peer_find()
40 return peer; in ath12k_peer_find()
49 struct ath12k_peer *peer; in ath12k_peer_find_by_pdev_idx() local
53 list_for_each_entry(peer, &ab->peers, list) { in ath12k_peer_find_by_pdev_idx()
54 if (peer->pdev_idx != pdev_idx) in ath12k_peer_find_by_pdev_idx()
56 if (!ether_addr_equal(peer->addr, addr)) in ath12k_peer_find_by_pdev_idx()
59 return peer; in ath12k_peer_find_by_pdev_idx()
[all …]
|
| /linux/net/sctp/ |
| H A D | associola.c | 171 asoc->peer.rwnd = SCTP_DEFAULT_MAXWINDOW; in sctp_association_init()
207 INIT_LIST_HEAD(&asoc->peer.transport_addr_list); in sctp_association_init()
220 asoc->peer.sack_needed = 1; in sctp_association_init()
221 asoc->peer.sack_generation = 1; in sctp_association_init()
239 /* Assume that peer would support both address types unless we are in sctp_association_init()
242 asoc->peer.ipv4_address = 1; in sctp_association_init()
244 asoc->peer.ipv6_address = 1; in sctp_association_init()
348 sctp_tsnmap_free(&asoc->peer.tsn_map); in sctp_association_free()
369 /* Free peer's cached cookie. */ in sctp_association_free()
370 kfree(asoc->peer in sctp_association_free()
483 sctp_assoc_rm_peer(struct sctp_association * asoc,struct sctp_transport * peer) sctp_assoc_rm_peer() argument
588 struct sctp_transport *peer; sctp_assoc_add_peer() local
[all...] |
| /linux/net/smc/ |
| H A D | smc_cdc.h | 195 static inline void smc_host_cursor_to_cdc(union smc_cdc_cursor *peer, in smc_host_cursor_to_cdc() argument
201 peer->count = htonl(save->count); in smc_host_cursor_to_cdc()
202 peer->wrap = htons(save->wrap); in smc_host_cursor_to_cdc()
206 static inline void smc_host_msg_to_cdc(struct smc_cdc_msg *peer, in smc_host_msg_to_cdc() argument
212 peer->common.type = local->common.type; in smc_host_msg_to_cdc()
213 peer->len = local->len; in smc_host_msg_to_cdc()
214 peer->seqno = htons(local->seqno); in smc_host_msg_to_cdc()
215 peer->token = htonl(local->token); in smc_host_msg_to_cdc()
216 smc_host_cursor_to_cdc(&peer->prod, &local->prod, save, conn); in smc_host_msg_to_cdc()
217 smc_host_cursor_to_cdc(&peer->cons, &local->cons, save, conn); in smc_host_msg_to_cdc()
[all …]
|
| /linux/net/bluetooth/ |
| H A D | 6lowpan.c | 92 struct lowpan_peer *peer) in peer_add() argument
94 list_add_rcu(&peer->list, &dev->peers); in peer_add()
99 struct lowpan_peer *peer) in peer_del() argument
101 list_del_rcu(&peer->list); in peer_del()
102 kfree_rcu(peer, rcu); in peer_del()
117 struct lowpan_peer *peer; in __peer_lookup_chan() local
119 list_for_each_entry_rcu(peer, &dev->peers, list) { in __peer_lookup_chan()
120 if (peer->chan == chan) in __peer_lookup_chan()
121 return peer; in __peer_lookup_chan()
130 struct lowpan_peer *peer; in __peer_lookup_conn() local
[all …]
|
| /linux/drivers/net/wireless/intel/iwlwifi/mvm/ |
| H A D | ftm-initiator.c | 218 struct cfg80211_pmsr_request_peer *peer, in iwl_mvm_ftm_target_chandef_v1() argument
222 u32 freq = peer->chandef.chan->center_freq; in iwl_mvm_ftm_target_chandef_v1()
226 switch (peer->chandef.width) { in iwl_mvm_ftm_target_chandef_v1()
241 peer->chandef.width); in iwl_mvm_ftm_target_chandef_v1()
245 *ctrl_ch_position = (peer->chandef.width > NL80211_CHAN_WIDTH_20) ? in iwl_mvm_ftm_target_chandef_v1()
246 iwl_mvm_get_ctrl_pos(&peer->chandef) : 0; in iwl_mvm_ftm_target_chandef_v1()
253 struct cfg80211_pmsr_request_peer *peer, in iwl_mvm_ftm_target_chandef_v2() argument
257 u32 freq = peer->chandef.chan->center_freq; in iwl_mvm_ftm_target_chandef_v2()
262 switch (peer->chandef.width) { in iwl_mvm_ftm_target_chandef_v2()
292 peer->chandef.width); in iwl_mvm_ftm_target_chandef_v2()
[all …]
|
| /linux/drivers/ntb/ |
| H A D | msi.c | 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_count(ntb); peer++) { in ntb_msi_setup_mws()
128 peer_widx = ntb_peer_highest_mw_idx(ntb, peer); in ntb_msi_setup_mws()
134 ret = ntb_mw_get_align(ntb, peer, peer_widx, NULL, 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()
[all …]
|