Home
last modified time | relevance | path

Searched refs:link (Results 1 – 25 of 77) sorted by relevance

1234

/net/smc/
Dsmc_llc.c144 struct smc_link *link, in smc_llc_tx_handler() argument
163 static int smc_llc_add_pending_send(struct smc_link *link, in smc_llc_add_pending_send() argument
169 rc = smc_wr_tx_get_free_slot(link, smc_llc_tx_handler, wr_buf, NULL, in smc_llc_add_pending_send()
186 int smc_llc_send_confirm_link(struct smc_link *link, in smc_llc_send_confirm_link() argument
189 struct smc_link_group *lgr = smc_get_lgr(link); in smc_llc_send_confirm_link()
195 rc = smc_llc_add_pending_send(link, &wr_buf, &pend); in smc_llc_send_confirm_link()
205 memcpy(confllc->sender_mac, link->smcibdev->mac[link->ibport - 1], in smc_llc_send_confirm_link()
207 memcpy(confllc->sender_gid, link->gid, SMC_GID_SIZE); in smc_llc_send_confirm_link()
208 hton24(confllc->sender_qp_num, link->roce_qp->qp_num); in smc_llc_send_confirm_link()
209 confllc->link_num = link->link_id; in smc_llc_send_confirm_link()
[all …]
Dsmc_wr.c44 struct smc_link *link; member
53 static inline int smc_wr_tx_find_pending_index(struct smc_link *link, u64 wr_id) in smc_wr_tx_find_pending_index() argument
57 for (i = 0; i < link->wr_tx_cnt; i++) { in smc_wr_tx_find_pending_index()
58 if (link->wr_tx_pends[i].wr_id == wr_id) in smc_wr_tx_find_pending_index()
61 return link->wr_tx_cnt; in smc_wr_tx_find_pending_index()
67 struct smc_link *link; in smc_wr_tx_process_cqe() local
71 link = wc->qp->qp_context; in smc_wr_tx_process_cqe()
75 link->wr_reg_state = FAILED; in smc_wr_tx_process_cqe()
77 link->wr_reg_state = CONFIRMED; in smc_wr_tx_process_cqe()
78 wake_up(&link->wr_reg_wait); in smc_wr_tx_process_cqe()
[all …]
Dsmc_wr.h53 static inline long smc_wr_tx_get_next_wr_id(struct smc_link *link) in smc_wr_tx_get_next_wr_id() argument
55 return atomic_long_inc_return(&link->wr_tx_id); in smc_wr_tx_get_next_wr_id()
64 static inline int smc_wr_rx_post(struct smc_link *link) in smc_wr_rx_post() argument
70 wr_id = ++link->wr_rx_id; /* tasklet context, thus not atomic */ in smc_wr_rx_post()
72 index = do_div(temp_wr_id, link->wr_rx_cnt); in smc_wr_rx_post()
73 link->wr_rx_ibs[index].wr_id = wr_id; in smc_wr_rx_post()
74 rc = ib_post_recv(link->roce_qp, &link->wr_rx_ibs[index], NULL); in smc_wr_rx_post()
86 int smc_wr_tx_get_free_slot(struct smc_link *link, smc_wr_tx_handler handler,
90 int smc_wr_tx_put_slot(struct smc_link *link,
92 int smc_wr_tx_send(struct smc_link *link,
[all …]
Dsmc_llc.h41 int smc_llc_send_add_link(struct smc_link *link, u8 mac[], u8 gid[],
43 int smc_llc_send_delete_link(struct smc_link *link,
45 int smc_llc_link_init(struct smc_link *link);
46 void smc_llc_link_active(struct smc_link *link, int testlink_time);
47 void smc_llc_link_deleting(struct smc_link *link);
48 void smc_llc_link_inactive(struct smc_link *link);
49 void smc_llc_link_clear(struct smc_link *link);
50 int smc_llc_do_confirm_rkey(struct smc_link *link,
52 int smc_llc_do_delete_rkey(struct smc_link *link,
Daf_smc.c344 static int smc_reg_rmb(struct smc_link *link, struct smc_buf_desc *rmb_desc, in smc_reg_rmb() argument
349 if (smc_wr_reg_send(link, rmb_desc->mr_rx[SMC_SINGLE_LINK])) { in smc_reg_rmb()
358 if (smc_llc_do_confirm_rkey(link, rmb_desc)) { in smc_reg_rmb()
369 struct smc_link *link; in smc_clnt_conf_first_link() local
373 link = &lgr->lnk[SMC_SINGLE_LINK]; in smc_clnt_conf_first_link()
376 &link->llc_confirm, in smc_clnt_conf_first_link()
386 if (link->llc_confirm_rc) in smc_clnt_conf_first_link()
389 rc = smc_ib_modify_qp_rts(link); in smc_clnt_conf_first_link()
393 smc_wr_remember_qp_attr(link); in smc_clnt_conf_first_link()
395 if (smc_reg_rmb(link, smc->conn.rmb_desc, false)) in smc_clnt_conf_first_link()
[all …]
Dsmc_clc.c474 struct smc_link *link; in smc_clc_send_confirm() local
499 link = &conn->lgr->lnk[SMC_SINGLE_LINK]; in smc_clc_send_confirm()
506 memcpy(&cclc.lcl.gid, link->gid, SMC_GID_SIZE); in smc_clc_send_confirm()
507 memcpy(&cclc.lcl.mac, &link->smcibdev->mac[link->ibport - 1], in smc_clc_send_confirm()
509 hton24(cclc.qpn, link->roce_qp->qp_num); in smc_clc_send_confirm()
514 cclc.qp_mtu = min(link->path_mtu, link->peer_mtu); in smc_clc_send_confirm()
518 hton24(cclc.psn, link->psn_initial); in smc_clc_send_confirm()
545 struct smc_link *link; in smc_clc_send_accept() local
575 link = &conn->lgr->lnk[SMC_SINGLE_LINK]; in smc_clc_send_accept()
578 memcpy(&aclc.lcl.gid, link->gid, SMC_GID_SIZE); in smc_clc_send_accept()
[all …]
Dsmc_cdc.c26 struct smc_link *link, in smc_cdc_tx_handler() argument
60 struct smc_link *link = &conn->lgr->lnk[SMC_SINGLE_LINK]; in smc_cdc_get_free_slot() local
63 rc = smc_wr_tx_get_free_slot(link, smc_cdc_tx_handler, wr_buf, in smc_cdc_get_free_slot()
95 struct smc_link *link; in smc_cdc_msg_send() local
98 link = &conn->lgr->lnk[SMC_SINGLE_LINK]; in smc_cdc_msg_send()
105 rc = smc_wr_tx_send(link, (struct smc_wr_tx_pend_priv *)pend); in smc_cdc_msg_send()
165 struct smc_link *link = &conn->lgr->lnk[SMC_SINGLE_LINK]; in smc_cdc_tx_dismiss_slots() local
167 smc_wr_tx_dismiss_slots(link, SMC_CDC_MSG_TYPE, in smc_cdc_tx_dismiss_slots()
353 struct smc_link *link = (struct smc_link *)wc->qp->qp_context; in smc_cdc_rx_handler() local
365 lgr = smc_get_lgr(link); in smc_cdc_rx_handler()
/net/unix/
Dgarbage.c154 BUG_ON(!list_empty(&u->link)); in scan_children()
155 list_add_tail(&u->link, &embryos); in scan_children()
160 u = list_entry(embryos.next, struct unix_sock, link); in scan_children()
162 list_del_init(&u->link); in scan_children()
185 list_move_tail(&u->link, &gc_candidates); in inc_inflight_move_tail()
238 list_for_each_entry_safe(u, next, &gc_inflight_list, link) { in unix_gc()
248 list_move_tail(&u->link, &gc_candidates); in unix_gc()
257 list_for_each_entry(u, &gc_candidates, link) in unix_gc()
269 u = list_entry(cursor.next, struct unix_sock, link); in unix_gc()
272 list_move(&cursor, &u->link); in unix_gc()
[all …]
Dscm.c55 BUG_ON(!list_empty(&u->link)); in unix_inflight()
56 list_add_tail(&u->link, &gc_inflight_list); in unix_inflight()
58 BUG_ON(list_empty(&u->link)); in unix_inflight()
77 BUG_ON(list_empty(&u->link)); in unix_notinflight()
80 list_del_init(&u->link); in unix_notinflight()
/net/tipc/
Dnode.c64 struct tipc_link *link; member
72 struct tipc_link *link; member
186 return n->links[bearer_id].link; in node_active_link()
252 kfree(n->bc_entry.link); in tipc_node_kref_release()
422 l = n->links[bearer_id].link; in tipc_node_create()
473 &n->bc_entry.link)) { in tipc_node_create()
636 if (le->link) { in tipc_node_clear_links()
637 kfree(le->link); in tipc_node_clear_links()
638 le->link = NULL; in tipc_node_clear_links()
705 if (le->link) { in tipc_node_timeout()
[all …]
Dnetlink_compat.c526 struct nlattr *link[TIPC_NLA_LINK_MAX + 1]; in tipc_nl_compat_link_stat_dump() local
535 err = nla_parse_nested_deprecated(link, TIPC_NLA_LINK_MAX, in tipc_nl_compat_link_stat_dump()
540 if (!link[TIPC_NLA_LINK_PROP]) in tipc_nl_compat_link_stat_dump()
544 link[TIPC_NLA_LINK_PROP], NULL, in tipc_nl_compat_link_stat_dump()
549 if (!link[TIPC_NLA_LINK_STATS]) in tipc_nl_compat_link_stat_dump()
553 link[TIPC_NLA_LINK_STATS], NULL, in tipc_nl_compat_link_stat_dump()
568 if (strcmp(name, nla_data(link[TIPC_NLA_LINK_NAME])) != 0) in tipc_nl_compat_link_stat_dump()
572 nla_data(link[TIPC_NLA_LINK_NAME])); in tipc_nl_compat_link_stat_dump()
574 if (link[TIPC_NLA_LINK_BROADCAST]) { in tipc_nl_compat_link_stat_dump()
579 if (link[TIPC_NLA_LINK_ACTIVE]) in tipc_nl_compat_link_stat_dump()
[all …]
Dlink.h82 struct tipc_link **link);
88 struct tipc_link **link);
107 int tipc_link_xmit(struct tipc_link *link, struct sk_buff_head *list,
129 struct tipc_link *link, int nlflags);
/net/core/
Dsock_map.c129 struct sk_psock_link *link, in sock_map_add_link() argument
132 link->link_raw = link_raw; in sock_map_add_link()
133 link->map = map; in sock_map_add_link()
135 list_add_tail(&link->list, &psock->link); in sock_map_add_link()
142 struct sk_psock_link *link, *tmp; in sock_map_del_link() local
146 list_for_each_entry_safe(link, tmp, &psock->link, list) { in sock_map_del_link()
147 if (link->link_raw == link_raw) { in sock_map_del_link()
148 struct bpf_map *map = link->map; in sock_map_del_link()
153 list_del(&link->list); in sock_map_del_link()
154 sk_psock_free_link(link); in sock_map_del_link()
[all …]
Dskmsg.c561 INIT_LIST_HEAD(&psock->link); in sk_psock_init()
580 struct sk_psock_link *link; in sk_psock_link_pop() local
583 link = list_first_entry_or_null(&psock->link, struct sk_psock_link, in sk_psock_link_pop()
585 if (link) in sk_psock_link_pop()
586 list_del(&link->list); in sk_psock_link_pop()
588 return link; in sk_psock_link_pop()
610 struct sk_psock_link *link, *tmp; in sk_psock_link_destroy() local
612 list_for_each_entry_safe(link, tmp, &psock->link, list) { in sk_psock_link_destroy()
613 list_del(&link->list); in sk_psock_link_destroy()
614 sk_psock_free_link(link); in sk_psock_link_destroy()
Drtnetlink.c177 struct rtnl_link *link, *old; in rtnl_register_internal() local
198 link = kmemdup(old, sizeof(*old), GFP_KERNEL); in rtnl_register_internal()
199 if (!link) in rtnl_register_internal()
202 link = kzalloc(sizeof(*link), GFP_KERNEL); in rtnl_register_internal()
203 if (!link) in rtnl_register_internal()
207 WARN_ON(link->owner && link->owner != owner); in rtnl_register_internal()
208 link->owner = owner; in rtnl_register_internal()
210 WARN_ON(doit && link->doit && link->doit != doit); in rtnl_register_internal()
212 link->doit = doit; in rtnl_register_internal()
213 WARN_ON(dumpit && link->dumpit && link->dumpit != dumpit); in rtnl_register_internal()
[all …]
/net/sched/
Dcls_basic.c34 struct list_head link; member
46 list_for_each_entry_rcu(f, &head->flist, link) { in basic_classify()
65 list_for_each_entry(f, &head->flist, link) { in basic_get()
112 list_for_each_entry_safe(f, n, &head->flist, link) { in basic_destroy()
113 list_del_rcu(&f->link); in basic_destroy()
131 list_del_rcu(&f->link); in basic_delete()
231 list_replace_rcu(&fold->link, &fnew->link); in basic_change()
236 list_add_rcu(&fnew->link, &head->flist); in basic_change()
253 list_for_each_entry(f, &head->flist, link) { in basic_walk()
Dcls_bpf.c39 struct list_head link; member
90 list_for_each_entry_rcu(prog, &head->plist, link) { in cls_bpf_classify()
294 list_del_rcu(&prog->link); in __cls_bpf_delete()
318 list_for_each_entry_safe(prog, tmp, &head->plist, link) in cls_bpf_destroy()
330 list_for_each_entry(prog, &head->plist, link) { in cls_bpf_get()
520 list_replace_rcu(&oldprog->link, &prog->link); in cls_bpf_change()
525 list_add_rcu(&prog->link, &head->plist); in cls_bpf_change()
653 list_for_each_entry(prog, &head->plist, link) { in cls_bpf_walk()
674 list_for_each_entry(prog, &head->plist, link) { in cls_bpf_reoffload()
/net/ipv4/
Dip_tunnel.c84 int link, __be16 flags, in ip_tunnel_lookup() argument
105 if (t->parms.link == link) in ip_tunnel_lookup()
120 if (t->parms.link == link) in ip_tunnel_lookup()
140 if (t->parms.link == link) in ip_tunnel_lookup()
153 if (t->parms.link == link) in ip_tunnel_lookup()
217 int link = parms->link; in ip_tunnel_find() local
224 link == t->parms.link && in ip_tunnel_find()
297 RT_TOS(iph->tos), tunnel->parms.link, in ip_tunnel_bind_dev()
311 if (!tdev && tunnel->parms.link) in ip_tunnel_bind_dev()
312 tdev = __dev_get_by_index(tunnel->net, tunnel->parms.link); in ip_tunnel_bind_dev()
[all …]
/net/hsr/
Dhsr_netlink.c34 struct net_device *link[2]; in hsr_newlink() local
45 link[0] = __dev_get_by_index(src_net, in hsr_newlink()
51 link[1] = __dev_get_by_index(src_net, in hsr_newlink()
54 if (!link[0] || !link[1]) in hsr_newlink()
56 if (link[0] == link[1]) in hsr_newlink()
75 return hsr_dev_finalize(dev, link, multicast_spec, hsr_version); in hsr_newlink()
/net/sunrpc/
Ddebugfs.c124 char link[9]; /* enough for 8 hex digits + NULL */ in do_xprt_debugfs() local
134 strcpy(link, "xprt"); in do_xprt_debugfs()
136 len = snprintf(link, sizeof(link), "xprt%d", *nump); in do_xprt_debugfs()
137 if (len >= sizeof(link)) in do_xprt_debugfs()
140 debugfs_create_symlink(link, clnt->cl_debugfs, name); in do_xprt_debugfs()
/net/ipv6/
Dsit.c103 (!dev || !t->parms.link || ifindex == t->parms.link || in ipip6_tunnel_lookup()
104 sifindex == t->parms.link) && in ipip6_tunnel_lookup()
110 (!dev || !t->parms.link || ifindex == t->parms.link || in ipip6_tunnel_lookup()
111 sifindex == t->parms.link) && in ipip6_tunnel_lookup()
117 (!dev || !t->parms.link || ifindex == t->parms.link || in ipip6_tunnel_lookup()
118 sifindex == t->parms.link) && in ipip6_tunnel_lookup()
237 parms->link == t->parms.link) { in ipip6_tunnel_locate()
529 t->parms.link, iph->protocol); in ipip6_err()
534 ipv4_redirect(skb, dev_net(skb->dev), t->parms.link, in ipip6_err()
895 flowi4_init_output(&fl4, tunnel->parms.link, tunnel->fwmark, in ipip6_tunnel_xmit()
[all …]
/net/rxrpc/
Dlocal_object.c84 INIT_LIST_HEAD(&local->link); in rxrpc_alloc_local()
239 local = list_entry(cursor, struct rxrpc_local, link); in rxrpc_lookup_local()
277 list_replace_init(cursor, &local->link); in rxrpc_lookup_local()
279 list_add_tail(&local->link, cursor); in rxrpc_lookup_local()
420 list_del_init(&local->link); in rxrpc_local_destroyer()
509 list_for_each_entry(local, &rxnet->local_endpoints, link) { in rxrpc_destroy_all_locals()
Dconn_object.c49 INIT_LIST_HEAD(&conn->link); in rxrpc_alloc_connection()
396 list_for_each_entry_safe(conn, _p, &rxnet->service_conns, link) { in rxrpc_service_connection_reaper()
432 list_move_tail(&conn->link, &graveyard); in rxrpc_service_connection_reaper()
444 link); in rxrpc_service_connection_reaper()
445 list_del_init(&conn->link); in rxrpc_service_connection_reaper()
473 list_for_each_entry_safe(conn, _p, &rxnet->service_conns, link) { in rxrpc_destroy_all_connections()
/net/ncsi/
Dncsi-aen.c80 chained = !list_empty(&nc->link); in ncsi_aen_handler_lsc()
97 list_add_tail_rcu(&nc->link, &ndp->channel_queue); in ncsi_aen_handler_lsc()
152 if (!list_empty(&nc->link) || in ncsi_aen_handler_cr()
166 list_add_tail_rcu(&nc->link, &ndp->channel_queue); in ncsi_aen_handler_cr()
Dncsi-manage.c67 if (!list_empty(&nc->link) || in ncsi_report_link()
101 chained = !list_empty(&nc->link); in ncsi_channel_monitor()
153 list_add_tail_rcu(&nc->link, &ndp->channel_queue); in ncsi_channel_monitor()
222 INIT_LIST_HEAD(&nc->link); in ncsi_add_channel()
801 list_for_each_entry_rcu(channel, &ndp->channel_queue, link) { in ncsi_channel_is_tx()
813 list_for_each_entry_rcu(channel, &ndp->channel_queue, link) in ncsi_channel_is_tx()
1109 list_add_tail_rcu(&nc->link, &ndp->channel_queue); in ncsi_configure_channel()
1174 if (!list_empty(&nc->link) || in ncsi_choose_active_channel()
1198 list_add_tail_rcu(&nc->link, in ncsi_choose_active_channel()
1222 list_add_tail_rcu(&found->link, &ndp->channel_queue); in ncsi_choose_active_channel()
[all …]

1234