| /linux-4.1.27/drivers/staging/lustre/lnet/klnds/socklnd/ |
| D | socklnd.h | 350 lnet_ni_t *ksnp_ni; /* which network */
357 lnet_ni_t *ksncr_ni; /* chosen NI */
470 extern void ksocknal_tx_done(lnet_ni_t *ni, ksock_tx_t *tx);
514 int ksocknal_startup(lnet_ni_t *ni);
515 void ksocknal_shutdown(lnet_ni_t *ni);
516 int ksocknal_ctl(lnet_ni_t *ni, unsigned int cmd, void *arg);
517 int ksocknal_send(lnet_ni_t *ni, void *private, lnet_msg_t *lntmsg);
518 int ksocknal_recv(lnet_ni_t *ni, void *private, lnet_msg_t *lntmsg,
522 int ksocknal_accept(lnet_ni_t *ni, struct socket *sock);
524 extern 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()
832 ksocknal_launch_packet (lnet_ni_t *ni, ksock_tx_t *tx, lnet_process_id_t id) in ksocknal_launch_packet()
923 ksocknal_send(lnet_ni_t *ni, void *private, lnet_msg_t *lntmsg) in ksocknal_send()
1313 ksocknal_recv (lnet_ni_t *ni, void *private, lnet_msg_t *msg, int delayed, in ksocknal_recv()
1649 ksocknal_send_hello (lnet_ni_t *ni, ksock_conn_t *conn, in ksocknal_send_hello()
1687 ksocknal_recv_hello (lnet_ni_t *ni, ksock_conn_t *conn, in ksocknal_recv_hello()
|
| /linux-4.1.27/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 | 725 lnet_ni_t *
729 lnet_ni_t *ni; in lnet_net2ni_locked()
734 ni = list_entry(tmp, lnet_ni_t, ni_list); in lnet_net2ni_locked()
745 lnet_ni_t *
748 lnet_ni_t *ni; in lnet_net2ni()
838 lnet_ni_t *
847 ni = list_entry(tmp, lnet_ni_t, ni_list); in lnet_nid2ni_locked()
884 ni = list_entry(tmp, lnet_ni_t, ni_list); in lnet_count_acceptor_nis()
896 lnet_ni_tq_credits(lnet_ni_t *ni) in lnet_ni_tq_credits()
917 lnet_ni_t *ni; in lnet_shutdown_lndnis()
[all …]
|
| D | lib-move.c | 565 lnet_ni_recv(lnet_ni_t *ni, void *private, lnet_msg_t *msg, int delayed, in lnet_ni_recv()
643 lnet_ni_send(lnet_ni_t *ni, lnet_msg_t *msg) in lnet_ni_send()
658 lnet_ni_eager_recv(lnet_ni_t *ni, lnet_msg_t *msg) in lnet_ni_eager_recv()
682 lnet_ni_query_locked(lnet_ni_t *ni, lnet_peer_t *lp) in lnet_ni_query_locked()
789 lnet_ni_t *ni = lp->lp_ni; in lnet_post_send_locked()
1123 lnet_find_route_locked(lnet_ni_t *ni, lnet_nid_t target, lnet_nid_t rtr_nid) in lnet_find_route_locked()
1354 lnet_drop_message(lnet_ni_t *ni, int cpt, void *private, unsigned int nob) in lnet_drop_message()
1365 lnet_recv_put(lnet_ni_t *ni, lnet_msg_t *msg) in lnet_recv_put()
1384 lnet_parse_put(lnet_ni_t *ni, lnet_msg_t *msg) in lnet_parse_put()
1434 lnet_parse_get(lnet_ni_t *ni, lnet_msg_t *msg, int rdma_get) in lnet_parse_get()
[all …]
|
| D | router.c | 58 lnet_peer_buffer_credits(lnet_ni_t *ni) in lnet_peer_buffer_credits()
76 lnet_peer_buffer_credits(lnet_ni_t *ni) in lnet_peer_buffer_credits()
140 lnet_ni_notify_locked(lnet_ni_t *ni, lnet_peer_t *lp) in lnet_ni_notify_locked()
252 lnet_ni_t *ni; in lnet_shuffle_seed()
263 ni = list_entry(tmp, lnet_ni_t, ni_list); in lnet_shuffle_seed()
311 lnet_ni_t *ni; in lnet_add_route()
802 lnet_ni_t *ni; in lnet_update_ni_status_locked()
1508 lnet_notify(lnet_ni_t *ni, lnet_nid_t nid, int alive, unsigned long when) in lnet_notify()
1585 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()
1216 lnet_set_ip_niaddr(lnet_ni_t *ni) in lnet_set_ip_niaddr()
|
| D | router_proc.c | 688 lnet_ni_t *ni = NULL; in proc_lnet_nis()
696 lnet_ni_t *a_ni = list_entry(n, lnet_ni_t, ni_list); in proc_lnet_nis()
|
| D | acceptor.c | 218 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.1.27/drivers/staging/lustre/include/linux/lnet/ |
| D | lib-lnet.h | 589 lnet_ni_addref_locked(lnet_ni_t *ni, int cpt) in lnet_ni_addref_locked()
598 lnet_ni_addref(lnet_ni_t *ni) in lnet_ni_addref()
606 lnet_ni_decref_locked(lnet_ni_t *ni, int cpt) in lnet_ni_decref_locked()
615 lnet_ni_decref(lnet_ni_t *ni) in lnet_ni_decref()
622 void lnet_ni_free(lnet_ni_t *ni);
643 lnet_ni_t *lnet_nid2ni_locked(lnet_nid_t nid, int cpt);
644 lnet_ni_t *lnet_net2ni_locked(__u32 net, int cpt);
645 lnet_ni_t *lnet_net2ni(__u32 net);
647 int lnet_notify(lnet_ni_t *ni, lnet_nid_t peer, int alive, unsigned long when);
734 int lnet_parse(lnet_ni_t *ni, lnet_hdr_t *hdr,
[all …]
|
| D | lib-types.h | 412 } lnet_ni_t; typedef
465 lnet_ni_t *lp_ni; /* interface peer is on */
705 lnet_ni_t *ln_loni; /* the loopback NI */
707 lnet_ni_t *ln_eq_waitni;
|
| /linux-4.1.27/drivers/staging/lustre/lnet/klnds/o2iblnd/ |
| D | o2iblnd.h | 614 lnet_ni_t *ibp_ni; /* LNet interface */
954 int kiblnd_map_tx(lnet_ni_t *ni, kib_tx_t *tx,
956 void kiblnd_unmap_tx(lnet_ni_t *ni, kib_tx_t *tx);
968 int kiblnd_startup (lnet_ni_t *ni);
969 void kiblnd_shutdown (lnet_ni_t *ni);
970 int kiblnd_ctl (lnet_ni_t *ni, unsigned int cmd, void *arg);
989 int kiblnd_create_peer (lnet_ni_t *ni, kib_peer_t **peerp, lnet_nid_t nid);
1010 void kiblnd_launch_tx (lnet_ni_t *ni, kib_tx_t *tx, lnet_nid_t nid);
1013 void kiblnd_init_tx_msg (lnet_ni_t *ni, kib_tx_t *tx, int type, int body_nob);
1014 void kiblnd_txlist_done (lnet_ni_t *ni, struct list_head *txlist,
[all …]
|
| D | o2iblnd_cb.c | 44 kiblnd_tx_done(lnet_ni_t *ni, kib_tx_t *tx) in kiblnd_tx_done()
87 kiblnd_txlist_done(lnet_ni_t *ni, struct list_head *txlist, int status) in kiblnd_txlist_done()
103 kiblnd_get_idle_tx(lnet_ni_t *ni, lnet_nid_t target) in kiblnd_get_idle_tx()
241 lnet_ni_t *ni = conn->ibc_peer->ibp_ni; in kiblnd_handle_completion()
279 lnet_ni_t *ni = conn->ibc_peer->ibp_ni; in kiblnd_send_completion()
300 lnet_ni_t *ni = conn->ibc_peer->ibp_ni; in kiblnd_handle_rx()
461 lnet_ni_t *ni = conn->ibc_peer->ibp_ni; in kiblnd_rx_complete()
632 kiblnd_unmap_tx(lnet_ni_t *ni, kib_tx_t *tx) in kiblnd_unmap_tx()
655 kiblnd_map_tx(lnet_ni_t *ni, kib_tx_t *tx, in kiblnd_map_tx()
699 kiblnd_setup_rd_iov(lnet_ni_t *ni, kib_tx_t *tx, kib_rdma_desc_t *rd, in kiblnd_setup_rd_iov()
[all …]
|
| D | o2iblnd.c | 186 void kiblnd_pack_msg(lnet_ni_t *ni, kib_msg_t *msg, int version, in kiblnd_pack_msg()
321 int kiblnd_create_peer(lnet_ni_t *ni, kib_peer_t **peerp, lnet_nid_t nid) in kiblnd_create_peer()
422 static int kiblnd_get_peer_info(lnet_ni_t *ni, int index, in kiblnd_get_peer_info()
480 static int kiblnd_del_peer(lnet_ni_t *ni, lnet_nid_t nid) in kiblnd_del_peer()
533 static kib_conn_t *kiblnd_get_conn_by_idx(lnet_ni_t *ni, int index) in kiblnd_get_conn_by_idx()
954 static int kiblnd_close_matching_conns(lnet_ni_t *ni, lnet_nid_t nid) in kiblnd_close_matching_conns()
1001 int kiblnd_ctl(lnet_ni_t *ni, unsigned int cmd, void *arg) in kiblnd_ctl()
1054 void kiblnd_query(lnet_ni_t *ni, lnet_nid_t nid, unsigned long *when) in kiblnd_query()
2733 void kiblnd_shutdown(lnet_ni_t *ni) in kiblnd_shutdown()
2993 int kiblnd_startup(lnet_ni_t *ni) in kiblnd_startup()
|