dd/d57/et__private_8h_source.html

 /*----------------------------------------------------------------------------*

  *  Copyright (c) 1998        Southeastern Universities Research Association, *

  *                            Thomas Jefferson National Accelerator Facility  *

  *                                                                            *

  *    This software was developed under a United States Government license    *

  *    described in the NOTICE file included as part of this distribution.     *

  *                                                                            *

  *    Author:  Carl Timmer                                                    *

  *             timmer@jlab.org                   Jefferson Lab, MS-12H        *

  *             Phone: (757) 269-5130             12000 Jefferson Ave.         *

  *             Fax:   (757) 269-5800             Newport News, VA 23606       *

  *                                                                            *

  *----------------------------------------------------------------------------*

  *

  * Description:

  *      Header file for ET system

  *

  *----------------------------------------------------------------------------*/


 #ifndef ET_PRIVATE_H_

 #define ET_PRIVATE_H_


 #include <stdint.h>

 #include <stdlib.h>

 #include <stdarg.h>

 #include <stddef.h>

 #include <limits.h>

 #include <pthread.h>


 #include "etCommonNetwork.h"


 #ifdef __cplusplus

 extern "C" {

 #endif


 /* The data-type model for Linux defines  __WORDSIZE to be 64 or 32. */

 #ifdef linux

   #if __WORDSIZE == 64

     #define _LP64 1

   #else

     #define _ILP32 1

   #endif

 #endif


 #define ET_VERSION 16

 #define ET_VERSION_MINOR 5

 #define ET_LANG_C     0

 #define ET_LANG_CPP   1

 #define ET_LANG_JAVA  2

 #define ET_SYSTEM_TYPE_C     1

 #define ET_SYSTEM_TYPE_JAVA  2

 #define ET_IPADDRSTRLEN 16

 #define ET_MAXHOSTNAMELEN 256


 #define ET_MAXADDRESSES 10


 /****************************************

  * times for heart beating & monitoring *

  ****************************************/

 /* 20 sec */

 #define ET_MON_SEC     20

 #define ET_MON_NSEC     0

 /* 0.5 sec */

 #define ET_BEAT_SEC   0

 #define ET_BEAT_NSEC  500000000

 /* 2 sec */

 #define ET_IS_ALIVE_SEC   2

 #define ET_IS_ALIVE_NSEC  0

 /* 2.5 sec */

 #define ET_CLOSE_SEC   2

 #define ET_CLOSE_NSEC  500000000

 #define ET_HBMODULO UINT_MAX


 /*

  * Maximum # of user attachments/processes on the system.

  * This is used only to allocate space in the system structure

  * for attachment/process housekeeping. The actual maximum #s of

  * attachments & processes are passed in a et_sys_config structure

  * to et_system_start.

  *

  * The number of attachments is the number of "et_station_attach"

  * calls successfully returned - each providing an access to events

  * from a certain station. A unix process may make several attachments

  * to one or more stations on one or more ET systems.

  *

  * The number of processes is just the number of "et_open" calls

  * successfully returned on the same host as the ET system. The

  * system must be one which can allow many processes to share the

  * ET mutexes, thus allowing full access to the shared memory. On

  * Linux this is not possible, meaning that the local user does NOT

  * have the proper access to the shared memory.

  *

  * Since a unix process may only call et_open once, as things now stand,

  * the number of processes is a count of the number of unix processes

  * on Solaris opened locally.

  */

 #define ET_ATTACHMENTS_MAX 100

 #define ET_PROCESSES_MAX   ET_ATTACHMENTS_MAX

 /* status of an attachment to an ET system */

 #define ET_ATT_UNUSED 0

 #define ET_ATT_ACTIVE 1

 /* values to tell attachment to return prematurely from ET routine */

 #define ET_ATT_CONTINUE 0

 #define ET_ATT_QUIT     1

 /* values telling whether an attachment is blocked in a read or not */

 #define ET_ATT_UNBLOCKED 0

 #define ET_ATT_BLOCKED   1

 /* values telling whether an attachment is in simulated sleep mode or not */

 #define ET_ATT_NOSLEEP 0

 #define ET_ATT_SLEEP   1

 /* status of a process in regards to an ET system */

 #define ET_PROC_CLOSED 0

 #define ET_PROC_OPEN   1

 /* what a process thinks of its ET system's status */

 #define ET_PROC_ETDEAD 0

 #define ET_PROC_ETOK   1

 /* certain structures need to be initialized before use */

 #define ET_STRUCT_NEW 0

 #define ET_STRUCT_OK  1

 /* values to tell thread to self-destruct or to stick around */

 #define ET_THREAD_KEEP 0

 #define ET_THREAD_KILL 1

 /* tells if operating sys can share pthread mutexes between processes */

 #define ET_MUTEX_SHARE   0

 #define ET_MUTEX_NOSHARE 1

 /* is pthread mutex locked or not */

 #define ET_MUTEX_UNLOCKED 0

 #define ET_MUTEX_LOCKED   1

 #define ET_INITIAL_SHARED_MEM_DATA_BYTES 64


 /*

  * STRUCTURES for the STATIONs:

  * --------------------------

  *  structures          purpose

  * ____________        ________________

  *  et_stat_config      station behavior parameters

  *  et_stat_data        station information

  *  et_event            single event

  *  et_list             list of events

  *  et_station          processes can "attach" to station

  *                      to get and put events

  */


 typedef int (*ET_SELECT_FUNCPTR) (void *, et_stat_id, et_event *);


 typedef struct et_stat_config_t {

   int  init;

   int  flow_mode;

   int  user_mode;

   int  restore_mode;

   int  block_mode;

   int  prescale;

   int  cue;

   int  select_mode;

   int  select[ET_STATION_SELECT_INTS];

   char fname[ET_FUNCNAME_LENGTH];

   char lib[ET_FILENAME_LENGTH];

   char classs[ET_FILENAME_LENGTH];

 } et_stat_config;


 typedef struct et_stat_data_t {

   int   status;

   int   pid_create;

   int   nattachments;

   int   att[ET_ATTACHMENTS_MAX];

   void *lib_handle;

   ET_SELECT_FUNCPTR func;

 } et_stat_data;


 typedef struct et_list_t {

   int              cnt;

   int              lasthigh;

   uint64_t         events_try;

   uint64_t         events_in;

   uint64_t         events_out;

   et_event        *firstevent;

   et_event        *lastevent;

   pthread_mutex_t  mutex;

   pthread_cond_t   cread;

 } et_list;


 #define ET_FIX_READ 0

 #define ET_FIX_DUMP 1

 struct et_fixin {

   et_event   *first;

   uint64_t    eventsin;

   int         start;

   int         cnt;

   int         num;

   int         call;

 };


 struct et_fixout {

     int         start;

     int         cnt;

     int         num;

 };


 struct et_fix {

   struct et_fixin  in;

   struct et_fixout out;

 };


 typedef struct et_station_t {

   et_stat_id            num;

   int                   conductor;

   et_stat_id            next;

   et_stat_id            prev;

   et_stat_id            nextparallel;

   et_stat_id            prevparallel;

   int                   waslast;

   char                  name[ET_STATNAME_LENGTH];

   pthread_mutex_t       mutex;

   struct et_fix         fix;

   et_stat_data          data;

   et_stat_config        config;

   et_list               list_in;

   et_list               list_out;

 } et_station;


 struct et_proc {

   et_proc_id    num;

   et_att_id     att[ET_ATTACHMENTS_MAX];

   uint64_t      time;

   int           nattachments;

   int           status;

   int           et_status;

   unsigned int  heartbeat;

   pid_t         pid;

   pthread_t     hbeat_thd_id;

   pthread_t     hmon_thd_id;

 };


 struct et_attach {

   et_att_id   num;

   et_proc_id  proc;

   et_stat_id  stat;

   int         status;

   int         blocked;

   int         quit;

   int         sleep;

   uint64_t    events_put;

   uint64_t    events_get;

   uint64_t    events_dump;

   uint64_t    events_make;

   pid_t       pid;

   char        host[ET_MAXHOSTNAMELEN];

   char        interface[ET_IPADDRSTRLEN];

 };


 typedef struct  et_sys_config_t {

   uint64_t          event_size;

   int               init;

   int               nevents;

   int               ntemps;

   int               nstations;

   int               nprocesses;

   int               nattachments;

   int               groupCount;

   int               groups[ET_EVENT_GROUPS_MAX];

   char              filename[ET_FILENAME_LENGTH];

   /* for remote use */

   int               port;

   int               serverport;

   int               tcpSendBufSize;

   int               tcpRecvBufSize;

   int               tcpNoDelay;

   codaNetInfo       netinfo;

   codaDotDecIpAddrs bcastaddrs;

   codaDotDecIpAddrs mcastaddrs;

 } et_sys_config;


 /* Macros to handle the bitInfo word in et_system structure following. */

 #define ET_BIT64_MASK 0x1

 #define ET_KILL_MASK  0x2

 #define ET_GET_BIT64(x)  ((x) & ET_BIT64_MASK)

 #define ET_GET_KILL(x)   ((x) & ET_KILL_MASK)

 #define ET_SET_BIT64(x)  ((x) | ET_BIT64_MASK)

 #define ET_SET_KILL(x)   ((x) | ET_KILL_MASK)

 typedef struct et_system_t {

   int              version;

   int              nselects;

   int              bitInfo;

   int              asthread;

   unsigned int     heartbeat;

   int              hz;

   int              nstations;

   int              ntemps;

   int              nprocesses;

   int              nattachments;

   int              port;

   int              tcpFd;

   int              udpFd;

   int              statAdd;

   int              statDone;

   et_stat_id       stat_head;

   et_stat_id       stat_tail;

   pid_t            mainpid;

   void            *pmap;

   pthread_mutex_t  mutex;

   pthread_mutex_t  stat_mutex;

   pthread_mutex_t  statadd_mutex;

   pthread_cond_t   statadd;

   pthread_cond_t   statdone;

   pthread_t        tid_hb;

   pthread_t        tid_hm;

   pthread_t        tid_as;

   pthread_t        tid_srv;

   pthread_t        tid_mul;

   char             host[ET_MAXHOSTNAMELEN];

   struct et_proc   proc[ET_PROCESSES_MAX];

   struct et_attach attach[ET_ATTACHMENTS_MAX];

   et_sys_config    config;

 } et_system;


 typedef struct et_open_config_t {

     int             init;

     int             wait;

     int             cast;

     int             ttl;

     int             mode;

     int             debug_default;

     int             udpport;

     int             serverport;

     int             policy;

     int             tcpSendBufSize;

     int             tcpRecvBufSize;

     int             tcpNoDelay;

     struct timespec timeout;

     char            host[ET_MAXHOSTNAMELEN];

     char            interface[ET_IPADDRSTRLEN];

     codaIpAddr       *netinfo;

     codaIpList       *bcastaddrs;

     codaDotDecIpAddrs mcastaddrs;

 } et_open_config;


 typedef struct  et_id_t {

     int              init;

     int              lang;

     int              alive;

     int              closed;

     int              bit64;

     et_proc_id       proc;

     int              race;

     int              cleanup;

     int              debug;

     int              nevents;

     int              group;

     int              version;

     int              nselects;

     int              share;

     size_t           memsize;

     uint64_t         esize;

     ptrdiff_t        offset;

     /* for REMOTE use */

     int              locality;

     int              sockfd;

     int              endian;

     int              systemendian;

     int              iov_max;

     int              port;

     char             ethost[ET_MAXHOSTNAMELEN];

     char             localAddr[ET_IPADDRSTRLEN];

     /******************/


     void            *pmap;

     et_system       *sys;

     et_station      *stats;

     int             *histogram;

     et_event        *events;

     char            *data;

     et_station      *grandcentral;

     pthread_mutex_t  mutex;

 #ifndef NO_RW_LOCK

     pthread_rwlock_t sharedMemlock;

 #endif

 } et_id;


 typedef struct  et_mem_t {

     uint32_t  byteOrder;

     uint32_t  systemType;

     uint32_t  majorVersion;

     uint32_t  minorVersion;

     uint32_t  numSelectInts;

     uint32_t  headerByteSize;

     uint64_t  eventByteSize;

     uint64_t  headerPosition;

     uint64_t  dataPosition;

     uint64_t  totalSize;

     uint64_t  usedSize;

 } et_mem;


 typedef struct et_response_t {

     int   port;

     int   castType;

     int   addrCount;

     char  uname[ET_MAXHOSTNAMELEN];

     char  canon[ET_MAXHOSTNAMELEN];

     char  castIP[ET_IPADDRSTRLEN];

     uint32_t *addrs;

     char  **ipaddrs;

     char  **bcastaddrs;

     struct et_response_t *next;

 } et_response;


 /****************************

  *       REMOTE STUFF       *

  ****************************/


 /* "table" of values representing ET commands for tcp/ip */


 /* for operating systems that cannot share mutexes (Linux) */

 #define  ET_NET_EV_GET_L        0

 #define  ET_NET_EVS_GET_L       1

 #define  ET_NET_EV_PUT_L        2

 #define  ET_NET_EVS_PUT_L       3

 #define  ET_NET_EV_NEW_L        4

 #define  ET_NET_EVS_NEW_L       5

 #define  ET_NET_EV_DUMP_L       6

 #define  ET_NET_EVS_DUMP_L      7

 #define  ET_NET_EVS_NEW_GRP_L   8

 /* for fully remote systems */

 #define  ET_NET_EV_GET         20

 #define  ET_NET_EVS_GET        21

 #define  ET_NET_EV_PUT         22

 #define  ET_NET_EVS_PUT        23

 #define  ET_NET_EV_NEW         24

 #define  ET_NET_EVS_NEW        25

 #define  ET_NET_EV_DUMP        26

 #define  ET_NET_EVS_DUMP       27

 #define  ET_NET_EVS_NEW_GRP    28

 #define  ET_NET_EVS_NEW_GRP_JAVA 29


 #define  ET_NET_ALIVE          40

 #define  ET_NET_WAIT           41

 #define  ET_NET_CLOSE          42

 #define  ET_NET_FCLOSE         43

 #define  ET_NET_WAKE_ATT       44

 #define  ET_NET_WAKE_ALL       45

 #define  ET_NET_KILL           46

 #define  ET_NET_STAT_ATT       60

 #define  ET_NET_STAT_DET       61

 #define  ET_NET_STAT_CRAT      62

 #define  ET_NET_STAT_RM        63

 #define  ET_NET_STAT_SPOS      64

 #define  ET_NET_STAT_GPOS      65

 #define  ET_NET_STAT_ISAT      80

 #define  ET_NET_STAT_EX        81

 #define  ET_NET_STAT_SSW       82

 #define  ET_NET_STAT_GSW       83

 #define  ET_NET_STAT_LIB       84

 #define  ET_NET_STAT_FUNC      85

 #define  ET_NET_STAT_CLASS     86

 #define  ET_NET_STAT_GATTS    100

 #define  ET_NET_STAT_STATUS   101

 #define  ET_NET_STAT_INCNT    102

 #define  ET_NET_STAT_OUTCNT   103

 #define  ET_NET_STAT_GBLOCK   104

 #define  ET_NET_STAT_GUSER    105

 #define  ET_NET_STAT_GRESTORE 106

 #define  ET_NET_STAT_GPRE     107

 #define  ET_NET_STAT_GCUE     108

 #define  ET_NET_STAT_GSELECT  109

 #define  ET_NET_STAT_SBLOCK   115

 #define  ET_NET_STAT_SUSER    116

 #define  ET_NET_STAT_SRESTORE 117

 #define  ET_NET_STAT_SPRE     118

 #define  ET_NET_STAT_SCUE     119

 #define  ET_NET_ATT_PUT       130

 #define  ET_NET_ATT_GET       131

 #define  ET_NET_ATT_DUMP      132

 #define  ET_NET_ATT_MAKE      133

 #define  ET_NET_SYS_TMP       150

 #define  ET_NET_SYS_TMPMAX    151

 #define  ET_NET_SYS_STAT      152

 #define  ET_NET_SYS_STATMAX   153

 #define  ET_NET_SYS_PROC      154

 #define  ET_NET_SYS_PROCMAX   155

 #define  ET_NET_SYS_ATT       156

 #define  ET_NET_SYS_ATTMAX    157

 #define  ET_NET_SYS_HBEAT     158

 #define  ET_NET_SYS_PID       159

 #define  ET_NET_SYS_GRP       160

 #define  ET_NET_SYS_DATA      170

 #define  ET_NET_SYS_HIST      171

 #define  ET_NET_SYS_GRPS      172

 typedef struct et_netthread_t {

     int   cast;

     et_id *id;

     et_sys_config *config;

     char *listenaddr;

     char uname[ET_MAXHOSTNAMELEN];

 } et_netthread;


 /****************************

  *       BRIDGE STUFF       *

  ****************************/


 typedef struct et_bridge_config_t {

     int             init;

     int             mode_from;

     int             mode_to;

     int             chunk_from;

     int             chunk_to;

     struct timespec timeout_from;

     struct timespec timeout_to;

     ET_SWAP_FUNCPTR func;

 } et_bridge_config;


 /****************************

  *    END BRIDGE STUFF      *

  ****************************/


 #define ET_P2EVENT(etid, place) ((et_event *)((et_event *)(etid->events) + (place)))


 /* Macros to switch ptrs from ET space to user space & vice versa. */


 #define ET_PEVENT2USR(p, offset) ((et_event *)((char *)(p) + (offset)))

 #define ET_PEVENT2ET(p, offset)  ((et_event *)((char *)(p) - (offset)))


 #define ET_PSTAT2USR(p, offset)  ((et_station *)((char *)(p) + (offset)))

 #define ET_PSTAT2ET(p, offset)   ((et_station *)((char *)(p) - (offset)))


 #define ET_PDATA2USR(p, offset)  ((void *)((char *)(p) + (offset)))

 #define ET_PDATA2ET(p, offset)   ((void *)((char *)(p) - (offset)))


 /* Macros to break a 64 int into 2, 32 bit ints & the reverse. */


 #define ET_64BIT_UINT(hi,lo)       (((uint64_t)(hi) << 32) | ((uint64_t)(lo) & 0x00000000FFFFFFFF))


 #define ET_64BIT_INT(hi,lo)         (((int64_t)(hi) << 32) | ((int64_t)(lo)  & 0x00000000FFFFFFFF))


 #define ET_64BIT_P(hi,lo) ((void *)(((uint64_t)(hi) << 32) | ((uint64_t)(lo) & 0x00000000FFFFFFFF)))


 #define ET_HIGHINT(i)         ((uint32_t)(((uint64_t)(i) >> 32) & 0x00000000FFFFFFFF))


 #define ET_LOWINT(i)           ((uint32_t)((uint64_t)(i) & 0x00000000FFFFFFFF))


 /***********************/

 /* Extern declarations */

 /***********************/


 /* mutex related */

 extern void et_station_lock(et_system *sys);

 extern void et_station_unlock(et_system *sys);


 extern void et_llist_lock(et_list *pl);

 extern void et_llist_unlock(et_list *pl);


 extern void et_system_lock(et_system *sys);

 extern void et_system_unlock(et_system *sys);


 extern void et_transfer_lock(et_station *ps);

 extern void et_transfer_unlock(et_station *ps);

 extern void et_transfer_lock_all(et_id *id);

 extern void et_transfer_unlock_all(et_id *id);


 extern void et_tcp_lock(et_id *id);

 extern void et_tcp_unlock(et_id *id);


 extern void et_memRead_lock(et_id *id);

 extern void et_memWrite_lock(et_id *id);

 extern void et_mem_unlock(et_id *id);


 extern int  et_mutex_locked(pthread_mutex_t *pmutex);


 extern int  et_repair_station(et_id *id, et_stat_id stat_id);

 extern int  et_repair_gc(et_id *id);


 /* initialization */

 extern void et_init_station(et_station *ps);

 extern void et_init_llist(et_list *pl);


 extern void et_init_event(et_event *pe);

 extern void et_init_event_(et_event *pe);


 extern void et_init_process(et_system *sys, et_proc_id id);

 extern void et_init_attachment(et_system *sys, et_att_id id);


 extern void et_init_histogram(et_id *id);

 extern void et_init_stats_att(et_system *sys, et_att_id id);

 extern void et_init_stats_allatts(et_system *sys);

 extern void et_init_stats_station(et_station *ps);

 extern void et_init_stats_allstations(et_id *id);

 extern void et_init_stats_all(et_id *id);


 extern int  et_id_init(et_sys_id* id);

 extern void et_id_destroy(et_sys_id id);


 /* read and write */

 extern int  et_station_write(et_id *id,  et_stat_id stat_id, et_event  *pe);

 extern int  et_station_nwrite(et_id *id, et_stat_id stat_id, et_event *pe[], int num);


 extern int  et_station_read(et_id *id,  et_stat_id stat_id, et_event **pe,

                             int _mode, et_att_id att, struct timespec *time);

 extern int  et_station_nread(et_id *id, et_stat_id stat_id, et_event *pe[], int mode,

                              et_att_id att, struct timespec *time, int num, int *nread);

 extern int  et_station_nread_group(et_id *id, et_stat_id stat_id, et_event *pe[], int mode,

                  et_att_id att, struct timespec *time, int num, int group, int *nread);

 extern int  et_station_dump(et_id *id, et_event *pe);

 extern int  et_station_ndump(et_id *id, et_event *pe[], int num);


 extern int  et_llist_read(et_list *pl, et_event **pe);

 extern int  et_llist_write(et_id *id, et_list *pl, et_event **pe, int num);

 extern int  et_llist_write_gc(et_id *id, et_event **pe, int num);


 extern int  et_restore_events(et_id *id, et_att_id att, et_stat_id stat_id);

 extern void et_flush_events(et_id *id, et_att_id att, et_stat_id stat_id);


 /* mmap/memory functions */

 extern int   et_mem_create(const char *name, size_t memsize, void **pmemory, size_t *totalSize);

 extern void  et_mem_write_first_block(char *ptr,

                                       uint32_t headerByteSize, uint64_t eventByteSize,

                                       uint64_t headerPosition, uint64_t dataPosition,

                                       uint64_t totalByteSize,  uint64_t usedByteSize);

 extern int   et_mem_attach(const char *name, void **pmemory, et_mem *pInfo);

 extern int   et_mem_unmap(const char *name, void *pmem);

 extern int   et_mem_remove(const char *name, void *pmem);

 extern int   et_mem_size(const char *name, size_t *totalsize, size_t *usedsize);


 extern void *et_temp_create(const char *name, size_t size);

 extern void *et_temp_attach(const char *name, size_t size);

 extern int   et_temp_remove(const char *name, void *pmem, size_t size);


 /* remote routines */

 extern int  etr_event_new(et_sys_id id, et_att_id att, et_event **ev,

                 int mode, struct timespec *deltatime, size_t size);

 extern int  etr_events_new(et_sys_id id, et_att_id att, et_event *evs[],

                 int mode, struct timespec *deltatime, size_t size, int num, int *nread);

 extern int  etr_events_new_group(et_sys_id id, et_att_id att, et_event *evs[],

                    int mode, struct timespec *deltatime,

                    size_t size, int num, int group, int *nread);

 extern int  etr_event_get(et_sys_id id, et_att_id att, et_event **ev,

                 int wait, struct timespec *deltatime);

 extern int  etr_events_get(et_sys_id id, et_att_id att, et_event *evs[],

                 int wait, struct timespec *deltatime, int num, int *nread);

 extern int  etr_event_put(et_sys_id id, et_att_id att, et_event *ev);

 extern int  etr_events_put(et_sys_id id, et_att_id att, et_event *evs[], int num);

 extern int  etr_event_dump(et_sys_id id, et_att_id att, et_event *ev);

 extern int  etr_events_dump(et_sys_id id, et_att_id att, et_event *evs[], int num);


 extern int  etr_open(et_sys_id *id, const char *et_filename, et_openconfig openconfig);

 extern int  etr_close(et_sys_id id);

 extern int  etr_forcedclose(et_sys_id id);

 extern int  etr_kill(et_sys_id id);

 extern int  etr_alive(et_sys_id id);

 extern int  etr_wait_for_alive(et_sys_id id);

 extern int  etr_wakeup_attachment(et_sys_id id, et_att_id att);

 extern int  etr_wakeup_all(et_sys_id id, et_stat_id stat_id);


 extern int  etr_station_create_at(et_sys_id id, et_stat_id *stat_id,

                  const char *stat_name, et_statconfig sconfig,

                  int position, int parallelposition);

 extern int  etr_station_create(et_sys_id id, et_stat_id *stat_id,

                  const char *stat_name, et_statconfig sconfig);

 extern int  etr_station_remove(et_sys_id id, et_stat_id stat_id);

 extern int  etr_station_attach(et_sys_id id, et_stat_id stat_id, et_att_id *att);

 extern int  etr_station_detach(et_sys_id id, et_att_id att);

 extern int  etr_station_setposition(et_sys_id id, et_stat_id stat_id, int position,

                                     int parallelposition);

 extern int  etr_station_getposition(et_sys_id id, et_stat_id stat_id, int *position,

                                     int *parallelposition);

 extern int  etr_station_isattached(et_sys_id id, et_stat_id stat_id, et_att_id att);

 extern int  etr_station_exists(et_sys_id id, et_stat_id *stat_id, const char *stat_name);


 extern int  etr_station_getattachments(et_sys_id id, et_stat_id stat_id, int *numatts);

 extern int  etr_station_getstatus(et_sys_id id, et_stat_id stat_id, int *status);

 extern int  etr_station_getstatus(et_sys_id id, et_stat_id stat_id, int *status);

 extern int  etr_station_getinputcount(et_sys_id id, et_stat_id stat_id, int *cnt);

 extern int  etr_station_getoutputcount(et_sys_id id, et_stat_id stat_id, int *cnt);

 extern int  etr_station_getselect(et_sys_id id, et_stat_id stat_id, int *select);

 extern int  etr_station_getlib(et_sys_id id, et_stat_id stat_id, char *lib);

 extern int  etr_station_getclass(et_sys_id id, et_stat_id stat_id, char *classs);

 extern int  etr_station_getfunction(et_sys_id id, et_stat_id stat_id, char *function);


 extern int  etr_station_getblock(et_sys_id id, et_stat_id stat_id, int *block);

 extern int  etr_station_setblock(et_sys_id id, et_stat_id stat_id, int  block);

 extern int  etr_station_getuser(et_sys_id id, et_stat_id stat_id, int *user);

 extern int  etr_station_setuser(et_sys_id id, et_stat_id stat_id, int  user);

 extern int  etr_station_getrestore(et_sys_id id, et_stat_id stat_id, int *restore);

 extern int  etr_station_setrestore(et_sys_id id, et_stat_id stat_id, int  restore);

 extern int  etr_station_getprescale(et_sys_id id, et_stat_id stat_id, int *prescale);

 extern int  etr_station_setprescale(et_sys_id id, et_stat_id stat_id, int  prescale);

 extern int  etr_station_getcue(et_sys_id id, et_stat_id stat_id, int *cue);

 extern int  etr_station_setcue(et_sys_id id, et_stat_id stat_id, int  cue);

 extern int  etr_station_getselectwords(et_sys_id id, et_stat_id stat_id, int select[]);

 extern int  etr_station_setselectwords(et_sys_id id, et_stat_id stat_id, int select[]);


 extern int  etr_system_gettemps (et_sys_id id, int *temps);

 extern int  etr_system_gettempsmax (et_sys_id id, int *tempsmax);

 extern int  etr_system_getstations (et_sys_id id, int *stations);

 extern int  etr_system_getstationsmax (et_sys_id id, int *stationsmax);

 extern int  etr_system_getprocs (et_sys_id id, int *procs);

 extern int  etr_system_getprocsmax (et_sys_id id, int *procsmax);

 extern int  etr_system_getattachments (et_sys_id id, int *atts);

 extern int  etr_system_getattsmax (et_sys_id id, int *attsmax);

 extern int  etr_system_getheartbeat (et_sys_id id, int *heartbeat);

 extern int  etr_system_getpid (et_sys_id id, int *pid);

 extern int  etr_system_getgroupcount (et_sys_id id, int *groupCnt);

 /* end remote routines */


 /* attachment rountines */

 extern int etr_attach_geteventsput(et_sys_id id, et_att_id att_id,

                                    uint64_t *events);

 extern int etr_attach_geteventsget(et_sys_id id, et_att_id att_id,

                                    uint64_t *events);

 extern int etr_attach_geteventsdump(et_sys_id id, et_att_id att_id,

                                     uint64_t *events);

 extern int etr_attach_geteventsmake(et_sys_id id, et_att_id att_id,

                                     uint64_t *events);

 /* end of attachment routines */


 /* local no-share (linux) routines */

 extern int  etn_open(et_sys_id *id, const char *filename, et_openconfig openconfig);

 extern int  etn_close(et_sys_id id);

 extern int  etn_forcedclose(et_sys_id id);

 extern int  etn_kill(et_sys_id id);

 extern int  etn_alive(et_sys_id id);

 extern int  etn_wait_for_alive(et_sys_id id);

 extern int  etn_event_new(et_sys_id id, et_att_id att, et_event **ev,

                  int mode, struct timespec *deltatime, size_t size);

 extern int  etn_events_new(et_sys_id id, et_att_id att, et_event *evs[],

                  int mode, struct timespec *deltatime, size_t size, int num, int *nread);

 extern int  etn_events_new_group(et_sys_id id, et_att_id att, et_event *evs[],

                  int mode, struct timespec *deltatime,

                  size_t size, int num, int group, int *nread);

 extern int  etn_event_get(et_sys_id id, et_att_id att, et_event **ev,

                  int mode, struct timespec *deltatime);

 extern int  etn_events_get(et_sys_id id, et_att_id att, et_event *evs[],

                  int mode, struct timespec *deltatime, int num, int *nread);

 extern int  etn_event_put(et_sys_id id, et_att_id att, et_event *ev);

 extern int  etn_events_put(et_sys_id id, et_att_id att, et_event *evs[], int num);

 extern int  etn_event_dump(et_sys_id id, et_att_id att, et_event *ev);

 extern int  etn_events_dump(et_sys_id id, et_att_id att, et_event *evs[], int num);

 /* end of local linux routines */


 /* local routines (Sun) */

 extern int  etl_open(et_sys_id *id, const char *filename, et_openconfig openconfig);

 extern int  etl_close(et_sys_id id);

 extern int  etl_forcedclose(et_sys_id id);

 extern int  etl_kill(et_sys_id id);

 extern int  etl_alive(et_sys_id id);

 extern int  etl_wait_for_alive(et_sys_id id);

 extern int  et_wait_for_system(et_sys_id id, struct timespec *timeout,

                                 const char *etname);

 extern int  et_look(et_sys_id *id, const char *filename);

 extern int  et_unlook(et_sys_id id);

 /* end local routines */


 /* server/network routines */

 extern void *et_cast_thread(void *arg);

 extern void *et_netserver(void *arg);

 extern int   et_findserver(const char *etname, char *ethost, int *port,

                            uint32_t *inetaddr, et_open_config *config,

                            et_response **allETinfo, int debug);

 extern int   et_responds(const char *etname);

 extern int   et_sharedmutex(void);

 extern int   et_findlocality(const char *filename, et_openconfig openconfig);

 /* end server/network routines */


 /* station configuration checks */

 extern int  et_station_config_check(et_id *id, et_stat_config *sc);

 extern int  et_station_compare_parallel(et_id *id, et_stat_config *group,

             et_stat_config *config);

 /* end station configuration checks */


 /* error logging */

 extern void et_logmsg (char *sev, char *fmt, ...);


 #ifdef __cplusplus

 }

 #endif


 #endif

