Home
last modified time | relevance | path

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

/linux-4.4.14/drivers/staging/lustre/lnet/lnet/
Dapi-ni.c45 lnet_t the_lnet; /* THE state of the network */ variable
46 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()
107 LASSERT(the_lnet.ln_remote_nets_hash == NULL); in lnet_create_remote_nets_table()
108 LASSERT(the_lnet.ln_remote_nets_hbits > 0); in lnet_create_remote_nets_table()
117 the_lnet.ln_remote_nets_hash = hash; in lnet_create_remote_nets_table()
126 if (the_lnet.ln_remote_nets_hash == NULL) in lnet_destroy_remote_nets_table()
[all …]
Drouter.c177 list_for_each_prev(pos, &the_lnet.ln_routers) { in lnet_rtr_addref_locked()
188 the_lnet.ln_routers_version++; in lnet_rtr_addref_locked()
205 &the_lnet.ln_rcd_deathrow); in lnet_rtr_decref_locked()
212 the_lnet.ln_routers_version++; in lnet_rtr_decref_locked()
223 LASSERT(!the_lnet.ln_shutdown); in lnet_find_net_locked()
250 list_for_each(tmp, &the_lnet.ln_nis) { in lnet_shuffle_seed()
287 the_lnet.ln_remote_nets_version++; in lnet_add_route_to_rnet()
354 LASSERT(!the_lnet.ln_shutdown); in lnet_add_route()
419 rn_list = &the_lnet.ln_remote_nets_hash[i]; in lnet_check_routes()
480 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 mutex_lock(&the_lnet.ln_api_mutex); in lnet_unconfigure()
79 refcount = the_lnet.ln_refcount; in lnet_unconfigure()
80 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()
323 __must_hold(&the_lnet.ln_eq_wait_lock) in lnet_eq_wait_locked()
335 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.c181 the_lnet.ln_routing ? "enabled" : "disabled"); in proc_lnet_routes()
189 ver = (unsigned int)the_lnet.ln_remote_nets_version; in proc_lnet_routes()
203 if (ver != LNET_PROC_VERSION(the_lnet.ln_remote_nets_version)) { in proc_lnet_routes()
211 rn_list = &the_lnet.ln_remote_nets_hash[i]; in proc_lnet_routes()
312 ver = (unsigned int)the_lnet.ln_routers_version; in proc_lnet_routers()
322 if (ver != LNET_PROC_VERSION(the_lnet.ln_routers_version)) { in proc_lnet_routers()
329 r = the_lnet.ln_routers.next; in proc_lnet_routers()
331 while (r != &the_lnet.ln_routers) { in proc_lnet_routers()
462 ptable = the_lnet.ln_peer_tables[cpt]; in proc_lnet_peers()
606 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()
637 msg->msg_hdr.src_pid = cpu_to_le32(the_lnet.ln_pid); in lnet_prep_send()
799 the_lnet.ln_counters[cpt]->drop_count++; in lnet_post_send_locked()
800 the_lnet.ln_counters[cpt]->drop_length += msg->msg_len; in lnet_post_send_locked()
877 rbp = &the_lnet.ln_rtrpools[cpt][0]; in lnet_msg2bufpool()
882 LASSERT(rbp < &the_lnet.ln_rtrpools[cpt][LNET_NRBPOOLS]); in lnet_msg2bufpool()
1206 if (the_lnet.ln_shutdown) { in lnet_send()
[all …]
Dacceptor.c172 if (the_lnet.ln_testprotocompat != 0) { in lnet_connect()
175 if ((the_lnet.ln_testprotocompat & 4) != 0) { in lnet_connect()
177 the_lnet.ln_testprotocompat &= ~4; in lnet_connect()
179 if ((the_lnet.ln_testprotocompat & 8) != 0) { in lnet_connect()
181 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.4.14/drivers/staging/lustre/include/linux/lnet/
Dlib-lnet.h43 extern lnet_t the_lnet; /* THE network */
60 #define LNET_CPT_NUMBER (the_lnet.ln_cpt_number)
61 #define LNET_CPT_BITS (the_lnet.ln_cpt_bits)
97 #define lnet_cpt_table() (the_lnet.ln_cpt_table)
98 #define lnet_cpt_current() cfs_cpt_current(the_lnet.ln_cpt_table, 1)
113 cfs_percpt_lock(the_lnet.ln_res_lock, cpt); in lnet_res_lock()
119 cfs_percpt_unlock(the_lnet.ln_res_lock, cpt); in lnet_res_unlock()
134 cfs_percpt_lock(the_lnet.ln_net_lock, cpt); in lnet_net_lock()
140 cfs_percpt_unlock(the_lnet.ln_net_lock, cpt); in lnet_net_unlock()
157 #define lnet_eq_wait_lock() spin_lock(&the_lnet.ln_eq_wait_lock)
[all …]
Dlib-types.h352 #define lnet_peer_aliveness_enabled(lp) (the_lnet.ln_routing != 0 && \
368 #define LNET_REMOTE_NETS_HASH_SIZE (1 << the_lnet.ln_remote_nets_hbits)
/linux-4.4.14/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()
535 if (the_lnet.ln_testprotocompat != 0) { in ksocknal_send_hello_v2()
538 if ((the_lnet.ln_testprotocompat & 1) != 0) { in ksocknal_send_hello_v2()
540 the_lnet.ln_testprotocompat &= ~1; in ksocknal_send_hello_v2()
Dsocklnd_cb.c1660 hello->kshm_src_pid = the_lnet.ln_pid; in ksocknal_send_hello()