/*
 * Copyright (C) 2008 Search Solution Corporation. All rights reserved by Search Solution. 
 *
 *   This program is free software; you can redistribute it and/or modify 
 *   it under the terms of the GNU General Public License as published by 
 *   the Free Software Foundation; version 2 of the License. 
 *
 *  This program is distributed in the hope that it will be useful, 
 *  but WITHOUT ANY WARRANTY; without even the implied warranty of 
 *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the 
 *  GNU General Public License for more details. 
 *
 *  You should have received a copy of the GNU General Public License 
 *  along with this program; if not, write to the Free Software 
 *  Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA 
 *
 */


/*
 * cas_common.h - 
 */

#ifndef	_CAS_COMMON_H_
#define	_CAS_COMMON_H_

#ident "$Id$"

#ifndef WIN32
#include <sys/types.h>
#include <sys/socket.h>
#endif

#include "porting.h"

#define makestring1(x) #x
#define makestring(x) makestring1(x)

#define MAX_SERVER_H_ID         256
#define MAX_BIND_VALUE          1024
#define MAX_QUERY_LEN           100000
#define CAS_RUNNER_CONF         "cas_runner.conf"
#define CAS_RUNNER_CONF_ENV     "CAS_RUNNER_CONF"

#define ON	1
#define OFF	0

#define TRUE	1
#define FALSE	0

#define TRAN_NOT_AUTOCOMMIT     0
#define TRAN_AUTOCOMMIT 	1
#define TRAN_AUTOROLLBACK 	2

#define INT_STR_LEN     16

#ifdef WIN32
#define MUTEX_INIT(MUTEX)				\
	do {						\
	  MUTEX = CreateMutex(NULL, FALSE, NULL);	\
	} while (0)
#define MUTEX_LOCK(MUTEX)		WaitForSingleObject(MUTEX, INFINITE)
#define MUTEX_UNLOCK(MUTEX)		ReleaseMutex(MUTEX)
#else
#define MUTEX_INIT(MUTEX)		pthread_mutex_init(&(MUTEX), NULL)
#define MUTEX_LOCK(MUTEX)		pthread_mutex_lock(&(MUTEX))
#define MUTEX_UNLOCK(MUTEX)		pthread_mutex_unlock(&(MUTEX))
#endif

#ifdef WIN32
#define         T_THREAD        uintptr_t
#define         T_MUTEX         HANDLE
#else
#define         T_THREAD        pthread_t
#define         T_MUTEX         pthread_mutex_t
#endif

#define MALLOC(SIZE)            malloc(SIZE)
#define REALLOC(PTR, SIZE)      \
        ((PTR == NULL) ? malloc(SIZE) : realloc(PTR, SIZE))
#define FREE(PTR)               free(PTR)

#define FREE_MEM(PTR)		\
	do {			\
	  if (PTR) {		\
	    FREE(PTR);		\
	    PTR = 0;	\
	  }			\
	} while (0)

#define ALLOC_COPY(PTR, STR)			\
	do {					\
	  if (STR == NULL)			\
	    PTR = NULL;				\
	  else {				\
	    PTR = (char *) MALLOC(strlen(STR) + 1);	\
	    if (PTR) {				\
	      strcpy(PTR, STR);			\
	    }					\
	  }					\
	} while (0)

#ifdef WIN32
#define CLOSE_SOCKET(X)		\
	do {			\
	  if (X >= 0) closesocket(X);	\
	  X = -1;		\
	} while (0)
#else
#define CLOSE_SOCKET(X)		\
	do {			\
	  if (X >= 0) close(X);		\
	  X = -1;		\
	} while (0)
#endif

#define ALLOC_N_COPY(PTR, STR, SIZE)		\
	do {					\
	  if (STR == NULL)			\
	    PTR = NULL;				\
	  else {				\
	    PTR = MALLOC(SIZE);			\
	    if (PTR) {				\
	      strncpy(PTR, STR, SIZE);		\
	      PTR[SIZE - 1] = '\0';		\
	    }					\
	  }					\
	} while (0)

#ifdef WIN32
#define SLEEP_SEC(X)                    Sleep((X) * 1000)
#define SLEEP_MILISEC(SEC, MSEC)	Sleep((SEC) * 1000 + (MSEC))
#else
#define SLEEP_SEC(X)                    sleep(X)
#define SLEEP_MILISEC(sec, msec)			\
	do {						\
	  struct timeval sleep_time_val;		\
	  sleep_time_val.tv_sec = sec;			\
	  sleep_time_val.tv_usec = (msec) * 1000;	\
	  select(0, 0, 0, 0, &sleep_time_val);		\
	} while(0)
#endif


#ifdef WIN32
#define THREAD_BEGIN(THR_ID, FUNC, ARG)				\
	do {							\
	  THR_ID = _beginthread(FUNC, 0, (void*) (ARG));	\
	} while(0)
#else
#define THREAD_BEGIN(THR_ID, FUNC, ARG)		\
	do {					\
	  pthread_attr_t	thread_attr;	\
	  pthread_attr_init(&thread_attr);	\
	  pthread_attr_setdetachstate(&thread_attr, PTHREAD_CREATE_DETACHED); \
	  pthread_create(&(THR_ID), &thread_attr, FUNC, ARG);	\
	} while (0)
#endif

#ifdef WIN32
#define TIMEVAL_MAKE(X)         _ftime(X)
#define TIMEVAL_GET_SEC(X)      ((int) ((X)->time))
#define TIMEVAL_GET_MSEC(X)     ((int) ((X)->millitm))
#else
#define TIMEVAL_MAKE(X)         gettimeofday(X, NULL)
#define TIMEVAL_GET_SEC(X)      ((int) ((X)->tv_sec))
#define TIMEVAL_GET_MSEC(X)     ((int) (((X)->tv_usec) / 1000))
#endif

#ifdef WIN32
#define READ_FROM_SOCKET(fd, buf, size)         recv(fd, buf, size, 0)
#define WRITE_TO_SOCKET(fd, buf, size)          send(fd, buf, size, 0)
#else
#define READ_FROM_SOCKET(fd, buf, size)         read(fd, buf, size)
#define WRITE_TO_SOCKET(fd, buf, size)          write(fd, buf, size)
#endif

#ifdef WIN32
#define THREAD_FUNC     void
#else
#define THREAD_FUNC     void*
#endif

#ifdef WIN32
typedef struct _timeb T_TIMEVAL;
#else
typedef struct timeval T_TIMEVAL;
#endif

#if defined(WIN32) || defined(SOLARIS) || defined(HPUX)
typedef int T_SOCKLEN;
#elif defined(UNIXWARE7)
typedef size_t T_SOCKLEN;
#else
typedef socklen_t T_SOCKLEN;
#endif

extern int uts_key_check_local_host (void);

#endif /* _CAS_COMMON_H_ */