et_statconfig
void * et_statconfig
ET station configuration.
Definition: et.h:340

ET_STATNAME_LENGTH
#define ET_STATNAME_LENGTH
Max length of station name + 1.
Definition: et.h:95

et_sys_id
void * et_sys_id
ET system id.
Definition: et.h:339

ET_SWAP_FUNCPTR
int(* ET_SWAP_FUNCPTR)(et_event *, et_event *, int, int)
Used to define a data-swapping function.
Definition: et.h:336

et_att_id
int et_att_id
ET attachment id.
Definition: et.h:346

et_openconfig
void * et_openconfig
ET open configuration.
Definition: et.h:342

ET_STATION_SELECT_INTS
#define ET_STATION_SELECT_INTS
Number of control integers associated with each station.
Definition: et.h:69

et_proc_id
int et_proc_id
ET process id.
Definition: et.h:345

ET_FUNCNAME_LENGTH
#define ET_FUNCNAME_LENGTH
Max length of user's event selection func name + 1.
Definition: et.h:94

ET_FILENAME_LENGTH
#define ET_FILENAME_LENGTH
Max length of ET system file name + 1.
Definition: et.h:93

ET_EVENT_GROUPS_MAX
#define ET_EVENT_GROUPS_MAX
Default max number of groups events are divided into.
Definition: et.h:60

