Whamcloud - gitweb
LU-7345 obdclass: annotate locks in __local_file_create
[fs/lustre-release.git] / lnet / selftest / module.c
1 /*
2  * GPL HEADER START
3  *
4  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
5  *
6  * This program is free software; you can redistribute it and/or modify
7  * it under the terms of the GNU General Public License version 2 only,
8  * as published by the Free Software Foundation.
9  *
10  * This program is distributed in the hope that it will be useful, but
11  * WITHOUT ANY WARRANTY; without even the implied warranty of
12  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
13  * General Public License version 2 for more details (a copy is included
14  * in the LICENSE file that accompanied this code).
15  *
16  * You should have received a copy of the GNU General Public License
17  * version 2 along with this program; If not, see
18  * http://www.sun.com/software/products/lustre/docs/GPLv2.pdf
19  *
20  * Please contact Sun Microsystems, Inc., 4150 Network Circle, Santa Clara,
21  * CA 95054 USA or visit www.sun.com if you need additional information or
22  * have any questions.
23  *
24  * GPL HEADER END
25  */
26 /*
27  * Copyright (c) 2007, 2010, Oracle and/or its affiliates. All rights reserved.
28  * Use is subject to license terms.
29  *
30  * Copyright (c) 2012, Intel Corporation.
31  */
32 /*
33  * This file is part of Lustre, http://www.lustre.org/
34  * Lustre is a trademark of Sun Microsystems, Inc.
35  */
36
37 #define DEBUG_SUBSYSTEM S_LNET
38
39 #include "selftest.h"
40 #include "console.h"
41
42 enum {
43         LST_INIT_NONE           = 0,
44         LST_INIT_WI_SERIAL,
45         LST_INIT_WI_TEST,
46         LST_INIT_RPC,
47         LST_INIT_FW,
48         LST_INIT_CONSOLE
49 };
50
51 static int lst_init_step = LST_INIT_NONE;
52
53 struct cfs_wi_sched *lst_sched_serial;
54 struct cfs_wi_sched **lst_sched_test;
55
56 static void
57 lnet_selftest_fini(void)
58 {
59         int     i;
60
61         switch (lst_init_step) {
62                 case LST_INIT_CONSOLE:
63                         lstcon_console_fini();
64                 case LST_INIT_FW:
65                         sfw_shutdown();
66                 case LST_INIT_RPC:
67                         srpc_shutdown();
68                 case LST_INIT_WI_TEST:
69                         for (i = 0;
70                              i < cfs_cpt_number(lnet_cpt_table()); i++) {
71                                 if (lst_sched_test[i] == NULL)
72                                         continue;
73                                 cfs_wi_sched_destroy(lst_sched_test[i]);
74                         }
75                         LIBCFS_FREE(lst_sched_test,
76                                     sizeof(lst_sched_test[0]) *
77                                     cfs_cpt_number(lnet_cpt_table()));
78                         lst_sched_test = NULL;
79
80                 case LST_INIT_WI_SERIAL:
81                         cfs_wi_sched_destroy(lst_sched_serial);
82                         lst_sched_serial = NULL;
83                 case LST_INIT_NONE:
84                         break;
85                 default:
86                         LBUG();
87         }
88         return;
89 }
90
91 void
92 lnet_selftest_structure_assertion(void)
93 {
94         CLASSERT(sizeof(srpc_msg_t) == 160);
95         CLASSERT(sizeof(srpc_test_reqst_t) == 70);
96         CLASSERT(offsetof(srpc_msg_t, msg_body.tes_reqst.tsr_concur) == 72);
97         CLASSERT(offsetof(srpc_msg_t, msg_body.tes_reqst.tsr_ndest) == 78);
98         CLASSERT(sizeof(srpc_stat_reply_t) == 136);
99         CLASSERT(sizeof(srpc_stat_reqst_t) == 28);
100 }
101
102 static int
103 lnet_selftest_init(void)
104 {
105         int     nscheds;
106         int     rc;
107         int     i;
108
109         rc = cfs_wi_sched_create("lst_s", lnet_cpt_table(), CFS_CPT_ANY,
110                                  1, &lst_sched_serial);
111         if (rc != 0) {
112                 CERROR("Failed to create serial WI scheduler for LST\n");
113                 return rc;
114         }
115         lst_init_step = LST_INIT_WI_SERIAL;
116
117         nscheds = cfs_cpt_number(lnet_cpt_table());
118         LIBCFS_ALLOC(lst_sched_test, sizeof(lst_sched_test[0]) * nscheds);
119         if (lst_sched_test == NULL)
120                 goto error;
121
122         lst_init_step = LST_INIT_WI_TEST;
123         for (i = 0; i < nscheds; i++) {
124                 int nthrs = cfs_cpt_weight(lnet_cpt_table(), i);
125
126                 /* reserve at least one CPU for LND */
127                 nthrs = max(nthrs - 1, 1);
128                 rc = cfs_wi_sched_create("lst_t", lnet_cpt_table(), i,
129                                          nthrs, &lst_sched_test[i]);
130                 if (rc != 0) {
131                         CERROR("Failed to create CPT affinity WI scheduler "
132                                "%d for LST\n", i);
133                         goto error;
134                 }
135         }
136
137         rc = srpc_startup();
138         if (rc != 0) {
139                 CERROR("LST can't startup rpc\n");
140                 goto error;
141         }
142         lst_init_step = LST_INIT_RPC;
143
144         rc = sfw_startup();
145         if (rc != 0) {
146                 CERROR("LST can't startup framework\n");
147                 goto error;
148         }
149         lst_init_step = LST_INIT_FW;
150
151         rc = lstcon_console_init();
152         if (rc != 0) {
153                 CERROR("LST can't startup console\n");
154                 goto error;
155         }
156         lst_init_step = LST_INIT_CONSOLE;
157         return 0;
158 error:
159         lnet_selftest_fini();
160         return rc;
161 }
162
163
164 MODULE_DESCRIPTION("LNet Selftest");
165 MODULE_VERSION("0.9.0");
166 MODULE_LICENSE("GPL");
167
168 module_init(lnet_selftest_init);
169 module_exit(lnet_selftest_fini);