server/ctdb_tunables.c

   1 /*
   2    ctdb tunables code
   3
   4    Copyright (C) Andrew Tridgell  2007
   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 as published by
   8    the Free Software Foundation; either version 2 of the License, or
   9    (at your option) any later version.
  10
  11    This program is distributed in the hope that it will be useful,
  12    but WITHOUT ANY WARRANTY; without even the implied warranty of
  13    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  14    GNU General Public License for more details.
  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., 675 Mass Ave, Cambridge, MA 02139, USA.
  19 */
  20 #include "includes.h"
  21 #include "../include/ctdb_private.h"
  22
  23 static const struct {
  24         const char *name;
  25         uint32_t default_v;
  26         size_t offset;
  27 } tunable_map[] = {
  28         { "MaxRedirectCount",     3,  offsetof(struct ctdb_tunable, max_redirect_count) },
  29         { "SeqnumFrequency",      1,  offsetof(struct ctdb_tunable, seqnum_frequency) },
  30         { "ControlTimeout",      60, offsetof(struct ctdb_tunable, control_timeout) },
  31         { "TraverseTimeout",     20, offsetof(struct ctdb_tunable, traverse_timeout) },
  32         { "KeepaliveInterval",    2,  offsetof(struct ctdb_tunable, keepalive_interval) },
  33         { "KeepaliveLimit",       3,  offsetof(struct ctdb_tunable, keepalive_limit) },
  34         { "MaxLACount",           7,  offsetof(struct ctdb_tunable, max_lacount) },
  35         { "RecoverTimeout",       5,  offsetof(struct ctdb_tunable, recover_timeout) },
  36         { "RecoverInterval",      1,  offsetof(struct ctdb_tunable, recover_interval) },
  37         { "ElectionTimeout",      3,  offsetof(struct ctdb_tunable, election_timeout) },
  38         { "TakeoverTimeout",      5,  offsetof(struct ctdb_tunable, takeover_timeout) },
  39         { "MonitorInterval",     15,  offsetof(struct ctdb_tunable, monitor_interval) },
  40         { "EventScriptTimeout",  20,  offsetof(struct ctdb_tunable, script_timeout) },
  41         { "RecoveryGracePeriod", 60,  offsetof(struct ctdb_tunable, recovery_grace_period) },
  42         { "RecoveryBanPeriod",  300,  offsetof(struct ctdb_tunable, recovery_ban_period) },
  43 };
  44
  45 /*
  46   set all tunables to defaults
  47  */
  48 void ctdb_tunables_set_defaults(struct ctdb_context *ctdb)
  49 {
  50         int i;
  51         for (i=0;i<ARRAY_SIZE(tunable_map);i++) {
  52                 *(uint32_t *)(tunable_map[i].offset + (uint8_t*)&ctdb->tunable) = tunable_map[i].default_v;
  53         }
  54 }
  55
  56
  57 /*
  58   get a tunable
  59  */
  60 int32_t ctdb_control_get_tunable(struct ctdb_context *ctdb, TDB_DATA indata,
  61                                  TDB_DATA *outdata)
  62 {
  63         struct ctdb_control_get_tunable *t =
  64                 (struct ctdb_control_get_tunable *)indata.dptr;
  65         char *name;
  66         uint32_t val;
  67         int i;
  68
  69         if (indata.dsize < sizeof(*t) ||
  70             t->length > indata.dsize - offsetof(struct ctdb_control_get_tunable, name)) {
  71                 DEBUG(0,("Bad indata in ctdb_control_get_tunable\n"));
  72                 return -1;
  73         }
  74
  75         name = talloc_strndup(ctdb, (char*)t->name, t->length);
  76         CTDB_NO_MEMORY(ctdb, name);
  77
  78         for (i=0;i<ARRAY_SIZE(tunable_map);i++) {
  79                 if (strcasecmp(name, tunable_map[i].name) == 0) break;
  80         }
  81         talloc_free(name);
  82
  83         if (i == ARRAY_SIZE(tunable_map)) {
  84                 return -1;
  85         }
  86
  87         val = *(uint32_t *)(tunable_map[i].offset + (uint8_t*)&ctdb->tunable);
  88
  89         outdata->dptr = (uint8_t *)talloc(outdata, uint32_t);
  90         CTDB_NO_MEMORY(ctdb, outdata->dptr);
  91
  92         *(uint32_t *)outdata->dptr = val;
  93         outdata->dsize = sizeof(uint32_t);
  94
  95         return 0;
  96 }
  97
  98
  99 /*
 100   set a tunable
 101  */
 102 int32_t ctdb_control_set_tunable(struct ctdb_context *ctdb, TDB_DATA indata)
 103 {
 104         struct ctdb_control_set_tunable *t =
 105                 (struct ctdb_control_set_tunable *)indata.dptr;
 106         char *name;
 107         int i;
 108
 109         if (indata.dsize < sizeof(*t) ||
 110             t->length > indata.dsize - offsetof(struct ctdb_control_set_tunable, name)) {
 111                 DEBUG(0,("Bad indata in ctdb_control_set_tunable\n"));
 112                 return -1;
 113         }
 114
 115         name = talloc_strndup(ctdb, (char *)t->name, t->length);
 116         CTDB_NO_MEMORY(ctdb, name);
 117
 118         for (i=0;i<ARRAY_SIZE(tunable_map);i++) {
 119                 if (strcasecmp(name, tunable_map[i].name) == 0) break;
 120         }
 121
 122         talloc_free(name);
 123
 124         if (i == ARRAY_SIZE(tunable_map)) {
 125                 return -1;
 126         }
 127
 128         *(uint32_t *)(tunable_map[i].offset + (uint8_t*)&ctdb->tunable) = t->value;
 129
 130         return 0;
 131 }
 132
 133 /*
 134   list tunables
 135  */
 136 int32_t ctdb_control_list_tunables(struct ctdb_context *ctdb, TDB_DATA *outdata)
 137 {
 138         char *list = NULL;
 139         int i;
 140         struct ctdb_control_list_tunable *t;
 141
 142         list = talloc_strdup(outdata, tunable_map[0].name);
 143         CTDB_NO_MEMORY(ctdb, list);
 144
 145         for (i=1;i<ARRAY_SIZE(tunable_map);i++) {
 146                 list = talloc_asprintf_append(list, ":%s", tunable_map[i].name);
 147                 CTDB_NO_MEMORY(ctdb, list);
 148         }
 149
 150         outdata->dsize = offsetof(struct ctdb_control_list_tunable, data) +
 151                 strlen(list) + 1;
 152         outdata->dptr = talloc_size(outdata, outdata->dsize);
 153         CTDB_NO_MEMORY(ctdb, outdata->dptr);
 154
 155         t = (struct ctdb_control_list_tunable *)outdata->dptr;
 156         t->length = strlen(list)+1;
 157
 158         memcpy(t->data, list, t->length);
 159         talloc_free(list);
 160
 161         return 0;
 162 }