et_stat_id
int et_stat_id
ET station id.
Definition: et.h:344

et_id_destroy
void et_id_destroy(et_sys_id id)

etr_station_getfunction
int etr_station_getfunction(et_sys_id id, et_stat_id stat_id, char *function)
Definition: et_remote.c:1156

etr_station_getstatus
int etr_station_getstatus(et_sys_id id, et_stat_id stat_id, int *status)
Definition: et_remote.c:1254

etn_events_new
int etn_events_new(et_sys_id id, et_att_id att, et_event *evs[], int mode, struct timespec *deltatime, size_t size, int num, int *nread)

ET_IPADDRSTRLEN
#define ET_IPADDRSTRLEN
Max string length of dotted-decimal ip address.
Definition: et_private.h:55

et_restore_events
int et_restore_events(et_id *id, et_att_id att, et_stat_id stat_id)

etr_system_getgroupcount
int etr_system_getgroupcount(et_sys_id id, int *groupCnt)
Definition: et_remote.c:1557

et_station_compare_parallel
int et_station_compare_parallel(et_id *id, et_stat_config *group, et_stat_config *config)
This routine compares all relevant station configuration parameters to see if both configs are compat...
Definition: et_statconfig.c:878

et_mem_size
int et_mem_size(const char *name, size_t *totalsize, size_t *usedsize)

