Home
last modified time | relevance | path

Searched refs:the_lnet (Results 1 – 17 of 17) sorted by relevance

/linux-4.1.27/drivers/staging/lustre/lnet/lnet/
Dapi-ni.c44 lnet_t the_lnet; /* THE state of the network */ variable
45 EXPORT_SYMBOL(the_lnet);
95 spin_lock_init(&the_lnet.ln_eq_wait_lock); in lnet_init_locks()
96 init_waitqueue_head(&the_lnet.ln_eq_waitq); in lnet_init_locks()
97 mutex_init(&the_lnet.ln_lnd_mutex); in lnet_init_locks()
98 mutex_init(&the_lnet.ln_api_mutex); in lnet_init_locks()
113 LASSERT(the_lnet.ln_remote_nets_hash == NULL); in lnet_create_remote_nets_table()
114 LASSERT(the_lnet.ln_remote_nets_hbits > 0); in lnet_create_remote_nets_table()
123 the_lnet.ln_remote_nets_hash = hash; in lnet_create_remote_nets_table()
132 if (the_lnet.ln_remote_nets_hash == NULL) in lnet_destroy_remote_nets_table()
[all …]
Drouter.c189 list_for_each_prev(pos, &the_lnet.ln_routers) { in lnet_rtr_addref_locked()
200 the_lnet.ln_routers_version++; in lnet_rtr_addref_locked()
217 &the_lnet.ln_rcd_deathrow); in lnet_rtr_decref_locked()
224 the_lnet.ln_routers_version++; in lnet_rtr_decref_locked()
235 LASSERT(!the_lnet.ln_shutdown); in lnet_find_net_locked()
262 list_for_each(tmp, &the_lnet.ln_nis) { in lnet_shuffle_seed()
299 the_lnet.ln_remote_nets_version++; in lnet_add_route_to_rnet()
366 LASSERT(!the_lnet.ln_shutdown); in lnet_add_route()
431 rn_list = &the_lnet.ln_remote_nets_hash[i]; in lnet_check_routes()
492 rn_list = &the_lnet.ln_remote_nets_hash[0]; in lnet_del_route()
[all …]
Dmodule.c54 if (!the_lnet.ln_niinit_self) { in lnet_configure()
57 the_lnet.ln_niinit_self = 1; in lnet_configure()
73 if (the_lnet.ln_niinit_self) { in lnet_unconfigure()
74 the_lnet.ln_niinit_self = 0; in lnet_unconfigure()
78 LNET_MUTEX_LOCK(&the_lnet.ln_api_mutex); in lnet_unconfigure()
79 refcount = the_lnet.ln_refcount; in lnet_unconfigure()
80 LNET_MUTEX_UNLOCK(&the_lnet.ln_api_mutex); in lnet_unconfigure()
Dlib-eq.c75 LASSERT(the_lnet.ln_init); in LNetEQAlloc()
76 LASSERT(the_lnet.ln_refcount > 0); in LNetEQAlloc()
120 lnet_res_lh_initialize(&the_lnet.ln_eq_container, &eq->eq_lh); in LNetEQAlloc()
121 list_add(&eq->eq_list, &the_lnet.ln_eq_container.rec_active); in LNetEQAlloc()
162 LASSERT(the_lnet.ln_init); in LNetEQFree()
163 LASSERT(the_lnet.ln_refcount > 0); in LNetEQFree()
232 if (waitqueue_active(&the_lnet.ln_eq_waitq)) in lnet_eq_enqueue_event()
233 wake_up_all(&the_lnet.ln_eq_waitq); in lnet_eq_enqueue_event()
324 __must_hold(&the_lnet.ln_eq_wait_lock) in lnet_eq_wait_locked()
336 add_wait_queue(&the_lnet.ln_eq_waitq, &wl); in lnet_eq_wait_locked()
[all …]
Dpeer.c51 the_lnet.ln_peer_tables = cfs_percpt_alloc(lnet_cpt_table(), in lnet_peer_tables_create()
53 if (the_lnet.ln_peer_tables == NULL) { in lnet_peer_tables_create()
58 cfs_percpt_for_each(ptable, i, the_lnet.ln_peer_tables) { in lnet_peer_tables_create()
85 if (the_lnet.ln_peer_tables == NULL) in lnet_peer_tables_destroy()
88 cfs_percpt_for_each(ptable, i, the_lnet.ln_peer_tables) { in lnet_peer_tables_destroy()
102 cfs_percpt_free(the_lnet.ln_peer_tables); in lnet_peer_tables_destroy()
103 the_lnet.ln_peer_tables = NULL; in lnet_peer_tables_destroy()
113 LASSERT(the_lnet.ln_shutdown); /* i.e. no new peers */ in lnet_peer_tables_cleanup()
115 cfs_percpt_for_each(ptable, i, the_lnet.ln_peer_tables) { in lnet_peer_tables_cleanup()
134 cfs_percpt_for_each(ptable, i, the_lnet.ln_peer_tables) { in lnet_peer_tables_cleanup()
[all …]
Dlib-me.c86 LASSERT(the_lnet.ln_init); in LNetMEAttach()
87 LASSERT(the_lnet.ln_refcount > 0); in LNetMEAttach()
89 if ((int)portal >= the_lnet.ln_nportals) in LNetMEAttach()
110 lnet_res_lh_initialize(the_lnet.ln_me_containers[mtable->mt_cpt], in LNetMEAttach()
159 LASSERT(the_lnet.ln_init); in LNetMEInsert()
160 LASSERT(the_lnet.ln_refcount > 0); in LNetMEInsert()
181 LASSERT(current_me->me_portal < the_lnet.ln_nportals); in LNetMEInsert()
183 ptl = the_lnet.ln_portals[current_me->me_portal]; in LNetMEInsert()
199 lnet_res_lh_initialize(the_lnet.ln_me_containers[cpt], &new_me->me_lh); in LNetMEInsert()
236 LASSERT(the_lnet.ln_init); in LNetMEUnlink()
[all …]
Dlib-ptl.c50 struct lnet_portal *ptl = the_lnet.ln_portals[index]; in lnet_ptl_match_type()
234 LASSERT(index < the_lnet.ln_nportals); in lnet_mt_of_attach()
239 ptl = the_lnet.ln_portals[index]; in lnet_mt_of_attach()
271 LASSERT(info->mi_portal < the_lnet.ln_nportals); in lnet_mt_of_match()
272 ptl = the_lnet.ln_portals[info->mi_portal]; in lnet_mt_of_match()
318 if (!lnet_ptl_is_wildcard(the_lnet.ln_portals[mtable->mt_portal])) in lnet_mt_test_exhausted()
342 LASSERT(lnet_ptl_is_wildcard(the_lnet.ln_portals[mtable->mt_portal])); in lnet_mt_set_exhausted()
359 struct lnet_portal *ptl = the_lnet.ln_portals[mtable->mt_portal]; in lnet_mt_match_head()
389 if (lnet_ptl_is_wildcard(the_lnet.ln_portals[mtable->mt_portal])) in lnet_mt_match_md()
422 !lnet_ptl_is_lazy(the_lnet.ln_portals[info->mi_portal])) in lnet_mt_match_md()
[all …]
Dlib-msg.c75 ev->initiator.pid = the_lnet.ln_pid; in lnet_build_msg_event()
139 struct lnet_msg_container *container = the_lnet.ln_msg_containers[cpt]; in lnet_msg_commit()
140 lnet_counters_t *counters = the_lnet.ln_counters[cpt]; in lnet_msg_commit()
179 counters = the_lnet.ln_counters[msg->msg_tx_cpt]; in lnet_msg_decommit_tx()
231 counters = the_lnet.ln_counters[msg->msg_rx_cpt]; in lnet_msg_decommit_rx()
299 the_lnet.ln_counters[cpt2]->msgs_alloc--; in lnet_msg_decommit()
491 container = the_lnet.ln_msg_containers[cpt]; in lnet_finalize()
613 if (the_lnet.ln_msg_containers == NULL) in lnet_msg_containers_destroy()
616 cfs_percpt_for_each(container, i, the_lnet.ln_msg_containers) in lnet_msg_containers_destroy()
619 cfs_percpt_free(the_lnet.ln_msg_containers); in lnet_msg_containers_destroy()
[all …]
Dlib-md.c170 struct lnet_res_container *container = the_lnet.ln_md_containers[cpt]; in lnet_md_link()
276 LASSERT(the_lnet.ln_init); in LNetMDAttach()
277 LASSERT(the_lnet.ln_refcount > 0); in LNetMDAttach()
353 LASSERT(the_lnet.ln_init); in LNetMDBind()
354 LASSERT(the_lnet.ln_refcount > 0); in LNetMDBind()
428 LASSERT(the_lnet.ln_init); in LNetMDUnlink()
429 LASSERT(the_lnet.ln_refcount > 0); in LNetMDUnlink()
Drouter_proc.c196 the_lnet.ln_routing ? "enabled" : "disabled"); in proc_lnet_routes()
204 ver = (unsigned int)the_lnet.ln_remote_nets_version; in proc_lnet_routes()
218 if (ver != LNET_PROC_VERSION(the_lnet.ln_remote_nets_version)) { in proc_lnet_routes()
226 rn_list = &the_lnet.ln_remote_nets_hash[i]; in proc_lnet_routes()
327 ver = (unsigned int)the_lnet.ln_routers_version; in proc_lnet_routers()
337 if (ver != LNET_PROC_VERSION(the_lnet.ln_routers_version)) { in proc_lnet_routers()
344 r = the_lnet.ln_routers.next; in proc_lnet_routers()
346 while (r != &the_lnet.ln_routers) { in proc_lnet_routers()
477 ptable = the_lnet.ln_peer_tables[cpt]; in proc_lnet_peers()
621 if (the_lnet.ln_rtrpools == NULL) in __proc_lnet_buffers()
[all …]
Dlib-move.c57 LASSERT(the_lnet.ln_init); in lnet_fail_nid()
70 list_add_tail(&tp->tp_list, &the_lnet.ln_test_peers); in lnet_fail_nid()
80 list_for_each_safe(el, next, &the_lnet.ln_test_peers) { in lnet_fail_nid()
116 list_for_each_safe(el, next, &the_lnet.ln_test_peers) { in fail_peer()
638 msg->msg_hdr.src_pid = cpu_to_le32(the_lnet.ln_pid); in lnet_prep_send()
801 the_lnet.ln_counters[cpt]->drop_count++; in lnet_post_send_locked()
802 the_lnet.ln_counters[cpt]->drop_length += msg->msg_len; in lnet_post_send_locked()
880 rbp = &the_lnet.ln_rtrpools[cpt][0]; in lnet_msg2bufpool()
885 LASSERT(rbp < &the_lnet.ln_rtrpools[cpt][LNET_NRBPOOLS]); in lnet_msg2bufpool()
1209 if (the_lnet.ln_shutdown) { in lnet_send()
[all …]
Dacceptor.c173 if (the_lnet.ln_testprotocompat != 0) { in lnet_connect()
176 if ((the_lnet.ln_testprotocompat & 4) != 0) { in lnet_connect()
178 the_lnet.ln_testprotocompat &= ~4; in lnet_connect()
180 if ((the_lnet.ln_testprotocompat & 8) != 0) { in lnet_connect()
182 the_lnet.ln_testprotocompat &= ~8; in lnet_connect()
Dconfig.c202 the_lnet.ln_network_tokens = tokens; in lnet_parse_networks()
203 the_lnet.ln_network_tokens_nob = tokensize; in lnet_parse_networks()
363 the_lnet.ln_network_tokens = NULL; in lnet_parse_networks()
/linux-4.1.27/drivers/staging/lustre/include/linux/lnet/
Dlib-lnet.h50 extern lnet_t the_lnet; /* THE network */
74 #define LNET_CPT_NUMBER (the_lnet.ln_cpt_number)
75 #define LNET_CPT_BITS (the_lnet.ln_cpt_bits)
111 #define lnet_cpt_table() (the_lnet.ln_cpt_table)
112 #define lnet_cpt_current() cfs_cpt_current(the_lnet.ln_cpt_table, 1)
127 cfs_percpt_lock(the_lnet.ln_res_lock, cpt); in lnet_res_lock()
133 cfs_percpt_unlock(the_lnet.ln_res_lock, cpt); in lnet_res_unlock()
148 cfs_percpt_lock(the_lnet.ln_net_lock, cpt); in lnet_net_lock()
154 cfs_percpt_unlock(the_lnet.ln_net_lock, cpt); in lnet_net_unlock()
171 #define lnet_eq_wait_lock() spin_lock(&the_lnet.ln_eq_wait_lock)
[all …]
Dlib-types.h491 #define lnet_peer_aliveness_enabled(lp) (the_lnet.ln_routing != 0 && \
507 #define LNET_REMOTE_NETS_HASH_SIZE (1 << the_lnet.ln_remote_nets_hbits)
/linux-4.1.27/drivers/staging/lustre/lnet/klnds/socklnd/
Dsocklnd_proto.c477 if (the_lnet.ln_testprotocompat != 0) { in ksocknal_send_hello_v1()
480 if ((the_lnet.ln_testprotocompat & 1) != 0) { in ksocknal_send_hello_v1()
482 the_lnet.ln_testprotocompat &= ~1; in ksocknal_send_hello_v1()
484 if ((the_lnet.ln_testprotocompat & 2) != 0) { in ksocknal_send_hello_v1()
486 the_lnet.ln_testprotocompat &= ~2; in ksocknal_send_hello_v1()
537 if (the_lnet.ln_testprotocompat != 0) { in ksocknal_send_hello_v2()
540 if ((the_lnet.ln_testprotocompat & 1) != 0) { in ksocknal_send_hello_v2()
542 the_lnet.ln_testprotocompat &= ~1; in ksocknal_send_hello_v2()
Dsocklnd_cb.c1662 hello->kshm_src_pid = the_lnet.ln_pid; in ksocknal_send_hello()