| /linux-4.4.14/drivers/staging/lustre/lnet/klnds/socklnd/ |
| D | socklnd.h | 417 lnet_ni_t *ksnp_ni; /* which network */
426 lnet_ni_t *ksncr_ni; /* chosen NI */
570 void ksocknal_tx_done(lnet_ni_t *ni, ksock_tx_t *tx);
614 int ksocknal_startup(lnet_ni_t *ni);
615 void ksocknal_shutdown(lnet_ni_t *ni);
616 int ksocknal_ctl(lnet_ni_t *ni, unsigned int cmd, void *arg);
617 int ksocknal_send(lnet_ni_t *ni, void *private, lnet_msg_t *lntmsg);
618 int ksocknal_recv(lnet_ni_t *ni, void *private, lnet_msg_t *lntmsg,
622 int ksocknal_accept(lnet_ni_t *ni, struct socket *sock);
624 int ksocknal_add_peer(lnet_ni_t *ni, lnet_process_id_t id, __u32 ip, int port);
[all …]
|
| D | socklnd.c | 50 ksocknal_ip2iface(lnet_ni_t *ni, __u32 ip) in ksocknal_ip2iface()
103 ksocknal_create_peer(ksock_peer_t **peerp, lnet_ni_t *ni, lnet_process_id_t id) in ksocknal_create_peer()
176 ksocknal_find_peer_locked(lnet_ni_t *ni, lnet_process_id_t id) in ksocknal_find_peer_locked()
204 ksocknal_find_peer(lnet_ni_t *ni, lnet_process_id_t id) in ksocknal_find_peer()
248 ksocknal_get_peer_info(lnet_ni_t *ni, int index, in ksocknal_get_peer_info()
448 ksocknal_add_peer(lnet_ni_t *ni, lnet_process_id_t id, __u32 ipaddr, int port) in ksocknal_add_peer()
565 ksocknal_del_peer(lnet_ni_t *ni, lnet_process_id_t id, __u32 ip) in ksocknal_del_peer()
624 ksocknal_get_conn_by_idx(lnet_ni_t *ni, int index) in ksocknal_get_conn_by_idx()
684 ksocknal_local_ipvec(lnet_ni_t *ni, __u32 *ipaddrs) in ksocknal_local_ipvec()
851 lnet_ni_t *ni = peer->ksnp_ni; in ksocknal_create_routes()
[all …]
|
| D | socklnd_cb.c | 389 ksocknal_tx_done (lnet_ni_t *ni, ksock_tx_t *tx) in ksocknal_tx_done()
408 ksocknal_txlist_done (lnet_ni_t *ni, struct list_head *txlist, int error) in ksocknal_txlist_done()
830 ksocknal_launch_packet (lnet_ni_t *ni, ksock_tx_t *tx, lnet_process_id_t id) in ksocknal_launch_packet()
921 ksocknal_send(lnet_ni_t *ni, void *private, lnet_msg_t *lntmsg) in ksocknal_send()
1311 ksocknal_recv (lnet_ni_t *ni, void *private, lnet_msg_t *msg, int delayed, in ksocknal_recv()
1647 ksocknal_send_hello (lnet_ni_t *ni, ksock_conn_t *conn, in ksocknal_send_hello()
1685 ksocknal_recv_hello (lnet_ni_t *ni, ksock_conn_t *conn, in ksocknal_recv_hello()
|
| /linux-4.4.14/drivers/staging/lustre/lnet/lnet/ |
| D | lo.c | 39 lolnd_send(lnet_ni_t *ni, void *private, lnet_msg_t *lntmsg) in lolnd_send()
48 lolnd_recv(lnet_ni_t *ni, void *private, lnet_msg_t *lntmsg, in lolnd_recv()
90 lolnd_shutdown(lnet_ni_t *ni) in lolnd_shutdown()
99 lolnd_startup(lnet_ni_t *ni) in lolnd_startup()
|
| D | api-ni.c | 652 lnet_ni_t *
656 lnet_ni_t *ni; in lnet_net2ni_locked()
661 ni = list_entry(tmp, lnet_ni_t, ni_list); in lnet_net2ni_locked()
672 lnet_ni_t *
675 lnet_ni_t *ni; in lnet_net2ni()
765 lnet_ni_t *
774 ni = list_entry(tmp, lnet_ni_t, ni_list); in lnet_nid2ni_locked()
811 ni = list_entry(tmp, lnet_ni_t, ni_list); in lnet_count_acceptor_nis()
823 lnet_ni_tq_credits(lnet_ni_t *ni) in lnet_ni_tq_credits()
844 lnet_ni_t *ni; in lnet_shutdown_lndnis()
[all …]
|
| D | lib-move.c | 564 lnet_ni_recv(lnet_ni_t *ni, void *private, lnet_msg_t *msg, int delayed, in lnet_ni_recv()
642 lnet_ni_send(lnet_ni_t *ni, lnet_msg_t *msg) in lnet_ni_send()
657 lnet_ni_eager_recv(lnet_ni_t *ni, lnet_msg_t *msg) in lnet_ni_eager_recv()
681 lnet_ni_query_locked(lnet_ni_t *ni, lnet_peer_t *lp) in lnet_ni_query_locked()
787 lnet_ni_t *ni = lp->lp_ni; in lnet_post_send_locked()
1120 lnet_find_route_locked(lnet_ni_t *ni, lnet_nid_t target, lnet_nid_t rtr_nid) in lnet_find_route_locked()
1351 lnet_drop_message(lnet_ni_t *ni, int cpt, void *private, unsigned int nob) in lnet_drop_message()
1362 lnet_recv_put(lnet_ni_t *ni, lnet_msg_t *msg) in lnet_recv_put()
1381 lnet_parse_put(lnet_ni_t *ni, lnet_msg_t *msg) in lnet_parse_put()
1431 lnet_parse_get(lnet_ni_t *ni, lnet_msg_t *msg, int rdma_get) in lnet_parse_get()
[all …]
|
| D | router.c | 56 lnet_peer_buffer_credits(lnet_ni_t *ni) in lnet_peer_buffer_credits()
129 lnet_ni_notify_locked(lnet_ni_t *ni, lnet_peer_t *lp) in lnet_ni_notify_locked()
240 lnet_ni_t *ni; in lnet_shuffle_seed()
251 ni = list_entry(tmp, lnet_ni_t, ni_list); in lnet_shuffle_seed()
299 lnet_ni_t *ni; in lnet_add_route()
790 lnet_ni_t *ni; in lnet_update_ni_status_locked()
1493 lnet_notify(lnet_ni_t *ni, lnet_nid_t nid, int alive, unsigned long when) in lnet_notify()
|
| D | config.c | 84 lnet_ni_t *ni; in lnet_net_unique()
87 ni = list_entry(tmp, lnet_ni_t, ni_list); in lnet_net_unique()
111 static lnet_ni_t *
353 ni = list_entry(nilist->next, lnet_ni_t, ni_list); in lnet_parse_networks()
|
| D | router_proc.c | 673 lnet_ni_t *ni = NULL; in proc_lnet_nis()
681 lnet_ni_t *a_ni = list_entry(n, lnet_ni_t, ni_list); in proc_lnet_nis()
|
| D | acceptor.c | 215 lnet_ni_t *ni; in lnet_accept()
|
| D | lib-msg.c | 435 lnet_finalize(lnet_ni_t *ni, lnet_msg_t *msg, int status) in lnet_finalize()
|
| /linux-4.4.14/drivers/staging/lustre/include/linux/lnet/ |
| D | lib-lnet.h | 375 lnet_ni_addref_locked(lnet_ni_t *ni, int cpt) in lnet_ni_addref_locked()
384 lnet_ni_addref(lnet_ni_t *ni) in lnet_ni_addref()
392 lnet_ni_decref_locked(lnet_ni_t *ni, int cpt) in lnet_ni_decref_locked()
401 lnet_ni_decref(lnet_ni_t *ni) in lnet_ni_decref()
408 void lnet_ni_free(lnet_ni_t *ni);
429 lnet_ni_t *lnet_nid2ni_locked(lnet_nid_t nid, int cpt);
430 lnet_ni_t *lnet_net2ni_locked(__u32 net, int cpt);
431 lnet_ni_t *lnet_net2ni(__u32 net);
436 int lnet_notify(lnet_ni_t *ni, lnet_nid_t peer, int alive, unsigned long when);
523 int lnet_parse(lnet_ni_t *ni, lnet_hdr_t *hdr,
[all …]
|
| D | lib-types.h | 271 } lnet_ni_t; typedef
326 lnet_ni_t *lp_ni; /* interface peer is on */
555 lnet_ni_t *ln_loni; /* the loopback NI */
557 lnet_ni_t *ln_eq_waitni;
|
| /linux-4.4.14/drivers/staging/lustre/lnet/klnds/o2iblnd/ |
| D | o2iblnd.h | 574 lnet_ni_t *ibp_ni; /* LNet interface */
922 int kiblnd_startup(lnet_ni_t *ni);
923 void kiblnd_shutdown(lnet_ni_t *ni);
924 int kiblnd_ctl(lnet_ni_t *ni, unsigned int cmd, void *arg);
943 int kiblnd_create_peer(lnet_ni_t *ni, kib_peer_t **peerp, lnet_nid_t nid);
964 void kiblnd_launch_tx(lnet_ni_t *ni, kib_tx_t *tx, lnet_nid_t nid);
967 void kiblnd_init_tx_msg(lnet_ni_t *ni, kib_tx_t *tx, int type, int body_nob);
968 void kiblnd_txlist_done(lnet_ni_t *ni, struct list_head *txlist,
976 void kiblnd_pack_msg(lnet_ni_t *ni, kib_msg_t *msg, int version,
981 int kiblnd_send(lnet_ni_t *ni, void *private, lnet_msg_t *lntmsg);
[all …]
|
| D | o2iblnd_cb.c | 43 static void kiblnd_unmap_tx(lnet_ni_t *ni, kib_tx_t *tx);
46 kiblnd_tx_done(lnet_ni_t *ni, kib_tx_t *tx) in kiblnd_tx_done()
89 kiblnd_txlist_done(lnet_ni_t *ni, struct list_head *txlist, int status) in kiblnd_txlist_done()
105 kiblnd_get_idle_tx(lnet_ni_t *ni, lnet_nid_t target) in kiblnd_get_idle_tx()
248 lnet_ni_t *ni = conn->ibc_peer->ibp_ni; in kiblnd_handle_completion()
285 lnet_ni_t *ni = conn->ibc_peer->ibp_ni; in kiblnd_send_completion()
306 lnet_ni_t *ni = conn->ibc_peer->ibp_ni; in kiblnd_handle_rx()
467 lnet_ni_t *ni = conn->ibc_peer->ibp_ni; in kiblnd_rx_complete()
601 static void kiblnd_unmap_tx(lnet_ni_t *ni, kib_tx_t *tx) in kiblnd_unmap_tx()
619 static int kiblnd_map_tx(lnet_ni_t *ni, kib_tx_t *tx, kib_rdma_desc_t *rd, in kiblnd_map_tx()
[all …]
|
| D | o2iblnd.c | 187 void kiblnd_pack_msg(lnet_ni_t *ni, kib_msg_t *msg, int version, in kiblnd_pack_msg()
322 int kiblnd_create_peer(lnet_ni_t *ni, kib_peer_t **peerp, lnet_nid_t nid) in kiblnd_create_peer()
423 static int kiblnd_get_peer_info(lnet_ni_t *ni, int index, in kiblnd_get_peer_info()
481 static int kiblnd_del_peer(lnet_ni_t *ni, lnet_nid_t nid) in kiblnd_del_peer()
534 static kib_conn_t *kiblnd_get_conn_by_idx(lnet_ni_t *ni, int index) in kiblnd_get_conn_by_idx()
957 static int kiblnd_close_matching_conns(lnet_ni_t *ni, lnet_nid_t nid) in kiblnd_close_matching_conns()
1004 int kiblnd_ctl(lnet_ni_t *ni, unsigned int cmd, void *arg) in kiblnd_ctl()
1057 void kiblnd_query(lnet_ni_t *ni, lnet_nid_t nid, unsigned long *when) in kiblnd_query()
2494 void kiblnd_shutdown(lnet_ni_t *ni) in kiblnd_shutdown()
2747 int kiblnd_startup(lnet_ni_t *ni) in kiblnd_startup()
|