etr_station_getselect
int etr_station_getselect(et_sys_id id, et_stat_id stat_id, int *select)
Definition: et_remote.c:1314

et_llist_lock
void et_llist_lock(et_list *pl)

et_system_lock
void et_system_lock(et_system *sys)

et_response
struct et_response_t et_response
Structure for holding an ET system's single response to ET client's broad/multicast.

et_station_unlock
void et_station_unlock(et_system *sys)

etl_wait_for_alive
int etl_wait_for_alive(et_sys_id id)

et_look
int et_look(et_sys_id *id, const char *filename)

et_temp_create
void * et_temp_create(const char *name, size_t size)

etr_events_new_group
int etr_events_new_group(et_sys_id id, et_att_id att, et_event *evs[], int mode, struct timespec *deltatime, size_t size, int num, int group, int *nread)
Definition: et_remote.c:2147

ET_ATTACHMENTS_MAX
#define ET_ATTACHMENTS_MAX
Maximum number of attachments allowed on the system.
Definition: et_private.h:108

etr_forcedclose
int etr_forcedclose(et_sys_id id)
Definition: et_remote.c:414

et_mem_create
int et_mem_create(const char *name, size_t memsize, void **pmemory, size_t *totalSize)

etr_system_getattachments
int etr_system_getattachments(et_sys_id id, int *atts)
Definition: et_remote.c:1517

etr_station_detach
int etr_station_detach(et_sys_id id, et_att_id att)
Definition: et_remote.c:786

etr_system_getprocs
int etr_system_getprocs(et_sys_id id, int *procs)
Definition: et_remote.c:1497

etn_event_put
int etn_event_put(et_sys_id id, et_att_id att, et_event *ev)

et_system
struct et_system_t et_system
Structure containing all ET system information.

et_temp_attach
void * et_temp_attach(const char *name, size_t size)

et_station_read
int et_station_read(et_id *id, et_stat_id stat_id, et_event **pe, int _mode, et_att_id att, struct timespec *time)

et_netthread
struct et_netthread_t et_netthread
Struct for passing data from system to network threads.

et_responds
int et_responds(const char *etname)

etr_open
int etr_open(et_sys_id *id, const char *et_filename, et_openconfig openconfig)
Definition: et_remote.c:37

et_station_nwrite
int et_station_nwrite(et_id *id, et_stat_id stat_id, et_event *pe[], int num)

etr_system_gettemps
int etr_system_gettemps(et_sys_id id, int *temps)
Definition: et_remote.c:1457

et_init_attachment
void et_init_attachment(et_system *sys, et_att_id id)

etr_station_getinputcount
int etr_station_getinputcount(et_sys_id id, et_stat_id stat_id, int *cnt)
Definition: et_remote.c:1264

etr_system_getstationsmax
int etr_system_getstationsmax(et_sys_id id, int *stationsmax)
Definition: et_remote.c:1487

etr_station_exists
int etr_station_exists(et_sys_id id, et_stat_id *stat_id, const char *stat_name)
Definition: et_remote.c:931

etr_station_getposition
int etr_station_getposition(et_sys_id id, et_stat_id stat_id, int *position, int *parallelposition)
Definition: et_remote.c:853

et_netserver
void * et_netserver(void *arg)

et_flush_events
void et_flush_events(et_id *id, et_att_id att, et_stat_id stat_id)

etr_kill
int etr_kill(et_sys_id id)
Definition: et_remote.c:438

et_llist_write_gc
int et_llist_write_gc(et_id *id, et_event **pe, int num)

ET_MAXHOSTNAMELEN
#define ET_MAXHOSTNAMELEN
Max length of a host name including the terminating char.
Definition: et_private.h:58

etr_station_setprescale
int etr_station_setprescale(et_sys_id id, et_stat_id stat_id, int prescale)
Definition: et_remote.c:1402

etr_system_gettempsmax
int etr_system_gettempsmax(et_sys_id id, int *tempsmax)
Definition: et_remote.c:1467

etr_station_getoutputcount
int etr_station_getoutputcount(et_sys_id id, et_stat_id stat_id, int *cnt)
Definition: et_remote.c:1274

etn_event_dump
int etn_event_dump(et_sys_id id, et_att_id att, et_event *ev)

etr_system_getheartbeat
int etr_system_getheartbeat(et_sys_id id, int *heartbeat)
Definition: et_remote.c:1537

etr_station_getrestore
int etr_station_getrestore(et_sys_id id, et_stat_id stat_id, int *restore)
Definition: et_remote.c:1304

etr_system_getprocsmax
int etr_system_getprocsmax(et_sys_id id, int *procsmax)
Definition: et_remote.c:1507

et_sys_config
struct et_sys_config_t et_sys_config
Structure containing all info necessary to configure an ET system.

etn_open
int etn_open(et_sys_id *id, const char *filename, et_openconfig openconfig)

et_init_event_
void et_init_event_(et_event *pe)

et_llist_unlock
void et_llist_unlock(et_list *pl)

et_init_event
void et_init_event(et_event *pe)

etr_station_setcue
int etr_station_setcue(et_sys_id id, et_stat_id stat_id, int cue)
Definition: et_remote.c:1410

etr_events_dump
int etr_events_dump(et_sys_id id, et_att_id att, et_event *evs[], int num)
Definition: et_remote.c:3148

et_station_lock
void et_station_lock(et_system *sys)

et_station_dump
int et_station_dump(et_id *id, et_event *pe)

et_repair_station
int et_repair_station(et_id *id, et_stat_id stat_id)

et_temp_remove
int et_temp_remove(const char *name, void *pmem, size_t size)

etr_events_new
int etr_events_new(et_sys_id id, et_att_id att, et_event *evs[], int mode, struct timespec *deltatime, size_t size, int num, int *nread)
Definition: et_remote.c:1895

etr_wait_for_alive
int etr_wait_for_alive(et_sys_id id)
Definition: et_remote.c:502

et_memRead_lock
void et_memRead_lock(et_id *id)

et_init_station
void et_init_station(et_station *ps)

et_station_nread
int et_station_nread(et_id *id, et_stat_id stat_id, et_event *pe[], int mode, et_att_id att, struct timespec *time, int num, int *nread)

et_system_unlock
void et_system_unlock(et_system *sys)

