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.gnu.org/licenses/gpl-2.0.html
  19  *
  20  * GPL HEADER END
  21  */
  22 /*
  23  * Copyright (c) 2007, 2010, Oracle and/or its affiliates. All rights reserved.
  24  * Use is subject to license terms.
  25  *
  26  * Copyright (c) 2012, 2015, Intel Corporation.
  27  */
  28 /*
  29  * This file is part of Lustre, http://www.lustre.org/
  30  * Lustre is a trademark of Sun Microsystems, Inc.
  31  */
  32
  33 #define DEBUG_SUBSYSTEM S_LNET
  34
  35 #include "selftest.h"
  36 #include "console.h"
  37
  38 enum {
  39         LST_INIT_NONE           = 0,
  40         LST_INIT_WI_SERIAL,
  41         LST_INIT_WI_TEST,
  42         LST_INIT_RPC,
  43         LST_INIT_FW,
  44         LST_INIT_CONSOLE
  45 };
  46
  47 static int lst_init_step = LST_INIT_NONE;
  48
  49 struct cfs_wi_sched *lst_sched_serial;
  50 struct cfs_wi_sched **lst_sched_test;
  51
  52 static void
  53 lnet_selftest_exit(void)
  54 {
  55         int     i;
  56
  57         switch (lst_init_step) {
  58                 case LST_INIT_CONSOLE:
  59                         lstcon_console_fini();
  60                 case LST_INIT_FW:
  61                         sfw_shutdown();
  62                 case LST_INIT_RPC:
  63                         srpc_shutdown();
  64                 case LST_INIT_WI_TEST:
  65                         for (i = 0;
  66                              i < cfs_cpt_number(lnet_cpt_table()); i++) {
  67                                 if (lst_sched_test[i] == NULL)
  68                                         continue;
  69                                 cfs_wi_sched_destroy(lst_sched_test[i]);
  70                         }
  71                         LIBCFS_FREE(lst_sched_test,
  72                                     sizeof(lst_sched_test[0]) *
  73                                     cfs_cpt_number(lnet_cpt_table()));
  74                         lst_sched_test = NULL;
  75
  76                 case LST_INIT_WI_SERIAL:
  77                         cfs_wi_sched_destroy(lst_sched_serial);
  78                         lst_sched_serial = NULL;
  79                 case LST_INIT_NONE:
  80                         break;
  81                 default:
  82                         LBUG();
  83         }
  84         return;
  85 }
  86
  87 void
  88 lnet_selftest_structure_assertion(void)
  89 {
  90 /*      CLASSERT(sizeof(struct srpc_msg) == 160);
  91         CLASSERT(sizeof(struct srpc_test_reqst) == 70);
  92         CLASSERT(offsetof(struct srpc_msg, msg_body.tes_reqst.tsr_concur) == 72);
  93         CLASSERT(offsetof(struct srpc_msg, msg_body.tes_reqst.tsr_ndest) == 78);
  94         CLASSERT(sizeof(struct srpc_stat_reply) == 136);
  95         CLASSERT(sizeof(struct srpc_stat_reqst) == 28);
  96 */
  97 }
  98
  99 static int __init
 100 lnet_selftest_init(void)
 101 {
 102         int     nscheds;
 103         int     rc;
 104         int     i;
 105
 106         rc = cfs_wi_sched_create("lst_s", lnet_cpt_table(), CFS_CPT_ANY,
 107                                  1, &lst_sched_serial);
 108         if (rc != 0) {
 109                 CERROR("Failed to create serial WI scheduler for LST\n");
 110                 return rc;
 111         }
 112         lst_init_step = LST_INIT_WI_SERIAL;
 113
 114         nscheds = cfs_cpt_number(lnet_cpt_table());
 115         LIBCFS_ALLOC(lst_sched_test, sizeof(lst_sched_test[0]) * nscheds);
 116         if (lst_sched_test == NULL)
 117                 goto error;
 118
 119         lst_init_step = LST_INIT_WI_TEST;
 120         for (i = 0; i < nscheds; i++) {
 121                 int nthrs = cfs_cpt_weight(lnet_cpt_table(), i);
 122
 123                 /* reserve at least one CPU for LND */
 124                 nthrs = max(nthrs - 1, 1);
 125                 rc = cfs_wi_sched_create("lst_t", lnet_cpt_table(), i,
 126                                          nthrs, &lst_sched_test[i]);
 127                 if (rc != 0) {
 128                         CERROR("Failed to create CPU partition affinity WI "
 129                                "scheduler %d for LST\n", i);
 130                         goto error;
 131                 }
 132         }
 133
 134         rc = srpc_startup();
 135         if (rc != 0) {
 136                 CERROR("LST can't startup rpc\n");
 137                 goto error;
 138         }
 139         lst_init_step = LST_INIT_RPC;
 140
 141         rc = sfw_startup();
 142         if (rc != 0) {
 143                 CERROR("LST can't startup framework\n");
 144                 goto error;
 145         }
 146         lst_init_step = LST_INIT_FW;
 147
 148         rc = lstcon_console_init();
 149         if (rc != 0) {
 150                 CERROR("LST can't startup console\n");
 151                 goto error;
 152         }
 153         lst_init_step = LST_INIT_CONSOLE;
 154         return 0;
 155 error:
 156         lnet_selftest_exit();
 157         return rc;
 158 }
 159
 160 MODULE_AUTHOR("OpenSFS, Inc. <http://www.lustre.org/>");
 161 MODULE_DESCRIPTION("LNet Selftest");
 162 MODULE_VERSION("2.8.0");
 163 MODULE_LICENSE("GPL");
 164
 165 module_init(lnet_selftest_init);
 166 module_exit(lnet_selftest_exit);