lustre/lod/lod_qos.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,
  11  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  12  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  13  * GNU General Public License version 2 for more details.  A copy is
  14  * included in the COPYING file that accompanied this code.
  15
  16  * You should have received a copy of the GNU General Public License
  17  * along with this program; if not, write to the Free Software
  18  * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
  19  *
  20  * GPL HEADER END
  21  */
  22 /*
  23  * Copyright  2009 Sun Microsystems, Inc. All rights reserved
  24  * Use is subject to license terms.
  25  *
  26  * Copyright (c) 2011, 2012, Whamcloud, Inc.
  27  */
  28 /*
  29  * This file is part of Lustre, http://www.lustre.org/
  30  * Lustre is a trademark of Sun Microsystems, Inc.
  31  *
  32  * lustre/lod/lod_qos.c
  33  *
  34  */
  35
  36 #define DEBUG_SUBSYSTEM S_LOV
  37
  38 #include <libcfs/libcfs.h>
  39 #include <obd_class.h>
  40 #include <obd_lov.h>
  41 #include <lustre/lustre_idl.h>
  42 #include "lod_internal.h"
  43
  44 /*
  45  * force QoS policy (not RR) to be used for testing purposes
  46  */
  47 #define FORCE_QOS_
  48
  49 #define D_QOS   D_OTHER
  50
  51 #if 0
  52 #define QOS_DEBUG(fmt, ...)     CDEBUG(D_OTHER, fmt, ## __VA_ARGS__)
  53 #define QOS_CONSOLE(fmt, ...)   LCONSOLE(D_OTHER, fmt, ## __VA_ARGS__)
  54 #else
  55 #define QOS_DEBUG(fmt, ...)
  56 #define QOS_CONSOLE(fmt, ...)
  57 #endif
  58
  59 #define TGT_BAVAIL(i) (OST_TGT(lod,i)->ltd_statfs.os_bavail * \
  60                        OST_TGT(lod,i)->ltd_statfs.os_bsize)
  61
  62 int qos_add_tgt(struct lod_device *lod, struct lod_ost_desc *ost_desc)
  63 {
  64         struct lov_qos_oss *oss = NULL, *temposs;
  65         struct obd_export  *exp = ost_desc->ltd_exp;
  66         int                 rc = 0, found = 0;
  67         cfs_list_t         *list;
  68         ENTRY;
  69
  70         cfs_down_write(&lod->lod_qos.lq_rw_sem);
  71         /*
  72          * a bit hacky approach to learn NID of corresponding connection
  73          * but there is no official API to access information like this
  74          * with OSD API.
  75          */
  76         cfs_list_for_each_entry(oss, &lod->lod_qos.lq_oss_list, lqo_oss_list) {
  77                 if (obd_uuid_equals(&oss->lqo_uuid,
  78                                     &exp->exp_connection->c_remote_uuid)) {
  79                         found++;
  80                         break;
  81                 }
  82         }
  83
  84         if (!found) {
  85                 OBD_ALLOC_PTR(oss);
  86                 if (!oss)
  87                         GOTO(out, rc = -ENOMEM);
  88                 memcpy(&oss->lqo_uuid, &exp->exp_connection->c_remote_uuid,
  89                        sizeof(oss->lqo_uuid));
  90         } else {
  91                 /* Assume we have to move this one */
  92                 cfs_list_del(&oss->lqo_oss_list);
  93         }
  94
  95         oss->lqo_ost_count++;
  96         ost_desc->ltd_qos.ltq_oss = oss;
  97
  98         CDEBUG(D_QOS, "add tgt %s to OSS %s (%d OSTs)\n",
  99                obd_uuid2str(&ost_desc->ltd_uuid), obd_uuid2str(&oss->lqo_uuid),
 100                oss->lqo_ost_count);
 101
 102         /* Add sorted by # of OSTs.  Find the first entry that we're
 103            bigger than... */
 104         list = &lod->lod_qos.lq_oss_list;
 105         cfs_list_for_each_entry(temposs, list, lqo_oss_list) {
 106                 if (oss->lqo_ost_count > temposs->lqo_ost_count)
 107                         break;
 108         }
 109         /* ...and add before it.  If we're the first or smallest, temposs
 110            points to the list head, and we add to the end. */
 111         cfs_list_add_tail(&oss->lqo_oss_list, &temposs->lqo_oss_list);
 112
 113         lod->lod_qos.lq_dirty = 1;
 114         lod->lod_qos.lq_rr.lqr_dirty = 1;
 115
 116 out:
 117         cfs_up_write(&lod->lod_qos.lq_rw_sem);
 118         RETURN(rc);
 119 }
 120
 121 int qos_del_tgt(struct lod_device *lod, struct lod_ost_desc *ost_desc)
 122 {
 123         struct lov_qos_oss *oss;
 124         int                 rc = 0;
 125         ENTRY;
 126
 127         cfs_down_write(&lod->lod_qos.lq_rw_sem);
 128         oss = ost_desc->ltd_qos.ltq_oss;
 129         if (!oss)
 130                 GOTO(out, rc = -ENOENT);
 131
 132         oss->lqo_ost_count--;
 133         if (oss->lqo_ost_count == 0) {
 134                 CDEBUG(D_QOS, "removing OSS %s\n",
 135                        obd_uuid2str(&oss->lqo_uuid));
 136                 cfs_list_del(&oss->lqo_oss_list);
 137                 ost_desc->ltd_qos.ltq_oss = NULL;
 138                 OBD_FREE_PTR(oss);
 139         }
 140
 141         lod->lod_qos.lq_dirty = 1;
 142         lod->lod_qos.lq_rr.lqr_dirty = 1;
 143 out:
 144         cfs_up_write(&lod->lod_qos.lq_rw_sem);
 145         RETURN(rc);
 146 }
 147