et_mem_unmap
int et_mem_unmap(const char *name, void *pmem)

etl_open
int etl_open(et_sys_id *id, const char *filename, et_openconfig openconfig)

etr_station_setrestore
int etr_station_setrestore(et_sys_id id, et_stat_id stat_id, int restore)
Definition: et_remote.c:1394

et_list
struct et_list_t et_list
Structure defining a station's input or output list of events.

etr_wakeup_attachment
int etr_wakeup_attachment(et_sys_id id, et_att_id att)
Definition: et_remote.c:530

etr_close
int etr_close(et_sys_id id)
Definition: et_remote.c:390

et_stat_data
struct et_stat_data_t et_stat_data
Structure to hold the current state of a station.

etr_station_create_at
int etr_station_create_at(et_sys_id id, et_stat_id *stat_id, const char *stat_name, et_statconfig sconfig, int position, int parallelposition)
Definition: et_remote.c:576

etr_station_getclass
int etr_station_getclass(et_sys_id id, et_stat_id stat_id, char *classs)
Definition: et_remote.c:1109

etn_kill
int etn_kill(et_sys_id id)

et_init_stats_station
void et_init_stats_station(et_station *ps)

et_station_config_check
int et_station_config_check(et_id *id, et_stat_config *sc)
This routine checks a station's configuration settings for internal inconsistencies or bad values.
Definition: et_statconfig.c:763

et_mutex_locked
int et_mutex_locked(pthread_mutex_t *pmutex)

et_mem
struct et_mem_t et_mem
Structure containing info stored at front of shared or mapped memory.

etn_forcedclose
int etn_forcedclose(et_sys_id id)

et_stat_config
struct et_stat_config_t et_stat_config
Structure to hold parameters used to configure a station.

et_cast_thread
void * et_cast_thread(void *arg)

etn_event_new
int etn_event_new(et_sys_id id, et_att_id att, et_event **ev, int mode, struct timespec *deltatime, size_t size)

et_mem_write_first_block
void et_mem_write_first_block(char *ptr, uint32_t headerByteSize, uint64_t eventByteSize, uint64_t headerPosition, uint64_t dataPosition, uint64_t totalByteSize, uint64_t usedByteSize)

et_station_write
int et_station_write(et_id *id, et_stat_id stat_id, et_event *pe)

et_init_process
void et_init_process(et_system *sys, et_proc_id id)

etr_system_getattsmax
int etr_system_getattsmax(et_sys_id id, int *attsmax)
Definition: et_remote.c:1527

etr_station_setselectwords
int etr_station_setselectwords(et_sys_id id, et_stat_id stat_id, int select[])
Definition: et_remote.c:987

ET_PROCESSES_MAX
#define ET_PROCESSES_MAX
Maximum number of local processes allowed to open the system.
Definition: et_private.h:109

etn_events_new_group
int etn_events_new_group(et_sys_id id, et_att_id att, et_event *evs[], int mode, struct timespec *deltatime, size_t size, int num, int group, int *nread)

et_init_stats_allatts
void et_init_stats_allatts(et_system *sys)

et_init_histogram
void et_init_histogram(et_id *id)

etn_events_get
int etn_events_get(et_sys_id id, et_att_id att, et_event *evs[], int mode, struct timespec *deltatime, int num, int *nread)

et_init_stats_allstations
void et_init_stats_allstations(et_id *id)

etr_station_getprescale
int etr_station_getprescale(et_sys_id id, et_stat_id stat_id, int *prescale)
Definition: et_remote.c:1334

et_sharedmutex
int et_sharedmutex(void)

etr_event_get
int etr_event_get(et_sys_id id, et_att_id att, et_event **ev, int wait, struct timespec *deltatime)
Definition: et_remote.c:2397

et_llist_write
int et_llist_write(et_id *id, et_list *pl, et_event **pe, int num)

etr_attach_geteventsdump
int etr_attach_geteventsdump(et_sys_id id, et_att_id att_id, uint64_t *events)
Definition: et_remote.c:1632

etr_station_setposition
int etr_station_setposition(et_sys_id id, et_stat_id stat_id, int position, int parallelposition)
Definition: et_remote.c:818

etr_station_attach
int etr_station_attach(et_sys_id id, et_stat_id stat_id, et_att_id *att)
Definition: et_remote.c:703

et_llist_read
int et_llist_read(et_list *pl, et_event **pe)

etr_system_getpid
int etr_system_getpid(et_sys_id id, int *pid)
Definition: et_remote.c:1547

etn_wait_for_alive
int etn_wait_for_alive(et_sys_id id)

etl_alive
int etl_alive(et_sys_id id)

etr_attach_geteventsget
int etr_attach_geteventsget(et_sys_id id, et_att_id att_id, uint64_t *events)
Definition: et_remote.c:1620

etr_station_getblock
int etr_station_getblock(et_sys_id id, et_stat_id stat_id, int *block)
Definition: et_remote.c:1284

et_init_stats_all
void et_init_stats_all(et_id *id)

etl_forcedclose
int etl_forcedclose(et_sys_id id)

et_tcp_lock
void et_tcp_lock(et_id *id)

et_mem_attach
int et_mem_attach(const char *name, void **pmemory, et_mem *pInfo)

et_findlocality
int et_findlocality(const char *filename, et_openconfig openconfig)
This routine determines whether we are looking for the ET system locally, locally on some non-pthread...
Definition: et_common.c:63

etn_event_get
int etn_event_get(et_sys_id id, et_att_id att, et_event **ev, int mode, struct timespec *deltatime)

et_mem_unlock
void et_mem_unlock(et_id *id)

etr_wakeup_all
int etr_wakeup_all(et_sys_id id, et_stat_id stat_id)
Definition: et_remote.c:552

et_repair_gc
int et_repair_gc(et_id *id)

et_transfer_unlock
void et_transfer_unlock(et_station *ps)

et_id
struct et_id_t et_id
Structure defining an ET system user id (one needed for each system in use) which contains pointers t...

et_findserver
int et_findserver(const char *etname, char *ethost, int *port, uint32_t *inetaddr, et_open_config *config, et_response **allETinfo, int debug)

etr_attach_geteventsmake
int etr_attach_geteventsmake(et_sys_id id, et_att_id att_id, uint64_t *events)
Definition: et_remote.c:1644

etr_events_get
int etr_events_get(et_sys_id id, et_att_id att, et_event *evs[], int wait, struct timespec *deltatime, int num, int *nread)
Definition: et_remote.c:2593

et_logmsg
void et_logmsg(char *sev, char *fmt,...)
Definition: et_common.c:35

etr_station_getlib
int etr_station_getlib(et_sys_id id, et_stat_id stat_id, char *lib)
Definition: et_remote.c:1062

etr_attach_geteventsput
int etr_attach_geteventsput(et_sys_id id, et_att_id att_id, uint64_t *events)
Definition: et_remote.c:1608

etr_station_getattachments
int etr_station_getattachments(et_sys_id id, et_stat_id stat_id, int *numatts)
Definition: et_remote.c:1244

etr_alive
int etr_alive(et_sys_id id)
Definition: et_remote.c:463

etl_kill
int etl_kill(et_sys_id id)

etr_station_remove
int etr_station_remove(et_sys_id id, et_stat_id stat_id)
Definition: et_remote.c:671

et_memWrite_lock
void et_memWrite_lock(et_id *id)

et_station_nread_group
int et_station_nread_group(et_id *id, et_stat_id stat_id, et_event *pe[], int mode, et_att_id att, struct timespec *time, int num, int group, int *nread)

et_station_ndump
int et_station_ndump(et_id *id, et_event *pe[], int num)

et_init_stats_att
void et_init_stats_att(et_system *sys, et_att_id id)

etr_station_setuser
int etr_station_setuser(et_sys_id id, et_stat_id stat_id, int user)
Definition: et_remote.c:1386

ET_SELECT_FUNCPTR
int(* ET_SELECT_FUNCPTR)(void *, et_stat_id, et_event *)
Defines event selection function.
Definition: et_private.h:172

et_mem_remove
int et_mem_remove(const char *name, void *pmem)

etr_station_getselectwords
int etr_station_getselectwords(et_sys_id id, et_stat_id stat_id, int select[])
Definition: et_remote.c:1022

et_wait_for_system
int et_wait_for_system(et_sys_id id, struct timespec *timeout, const char *etname)

etr_station_getuser
int etr_station_getuser(et_sys_id id, et_stat_id stat_id, int *user)
Definition: et_remote.c:1294

etn_events_put
int etn_events_put(et_sys_id id, et_att_id att, et_event *evs[], int num)

etn_events_dump
int etn_events_dump(et_sys_id id, et_att_id att, et_event *evs[], int num)

et_unlook
int et_unlook(et_sys_id id)

et_init_llist
void et_init_llist(et_list *pl)

etr_events_put
int etr_events_put(et_sys_id id, et_att_id att, et_event *evs[], int num)
Definition: et_remote.c:2938

etr_event_dump
int etr_event_dump(et_sys_id id, et_att_id att, et_event *ev)
Definition: et_remote.c:3104

etr_event_put
int etr_event_put(et_sys_id id, et_att_id att, et_event *ev)
Definition: et_remote.c:2848

et_id_init
int et_id_init(et_sys_id *id)

et_transfer_lock_all
void et_transfer_lock_all(et_id *id)

et_tcp_unlock
void et_tcp_unlock(et_id *id)

et_open_config
struct et_open_config_t et_open_config
Structure holding all configuration parameters used to open an ET system.

et_station
struct et_station_t et_station
Structure defining a station.

etn_close
int etn_close(et_sys_id id)

etr_station_isattached
int etr_station_isattached(et_sys_id id, et_stat_id stat_id, et_att_id att)
Definition: et_remote.c:899

etr_station_create
int etr_station_create(et_sys_id id, et_stat_id *stat_id, const char *stat_name, et_statconfig sconfig)
Definition: et_remote.c:664

etr_system_getstations
int etr_system_getstations(et_sys_id id, int *stations)
Definition: et_remote.c:1477

et_transfer_lock
void et_transfer_lock(et_station *ps)

etr_station_getcue
int etr_station_getcue(et_sys_id id, et_stat_id stat_id, int *cue)
Definition: et_remote.c:1324

