Home
last modified time | relevance | path

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

/drivers/staging/lustre/lnet/lnet/
Dapi-ni.c42 lnet_t the_lnet; /* THE state of the network */ variable
43 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 init_waitqueue_head(&the_lnet.ln_rc_waitq); in lnet_init_locks()
98 mutex_init(&the_lnet.ln_lnd_mutex); in lnet_init_locks()
99 mutex_init(&the_lnet.ln_api_mutex); in lnet_init_locks()
108 LASSERT(!the_lnet.ln_remote_nets_hash); in lnet_create_remote_nets_table()
109 LASSERT(the_lnet.ln_remote_nets_hbits > 0); in lnet_create_remote_nets_table()
118 the_lnet.ln_remote_nets_hash = hash; in lnet_create_remote_nets_table()
[all …]
Drouter.c181 list_for_each_prev(pos, &the_lnet.ln_routers) { in lnet_rtr_addref_locked()
192 the_lnet.ln_routers_version++; in lnet_rtr_addref_locked()
209 &the_lnet.ln_rcd_deathrow); in lnet_rtr_decref_locked()
216 the_lnet.ln_routers_version++; in lnet_rtr_decref_locked()
227 LASSERT(!the_lnet.ln_shutdown); in lnet_find_net_locked()
256 list_for_each(tmp, &the_lnet.ln_nis) { in lnet_shuffle_seed()
293 the_lnet.ln_remote_nets_version++; in lnet_add_route_to_rnet()
359 LASSERT(!the_lnet.ln_shutdown); in lnet_add_route()
410 wake_up(&the_lnet.ln_rc_waitq); in lnet_add_route()
430 rn_list = &the_lnet.ln_remote_nets_hash[i]; in lnet_check_routes()
[all …]
Dmodule.c51 if (!the_lnet.ln_niinit_self) { in lnet_configure()
59 the_lnet.ln_niinit_self = 1; in lnet_configure()
78 if (the_lnet.ln_niinit_self) { in lnet_unconfigure()
79 the_lnet.ln_niinit_self = 0; in lnet_unconfigure()
84 mutex_lock(&the_lnet.ln_api_mutex); in lnet_unconfigure()
85 refcount = the_lnet.ln_refcount; in lnet_unconfigure()
86 mutex_unlock(&the_lnet.ln_api_mutex); in lnet_unconfigure()
103 if (!the_lnet.ln_niinit_self) { in lnet_dyn_configure()
125 if (!the_lnet.ln_niinit_self) { in lnet_dyn_unconfigure()
149 the_lnet.ln_nis_from_mod_params = data->ioc_flags; in lnet_ioctl()
Dlib-ptl.c45 struct lnet_portal *ptl = the_lnet.ln_portals[index]; in lnet_ptl_match_type()
233 LASSERT(index < the_lnet.ln_nportals); in lnet_mt_of_attach()
238 ptl = the_lnet.ln_portals[index]; in lnet_mt_of_attach()
272 LASSERT(info->mi_portal < the_lnet.ln_nportals); in lnet_mt_of_match()
273 ptl = the_lnet.ln_portals[info->mi_portal]; in lnet_mt_of_match()
321 if (!lnet_ptl_is_wildcard(the_lnet.ln_portals[mtable->mt_portal])) in lnet_mt_test_exhausted()
345 LASSERT(lnet_ptl_is_wildcard(the_lnet.ln_portals[mtable->mt_portal])); in lnet_mt_set_exhausted()
362 struct lnet_portal *ptl = the_lnet.ln_portals[mtable->mt_portal]; in lnet_mt_match_head()
391 if (lnet_ptl_is_wildcard(the_lnet.ln_portals[mtable->mt_portal])) in lnet_mt_match_md()
426 !lnet_ptl_is_lazy(the_lnet.ln_portals[info->mi_portal])) in lnet_mt_match_md()
[all …]
Dpeer.c48 the_lnet.ln_peer_tables = cfs_percpt_alloc(lnet_cpt_table(), in lnet_peer_tables_create()
50 if (!the_lnet.ln_peer_tables) { in lnet_peer_tables_create()
55 cfs_percpt_for_each(ptable, i, the_lnet.ln_peer_tables) { in lnet_peer_tables_create()
82 if (!the_lnet.ln_peer_tables) in lnet_peer_tables_destroy()
85 cfs_percpt_for_each(ptable, i, the_lnet.ln_peer_tables) { in lnet_peer_tables_destroy()
99 cfs_percpt_free(the_lnet.ln_peer_tables); in lnet_peer_tables_destroy()
100 the_lnet.ln_peer_tables = NULL; in lnet_peer_tables_destroy()
181 LASSERT(the_lnet.ln_shutdown || ni); in lnet_peer_tables_cleanup()
186 cfs_percpt_for_each(ptable, i, the_lnet.ln_peer_tables) { in lnet_peer_tables_cleanup()
196 cfs_percpt_for_each(ptable, i, the_lnet.ln_peer_tables) { in lnet_peer_tables_cleanup()
[all …]
Dlib-eq.c71 LASSERT(the_lnet.ln_refcount > 0); in LNetEQAlloc()
123 lnet_res_lh_initialize(&the_lnet.ln_eq_container, &eq->eq_lh); in LNetEQAlloc()
124 list_add(&eq->eq_list, &the_lnet.ln_eq_container.rec_active); in LNetEQAlloc()
165 LASSERT(the_lnet.ln_refcount > 0); in LNetEQFree()
236 if (waitqueue_active(&the_lnet.ln_eq_waitq)) in lnet_eq_enqueue_event()
237 wake_up_all(&the_lnet.ln_eq_waitq); in lnet_eq_enqueue_event()
311 __must_hold(&the_lnet.ln_eq_wait_lock) in lnet_eq_wait_locked()
323 add_wait_queue(&the_lnet.ln_eq_waitq, &wl); in lnet_eq_wait_locked()
341 remove_wait_queue(&the_lnet.ln_eq_waitq, &wl); in lnet_eq_wait_locked()
380 LASSERT(the_lnet.ln_refcount > 0); in LNetEQPoll()
Dlib-me.c82 LASSERT(the_lnet.ln_refcount > 0); in LNetMEAttach()
84 if ((int)portal >= the_lnet.ln_nportals) in LNetMEAttach()
105 lnet_res_lh_initialize(the_lnet.ln_me_containers[mtable->mt_cpt], in LNetMEAttach()
154 LASSERT(the_lnet.ln_refcount > 0); in LNetMEInsert()
175 LASSERT(current_me->me_portal < the_lnet.ln_nportals); in LNetMEInsert()
177 ptl = the_lnet.ln_portals[current_me->me_portal]; in LNetMEInsert()
193 lnet_res_lh_initialize(the_lnet.ln_me_containers[cpt], &new_me->me_lh); in LNetMEInsert()
230 LASSERT(the_lnet.ln_refcount > 0); in LNetMEUnlink()
Dlib-msg.c71 ev->initiator.pid = the_lnet.ln_pid; in lnet_build_msg_event()
134 struct lnet_msg_container *container = the_lnet.ln_msg_containers[cpt]; in lnet_msg_commit()
135 lnet_counters_t *counters = the_lnet.ln_counters[cpt]; in lnet_msg_commit()
174 counters = the_lnet.ln_counters[msg->msg_tx_cpt]; in lnet_msg_decommit_tx()
228 counters = the_lnet.ln_counters[msg->msg_rx_cpt]; in lnet_msg_decommit_rx()
300 the_lnet.ln_counters[cpt2]->msgs_alloc--; in lnet_msg_decommit()
480 container = the_lnet.ln_msg_containers[cpt]; in lnet_finalize()
518 if (unlikely(!list_empty(&the_lnet.ln_delay_rules))) { in lnet_finalize()
593 if (!the_lnet.ln_msg_containers) in lnet_msg_containers_destroy()
596 cfs_percpt_for_each(container, i, the_lnet.ln_msg_containers) in lnet_msg_containers_destroy()
[all …]
Drouter_proc.c160 the_lnet.ln_routing ? "enabled" : "disabled"); in proc_lnet_routes()
168 ver = (unsigned int)the_lnet.ln_remote_nets_version; in proc_lnet_routes()
182 if (ver != LNET_PROC_VERSION(the_lnet.ln_remote_nets_version)) { in proc_lnet_routes()
189 rn_list = &the_lnet.ln_remote_nets_hash[i]; in proc_lnet_routes()
290 ver = (unsigned int)the_lnet.ln_routers_version; in proc_lnet_routers()
300 if (ver != LNET_PROC_VERSION(the_lnet.ln_routers_version)) { in proc_lnet_routers()
307 r = the_lnet.ln_routers.next; in proc_lnet_routers()
309 while (r != &the_lnet.ln_routers) { in proc_lnet_routers()
442 ptable = the_lnet.ln_peer_tables[cpt]; in proc_lnet_peers()
588 if (!the_lnet.ln_rtrpools) in __proc_lnet_buffers()
[all …]
Dlib-move.c67 list_add_tail(&tp->tp_list, &the_lnet.ln_test_peers); in lnet_fail_nid()
77 list_for_each_safe(el, next, &the_lnet.ln_test_peers) { in lnet_fail_nid()
112 list_for_each_safe(el, next, &the_lnet.ln_test_peers) { in fail_peer()
446 msg->msg_hdr.src_pid = cpu_to_le32(the_lnet.ln_pid); in lnet_prep_send()
612 the_lnet.ln_counters[cpt]->drop_count++; in lnet_post_send_locked()
613 the_lnet.ln_counters[cpt]->drop_length += msg->msg_len; in lnet_post_send_locked()
690 rbp = &the_lnet.ln_rtrpools[cpt][0]; in lnet_msg2bufpool()
695 LASSERT(rbp < &the_lnet.ln_rtrpools[cpt][LNET_NRBPOOLS]); in lnet_msg2bufpool()
905 if (!the_lnet.ln_routing) { in lnet_return_rx_credits_locked()
940 if (!the_lnet.ln_routing) { in lnet_return_rx_credits_locked()
[all …]
Dnet_fault.c179 list_add(&rule->dr_link, &the_lnet.ln_drop_rules); in lnet_drop_rule_add()
206 list_for_each_entry_safe(rule, tmp, &the_lnet.ln_drop_rules, dr_link) { in lnet_drop_rule_del()
245 list_for_each_entry(rule, &the_lnet.ln_drop_rules, dr_link) { in lnet_drop_rule_list()
272 list_for_each_entry(rule, &the_lnet.ln_drop_rules, dr_link) { in lnet_drop_rule_reset()
372 list_for_each_entry(rule, &the_lnet.ln_drop_rules, dr_link) { in lnet_drop_rule_match()
552 list_for_each_entry(rule, &the_lnet.ln_delay_rules, dl_link) { in lnet_delay_rule_match_locked()
782 list_add(&rule->dl_link, &the_lnet.ln_delay_rules); in lnet_delay_rule_add()
828 list_for_each_entry_safe(rule, tmp, &the_lnet.ln_delay_rules, dl_link) { in lnet_delay_rule_del()
845 cleanup = list_empty(&the_lnet.ln_delay_rules) && in lnet_delay_rule_del()
887 list_for_each_entry(rule, &the_lnet.ln_delay_rules, dl_link) { in lnet_delay_rule_list()
[all …]
Dacceptor.c173 if (the_lnet.ln_testprotocompat) { in lnet_connect()
176 if (the_lnet.ln_testprotocompat & 4) { in lnet_connect()
178 the_lnet.ln_testprotocompat &= ~4; in lnet_connect()
180 if (the_lnet.ln_testprotocompat & 8) { in lnet_connect()
182 the_lnet.ln_testprotocompat &= ~8; in lnet_connect()
Dlib-md.c170 struct lnet_res_container *container = the_lnet.ln_md_containers[cpt]; in lnet_md_link()
280 LASSERT(the_lnet.ln_refcount > 0); in LNetMDAttach()
359 LASSERT(the_lnet.ln_refcount > 0); in LNetMDBind()
434 LASSERT(the_lnet.ln_refcount > 0); in LNetMDUnlink()
/drivers/staging/lustre/include/linux/lnet/
Dlib-lnet.h44 extern lnet_t the_lnet; /* THE network */
61 #define LNET_CPT_NUMBER (the_lnet.ln_cpt_number)
62 #define LNET_CPT_BITS (the_lnet.ln_cpt_bits)
112 #define lnet_cpt_table() (the_lnet.ln_cpt_table)
113 #define lnet_cpt_current() cfs_cpt_current(the_lnet.ln_cpt_table, 1)
130 cfs_percpt_lock(the_lnet.ln_res_lock, cpt); in lnet_res_lock()
136 cfs_percpt_unlock(the_lnet.ln_res_lock, cpt); in lnet_res_unlock()
151 cfs_percpt_lock(the_lnet.ln_net_lock, cpt); in lnet_net_lock()
157 cfs_percpt_unlock(the_lnet.ln_net_lock, cpt); in lnet_net_unlock()
174 #define lnet_eq_wait_lock() spin_lock(&the_lnet.ln_eq_wait_lock)
[all …]
Dlib-types.h368 #define lnet_peer_aliveness_enabled(lp) (the_lnet.ln_routing && \
384 #define LNET_REMOTE_NETS_HASH_SIZE (1 << the_lnet.ln_remote_nets_hbits)
/drivers/staging/lustre/lnet/klnds/socklnd/
Dsocklnd_proto.c475 if (the_lnet.ln_testprotocompat) { in ksocknal_send_hello_v1()
478 if (the_lnet.ln_testprotocompat & 1) { in ksocknal_send_hello_v1()
480 the_lnet.ln_testprotocompat &= ~1; in ksocknal_send_hello_v1()
482 if (the_lnet.ln_testprotocompat & 2) { in ksocknal_send_hello_v1()
484 the_lnet.ln_testprotocompat &= ~2; in ksocknal_send_hello_v1()
532 if (the_lnet.ln_testprotocompat) { in ksocknal_send_hello_v2()
535 if (the_lnet.ln_testprotocompat & 1) { in ksocknal_send_hello_v2()
537 the_lnet.ln_testprotocompat &= ~1; in ksocknal_send_hello_v2()
Dsocklnd_cb.c1679 hello->kshm_src_pid = the_lnet.ln_pid; in ksocknal_send_hello()