Edit File: rep_base.h
/*- * See the file LICENSE for redistribution information. * * Copyright (c) 2001,2008 Oracle. All rights reserved. * * $Id: rep_base.h,v 12.17 2008/02/27 22:04:15 alanb Exp $ */ #ifndef _EX_REPQUOTE_H_ #define _EX_REPQUOTE_H_ #include "../common/rep_common.h" #define SELF_EID 1 typedef struct { char *host; /* Host name. */ u_int32_t port; /* Port on which to connect to this site. */ } repsite_t; /* Globals */ typedef struct { SHARED_DATA shared_data; int elected; void *comm_infrastructure; } APP_DATA; extern int master_eid; extern char *myaddr; extern unsigned short myport; struct __member; typedef struct __member member_t; struct __machtab; typedef struct __machtab machtab_t; /* Arguments for the connect_all thread. */ typedef struct { DB_ENV *dbenv; const char *progname; const char *home; machtab_t *machtab; repsite_t *sites; int nsites; } all_args; /* Arguments for the connect_loop thread. */ typedef struct { DB_ENV *dbenv; const char * home; const char * progname; machtab_t *machtab; int port; } connect_args; #define CACHESIZE (10 * 1024 * 1024) #define DATABASE "quote.db" #define MAX_THREADS 25 #define SLEEPTIME 3 #ifndef COMPQUIET #define COMPQUIET(x,y) x = (y) #endif /* Portability macros for basic threading and networking */ #ifdef _WIN32 #include <winsock2.h> #include <windows.h> extern int getopt(int, char * const *, const char *); typedef HANDLE thread_t; #define thread_create(thrp, attr, func, arg) \ (((*(thrp) = CreateThread(NULL, 0, \ (LPTHREAD_START_ROUTINE)(func), (arg), 0, NULL)) == NULL) ? -1 : 0) #define thread_join(thr, statusp) \ ((WaitForSingleObject((thr), INFINITE) == WAIT_OBJECT_0) && \ GetExitCodeThread((thr), (LPDWORD)(statusp)) ? 0 : -1) typedef HANDLE mutex_t; #define mutex_init(m, attr) \ (((*(m) = CreateMutex(NULL, FALSE, NULL)) != NULL) ? 0 : -1) #define mutex_lock(m) \ ((WaitForSingleObject(*(m), INFINITE) == WAIT_OBJECT_0) ? 0 : -1) #define mutex_unlock(m) (ReleaseMutex(*(m)) ? 0 : -1) #define sleep(s) Sleep(1000 * (s)) typedef int socklen_t; typedef SOCKET socket_t; #define SOCKET_CREATION_FAILURE INVALID_SOCKET #define readsocket(s, buf, sz) recv((s), (buf), (int)(sz), 0) #define writesocket(s, buf, sz) send((s), (const char *)(buf), (int)(sz), 0) #define net_errno WSAGetLastError() #else /* !_WIN32 */ #include <netinet/in.h> #include <sys/socket.h> #include <sys/wait.h> #include <netdb.h> #include <pthread.h> #include <signal.h> #include <unistd.h> typedef pthread_t thread_t; #define thread_create(thrp, attr, func, arg) \ pthread_create((thrp), (attr), (func), (arg)) #define thread_join(thr, statusp) pthread_join((thr), (statusp)) typedef pthread_mutex_t mutex_t; #define mutex_init(m, attr) pthread_mutex_init((m), (attr)) #define mutex_lock(m) pthread_mutex_lock(m) #define mutex_unlock(m) pthread_mutex_unlock(m) typedef int socket_t; #define SOCKET_CREATION_FAILURE -1 #define closesocket(fd) close(fd) #define net_errno errno #define readsocket(s, buf, sz) read((s), (buf), (sz)) #define writesocket(s, buf, sz) write((s), (buf), (sz)) #endif void *connect_all __P((void *args)); void *connect_thread __P((void *args)); int doclient __P((DB_ENV *, const char *, machtab_t *)); int domaster __P((DB_ENV *, const char *)); socket_t get_accepted_socket __P((const char *, int)); socket_t get_connected_socket __P((machtab_t *, const char *, const char *, int, int *, int *)); int get_next_message __P((socket_t, DBT *, DBT *)); socket_t listen_socket_init __P((const char *, int)); socket_t listen_socket_accept __P((machtab_t *, const char *, socket_t, int *)); int machtab_getinfo __P((machtab_t *, int, u_int32_t *, int *)); int machtab_init __P((machtab_t **, int)); void machtab_parm __P((machtab_t *, int *, u_int32_t *)); int machtab_rem __P((machtab_t *, int, int)); int quote_send __P((DB_ENV *, const DBT *, const DBT *, const DB_LSN *, int, u_int32_t)); #endif /* !_EX_REPQUOTE_H_ */
Back to File Manager