et_bridge_config
struct et_bridge_config_t et_bridge_config
Structure to define configuration parameters used to bridge ET systems (transfer events between 2 sys...

etl_close
int etl_close(et_sys_id id)

etn_alive
int etn_alive(et_sys_id id)

et_transfer_unlock_all
void et_transfer_unlock_all(et_id *id)

etr_event_new
int etr_event_new(et_sys_id id, et_att_id att, et_event **ev, int mode, struct timespec *deltatime, size_t size)
Definition: et_remote.c:1706

etr_station_setblock
int etr_station_setblock(et_sys_id id, et_stat_id stat_id, int block)
Definition: et_remote.c:1378

et_attach
Structure containing attachment info.
Definition: et_private.h:326

et_attach::events_get
uint64_t events_get
Number of events obtained from station input list.
Definition: et_private.h:339

et_attach::interface
char interface[ET_IPADDRSTRLEN]
Dot-decimal IP address of outgoing network interface.
Definition: et_private.h:344

et_attach::quit
int quit
ET_ATT_QUIT to force return from ET API routine, else ET_ATT_CONTINUE if everything OK.
Definition: et_private.h:332

et_attach::events_put
uint64_t events_put
Number of events put into station output list.
Definition: et_private.h:338

et_attach::stat
et_stat_id stat
Unique index # of station we're attached to.
Definition: et_private.h:329

et_attach::host
char host[ET_MAXHOSTNAMELEN]
Host running process that owns attachment.
Definition: et_private.h:343

et_attach::proc
et_proc_id proc
Unique index # of process owning this attachment.
Definition: et_private.h:328

et_attach::num
et_att_id num
Unique index # of this attachment.
Definition: et_private.h:327

et_attach::status
int status
ET_ATT_UNUSED is attachment unused or ET_ATT_ACTIVE if active.
Definition: et_private.h:330

et_attach::events_make
uint64_t events_make
Number of new events requested.
Definition: et_private.h:341

et_attach::sleep
int sleep
ET_ATT_SLEEP if attachment is remote and sleeping when getting events (sleep is simulated by multiple...
Definition: et_private.h:334

et_attach::events_dump
uint64_t events_dump
Number of events dumped back into GrandCentral's input list (recycles).
Definition: et_private.h:340

et_attach::blocked
int blocked
ET_ATT_BLOCKED if blocked waiting to read events, else ET_ATT_UNBLOCKED.
Definition: et_private.h:331

et_attach::pid
pid_t pid
Unix process id# of process that owns attachment.
Definition: et_private.h:342

et_bridge_config_t
Structure to define configuration parameters used to bridge ET systems (transfer events between 2 sys...
Definition: et_private.h:687

et_bridge_config_t::chunk_to
int chunk_to
Number of new events to get from the "to" ET system at one time.
Definition: et_private.h:694

et_bridge_config_t::timeout_from
struct timespec timeout_from
Max time to wait when getting events from the "from" ET system.
Definition: et_private.h:695

et_bridge_config_t::init
int init
ET_STRUCT_OK if structure initialized, else ET_STRUCT_NEW.
Definition: et_private.h:688

et_bridge_config_t::mode_to
int mode_to
ET_SLEEP, ET_TIMED, or ET_ASYNC for getting events from the "to" ET system into which the "from" even...
Definition: et_private.h:691

et_bridge_config_t::chunk_from
int chunk_from
Number of events to get from the "from" ET system at one time.
Definition: et_private.h:693

et_bridge_config_t::mode_from
int mode_from
ET_SLEEP, ET_TIMED, or ET_ASYNC for getting events from the "from" ET system.
Definition: et_private.h:689

et_bridge_config_t::func
ET_SWAP_FUNCPTR func
Pointer to function which takes a pointer to an event as an argument, swaps the data,...
Definition: et_private.h:697

et_bridge_config_t::timeout_to
struct timespec timeout_to
Max time to wait when getting new events from the "to" ET system.
Definition: et_private.h:696

et_event_t
This structure defines an Event which exists in shared memory, holds data, and gets passed from stati...
Definition: et.h:294

et_fix
Struct to fix station's input and output linked lists after crash.
Definition: et_private.h:268

et_fix::out
struct et_fixout out
Structure to fix station output list.
Definition: et_private.h:270

et_fix::in
struct et_fixin in
Structure to fix station input list.
Definition: et_private.h:269

et_fixin
Structure for fixing station input list.
Definition: et_private.h:248

et_fixin::eventsin
uint64_t eventsin
Value of et_list->events_in at start of dump.
Definition: et_private.h:250

et_fixin::num
int num
Number of events intended to read/write.
Definition: et_private.h:253

et_fixin::call
int call
ET_FIX_DUMP if fixing after et_station_(n)dump call, or ET_FIX_READ if fixing after et_station_(n)rea...
Definition: et_private.h:254

et_fixin::start
int start
Is 1 at start of write and 0 at end.
Definition: et_private.h:251

et_fixin::first
et_event * first
Value of et_list->firstevent at start of read (NULL if no damage).
Definition: et_private.h:249

et_fixin::cnt
int cnt
Value of et_list->cnt at start of read/write.
Definition: et_private.h:252

et_fixout
Structure for fixing station output list.
Definition: et_private.h:260

et_fixout::num
int num
Number of events intended to read/write.
Definition: et_private.h:263

et_fixout::cnt
int cnt
Value of et_list->cnt at start of read/write.
Definition: et_private.h:262

et_fixout::start
int start
Is 1 at start of write and 0 at end.
Definition: et_private.h:261

et_id_t
Structure defining an ET system user id (one needed for each system in use) which contains pointers t...
Definition: et_private.h:480

et_id_t::closed
int closed
Has et_close been called? 1 = yes, 0 = no.
Definition: et_private.h:485

et_id_t::port
int port
Port number for ET TCP server.
Definition: et_private.h:523

et_id_t::locality
int locality
ET_LOCAL if process is on same machine as ET system, ET_REMOTE if process is on another machine,...
Definition: et_private.h:515

et_id_t::stats
et_station * stats
Pointer to start of et_station structures in shared memory.
Definition: et_private.h:530

et_id_t::init
int init
ET_STRUCT_OK if structure initialized, else ET_STRUCT_NEW.
Definition: et_private.h:481

et_id_t::offset
ptrdiff_t offset
Offset between pointers to same shared memory for ET & user's processes (needed for user process to m...
Definition: et_private.h:511

et_id_t::bit64
int bit64
1 if the ET system is a 64 bit executable, else 0.
Definition: et_private.h:486

et_id_t::proc
et_proc_id proc
Unique process id# for process connected to ET system (index into data stored in the et_system struct...
Definition: et_private.h:487

et_id_t::esize
uint64_t esize
Size in bytes of events in ET system.
Definition: et_private.h:510

et_id_t::alive
int alive
Is system alive? 1 = yes, 0 = no.
Definition: et_private.h:484

et_id_t::version
int version
Major version number of this ET software release.
Definition: et_private.h:503

et_id_t::grandcentral
et_station * grandcentral
Pointer to grandcentral station in shared memory.
Definition: et_private.h:534

et_id_t::nselects
int nselects
Number of selection ints per station (or control ints per event).
Definition: et_private.h:504

et_id_t::mutex
pthread_mutex_t mutex
Pthread mutex for thread-safe remote communications.
Definition: et_private.h:535

et_id_t::iov_max
int iov_max
Store the operating system's value iovmax of client's node, default to ET_IOV_MAX (how many separate ...
Definition: et_private.h:521

et_id_t::group
int group
Default event group for calls to et_event_new and et_events_new.
Definition: et_private.h:502

et_id_t::pmap
void * pmap
Pointer to start of shared (mapped) memory.
Definition: et_private.h:528

et_id_t::memsize
size_t memsize
Total size of shared memory in bytes - used to unmap the mmapped file when it's already been deleted.
Definition: et_private.h:508

et_id_t::localAddr
char localAddr[ET_IPADDRSTRLEN]
Local dot-decimal address of socket connection to ET.
Definition: et_private.h:525

et_id_t::sharedMemlock
pthread_rwlock_t sharedMemlock
Pthread read-write lock for preventing access of unmapped memory after calling et_close.
Definition: et_private.h:537

et_id_t::nevents
int nevents
Total number of events in ET system.
Definition: et_private.h:501

et_id_t::sys
et_system * sys
Pointer to et_system structure in shared memory.
Definition: et_private.h:529

et_id_t::endian
int endian
Endianness of client's node ET_ENDIAN_BIG or ET_ENDIAN_LITTLE.
Definition: et_private.h:519

et_id_t::debug
int debug
Level of desired printed debug output which may be ET_DEBUG_NONE, ET_DEBUG_SEVERE,...
Definition: et_private.h:498

et_id_t::cleanup
int cleanup
Flag used to warn certain routines (such as et_station_detach and et_restore_events) that they are be...
Definition: et_private.h:492

et_id_t::race
int race
Flag used to eliminate race conditions.
Definition: et_private.h:491

et_id_t::data
char * data
Pointer to start of event data in shared memory.
Definition: et_private.h:533

et_id_t::histogram
int * histogram
Pointer to histogram data in shared memory.
Definition: et_private.h:531

et_id_t::lang
int lang
Language this ET system was written in: ET_LANG_C, ET_LANG_CPP, or ET_LANG_JAVA.
Definition: et_private.h:482

et_id_t::sockfd
int sockfd
File descriptor of client's TCP socket connection to ET server.
Definition: et_private.h:518

et_id_t::share
int share
ET_MUTEX_SHARE if operating system can share mutexes between local processes, or ET_MUTEX_NOSHARE for...
Definition: et_private.h:505

et_id_t::events
et_event * events
Pointer to start of et_event structures in shared memory.
Definition: et_private.h:532

et_id_t::ethost
char ethost[ET_MAXHOSTNAMELEN]
Host of the ET system.
Definition: et_private.h:524

et_id_t::systemendian
int systemendian
Endianness of ET system's node ET_ENDIAN_BIG or ET_ENDIAN_LITTLE.
Definition: et_private.h:520

et_list_t
Structure defining a station's input or output list of events.
Definition: et_private.h:231

et_list_t::events_in
uint64_t events_in
Number of events actually put in.
Definition: et_private.h:235

et_list_t::lasthigh
int lasthigh
Place in list of last high priority event.
Definition: et_private.h:233

et_list_t::lastevent
et_event * lastevent
pointer to last event in linked list.
Definition: et_private.h:238

et_list_t::firstevent
et_event * firstevent
Pointer to first event in linked list.
Definition: et_private.h:237

et_list_t::cread
pthread_cond_t cread
Pthread condition variable to notify reader that events are here.
Definition: et_private.h:240

et_list_t::mutex
pthread_mutex_t mutex
Pthread mutex which protects linked list when reading & writing.
Definition: et_private.h:239

et_list_t::events_out
uint64_t events_out
Number of events actually taken out.
Definition: et_private.h:236

et_list_t::cnt
int cnt
Number of events in list.
Definition: et_private.h:232

et_list_t::events_try
uint64_t events_try
Number of events attempted to be put in (before prescale).
Definition: et_private.h:234

et_mem_t
Structure containing info stored at front of shared or mapped memory.
Definition: et_private.h:544

et_mem_t::usedSize
uint64_t usedSize
Desired size of shared memory given as arg to et_mem_create .
Definition: et_private.h:558

et_mem_t::totalSize
uint64_t totalSize
Total size of shared (mapped) memory (must be allocated in pages).
Definition: et_private.h:557

et_mem_t::byteOrder
uint32_t byteOrder
Should be 0x01020304, if not, byte order is reversed from local order.
Definition: et_private.h:545

et_mem_t::minorVersion
uint32_t minorVersion
Minor version number of this ET software release.
Definition: et_private.h:550

et_mem_t::numSelectInts
uint32_t numSelectInts
Number of station selection integers per event.
Definition: et_private.h:551

et_mem_t::headerPosition
uint64_t headerPosition
Number of bytes past beginning of shared memory that the headers are stored.
Definition: et_private.h:555

et_mem_t::systemType
uint32_t systemType
Type of local system using the shared memory: ET_SYSTEM_TYPE_C is an ET system written in C,...
Definition: et_private.h:546

et_mem_t::majorVersion
uint32_t majorVersion
Major version number of this ET software release.
Definition: et_private.h:549

et_mem_t::headerByteSize
uint32_t headerByteSize
Total size of a single event's "header" or metadata structure in bytes.
Definition: et_private.h:552

et_mem_t::eventByteSize
uint64_t eventByteSize
Total size of a single event's data memory in bytes.
Definition: et_private.h:554

et_mem_t::dataPosition
uint64_t dataPosition
Number of bytes past beginning of shared memory that the data are stored.
Definition: et_private.h:556

et_netthread_t
Struct for passing data from system to network threads.
Definition: et_private.h:670

et_netthread_t::uname
char uname[ET_MAXHOSTNAMELEN]
host obtained with "uname" cmd
Definition: et_private.h:675

et_netthread_t::id
et_id * id
system id
Definition: et_private.h:672

et_netthread_t::config
et_sys_config * config
system configuration
Definition: et_private.h:673

et_netthread_t::listenaddr
char * listenaddr
broadcast or multicast address (dot-decimal)
Definition: et_private.h:674

et_netthread_t::cast
int cast
broad or multicast
Definition: et_private.h:671

et_open_config_t
Structure holding all configuration parameters used to open an ET system.
Definition: et_private.h:435

et_open_config_t::policy
int policy
Policy to determine which responding ET system to a broad/ulticast will be chosen as the official res...
Definition: et_private.h:455

et_open_config_t::bcastaddrs
codaIpList * bcastaddrs
Linked list of all local subnet broadcast addresses (dot-decimal).
Definition: et_private.h:471

et_open_config_t::udpport
int udpport
Port number for broadcast, multicast & direct UDP communication.
Definition: et_private.h:453

et_open_config_t::tcpRecvBufSize
int tcpRecvBufSize
TCP receive buffer size in bytes of socket connecting to ET TCP server.
Definition: et_private.h:461

et_open_config_t::netinfo
codaIpAddr * netinfo
Linked list of structs containing all network info.
Definition: et_private.h:470

et_open_config_t::interface
char interface[ET_IPADDRSTRLEN]
Dot-decimal IP address specifying the network interface.
Definition: et_private.h:469

et_open_config_t::debug_default
int debug_default
Default debug output level which may be ET_DEBUG_NONE, ET_DEBUG_SEVERE, ET_DEBUG_ERROR,...
Definition: et_private.h:450

et_open_config_t::tcpSendBufSize
int tcpSendBufSize
TCP send buffer size in bytes of socket connecting to ET TCP server.
Definition: et_private.h:460

et_open_config_t::wait
int wait
ET_OPEN_WAIT if user wants to wait for ET system to appear, else ET_OPEN_NOWAIT.
Definition: et_private.h:437

et_open_config_t::cast
int cast
ET_BROADCAST for users to discover host & port # of ET system server by broadcasting,...
Definition: et_private.h:439

et_open_config_t::mode
int mode
ET_HOST_AS_REMOTE if connection to a local ET system is made as if the client were remote,...
Definition: et_private.h:447

et_open_config_t::timeout
struct timespec timeout
Max time to wait for ET system to appear if wait = ET_OPEN_WAIT.
Definition: et_private.h:463

et_open_config_t::serverport
int serverport
Port number for ET system's TCP server thread.
Definition: et_private.h:454

et_open_config_t::mcastaddrs
codaDotDecIpAddrs mcastaddrs
All multicast addresses (dot-decimal).
Definition: et_private.h:472

et_open_config_t::init
int init
ET_STRUCT_OK if structure initialized, else ET_STRUCT_NEW.
Definition: et_private.h:436

et_open_config_t::ttl
int ttl
Multicast ttl value (number of router hops permitted).
Definition: et_private.h:446

et_open_config_t::tcpNoDelay
int tcpNoDelay
If 0, sockets to system have TCP_NODELAY option off, else on.
Definition: et_private.h:462

et_open_config_t::host
char host[ET_MAXHOSTNAMELEN]
Host of ET system which defaults to local host if unset and may be ET_HOST_ANYWHERE for an ET system ...
Definition: et_private.h:464

et_proc
Structure containing local process info.
Definition: et_private.h:307

et_proc::et_status
int et_status
ET_PROC_ETDEAD if ET system is dead, or ET_PROC_ETOK if ET system is OK.
Definition: et_private.h:316

et_proc::num
et_proc_id num
Unique index # of this process.
Definition: et_private.h:308

et_proc::status
int status
ET_PROC_OPEN if open or connected to ET system, or ET_PROC_CLOSED if closed/unconnected.
Definition: et_private.h:314

et_proc::pid
pid_t pid
Unix process id.
Definition: et_private.h:319

et_proc::hmon_thd_id
pthread_t hmon_thd_id
Heart monitor pthread id.
Definition: et_private.h:321

et_proc::time
uint64_t time
Time ET system opened, used to prevent race conditions caused by rapid open and close cycles.
Definition: et_private.h:311

et_proc::hbeat_thd_id
pthread_t hbeat_thd_id
Heartbeat pthread id .
Definition: et_private.h:320

et_proc::heartbeat
unsigned int heartbeat
Heartbeat periodically incremented to tell ET system it's alive.
Definition: et_private.h:318

et_proc::att
et_att_id att[ET_ATTACHMENTS_MAX]
Array in which an element (indexed by the id# of an attachment owned by this process) gives the id# o...
Definition: et_private.h:309

et_proc::nattachments
int nattachments
Number of attachments to an ET system in this process.
Definition: et_private.h:313

et_response_t
Structure for holding an ET system's single response to ET client's broad/multicast.
Definition: et_private.h:563

et_response_t::ipaddrs
char ** ipaddrs
Array of all IP addresses (dot-decimal string) of host.
Definition: et_private.h:571

et_response_t::addrs
uint32_t * addrs
Array of 32bit net byte ordered addresses (1 for each addr).
Definition: et_private.h:570

et_response_t::addrCount
int addrCount
Number of addresses.
Definition: et_private.h:566

et_response_t::castIP
char castIP[ET_IPADDRSTRLEN]
Original broad/multicast IP addr.
Definition: et_private.h:569

et_response_t::port
int port
ET system's TCP server port.
Definition: et_private.h:564

et_response_t::next
struct et_response_t * next
Next response in linked list.
Definition: et_private.h:573

et_response_t::uname
char uname[ET_MAXHOSTNAMELEN]
Uname of sending host.
Definition: et_private.h:567

et_response_t::castType
int castType
ET_BROADCAST or ET_MULTICAST (what this is a response to).
Definition: et_private.h:565

et_response_t::bcastaddrs
char ** bcastaddrs
Array of all broadcast addresses (dot-decimal string) of host.
Definition: et_private.h:572

et_response_t::canon
char canon[ET_MAXHOSTNAMELEN]
Canonical name of sending host.
Definition: et_private.h:568

et_stat_config_t
Structure to hold parameters used to configure a station.
Definition: et_private.h:176

et_stat_config_t::restore_mode
int restore_mode
if process dies, events it read but didn't write can be sent to: 1) station's ouput with ET_STATION_R...
Definition: et_private.h:184

et_stat_config_t::fname
char fname[ET_FUNCNAME_LENGTH]
Name of user-defined event selection routine (for C-based ET system).
Definition: et_private.h:206

et_stat_config_t::classs
char classs[ET_FILENAME_LENGTH]
Name of JAVA class containing method to implement event selection (for Java-based ET system).
Definition: et_private.h:209

et_stat_config_t::init
int init
ET_STRUCT_OK if structure properly initialized, else ET_STRUCT_NEW.
Definition: et_private.h:177

et_stat_config_t::user_mode
int user_mode
Number of attachment allowed, ET_STATION_USER_MULTI for any number, or ET_STATION_USER_SINGLE for onl...
Definition: et_private.h:182

et_stat_config_t::flow_mode
int flow_mode
ET_STATION_PARALLEL if station part of a group of stations through which events flow in parallel,...
Definition: et_private.h:179

et_stat_config_t::cue
int cue
For nonblocking stations only, max number of events accepted into input list.
Definition: et_private.h:195

et_stat_config_t::select
int select[ET_STATION_SELECT_INTS]
Array of ints for use in event selection.
Definition: et_private.h:205

et_stat_config_t::block_mode
int block_mode
ET_STATION_BLOCKING for accepting every event which meets its condition, or ET_STATION_NONBLOCKING fo...
Definition: et_private.h:190

et_stat_config_t::lib
char lib[ET_FILENAME_LENGTH]
Name of shared library containing user-defined event selection routine (for C-based ET system).
Definition: et_private.h:207

et_stat_config_t::prescale
int prescale
For blocking stations only, accept only every Nth normally accepted event.
Definition: et_private.h:193

et_stat_config_t::select_mode
int select_mode
ET_STATION_SELECT_ALL for accepting every event, ET_STATION_SELECT_MATCH for accepting events whose c...
Definition: et_private.h:196

et_stat_data_t
Structure to hold the current state of a station.
Definition: et_private.h:215

et_stat_data_t::lib_handle
void * lib_handle
Handle for the opened shared library of a user-defined event selection routine.
Definition: et_private.h:225

et_stat_data_t::pid_create
int pid_create
Process id of process that created the station.
Definition: et_private.h:221

et_stat_data_t::nattachments
int nattachments
Number of attachments to this station.
Definition: et_private.h:222

et_stat_data_t::status
int status
Station's state may be ET_STATION_ACTIVE for a station accepting events, ET_STATION_IDLE for a statio...
Definition: et_private.h:216

et_stat_data_t::func
ET_SELECT_FUNCPTR func
Pointer to user-defined event selection routine.
Definition: et_private.h:226

et_stat_data_t::att
int att[ET_ATTACHMENTS_MAX]
Array in which the unique id# of an attachment is the index and the value is id# if attached and -1 o...
Definition: et_private.h:223

et_station_t
Structure defining a station.
Definition: et_private.h:275

et_station_t::waslast
int waslast
Flag = 1 if this station was last one to receive an event when using the round-robin selection method...
Definition: et_private.h:292

et_station_t::config
et_stat_config config
Station configuration.
Definition: et_private.h:300

et_station_t::data
et_stat_data data
Current state of station.
Definition: et_private.h:299

et_station_t::conductor
int conductor
Flag to kill conductor thread: when station deleted ET_THREAD_KILL else ET_THREAD_KEEP.
Definition: et_private.h:278

et_station_t::num
et_stat_id num
Unique id # of station, 0 for first station (GrandCentral), = 1 for next station in mapped memory,...
Definition: et_private.h:276

et_station_t::list_out
et_list list_out
Output list - a linked list containing events to be written.
Definition: et_private.h:302

et_station_t::mutex
pthread_mutex_t mutex
Pthread mutex used for keeping the linked list of used stations in order for event transfers.
Definition: et_private.h:296

et_station_t::fix
struct et_fix fix
Info to repair station's lists after user crash.
Definition: et_private.h:298

et_station_t::nextparallel
et_stat_id nextparallel
If this station is in a group of parallel stations, this is a "pointer" (actually and index) to the n...
Definition: et_private.h:286

et_station_t::list_in
et_list list_in
Input list - a linked list containing events to read.
Definition: et_private.h:301

et_station_t::prevparallel
et_stat_id prevparallel
If this station is in a group of parallel stations, this is a "pointer" (actually an index) to the pr...
Definition: et_private.h:289

et_station_t::name
char name[ET_STATNAME_LENGTH]
Unique station name.
Definition: et_private.h:295

et_station_t::next
et_stat_id next
Integer specifying next active or idle station in station chain, (not storing this as a pointer makes...
Definition: et_private.h:280

et_station_t::prev
et_stat_id prev
Previous active or idle station in station chain and for first station this is -1.
Definition: et_private.h:284

et_sys_config_t
Structure containing all info necessary to configure an ET system.
Definition: et_private.h:349

et_sys_config_t::nprocesses
int nprocesses
Max number of local processes allowed to open ET system.
Definition: et_private.h:355

et_sys_config_t::event_size
uint64_t event_size
Event size in bytes.
Definition: et_private.h:350

et_sys_config_t::ntemps
int ntemps
Max number of temporary events allowed (<= nevents).
Definition: et_private.h:353

et_sys_config_t::groupCount
int groupCount
Number of event groups.
Definition: et_private.h:357

et_sys_config_t::mcastaddrs
codaDotDecIpAddrs mcastaddrs
All multicast addresses to listen on (dot-decimal).
Definition: et_private.h:371

et_sys_config_t::nevents
int nevents
Total # of events.
Definition: et_private.h:352

et_sys_config_t::bcastaddrs
codaDotDecIpAddrs bcastaddrs
All local subnet broadcast addresses (dot-decimal).
Definition: et_private.h:370

et_sys_config_t::nattachments
int nattachments
Max number of attachments to stations allowed.
Definition: et_private.h:356

et_sys_config_t::port
int port
Broad/multicast port # for UDP communication.
Definition: et_private.h:364

et_sys_config_t::tcpSendBufSize
int tcpSendBufSize
TCP send buffer size in bytes of socket connecting to ET client.
Definition: et_private.h:366

et_sys_config_t::groups
int groups[ET_EVENT_GROUPS_MAX]
Array in which index is the group number (-1) and value is the number of events in that group (there ...
Definition: et_private.h:358

et_sys_config_t::init
int init
ET_STRUCT_OK if structure initialized, else ET_STRUCT_NEW.
Definition: et_private.h:351

et_sys_config_t::nstations
int nstations
Max number of stations allowed (including GrandCentral).
Definition: et_private.h:354

et_sys_config_t::tcpNoDelay
int tcpNoDelay
If 0, sockets to clients have TCP_NODELAY option off, else on.
Definition: et_private.h:368

et_sys_config_t::tcpRecvBufSize
int tcpRecvBufSize
TCP receive buffer size in bytes of socket connecting to ET client.
Definition: et_private.h:367

et_sys_config_t::serverport
int serverport
Port # for ET system TCP server thread.
Definition: et_private.h:365

et_sys_config_t::netinfo
codaNetInfo netinfo
All local network info.
Definition: et_private.h:369

et_sys_config_t::filename
char filename[ET_FILENAME_LENGTH]
Name of the ET system file.
Definition: et_private.h:361

et_system_t
Structure containing all ET system information.
Definition: et_private.h:391

et_system_t::tid_srv
pthread_t tid_srv
ET TCP server thread id.
Definition: et_private.h:425

et_system_t::tid_hb
pthread_t tid_hb
System heartbeat thread id.
Definition: et_private.h:422

et_system_t::stat_mutex
pthread_mutex_t stat_mutex
Pthread mutex to protect station data during changes.
Definition: et_private.h:418

et_system_t::tid_mul
pthread_t tid_mul
Id of thread spawning broad/multicast listening threads.
Definition: et_private.h:426

et_system_t::statadd_mutex
pthread_mutex_t statadd_mutex
Pthread mutex used to add stations one at a time.
Definition: et_private.h:419

et_system_t::ntemps
int ntemps
Current number of temp events.
Definition: et_private.h:400

et_system_t::tid_hm
pthread_t tid_hm
System heartmonitor thread id.
Definition: et_private.h:423

et_system_t::udpFd
int udpFd
UDP server's listening socket file descriptor.
Definition: et_private.h:405

et_system_t::heartbeat
unsigned int heartbeat
Heartbeat which periodically increments to indicate ET is alive.
Definition: et_private.h:397

et_system_t::pmap
void * pmap
Pointer to mapped mem in ET system's process (used for user-called routines to read/write pointers co...
Definition: et_private.h:415

et_system_t::tid_as
pthread_t tid_as
System add station thread id.
Definition: et_private.h:424

et_system_t::nprocesses
int nprocesses
Current number of local processes which have opened system.
Definition: et_private.h:401

et_system_t::host
char host[ET_MAXHOSTNAMELEN]
Host of the ET system.
Definition: et_private.h:427

et_system_t::nstations
int nstations
Current number of stations idle or active.
Definition: et_private.h:399

et_system_t::statDone
int statDone
Flag to use with statdone condition variable.
Definition: et_private.h:407

et_system_t::port
int port
TCP server port.
Definition: et_private.h:403

et_system_t::nselects
int nselects
Number of selection ints per station (also control ints per event).
Definition: et_private.h:393

et_system_t::asthread
int asthread
ET_THREAD_KILL if killing add-station thread, else ET_THREAD_KEEP.
Definition: et_private.h:396

et_system_t::proc
struct et_proc proc[ET_PROCESSES_MAX]
Array of info on processes.
Definition: et_private.h:428

et_system_t::mutex
pthread_mutex_t mutex
Pthread mutex to protect system data during changes.
Definition: et_private.h:417

et_system_t::config
et_sys_config config
Configuration parameters used to create ET system.
Definition: et_private.h:430

et_system_t::stat_head
et_stat_id stat_head
Index to head of linked list of used stations (not storing this as a pointer makes for an awkward lin...
Definition: et_private.h:408

et_system_t::bitInfo
int bitInfo
Least significant bit = 1 if ET system created by 64 bit executable, and next bit = 1 if ET system is...
Definition: et_private.h:394

et_system_t::hz
int hz
System clock rate in Hz.
Definition: et_private.h:398

et_system_t::statdone
pthread_cond_t statdone
Pthread condition variable used to signal end of station creation.
Definition: et_private.h:421

et_system_t::statadd
pthread_cond_t statadd
Pthread condition variable used to add new stations.
Definition: et_private.h:420

et_system_t::mainpid
pid_t mainpid
Unix pid of ET system.
Definition: et_private.h:414

et_system_t::stat_tail
et_stat_id stat_tail
Index to tail of linked list of used stations (not storing this as a pointer makes for an awkward lin...
Definition: et_private.h:411

et_system_t::statAdd
int statAdd
Flag to use with statadd condition variable.
Definition: et_private.h:406

et_system_t::attach
struct et_attach attach[ET_ATTACHMENTS_MAX]
Array of info on attachments.
Definition: et_private.h:429

et_system_t::version
int version
Major version number of this ET software release.
Definition: et_private.h:392

et_system_t::tcpFd
int tcpFd
TCP server's listening socket file descriptor.
Definition: et_private.h:404

et_system_t::nattachments
int nattachments
Current number of attachments to stations in system.
Definition: et_private.h:402