/*

 * Copyright (c) 2019 TAOS Data, Inc. <jhtao@taosdata.com>

 *

 * This program is free software: you can use, redistribute, and/or modify

 * it under the terms of the GNU Affero General Public License, version 3

 * or later ("AGPL"), as published by the Free Software Foundation.

 *

 * 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.

 *

 * You should have received a copy of the GNU Affero General Public License

 * along with this program. If not, see <http://www.gnu.org/licenses/>.

 */

#ifndef _TD_OS_DEF_H_

#define _TD_OS_DEF_H_

#ifdef __cplusplus

extern "C" {

#endif

#if defined(_TD_DARWIN_64)

// specific

#ifndef __COMPAR_FN_T

#define __COMPAR_FN_T

typedef int (*__compar_fn_t)(const void *, const void *);

#endif

// for send function in tsocket.c

#if defined(MSG_NOSIGNAL)

#undef MSG_NOSIGNAL

#endif

#define MSG_NOSIGNAL 0

#define SO_NO_CHECK  0x1234

#define SOL_TCP      0x1234

#define TCP_KEEPIDLE 0x1234

#ifndef PTHREAD_MUTEX_RECURSIVE_NP

#define PTHREAD_MUTEX_RECURSIVE_NP PTHREAD_MUTEX_RECURSIVE

#endif

#endif

#if defined(_ALPINE)

#ifndef __COMPAR_FN_T

#define __COMPAR_FN_T

typedef int (*__compar_fn_t)(const void *, const void *);

#endif

void error(int, int, const char *);

#ifndef PTHREAD_MUTEX_RECURSIVE_NP

#define PTHREAD_MUTEX_RECURSIVE_NP PTHREAD_MUTEX_RECURSIVE

#endif

#endif

#if defined(WINDOWS)

char *stpcpy(char *dest, const char *src);

char *stpncpy(char *dest, const char *src, int n);

// specific

#ifndef __COMPAR_FN_T

#define __COMPAR_FN_T

typedef int (*__compar_fn_t)(const void *, const void *);

#endif

#define ssize_t int

#define _SSIZE_T_

#define bzero(ptr, size) (void)memset((ptr), 0, (size))

#define strcasecmp       _stricmp

#define strncasecmp      _strnicmp

#define wcsncasecmp      _wcsnicmp

#define strtok_r         strtok_s

// #define snprintf _snprintf

#define in_addr_t unsigned long

//  #define socklen_t int

char *strsep(char **stringp, const char *delim);

char *getpass(const char *prefix);

// for send function in tsocket.c

#define MSG_NOSIGNAL 0

#define SO_NO_CHECK  0x1234

#define SOL_TCP      0x1234

#define SHUT_RDWR SD_BOTH

#define SHUT_RD   SD_RECEIVE

#define SHUT_WR   SD_SEND

#define LOCK_EX 1

#define LOCK_NB 2

#define LOCK_UN 3

#ifndef PATH_MAX

#define PATH_MAX 256

#endif

typedef struct {

  int   we_wordc;

  char *we_wordv[1];

  int   we_offs;

  char  wordPos[1025];

} wordexp_t;

int  wordexp(char *words, wordexp_t *pwordexp, int flags);

void wordfree(wordexp_t *pwordexp);

#define openlog(a, b, c)

#define closelog()

#define LOG_ERR  0

#define LOG_INFO 1

void syslog(int unused, const char *format, ...);

#elif defined(TD_ASTRA)

char *stpncpy(char *dest, const char *src, int n);

char *strsep(char **stringp, const char *delim);

#endif  // WINDOWS

#ifndef WINDOWS

#ifndef O_BINARY

#define O_BINARY 0

#endif

#endif

#define POINTER_SHIFT(p, b)      ((void *)((char *)(p) + (b)))

#define POINTER_DISTANCE(p1, p2) ((char *)(p1) - (char *)(p2))

#ifndef UNUSED

#define UNUSED(x) ((void)(x))

#endif

#ifdef UNUSED_FUNC

#undefine UNUSED_FUNC

#endif

#ifdef UNUSED_PARAM

#undef UNUSED_PARAM

#endif

#if defined(__GNUC__)

#define UNUSED_PARAM(x) _UNUSED##x __attribute__((unused))

#define UNUSED_FUNC     __attribute__((unused))

#else

#define UNUSED_PARAM(x) x

#define UNUSED_FUNC

#endif

#ifdef tListLen

#undefine tListLen

#endif

#define tListLen(x) (sizeof(x) / sizeof((x)[0]))

#if defined(__GNUC__)

#define FORCE_INLINE inline __attribute__((always_inline))

#else

#define FORCE_INLINE

#endif

#define DEFAULT_UNICODE_ENCODEC "UCS-4LE"

#define DEFAULT_COMP(x, y)       \

  do {                           \

    if ((x) == (y)) {            \

      return 0;                  \

    } else {                     \

      return (x) < (y) ? -1 : 1; \

    }                            \

  } while (0)

#define DEFAULT_DOUBLE_COMP(x, y)         \

  do {                                    \

    if (isnan(x) && isnan(y)) {           \

      return 0;                           \

    }                                     \

    if (isnan(x)) {                       \

      return -1;                          \

    }                                     \

    if (isnan(y)) {                       \

      return 1;                           \

    }                                     \

    if (fabs((x) - (y)) <= DBL_EPSILON) { \

      return 0;                           \

    } else {                              \

      return (x) < (y) ? -1 : 1;          \

    }                                     \

  } while (0)

#define DEFAULT_FLOAT_COMP(x, y) DEFAULT_DOUBLE_COMP(x, y)

#define ALIGN_NUM(n, align) (((n) + ((align)-1)) & (~((align)-1)))

// align to 8bytes

#define ALIGN8(n) ALIGN_NUM(n, 8)

#undef threadlocal

//#ifdef _ISOC11_SOURCE

//#define threadlocal _Thread_local

//#elif defined(__APPLE__)

#if defined(__APPLE__)

#define threadlocal __thread

#elif defined(__GNUC__) && !defined(threadlocal)

#define threadlocal __thread

#else

#define threadlocal __declspec(thread)

#endif

#ifdef WINDOWS

#define PRIzu "ld"

#else

#define PRIzu "zu"

#endif

#if !defined(WINDOWS)

#if defined(_TD_DARWIN_64)

// MacOS

#if !defined(_GNU_SOURCE)

#define setThreadName(name)     \

  do {                          \

    pthread_setname_np((name)); \

  } while (0)

#else

// pthread_setname_np not defined

#define setThreadName(name)

#endif

#elif defined(TD_ASTRA)

#define setThreadName(name)

#define getThreadName(name)

#else

// Linux, length of name must <= 16 (the last '\0' included)

#define setThreadName(name)     \

  do {                          \

    (void)prctl(PR_SET_NAME, (name)); \

  } while (0)

#define getThreadName(name)     \

  do {                          \

    prctl(PR_GET_NAME, (name)); \

  } while (0)

#endif

#else

// Windows

#define setThreadName(name)                       \

  do {                                            \

    pthread_setname_np(taosThreadSelf(), (name)); \

  } while (0)

#endif

#if defined(_WIN32)

#define TD_DIRSEP "\\"

#elif defined(TD_ASTRA)

#ifdef TD_ASTRA_TARGET

#define TD_DIRSEP "/"

#else

#define TD_DIRSEP "\\"

#endif

#else

#define TD_DIRSEP "/"

#endif

#if defined(_WIN32)

#define TD_DIRSEP_CHAR '\\'

#elif defined(TD_ASTRA)

#ifdef TD_ASTRA_TARGET

#define TD_DIRSEP_CHAR '/'

#else

#define TD_DIRSEP_CHAR '\\'

#endif

#else

#define TD_DIRSEP_CHAR '/'

#endif

#define TD_FQDN_LEN     128

#define TD_LOCALE_LEN   64

#define TD_CHARSET_LEN  64

#define TD_TIMEZONE_LEN 96

#define TD_TIME_STR_LEN 128

#define TD_IP_LEN       128

#ifdef __cplusplus

}

#endif

#endif /*_TD_OS_DEF_H_*/