include/os.h

   1 /***************************************************************************
   2  *                                                                         *
   3  *    Copyright (C) Lakshya Solutions Ltd. All rights reserved.            *
   4  *                                                                         *
   5  ***************************************************************************/
   6
   7 #ifndef OS_H
   8 #define OS_H
   9 #include<build.h>
  10
  11 #if defined(SOLARIS) || defined(LINUX) || defined(FreeBSD)
  12
  13 #include <stdio.h>
  14 #include <sys/mman.h>
  15 #include <sys/msg.h>
  16 #include <sys/shm.h>
  17 #include <unistd.h>
  18 #include <string.h>
  19 #include <stdlib.h>
  20 #include <sys/types.h>
  21 #include <sys/stat.h>
  22 #include <fcntl.h>
  23 #include <pthread.h>
  24 #include <math.h>
  25 #include <signal.h>
  26 #include <ctype.h>
  27 #include <limits.h>
  28 #include <sys/socket.h>
  29 #include <fnmatch.h>
  30 #include <sys/time.h>
  31 #include <stdarg.h>
  32 #include <net/if.h>
  33 #include <arpa/inet.h>
  34 #include <netinet/in.h>
  35 #include <netinet/tcp.h>
  36 #include <sys/file.h>
  37 #include <sys/wait.h>
  38 #if defined(SOLARIS)
  39     #include <sys/varargs.h>
  40     #include <crypt.h>
  41     #include <errno.h>
  42     #include <sys/atomic.h>
  43     #include <timecsql.h>
  44     #include <ucontext.h>
  45     //extern int errno;
  46 #endif
  47 #if defined(LINUX)
  48     #include <execinfo.h>
  49     #include <ifaddrs.h>
  50     #include <sys/errno.h>
  51     #include <crypt.h>
  52 #endif
  53 #if defined(FreeBSD)
  54     #include <sys/errno.h>
  55 #endif
  56
  57 typedef void (*sighandler_t)(int);
  58
  59 enum FileOpenMode
  60 {
  61     fileOpenReadOnly = O_RDONLY,
  62     fileOpenWriteOnly = O_WRONLY,
  63     fileOpenReadWrite = O_RDWR,
  64     fileOpenAppend = O_CREAT| O_APPEND |O_RDWR,
  65     fileOpenCreat = O_CREAT |O_RDWR,
  66     // If set and fileOpenExcl is set, the
  67     // open will fail if the file already exists.
  68     fileOpenExcl = O_EXCL,
  69     fileOpenTrunc = O_TRUNC
  70 };
  71
  72 enum MapProtMode
  73 {
  74     mapProtRead = PROT_READ,
  75     mapProtWrite = PROT_WRITE,
  76     mapProcExec = PROT_EXEC,
  77     mapProcNone = PROT_NONE
  78 };
  79
  80 enum MapMode
  81 {
  82     mapShared = MAP_SHARED,
  83     mapPrivate = MAP_PRIVATE,
  84     mapFixed = MAP_FIXED,
  85     // Interpret address exactly.
  86     mapNoReserve = MAP_NORESERVE,
  87     // Don't reserver swap space.
  88
  89     //mapAlign = MAP_ALIGN,
  90     //for msync system call
  91     mapSync = MS_SYNC ,
  92     mapASync = MS_ASYNC
  93
  94 };
  95
  96 #define SQL_STMT_LEN 8192
  97 #define MAX_FILE_LEN 1024
  98 #define IDENTIFIER_LENGTH 64
  99 #define ERROR_STRING_LENGTH 128
 100 #define DEFAULT_VALUE_BUF_LENGTH 32
 101 #define STATE_LENGTH 8
 102 #define SYSTEMDB "SYSTEMDB"
 103 #define DBAUSER "root"
 104 #define DBAPASS "manager"
 105 #define I_USER "i@1r4D_f$_a"
 106 #define I_PASS "a_$f_D4r1@i"
 107 #define DEFAULT_CONFIG_FILE "/etc/csql/csql.conf"
 108 #define LOCK_BUCKET_SIZE 2048
 109 #define STMT_BUCKET_SIZE 1023
 110 #define MAX_CHUNKS 20
 111 #define PAGE_SIZE Conf::config.getPageSize()
 112 #define MAX_MUTEX_PER_THREAD 4
 113 #define MAX_THREADS_PER_PROCESS 30
 114 #define MAX_FILE_PATH_LEN 1024
 115 #define CHUNK_NAME_LEN 64
 116 #define LOG_ROLLOVER_SIZE 20*1024*1024
 117 #define SIGCSQL1 SIGUSR1
 118 #define MIN_VARCHAR_ALLOC_SIZE 30
 119
 120 #define BIT(x) (1 << (x))
 121 #define SETBITS(x,y) ((x) |= (y))
 122 #define CLEARBITS(x,y) ((x) &= (~(y)))
 123 #define SETBIT(x,y) SETBITS((x), (BIT((y))))
 124 #define CLEARBIT(x,y) CLEARBITS((x), (BIT((y))))
 125 #define BITSET(x,y) ((x) & (BIT(y)))
 126
 127
 128 typedef key_t shared_memory_key;
 129 typedef int   shared_memory_id;
 130 #if defined(__sparcv9)
 131     typedef long InUse;
 132 #else
 133     typedef int InUse;
 134 #endif
 135
 136 #endif
 137
 138 class os
 139 {
 140     public:
 141     static void* mmap(void* addr, size_t len, int prot, int flags, int fildes, off_t off);
 142     static int munmap(caddr_t addr, size_t len);
 143     static int openFile(const char *name, FileOpenMode flags, size_t size);
 144     static int closeFile(int fd);
 145     static int lockFile(int fd);
 146     static int unlockFile(int fd);
 147     static off_t lseek(int fildes, off_t offset, int whence);
 148     static int openFileForAppend(const char* fname, int flags);
 149     static int getFileSize(const char* fname);
 150     static size_t write(int fildes, char *buf, size_t size);
 151     static int msync(caddr_t addr, size_t len, int flags);
 152     static int fsync(int fildes);
 153     inline static size_t alignLong(size_t size)
 154         { return ((size - 1) | (sizeof(long) - 1)) + 1;}
 155     inline static size_t align(size_t size)
 156         { return ((size - 1) | (sizeof(InUse) - 1)) + 1;}
 157     static char*  encrypt(const char * key, const char *salt);
 158     static void* memset(void *src, int c, size_t size);
 159     static void* memcpy(void *src, const void *dest, size_t size);
 160     static int   memcmp(const void *s1, const void *s2, size_t size);
 161     static int select(int nfds, fd_set *readfds, fd_set *writefds,
 162                       fd_set *exceptfds, struct timeval * timeout);
 163
 164     static int usleep(int microsecs);
 165     static int sleep(int secs);
 166     static shared_memory_id shm_create(shared_memory_key key, size_t size, int flag);
 167     static shared_memory_id shm_open(shared_memory_key key, size_t size, int flag);
 168     static void*  shm_attach(shared_memory_id id, const void *ptr, int flag);
 169     static int shm_detach (void*);
 170     static int shmctl(int shmid, int cmd);
 171     inline static double floor(double val)
 172         { return ::floor(val); }
 173     static sighandler_t signal(int signum, sighandler_t handler);
 174
 175     static int gettimeofday(struct timeval *tp);
 176     static struct tm* localtime(long *secs);
 177     static pid_t getpid()
 178        { return ::getpid(); }
 179     static pthread_t getthrid()
 180        { return ::pthread_self(); }
 181     static char* getenv(const char *envVarName);
 182     static int setenv(const char *envVarName, const char *value);
 183
 184     static int kill(pid_t pid, int sig);
 185     static bool atobool(char *value);
 186     static pid_t createProcess(const char* cmdName, const char *arg0);
 187     static pid_t fork();
 188     static size_t send(int fd, const void *buf, size_t len, int flags);
 189     static size_t recv(int fd, void *buf, size_t len, int flags);
 190     static int gethostname(char *hostname, size_t len);
 191     static int strmatch(char *pattern, char *str);
 192     static int msgget(key_t key, int oflag);
 193     static int msgsnd(int msqid, const void *ptr, size_t len, int flag);
 194     static ssize_t msgrcv(int msqid, void *ptr, size_t len, long type, int flag);
 195     static int msgctl(int msqid, int cmd, struct msqid_ds *buff);
 196     static int isValidIP(char ipstr[] );
 197     static bool fileExists(char *fileName);
 198     static char* strcasestr(char *s1, const char *s2);
 199     static int getNoOfProcessors();
 200     static mode_t umask(mode_t mask);
 201     static int fdatasync(int fd);
 202     static int atexit(void (*exitHndlr)(void));
 203 };
 204
 205 #endif