posix.h

extremeDB s sample code,useful for you

#ifndef _POSIX_H_
 #define _POSIX_H_


#ifdef __cplusplus
  extern "C" { 
#endif

#include <stdlib.h>
#include <stdio.h>
#include <stdarg.h>
#ifndef _QNX
 #include <string.h>
#endif
#include <time.h>
#include <sys/timeb.h>
#include <sys/stat.h>
#include <sched.h>
#include <signal.h>
#include <sys/resource.h>
#include <pthread.h>
#include <signal.h>
#include <unistd.h>
#include <sys/ioctl.h>
#include <errno.h>

#ifdef INCLUDE_SOCKETS
  #include <sys/socket.h>
  #include <netdb.h>     
  #include <netinet/in.h>
  #include <netinet/tcp.h> 

#define INVALID_SOCKET_VALUE -1
#endif

typedef signed   char   CHAR,  *PSTR,   *LPSTR,	           *PCHAR;
typedef unsigned char   BYTE,  *PBYTE,  *LPBYTE,  UCHAR,   *PUCHAR;
typedef signed   short  SHORT, *PSHORT, *LPSHORT;
typedef unsigned short  WORD,  *PWORD,  *LPWORD,  USHORT,  *PUSHORT;
typedef signed   long   LONG,  *PLONG,  *LPLONG;
typedef unsigned long   DWORD, *PDWORD, *LPDWORD, ULONG,   *PULONG;
typedef void                   *PVOID,  *LPVOID;
typedef long            BOOL;

#define TRUE  1
#define FALSE 0
#define NORMAL_PRIORITY 0
#define INVALID_HANDLE_VALUE -1

#define msec  mco_system_get_current_time
#define THREAD_ID   pthread_t
#define THREAD_ID_T THREAD_ID
#define THREAD_PROC_DECLARE(name) void name( void * p );
#define THREAD_PROC_DEFINE(name,par)  void name( void * par )
#define THREAD_PROC_START(name,par,ptid)   pthread_create(ptid, 0, (void*(*)(void*))name, par)
#define THREAD_CANCEL(id)      \
    pthread_cancel(id);
#define THREAD_PROC_FINISH_DEFINE

#define MUTEX_T pthread_mutex_t
#define MUTEX_INIT(pmutex) pthread_mutex_init((pmutex),0)
#define MUTEX_DESTROY(pmutex) pthread_mutex_destroy(pmutex)
#define MUTEX_LOCK(pmutex) pthread_mutex_lock(pmutex)
#define MUTEX_UNLOCK(pmutex) pthread_mutex_unlock(pmutex)

#define SLEEP( ms ) Sleep( ms )

//for haframework
#define THREAD_PROC_MODE()
#define createThread    THREAD_PROC_START
#define cancelThread    THREAD_CANCEL

#define EXIT(code)  _exit(code)

#define PROG_EXIT(code) \
    return code;

#define KILL() raise(SIGQUIT);

#define closeSocket(socket) close(socket)
#define createTcpSocket(prot) socket(PF_INET,SOCK_STREAM, 0)
#define ioSelect(sock,fd,time)	select(sock+1, fd, 0, 0, time);
#define NBIO(socket,res) \
{ int mode = 1; *res = ioctl(socket, FIONBIO, &mode);}

#define DEFINE_PROCESS_MASKS(set) sigset_t set;
#define DECLARE_PROCESS_MASKS(set) extern sigset_t set;

#define SET_PROCESS_MASKS(set) \
  sigfillset(&set);        \
  sigprocmask(SIG_SETMASK,&set, 0);
#define CLEAR_PROCESS_MASKS(set) \
  sigemptyset(&set);         \
  sigprocmask(SIG_SETMASK,&set, 0);\

#define SET_PROCESS_MASK(set,mask) \
  sigaddset(&set,mask);    \
  sigprocmask(SIG_SETMASK,&set, 0);\

#define CLEAR_PROCESS_MASK(set,mask) \
   sigdelset(&set,mask);         \
   sigprocmask(SIG_SETMASK,&set, 0);\

#define SET_PROCESS_PRIORITY(prio) \
    setpriority(PRIO_PROCESS,0,prio);

#define PROCESS_MASKS() \
  CLEAR_PROCESS_MASKS(set); \
  SET_PROCESS_MASK(set,SIGPIPE); \
  SET_PROCESS_PRIORITY(NORMAL_PRIORITY);

/* Suspend the current thread for the specified # of milliseconds */
extern void Sleep(unsigned long );
/* print to stdout & then flush the buffer */
extern void Printf(char *str,...);

#ifdef __cplusplus
  }
#endif

#endif //_POSIX_H_