src/server/Config.cxx

   1 /***************************************************************************
   2  *   Copyright (C) 2007 by www.databasecache.com                           *
   3  *   Contact: praba_tuty@databasecache.com                                 *
   4  *                                                                         *
   5  *   This program is free software; you can redistribute it and/or modify  *
   6  *   it under the terms of the GNU General Public License as published by  *
   7  *   the Free Software Foundation; either version 2 of the License, or     *
   8  *   (at your option) any later version.                                   *
   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 for more details.                          *
  14  *                                                                         *
  15   ***************************************************************************/
  16 #include<Config.h>
  17 #include<ErrorType.h>
  18 #include<Debug.h>
  19
  20 Config Conf::config;
  21
  22 int Config::readLine(FILE *fp, char * buffer)
  23 {
  24   char c =0;
  25   int count =0;
  26   while ( true)
  27   {
  28       c = fgetc(fp);
  29       if (c == '\n') break;
  30       if (c == EOF) return EOF;
  31       buffer[count++] = c;
  32   }
  33   return count;
  34 }
  35 int Config::storeKeyVal(char *key, char *value)
  36 {
  37     if (strcasestr(key, "PAGE_SIZE") != NULL )
  38            { cVal.pageSize = atoi(value);  }
  39     else if (strcasestr(key, "MAX_PROCS") != NULL)
  40            { cVal.maxProcs = atoi(value);  }
  41     else if (strcasestr(key, "MAX_SYS_DB_SIZE") != NULL)
  42            { cVal.maxSysSize = atol(value);  }
  43     else if (strcasestr(key, "MAX_DB_SIZE") != NULL)
  44            { cVal.maxDbSize = atol(value);  }
  45     else if (strcasestr(key, "SYS_DB_KEY") != NULL)
  46            { cVal.sysDbKey = atoi(value);  }
  47     else if (strcasestr(key, "USER_DB_KEY") != NULL)
  48            { cVal.userDbKey = atoi(value);  }
  49     else if (strcasestr(key, "LOG_FILE") != NULL)
  50            { strcpy(cVal.logFile , value);  }
  51     else if (strcasestr(key, "MAP_ADDRESS") != NULL)
  52            { cVal.mapAddr = atol(value);  }
  53     else if (strcasestr(key, "MUTEX_TIMEOUT_SECS") != NULL)
  54            { cVal.mutexSecs = atoi(value);  }
  55     else if (strcasestr(key, "MUTEX_TIMEOUT_USECS") != NULL)
  56            { cVal.mutexUSecs = atoi(value);  }
  57     else if (strcasestr(key, "MUTEX_TIMEOUT_RETRIES") != NULL)
  58            { cVal.mutexRetries = atoi(value);  }
  59     else if (strcasestr(key, "LOCK_TIMEOUT_SECS") != NULL)
  60            { cVal.lockSecs = atoi(value);  }
  61     else if (strcasestr(key, "LOCK_TIMEOUT_USECS") != NULL)
  62            { cVal.lockUSecs = atoi(value);  }
  63     else if (strcasestr(key, "LOCK_TIMEOUT_RETRIES") != NULL)
  64            { cVal.lockRetries = atoi(value);  }
  65     else if (strcasestr(key, "DSN") != NULL)
  66            { strcpy(cVal.dsn , value);  }
  67     else if (strcasestr(key, "TABLE_CONFIG_FILE") != NULL)
  68            { strcpy(cVal.tableConfigFile , value);  }
  69     else if (strcasestr(key, "CACHE_TABLE") != NULL)
  70            { cVal.isCache = os::atobool(value); }
  71     else if (strcasestr(key, "REPLICATION") != NULL)
  72            { cVal.isReplication = os::atobool(value); }
  73     else if (strcasestr(key, "NETWORK_CONFIG_FILE") != NULL)
  74            { strcpy(cVal.replConfigFile , value);  }
  75     else if (strcasestr(key, "MAX_LOG_STORE_SIZE") != NULL)
  76            { cVal.logStoreSize = atol(value);  }
  77     else if (strcasestr(key, "MY_NETWORK_ID") != NULL)
  78            { cVal.networkID = atoi(value);  }
  79     else if (strcasestr(key, "CACHE_NETWORK_ID") != NULL)
  80            { cVal.cacheNetworkID = atoi(value);  }
  81     else if (strcasestr(key, "NETWORK_RESPONSE_TIMEOUT") != NULL)
  82            { cVal.nwResponseTimeout = atoi(value);  }
  83     else if (strcasestr(key, "NETWORK_CONNECT_TIMEOUT") != NULL)
  84            { cVal.nwConnectTimeout = atoi(value);  }
  85     else  return 1;
  86     return 0;
  87 }
  88 int Config::validateValues()
  89 {
  90     if (cVal.pageSize < 8192 || cVal.pageSize > 1024 * 1024 * 10 )
  91     {
  92         printError(ErrBadArg,  "PAGE_SIZE should be >= 8192 and <= 10 MB");
  93         return 1;
  94     }
  95     if (cVal.pageSize  % 1024 !=0 )
  96     {
  97         printError(ErrBadArg,  "PAGE_SIZE should be multiples of 1024");
  98         return 1;
  99     }
 100     if (cVal.maxProcs < 10 || cVal.maxProcs > 8192)
 101     {
 102         printError(ErrBadArg,  "MAX_PROCS should be >= 10 and <= 8192");
 103         return 1;
 104     }
 105     if (cVal.maxSysSize < 1024 * 1024  || cVal.maxSysSize > 1024 *1024 *1024)
 106     {
 107         printError(ErrBadArg,  "MAX_SYS_DB_SIZE should be >= 1 MB and <= 1 GB");
 108         return 1;
 109     }
 110     if (cVal.maxSysSize % 8192 !=0 )
 111     {
 112         printError(ErrBadArg,  "MAX_SYS_DB_SIZE should be multiples of 8192");
 113         return 1;
 114     }
 115
 116     if (cVal.maxDbSize < 1024 * 1024  || cVal.maxDbSize > (1024*1024*1024))
 117     {
 118         printError(ErrBadArg,  "MAX_DB_SIZE should be >= 1 MB and <= 2 GB");
 119         return 1;
 120     }
 121     if (cVal.maxDbSize % 8192 !=0)
 122     {
 123         printError(ErrBadArg,  "MAX_DB_SIZE should be multiples of 8192");
 124         return 1;
 125     }
 126
 127     if (cVal.sysDbKey < 10 || cVal.sysDbKey > 8192)
 128     {
 129         printError(ErrBadArg,  "SYS_DB_KEY should be >= 10 and <= 8192");
 130         return 1;
 131     }
 132     if (cVal.userDbKey < 10 || cVal.userDbKey > 8192)
 133     {
 134         printError(ErrBadArg,  "USER_DB_KEY should be >= 10 and <= 8192");
 135         return 1;
 136     }
 137     if ( cVal.sysDbKey == cVal.userDbKey)
 138     {
 139         printError(ErrBadArg,  "USER_DB_KEY and SYS_DB_KEY have same value %d", cVal.userDbKey);
 140         return 1;
 141     }
 142     if (0 == strcmp(cVal.logFile,""))
 143     {
 144         //TODO::check whether file exists
 145         printError(ErrBadArg,  "LOG_FILE is set to NULL");
 146         return 1;
 147     }
 148     //TODO::Check for the existence of the log file
 149     if (cVal.mapAddr < 400000000 || cVal.mapAddr > 2000000000)
 150     {
 151         printError(ErrBadArg,  "MAP_ADDRESS should be >= 400000000 and <= 2000000000");
 152         return 1;
 153     }
 154     if (cVal.mutexSecs < 0 || cVal.mutexSecs > 360)
 155     {
 156         printError(ErrBadArg,  "MUTEX_TIMEOUT_SECS should be >= 0 and <= 360");
 157         return 1;
 158     }
 159     if (cVal.mutexUSecs < 0 || cVal.mutexUSecs > 1000000)
 160     {
 161         printError(ErrBadArg,  "MUTEX_TIMEOUT_USECS should be >= 0 and <= 1000000");
 162         return 1;
 163     }
 164     if (cVal.mutexRetries < 0 || cVal.mutexRetries > 100)
 165     {
 166         printError(ErrBadArg,  "MUTEX_TIMEOUT_RETRY should be >= 0 and <= 100");
 167         return 1;
 168     }
 169     if (cVal.lockSecs < 0 || cVal.lockSecs > 360)
 170     {
 171         printError(ErrBadArg,  "LOCK_TIMEOUT_SECS should be >= 0 and <= 360");
 172         return 1;
 173     }
 174     if (cVal.lockUSecs < 0 || cVal.lockUSecs > 1000000)
 175     {
 176         printError(ErrBadArg,  "LOCK_TIMEOUT_USECS should be >= 0 and <= 1000000");
 177         return 1;
 178     }
 179     if (cVal.lockRetries < 0 || cVal.lockRetries > 100)
 180     {
 181         printError(ErrBadArg,  "LOCK_TIMEOUT_RETRY should be >= 0 and <= 100");
 182         return 1;
 183     }
 184     if (cVal.isCache && cVal.isReplication) {
 185         printError(ErrBadArg, "Either caching or replication option should be set."
 186                               " Both options are not supported together");
 187         return 1;
 188     }
 189     if (cVal.isCache) {
 190         if (0 == strcmp(cVal.dsn,""))
 191         {
 192             printError(ErrBadArg,  "DSN is set to NULL");
 193             return 1;
 194         }
 195     }
 196     if (cVal.isReplication || cVal.isCache) {
 197         if (0 == strcmp(cVal.replConfigFile,""))
 198         {
 199             //TODO::check whether file exists
 200             printError(ErrBadArg,  "NETWORK_CONFIG_FILE is set to NULL");
 201             return 1;
 202         }
 203         if (0 == strcmp(cVal.tableConfigFile,""))
 204         {
 205             //TODO::check whether file exists
 206             printError(ErrBadArg,  "TABLE_CONFIG_FILE is set to NULL");
 207             return 1;
 208         }
 209         if (cVal.networkID == -1)
 210         {
 211             printError(ErrBadArg,  "MY_NETWORK_ID should not be -1");
 212             return 1;
 213         }
 214         FILE *fp = fopen(cVal.replConfigFile,"r");
 215         if( fp == NULL ) {
 216             printError(ErrSysInit, "Invalid path/filename for NETWORK_CONFIG_FILE.\n");
 217             return 1;
 218         }
 219         int count =0;
 220         int nwid, port;
 221         char hostname[IDENTIFIER_LENGTH];
 222         char nwmode;
 223
 224         while(!feof(fp)) {
 225             fscanf(fp, "%d:%c:%d:%s\n", &nwid, &nwmode, &port, hostname);
 226             count++;
 227         }
 228         if (count >2) {
 229             printError(ErrSysInit, "NETWORK_CONFIG_FILE has more than 2 entries\n");
 230             return 1;
 231         }
 232
 233     }
 234     if (cVal.isCache)
 235     {
 236         if (cVal.cacheNetworkID == -1)
 237         {
 238             printError(ErrBadArg,  "CACHE_NETWORK_ID should not be -1");
 239             return 1;
 240         }else {
 241             FILE *fp;
 242             int nwid;
 243             char hostname[IDENTIFIER_LENGTH];
 244             char nwmode;
 245             int port;
 246             fp = fopen(Conf::config.getReplConfigFile(),"r");
 247             if( fp == NULL ) {
 248                 printError(ErrSysInit, "Invalid path/filename for NETWORK_CONFIG_FILE.\n");
 249                 return 1;
 250             }
 251             bool found = false;
 252             while(!feof(fp)) {
 253                 fscanf(fp, "%d:%c:%d:%s\n", &nwid, &nwmode, &port, hostname);
 254                 if (cVal.cacheNetworkID == nwid) found = true;
 255             }
 256             if (!found) return 1;
 257         }
 258     }
 259     if (cVal.logStoreSize < 1024 * 1024  || cVal.logStoreSize > 1024 *1024 *1024)
 260     {
 261         printError(ErrBadArg,  "MAX_LOG_STORE_SIZE should be >= 1 MB and <= 1 GB");
 262         return 1;
 263     }
 264     if (cVal.logStoreSize % 8192 !=0)
 265     {
 266         printError(ErrBadArg,  "MAX_LOG_STORE_SIZE should be multiples of 8192");
 267         return 1;
 268     }
 269     if (cVal.nwResponseTimeout <0 || cVal.nwResponseTimeout > 60)
 270     {
 271         printError(ErrBadArg,  "NETWORK_RESPONSE_TIMEOUT should be 0 to 60");
 272         return 1;
 273     }
 274     if (cVal.nwConnectTimeout <0 || cVal.nwConnectTimeout > 60)
 275     {
 276         printError(ErrBadArg,  "NETWORK_CONNECT_TIMEOUT should be 0 to 60");
 277         return 1;
 278     }
 279     return 0;
 280 }
 281
 282 int Config::readAllValues(char *fileName)
 283 {
 284     FILE *fp;
 285
 286     fp = fopen(fileName,"r");
 287     if( fp == NULL ) {
 288         printError(ErrSysInit, "Invalid path/filename in CSQL_CONFIG_FILE.");
 289         return 1;
 290     }
 291
 292     int hasData = 1;
 293     char buffer[1024];
 294     char key[1024];
 295     char value[1024];
 296     while (hasData)
 297     {
 298         memset(buffer, 0, 1024);
 299         //int ret = fscanf(fp,"%s\r",buffer);
 300         int ret = readLine(fp, buffer);
 301         if (ret == EOF) break;
 302         bool isComment= false;
 303         int posEqual =0;
 304         for (int i = 0; i <1024; i++)
 305         {
 306               if (buffer[i] == '=' ) posEqual=i;
 307               else if (buffer[i] == '#' ) { isComment = true; break; }
 308               else if (buffer[i] == '\n') { break; }
 309               else if (buffer[i] == '\0') { break; }
 310         }
 311       if (isComment) continue;
 312       if (!posEqual) continue;
 313       strncpy(key, buffer, posEqual);
 314       key[posEqual] = '\0';
 315       posEqual++;
 316       strcpy(value, &buffer[posEqual]);
 317       storeKeyVal(key, value);
 318     }
 319     fclose(fp);
 320     if (validateValues())
 321     {
 322         return 1;
 323     }
 324
 325     return 0;
 326 }
 327 void Config::print()
 328 {
 329     printf("ConfigValues\n");
 330     printf(" getPageSize %d\n", getPageSize());
 331     printf(" getMaxProcs %d\n", getMaxProcs());
 332     printf(" getMaxSysDbSize %ld\n", getMaxSysDbSize());
 333     printf(" getMaxDbSize %ld\n", getMaxDbSize());
 334     printf(" getSysDbKey %d\n", getSysDbKey());
 335     printf(" getUserDbKey %d\n", getUserDbKey());
 336     printf(" getLogFile %s\n", getLogFile());
 337     printf(" getMapAddress %ld\n", getMapAddress());
 338     printf(" getMutexSecs %d\n", getMutexSecs());
 339     printf(" getMutexUSecs %d\n", getMutexUSecs());
 340     printf(" getMutexRetries %d\n", getMutexRetries());
 341     printf(" getLockSecs %d\n", getLockSecs());
 342     printf(" getLockUSecs %d\n", getLockUSecs());
 343     printf(" getLockRetries %d\n", getLockRetries());
 344     printf(" useCache %d\n", useCache());
 345     printf(" getDSN %s\n", getDSN());
 346     printf(" getTableConfigFile %s\n", getTableConfigFile());
 347     printf(" useReplication %d\n", useReplication());
 348     printf(" getReplConfigFile %s\n", getReplConfigFile());
 349     printf(" getMaxLogStoreSize %ld\n", getMaxLogStoreSize());
 350     printf(" getNetworkID %d\n", getNetworkID());
 351     printf(" getCacheNetworkID %d\n", getCacheNetworkID());
 352 }