et_private.h File Reference

#include <stdint.h>
#include <stdlib.h>
#include <stdarg.h>
#include <stddef.h>
#include <limits.h>
#include <pthread.h>
#include "etCommonNetwork.h"

Go to the source code of this file.

Data Structures
struct	et_stat_config_t
	Structure to hold parameters used to configure a station. More...
struct	et_stat_data_t
	Structure to hold the current state of a station. More...
struct	et_list_t
	Structure defining a station's input or output list of events. More...
struct	et_fixin
	Structure for fixing station input list. More...
struct	et_fixout
	Structure for fixing station output list. More...
struct	et_fix
	Struct to fix station's input and output linked lists after crash. More...
struct	et_station_t
	Structure defining a station. More...
struct	et_proc
	Structure containing local process info. More...
struct	et_attach
	Structure containing attachment info. More...
struct	et_sys_config_t
	Structure containing all info necessary to configure an ET system. More...
struct	et_system_t
	Structure containing all ET system information. More...
struct	et_open_config_t
	Structure holding all configuration parameters used to open an ET system. More...
struct	et_id_t
	Structure defining an ET system user id (one needed for each system in use) which contains pointers to key mem locations, config info, status info, node locality and remote node info. More...
struct	et_mem_t
	Structure containing info stored at front of shared or mapped memory. More...
struct	et_response_t
	Structure for holding an ET system's single response to ET client's broad/multicast. More...
struct	et_netthread_t
	Struct for passing data from system to network threads. More...
struct	et_bridge_config_t
	Structure to define configuration parameters used to bridge ET systems (transfer events between 2 systems). More...
Defines
#define	ET_VERSION 15
	Major version number.
#define	ET_VERSION_MINOR 1
	Minor version number.
#define	ET_LANG_C 0
	C language version of ET software.
#define	ET_LANG_CPP 1
	C++ language version of ET software.
#define	ET_LANG_JAVA 2
	Java language version of ET software.
#define	ET_SYSTEM_TYPE_C 1
	ET system implemented through C language library.
#define	ET_SYSTEM_TYPE_JAVA 2
	ET system implemented through Java language library.
#define	ET_IPADDRSTRLEN 16
	Max string length of dotted-decimal ip address.
#define	ET_MAXHOSTNAMELEN 256
	Max length of a host name including the terminating char.
#define	ET_MAXADDRESSES 10
	Max number of network addresses/names per host we'll examine.
#define	ET_MON_SEC 1
	Seconds between monitoring heartbeat value (add to ET_MON_NSEC).
#define	ET_MON_NSEC 600000000
	Nanoseconds between monitoring heartbeat value (add to ET_MON_SEC).
#define	ET_BEAT_SEC 0
	Seconds between heartbeat increment (add to ET_BEAT_NSEC).
#define	ET_BEAT_NSEC 500000000
	Nanoseconds between heartbeat increment (add to ET_BEAT_SEC).
#define	ET_HBMODULO UINT_MAX
	Max value for heartbeat.
#define	ET_EXTRA_THREADS 2
	Number of extra POSIX threads ET client/producer will start.
#define	ET_ATTACHMENTS_MAX 100
	Maximum number of attachments allowed on the system.
#define	ET_PROCESSES_MAX ET_ATTACHMENTS_MAX
	Maximum number of local processes allowed to open the system.
#define	ET_ATT_UNUSED 0
	Attachment number not in use.
#define	ET_ATT_ACTIVE 1
	Attachment is active (attached to a station).
#define	ET_ATT_CONTINUE 0
	Attachment is normal.
#define	ET_ATT_QUIT 1
	Attachment must return immediately from ET API call.
#define	ET_ATT_UNBLOCKED 0
	Attachment is not blocked on a read.
#define	ET_ATT_BLOCKED 1
	Attachment is blocked on a read.
#define	ET_ATT_NOSLEEP 0
	Attachment is not in sleep mode.
#define	ET_ATT_SLEEP 1
	Attachment is in simulated sleep mode.
#define	ET_PROC_CLOSED 0
	Process has closed ET systems (no access to mapped memory).
#define	ET_PROC_OPEN 1
	Process has opened ET system (has access to mapped memory).
#define	ET_PROC_ETDEAD 0
	Process thinks ET system it is connected to is dead.
#define	ET_PROC_ETOK 1
	Process thinks ET system it is connected to is OK.
#define	ET_STRUCT_NEW 0
	Structure is newly created and not yet initialized.
#define	ET_STRUCT_OK 1
	Structure is initialized and ready for use.
#define	ET_THREAD_KEEP 0
	Keep thread around.
#define	ET_THREAD_KILL 1
	Kill thread.
#define	ET_MUTEX_SHARE 0
	Operating system can share pthread mutex between different local processes.
#define	ET_MUTEX_NOSHARE 1
	Operating system cannot share pthread mutex between different local processes.
#define	ET_MUTEX_UNLOCKED 0
	Pthread mutex is unlocked.
#define	ET_MUTEX_LOCKED 1
	Pthread mutex is locked.
#define	ET_INITIAL_SHARED_MEM_DATA_BYTES 64
	Size in bytes of the data stored at the beginning of the shared memory (these data give general info necessary for Java and C clients to handle the ET system file properly).
#define	ET_FIX_READ 0
	Fixing station's in/output event list after et_events_get or et_events_new.
#define	ET_FIX_DUMP 1
	Fixing station's in/output event list after et_events_dump.
#define	ET_BIT64_MASK 0x1
	Bit mask to select bit in bitInfo word of et_system structure identifying ET system's host running 64-bit OS.
#define	ET_KILL_MASK 0x2
	Bit mask to select bit in bitInfo word of et_system structure telling ET system to kill itself ASAP.
#define	ET_GET_BIT64(x) ((x) & ET_BIT64_MASK)
	Get the bit in the bitInfo word identifying ET system's host as running a 64-bit OS.
#define	ET_GET_KILL(x) ((x) & ET_KILL_MASK)
	Get the bit in the bitInfo word telling ET system to kill itself ASAP.
#define	ET_SET_BIT64(x) ((x) \| ET_BIT64_MASK)
	Set the bit in the bitInfo word identifying ET system's host as running a 64-bit OS.
#define	ET_SET_KILL(x) ((x) \| ET_KILL_MASK)
	Set the bit in the bitInfo word telling ET system to kill itself ASAP.
#define	ET_NET_EV_GET_L 0
	et_event_get
#define	ET_NET_EVS_GET_L 1
	et_events_get
#define	ET_NET_EV_PUT_L 2
	et_event_put
#define	ET_NET_EVS_PUT_L 3
	et_events_put
#define	ET_NET_EV_NEW_L 4
	et_event_new
#define	ET_NET_EVS_NEW_L 5
	et_events_new
#define	ET_NET_EV_DUMP_L 6
	et_event_dump
#define	ET_NET_EVS_DUMP_L 7
	et_events_dump
#define	ET_NET_EVS_NEW_GRP_L 8
	et_events_new_group
#define	ET_NET_EV_GET 20
	et_event_get
#define	ET_NET_EVS_GET 21
	et_events_get
#define	ET_NET_EV_PUT 22
	et_event_put
#define	ET_NET_EVS_PUT 23
	et_events_put
#define	ET_NET_EV_NEW 24
	et_event_new
#define	ET_NET_EVS_NEW 25
	et_events_new
#define	ET_NET_EV_DUMP 26
	et_event_dump
#define	ET_NET_EVS_DUMP 27
	et_events_dump
#define	ET_NET_EVS_NEW_GRP 28
	et_events_new_group
#define	ET_NET_EVS_NEW_GRP_JAVA 29
#define	ET_NET_ALIVE 40
	et_alive
#define	ET_NET_WAIT 41
	et_wait_for_alive
#define	ET_NET_CLOSE 42
	et_close
#define	ET_NET_FCLOSE 43
	et_forcedclose
#define	ET_NET_WAKE_ATT 44
	et_wakeup_attachment
#define	ET_NET_WAKE_ALL 45
	et_wakeup_all
#define	ET_NET_KILL 46
	et_kill
#define	ET_NET_STAT_ATT 60
	et_station_attach
#define	ET_NET_STAT_DET 61
	et_station_detach
#define	ET_NET_STAT_CRAT 62
	et_station_create_at
#define	ET_NET_STAT_RM 63
	et_station_remove
#define	ET_NET_STAT_SPOS 64
	et_station_setposition
#define	ET_NET_STAT_GPOS 65
	et_station_getposition
#define	ET_NET_STAT_ISAT 80
	et_station_isattached
#define	ET_NET_STAT_EX 81
	et_station_exists
#define	ET_NET_STAT_SSW 82
	et_station_setselectwords
#define	ET_NET_STAT_GSW 83
	et_station_getselectwords
#define	ET_NET_STAT_LIB 84
	et_station_getlib
#define	ET_NET_STAT_FUNC 85
	et_station_getfunction
#define	ET_NET_STAT_CLASS 86
	et_station_getclass
#define	ET_NET_STAT_GATTS 100
	et_station_getattachments
#define	ET_NET_STAT_STATUS 101
	et_station_getstatus
#define	ET_NET_STAT_INCNT 102
	et_station_getinputcount
#define	ET_NET_STAT_OUTCNT 103
	et_station_getoutputcount
#define	ET_NET_STAT_GBLOCK 104
	et_station_getblock
#define	ET_NET_STAT_GUSER 105
	et_station_getuser
#define	ET_NET_STAT_GRESTORE 106
	et_station_getrestore
#define	ET_NET_STAT_GPRE 107
	et_station_getprescale
#define	ET_NET_STAT_GCUE 108
	et_station_getcue
#define	ET_NET_STAT_GSELECT 109
	et_station_getselect
#define	ET_NET_STAT_SBLOCK 115
	et_station_getblock
#define	ET_NET_STAT_SUSER 116
	et_station_getuser
#define	ET_NET_STAT_SRESTORE 117
	et_station_getrestore
#define	ET_NET_STAT_SPRE 118
	et_station_getprescale
#define	ET_NET_STAT_SCUE 119
	et_station_getcue
#define	ET_NET_ATT_PUT 130
	et_att_getput
#define	ET_NET_ATT_GET 131
	et_att_getget
#define	ET_NET_ATT_DUMP 132
	et_att_getdump
#define	ET_NET_ATT_MAKE 133
	et_att_getmake
#define	ET_NET_SYS_TMP 150
	et_system_gettemps
#define	ET_NET_SYS_TMPMAX 151
	et_system_gettempsmax
#define	ET_NET_SYS_STAT 152
	et_system_getstations
#define	ET_NET_SYS_STATMAX 153
	et_system_getstationsmax
#define	ET_NET_SYS_PROC 154
	et_system_getprocs
#define	ET_NET_SYS_PROCMAX 155
	et_system_getprocsmax
#define	ET_NET_SYS_ATT 156
	et_system_getattachments
#define	ET_NET_SYS_ATTMAX 157
	et_system_getattsmax
#define	ET_NET_SYS_HBEAT 158
	et_system_getheartbeat
#define	ET_NET_SYS_PID 159
	et_system_getpid
#define	ET_NET_SYS_GRP 160
	et_system_getgroup
#define	ET_NET_SYS_DATA 170
	send ET system data
#define	ET_NET_SYS_HIST 171
	send ET histogram data
#define	ET_NET_SYS_GRPS 172
	send size of each event group
#define	ET_P2EVENT(etid, place) ((et_event )((et_event )(etid->events) + (place)))
	Macro to get pointer to event from system id and event place.
#define	ET_PEVENT2USR(p, offset) ((et_event )((char )(p) + (offset)))
	Macro to change event pointer from ET system space to user space.
#define	ET_PEVENT2ET(p, offset) ((et_event )((char )(p) - (offset)))
	Macro to change event pointer from user space to ET system space.
#define	ET_PSTAT2USR(p, offset) ((et_station )((char )(p) + (offset)))
	Macro to change station pointer from ET system space to user space.
#define	ET_PSTAT2ET(p, offset) ((et_station )((char )(p) - (offset)))
	Macro to change station pointer from user space to ET system space.
#define	ET_PDATA2USR(p, offset) ((void )((char )(p) + (offset)))
	Macro to change data pointer from ET system space to user space.
#define	ET_PDATA2ET(p, offset) ((void )((char )(p) - (offset)))
	Macro to change data pointer from user space to ET system space.
#define	ET_64BIT_UINT(hi, lo) (((uint64_t)(hi) << 32) \| ((uint64_t)(lo) & 0x00000000FFFFFFFF))
	Macro to take 2 ints (up to 64 bits each) and change into 1, unsigned 64-bit int (hi becomes the high 32 bits and lo becomes the low 32 bits).
#define	ET_64BIT_INT(hi, lo) (((int64_t)(hi) << 32) \| ((int64_t)(lo) & 0x00000000FFFFFFFF))
	Macro to take 2 ints (up to 64 bits each) and change into 1, signed 64-bit int (hi becomes the high 32 bits and lo becomes the low 32 bits).
#define	ET_64BIT_P(hi, lo) ((void *)(((uint64_t)(hi) << 32) \| ((uint64_t)(lo) & 0x00000000FFFFFFFF)))
	Macro to take 2 ints (up to 64 bits each) and change into 64-bit void pointer (hi becomes the high 32 bits and lo becomes the low 32 bits).
#define	ET_HIGHINT(i) ((uint32_t)(((uint64_t)(i) >> 32) & 0x00000000FFFFFFFF))
	Macro to take a 64-bit unsigned int and return the high 32 bits as an unsigned 32-bit int.
#define	ET_LOWINT(i) ((uint32_t)((uint64_t)(i) & 0x00000000FFFFFFFF))
	Macro to take a 64-bit unsigned int and return the low 32 bits as an unsigned 32-bit int.
Typedefs
typedef int(*	ET_SELECT_FUNCPTR )(void , et_stat_id, et_event )
	Defines event selection function.
typedef struct et_stat_config_t	et_stat_config
	Structure to hold parameters used to configure a station.
typedef struct et_stat_data_t	et_stat_data
	Structure to hold the current state of a station.
typedef struct et_list_t	et_list
	Structure defining a station's input or output list of events.
typedef struct et_station_t	et_station
	Structure defining a station.
typedef struct et_sys_config_t	et_sys_config
	Structure containing all info necessary to configure an ET system.
typedef struct et_system_t	et_system
	Structure containing all ET system information.
typedef struct et_open_config_t	et_open_config
	Structure holding all configuration parameters used to open an ET system.
typedef struct et_id_t	et_id
	Structure defining an ET system user id (one needed for each system in use) which contains pointers to key mem locations, config info, status info, node locality and remote node info.
typedef struct et_mem_t	et_mem
	Structure containing info stored at front of shared or mapped memory.
typedef struct et_response_t	et_response
	Structure for holding an ET system's single response to ET client's broad/multicast.
typedef struct et_netthread_t	et_netthread
	Struct for passing data from system to network threads.
typedef struct et_bridge_config_t	et_bridge_config
	Structure to define configuration parameters used to bridge ET systems (transfer events between 2 systems).
Functions
void	et_station_lock (et_system *sys)
void	et_station_unlock (et_system *sys)
void	et_llist_lock (et_list *pl)
void	et_llist_unlock (et_list *pl)
void	et_system_lock (et_system *sys)
void	et_system_unlock (et_system *sys)
void	et_transfer_lock (et_station *ps)
void	et_transfer_unlock (et_station *ps)
void	et_transfer_lock_all (et_id *id)
void	et_transfer_unlock_all (et_id *id)
void	et_tcp_lock (et_id *id)
void	et_tcp_unlock (et_id *id)
void	et_memRead_lock (et_id *id)
void	et_memWrite_lock (et_id *id)
void	et_mem_unlock (et_id *id)
int	et_mutex_locked (pthread_mutex_t *pmutex)
int	et_repair_station (et_id *id, et_stat_id stat_id)
int	et_repair_gc (et_id *id)
void	et_init_station (et_station *ps)
void	et_init_llist (et_list *pl)
void	et_init_event (et_event *pe)
void	et_init_event_ (et_event *pe)
void	et_init_process (et_system *sys, et_proc_id id)
void	et_init_attachment (et_system *sys, et_att_id id)
void	et_init_histogram (et_id *id)
void	et_init_stats_att (et_system *sys, et_att_id id)
void	et_init_stats_allatts (et_system *sys)
void	et_init_stats_station (et_station *ps)
void	et_init_stats_allstations (et_id *id)
void	et_init_stats_all (et_id *id)
int	et_id_init (et_sys_id *id)
void	et_id_destroy (et_sys_id id)
int	et_station_write (et_id id, et_stat_id stat_id, et_event pe)
int	et_station_nwrite (et_id id, et_stat_id stat_id, et_event pe[], int num)
int	et_station_read (et_id id, et_stat_id stat_id, et_event pe, int _mode, et_att_id att, struct timespec time)
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)
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)
int	et_station_dump (et_id id, et_event pe)
int	et_station_ndump (et_id id, et_event pe[], int num)
int	et_llist_read (et_list pl, et_event *pe)
int	et_llist_write (et_id id, et_list pl, et_event **pe, int num)
int	et_llist_write_gc (et_id id, et_event *pe, int num)
int	et_restore_events (et_id *id, et_att_id att, et_stat_id stat_id)
void	et_flush_events (et_id *id, et_att_id att, et_stat_id stat_id)
int	et_mem_create (const char name, size_t memsize, void pmemory, size_t totalSize)
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)
int	et_mem_attach (const char name, void pmemory, et_mem pInfo)
int	et_mem_unmap (const char name, void pmem)
int	et_mem_remove (const char name, void pmem)
int	et_mem_size (const char name, size_t totalsize, size_t *usedsize)
void *	et_temp_create (const char *name, size_t size)
void *	et_temp_attach (const char *name, size_t size)
int	et_temp_remove (const char name, void pmem, size_t size)
int	etr_event_new (et_sys_id id, et_att_id att, et_event *ev, int mode, struct timespec deltatime, size_t size)
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)
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)
int	etr_event_get (et_sys_id id, et_att_id att, et_event *ev, int wait, struct timespec deltatime)
int	etr_events_get (et_sys_id id, et_att_id att, et_event evs[], int wait, struct timespec deltatime, int num, int *nread)
int	etr_event_put (et_sys_id id, et_att_id att, et_event *ev)
int	etr_events_put (et_sys_id id, et_att_id att, et_event *evs[], int num)
int	etr_event_dump (et_sys_id id, et_att_id att, et_event *ev)
int	etr_events_dump (et_sys_id id, et_att_id att, et_event *evs[], int num)
int	etr_open (et_sys_id id, const char et_filename, et_openconfig openconfig)
int	etr_close (et_sys_id id)
int	etr_forcedclose (et_sys_id id)
int	etr_kill (et_sys_id id)
int	etr_alive (et_sys_id id)
int	etr_wait_for_alive (et_sys_id id)
int	etr_wakeup_attachment (et_sys_id id, et_att_id att)
int	etr_wakeup_all (et_sys_id id, et_stat_id stat_id)
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)
int	etr_station_create (et_sys_id id, et_stat_id stat_id, const char stat_name, et_statconfig sconfig)
int	etr_station_remove (et_sys_id id, et_stat_id stat_id)
int	etr_station_attach (et_sys_id id, et_stat_id stat_id, et_att_id *att)
int	etr_station_detach (et_sys_id id, et_att_id att)
int	etr_station_setposition (et_sys_id id, et_stat_id stat_id, int position, int parallelposition)
int	etr_station_getposition (et_sys_id id, et_stat_id stat_id, int position, int parallelposition)
int	etr_station_isattached (et_sys_id id, et_stat_id stat_id, et_att_id att)
int	etr_station_exists (et_sys_id id, et_stat_id stat_id, const char stat_name)
int	etr_station_getattachments (et_sys_id id, et_stat_id stat_id, int *numatts)
int	etr_station_getstatus (et_sys_id id, et_stat_id stat_id, int *status)
int	etr_station_getinputcount (et_sys_id id, et_stat_id stat_id, int *cnt)
int	etr_station_getoutputcount (et_sys_id id, et_stat_id stat_id, int *cnt)
int	etr_station_getselect (et_sys_id id, et_stat_id stat_id, int *select)
int	etr_station_getlib (et_sys_id id, et_stat_id stat_id, char *lib)
int	etr_station_getclass (et_sys_id id, et_stat_id stat_id, char *classs)
int	etr_station_getfunction (et_sys_id id, et_stat_id stat_id, char *function)
int	etr_station_getblock (et_sys_id id, et_stat_id stat_id, int *block)
int	etr_station_setblock (et_sys_id id, et_stat_id stat_id, int block)
int	etr_station_getuser (et_sys_id id, et_stat_id stat_id, int *user)
int	etr_station_setuser (et_sys_id id, et_stat_id stat_id, int user)
int	etr_station_getrestore (et_sys_id id, et_stat_id stat_id, int *restore)
int	etr_station_setrestore (et_sys_id id, et_stat_id stat_id, int restore)
int	etr_station_getprescale (et_sys_id id, et_stat_id stat_id, int *prescale)
int	etr_station_setprescale (et_sys_id id, et_stat_id stat_id, int prescale)
int	etr_station_getcue (et_sys_id id, et_stat_id stat_id, int *cue)
int	etr_station_setcue (et_sys_id id, et_stat_id stat_id, int cue)
int	etr_station_getselectwords (et_sys_id id, et_stat_id stat_id, int select[])
int	etr_station_setselectwords (et_sys_id id, et_stat_id stat_id, int select[])
int	etr_system_gettemps (et_sys_id id, int *temps)
int	etr_system_gettempsmax (et_sys_id id, int *tempsmax)
int	etr_system_getstations (et_sys_id id, int *stations)
int	etr_system_getstationsmax (et_sys_id id, int *stationsmax)
int	etr_system_getprocs (et_sys_id id, int *procs)
int	etr_system_getprocsmax (et_sys_id id, int *procsmax)
int	etr_system_getattachments (et_sys_id id, int *atts)
int	etr_system_getattsmax (et_sys_id id, int *attsmax)
int	etr_system_getheartbeat (et_sys_id id, int *heartbeat)
int	etr_system_getpid (et_sys_id id, int *pid)
int	etr_system_getgroupcount (et_sys_id id, int *groupCnt)
int	etr_attach_geteventsput (et_sys_id id, et_att_id att_id, uint64_t *events)
int	etr_attach_geteventsget (et_sys_id id, et_att_id att_id, uint64_t *events)
int	etr_attach_geteventsdump (et_sys_id id, et_att_id att_id, uint64_t *events)
int	etr_attach_geteventsmake (et_sys_id id, et_att_id att_id, uint64_t *events)
int	etn_open (et_sys_id id, const char filename, et_openconfig openconfig)
int	etn_close (et_sys_id id)
int	etn_forcedclose (et_sys_id id)
int	etn_kill (et_sys_id id)
int	etn_alive (et_sys_id id)
int	etn_wait_for_alive (et_sys_id id)
int	etn_event_new (et_sys_id id, et_att_id att, et_event *ev, int mode, struct timespec deltatime, size_t size)
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)
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)
int	etn_event_get (et_sys_id id, et_att_id att, et_event *ev, int mode, struct timespec deltatime)
int	etn_events_get (et_sys_id id, et_att_id att, et_event evs[], int mode, struct timespec deltatime, int num, int *nread)
int	etn_event_put (et_sys_id id, et_att_id att, et_event *ev)
int	etn_events_put (et_sys_id id, et_att_id att, et_event *evs[], int num)
int	etn_event_dump (et_sys_id id, et_att_id att, et_event *ev)
int	etn_events_dump (et_sys_id id, et_att_id att, et_event *evs[], int num)
int	etl_open (et_sys_id id, const char filename, et_openconfig openconfig)
int	etl_close (et_sys_id id)
int	etl_forcedclose (et_sys_id id)
int	etl_kill (et_sys_id id)
int	etl_alive (et_sys_id id)
int	etl_wait_for_alive (et_sys_id id)
int	et_wait_for_system (et_sys_id id, struct timespec timeout, const char etname)
int	et_look (et_sys_id id, const char filename)
int	et_unlook (et_sys_id id)
void *	et_cast_thread (void *arg)
void *	et_netserver (void *arg)
int	et_findserver (const char etname, char ethost, int port, uint32_t inetaddr, et_open_config config, et_response *allETinfo)
int	et_responds (const char *etname)
int	et_sharedmutex (void)
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-mutex-sharing operating system, or remotely.
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.
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 compatible enough to belong in the same parallel station group.
void	et_logmsg (char sev, char fmt,...)

Define Documentation

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

Macro to take 2 ints (up to 64 bits each) and change into 1, signed 64-bit int (hi becomes the high 32 bits and lo becomes the low 32 bits).

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

Macro to take 2 ints (up to 64 bits each) and change into 64-bit void pointer (hi becomes the high 32 bits and lo becomes the low 32 bits).

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

Macro to take 2 ints (up to 64 bits each) and change into 1, unsigned 64-bit int (hi becomes the high 32 bits and lo becomes the low 32 bits).

Referenced by etr_event_get(), etr_events_get(), and etr_open().

#define ET_ATT_ACTIVE 1

Attachment is active (attached to a station).

Referenced by et_event_get(), et_event_new(), et_events_get(), et_events_new(), et_events_new_group(), and et_station_attach().

#define ET_ATT_BLOCKED 1

Attachment is blocked on a read.

Referenced by et_wakeup_all().

#define ET_ATT_CONTINUE 0

Attachment is normal.

#define ET_ATT_NOSLEEP 0

Attachment is not in sleep mode.

Referenced by et_wakeup_attachment().

#define ET_ATT_QUIT 1

Attachment must return immediately from ET API call.

Referenced by et_wakeup_all(), and et_wakeup_attachment().

#define ET_ATT_SLEEP 1

Attachment is in simulated sleep mode.

Referenced by et_wakeup_all().

#define ET_ATT_UNBLOCKED 0

Attachment is not blocked on a read.

Referenced by et_wakeup_attachment().

#define ET_ATT_UNUSED 0

Attachment number not in use.

Referenced by et_station_detach().

#define ET_ATTACHMENTS_MAX 100

Maximum number of attachments allowed on the system.

Referenced by et_station_detach(), et_system_config_init(), and et_system_config_setattachments().

#define ET_BEAT_NSEC 500000000

Nanoseconds between heartbeat increment (add to ET_BEAT_SEC).

Referenced by et_system_start().

#define ET_BEAT_SEC 0

Seconds between heartbeat increment (add to ET_BEAT_NSEC).

Referenced by et_system_start().

#define ET_BIT64_MASK 0x1

Bit mask to select bit in bitInfo word of et_system structure identifying ET system's host running 64-bit OS.

#define ET_EXTRA_THREADS 2

Number of extra POSIX threads ET client/producer will start.

Referenced by et_system_start().

#define ET_FIX_DUMP 1

Fixing station's in/output event list after et_events_dump.

#define ET_FIX_READ 0

Fixing station's in/output event list after et_events_get or et_events_new.

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

Get the bit in the bitInfo word identifying ET system's host as running a 64-bit OS.

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

Get the bit in the bitInfo word telling ET system to kill itself ASAP.

#define ET_HBMODULO UINT_MAX

Max value for heartbeat.

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

Macro to take a 64-bit unsigned int and return the high 32 bits as an unsigned 32-bit int.

Referenced by etr_event_new(), etr_event_put(), etr_events_new(), etr_events_new_group(), and etr_events_put().

#define ET_INITIAL_SHARED_MEM_DATA_BYTES 64

Size in bytes of the data stored at the beginning of the shared memory (these data give general info necessary for Java and C clients to handle the ET system file properly).

Referenced by et_system_start().

#define ET_IPADDRSTRLEN 16

Max string length of dotted-decimal ip address.

Referenced by et_findlocality(), et_open_config_addmulticast(), et_open_config_getinterface(), et_open_config_init(), et_open_config_removemulticast(), et_open_config_setinterface(), et_system_config_addmulticast(), et_system_config_removemulticast(), etr_open(), and etr_station_attach().

#define ET_KILL_MASK 0x2

Bit mask to select bit in bitInfo word of et_system structure telling ET system to kill itself ASAP.

#define ET_LANG_C 0

C language version of ET software.

#define ET_LANG_CPP 1

C++ language version of ET software.

#define ET_LANG_JAVA 2

Java language version of ET software.

Referenced by et_station_getclass(), et_station_getfunction(), and et_station_getlib().

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

Macro to take a 64-bit unsigned int and return the low 32 bits as an unsigned 32-bit int.

Referenced by etr_event_new(), etr_event_put(), etr_events_new(), etr_events_new_group(), and etr_events_put().

#define ET_MAXADDRESSES 10

Max number of network addresses/names per host we'll examine.

Referenced by et_open_config_addmulticast(), et_system_config_addmulticast(), and et_system_config_init().

#define ET_MAXHOSTNAMELEN 256

Max length of a host name including the terminating char.

Referenced by et_station_attach(), and etr_station_attach().

#define ET_MON_NSEC 600000000

Nanoseconds between monitoring heartbeat value (add to ET_MON_SEC).

Referenced by et_system_close(), and et_system_start().

#define ET_MON_SEC 1

Seconds between monitoring heartbeat value (add to ET_MON_NSEC).

Referenced by et_system_close(), and et_system_start().

#define ET_MUTEX_LOCKED 1

Pthread mutex is locked.

#define ET_MUTEX_NOSHARE 1

Operating system cannot share pthread mutex between different local processes.

#define ET_MUTEX_SHARE 0

Operating system can share pthread mutex between different local processes.

Referenced by et_findlocality(), and et_open().

#define ET_MUTEX_UNLOCKED 0

Pthread mutex is unlocked.

#define ET_NET_ALIVE 40

et_alive

Referenced by etr_alive().

#define ET_NET_ATT_DUMP 132

et_att_getdump

Referenced by etr_attach_geteventsdump().

#define ET_NET_ATT_GET 131

et_att_getget

Referenced by etr_attach_geteventsget().

#define ET_NET_ATT_MAKE 133

et_att_getmake

Referenced by etr_attach_geteventsmake().

#define ET_NET_ATT_PUT 130

et_att_getput

Referenced by etr_attach_geteventsput().

#define ET_NET_CLOSE 42

et_close

Referenced by etr_close().

#define ET_NET_EV_DUMP 26

et_event_dump

Referenced by etr_event_dump().

#define ET_NET_EV_DUMP_L 6

et_event_dump

#define ET_NET_EV_GET 20

et_event_get

Referenced by etr_event_get().

#define ET_NET_EV_GET_L 0

et_event_get

#define ET_NET_EV_NEW 24

et_event_new

Referenced by etr_event_new().

#define ET_NET_EV_NEW_L 4

et_event_new

#define ET_NET_EV_PUT 22

et_event_put

Referenced by etr_event_put().

#define ET_NET_EV_PUT_L 2

et_event_put

#define ET_NET_EVS_DUMP 27

et_events_dump

Referenced by etr_events_dump().

#define ET_NET_EVS_DUMP_L 7

et_events_dump

#define ET_NET_EVS_GET 21

et_events_get

Referenced by etr_events_get().

#define ET_NET_EVS_GET_L 1

et_events_get

#define ET_NET_EVS_NEW 25

et_events_new

Referenced by etr_events_new().

#define ET_NET_EVS_NEW_GRP 28

et_events_new_group

Referenced by etr_events_new_group().

#define ET_NET_EVS_NEW_GRP_JAVA 29

#define ET_NET_EVS_NEW_GRP_L 8

et_events_new_group

#define ET_NET_EVS_NEW_L 5

et_events_new

#define ET_NET_EVS_PUT 23

et_events_put

Referenced by etr_events_put().

#define ET_NET_EVS_PUT_L 3

et_events_put

#define ET_NET_FCLOSE 43

et_forcedclose

Referenced by etr_forcedclose().

#define ET_NET_KILL 46

et_kill

Referenced by etr_kill().

#define ET_NET_STAT_ATT 60

et_station_attach

Referenced by etr_station_attach().

#define ET_NET_STAT_CLASS 86

et_station_getclass

Referenced by etr_station_getclass().

#define ET_NET_STAT_CRAT 62

et_station_create_at

Referenced by etr_station_create_at().

#define ET_NET_STAT_DET 61

et_station_detach

Referenced by etr_station_detach().

#define ET_NET_STAT_EX 81

et_station_exists

Referenced by etr_station_exists().

#define ET_NET_STAT_FUNC 85

et_station_getfunction

Referenced by etr_station_getfunction().

#define ET_NET_STAT_GATTS 100

et_station_getattachments

Referenced by etr_station_getattachments().

#define ET_NET_STAT_GBLOCK 104

et_station_getblock

Referenced by etr_station_getblock().

#define ET_NET_STAT_GCUE 108

et_station_getcue

Referenced by etr_station_getcue().

#define ET_NET_STAT_GPOS 65

et_station_getposition

Referenced by etr_station_getposition().

#define ET_NET_STAT_GPRE 107

et_station_getprescale

Referenced by etr_station_getprescale().

#define ET_NET_STAT_GRESTORE 106

et_station_getrestore

Referenced by etr_station_getrestore().

#define ET_NET_STAT_GSELECT 109

et_station_getselect

Referenced by etr_station_getselect().

#define ET_NET_STAT_GSW 83

et_station_getselectwords

Referenced by etr_station_getselectwords().

#define ET_NET_STAT_GUSER 105

et_station_getuser

Referenced by etr_station_getuser().

#define ET_NET_STAT_INCNT 102

et_station_getinputcount

Referenced by etr_station_getinputcount().

#define ET_NET_STAT_ISAT 80

et_station_isattached

Referenced by etr_station_isattached().

#define ET_NET_STAT_LIB 84

et_station_getlib

Referenced by etr_station_getlib().

#define ET_NET_STAT_OUTCNT 103

et_station_getoutputcount

Referenced by etr_station_getoutputcount().

#define ET_NET_STAT_RM 63

et_station_remove

Referenced by etr_station_remove().

#define ET_NET_STAT_SBLOCK 115

et_station_getblock

Referenced by etr_station_setblock().

#define ET_NET_STAT_SCUE 119

et_station_getcue

Referenced by etr_station_setcue().

#define ET_NET_STAT_SPOS 64

et_station_setposition

Referenced by etr_station_setposition().

#define ET_NET_STAT_SPRE 118

et_station_getprescale

Referenced by etr_station_setprescale().

#define ET_NET_STAT_SRESTORE 117

et_station_getrestore

Referenced by etr_station_setrestore().

#define ET_NET_STAT_SSW 82

et_station_setselectwords

Referenced by etr_station_setselectwords().

#define ET_NET_STAT_STATUS 101

et_station_getstatus

Referenced by etr_station_getstatus().

#define ET_NET_STAT_SUSER 116

et_station_getuser

Referenced by etr_station_setuser().

#define ET_NET_SYS_ATT 156

et_system_getattachments

Referenced by etr_system_getattachments().

#define ET_NET_SYS_ATTMAX 157

et_system_getattsmax

Referenced by etr_system_getattsmax().

#define ET_NET_SYS_DATA 170

send ET system data

#define ET_NET_SYS_GRP 160

et_system_getgroup

Referenced by etr_system_getgroupcount().

#define ET_NET_SYS_GRPS 172

send size of each event group

#define ET_NET_SYS_HBEAT 158

et_system_getheartbeat

Referenced by etr_system_getheartbeat().

#define ET_NET_SYS_HIST 171

send ET histogram data

#define ET_NET_SYS_PID 159

et_system_getpid

Referenced by etr_system_getpid().

#define ET_NET_SYS_PROC 154

et_system_getprocs

Referenced by etr_system_getprocs().

#define ET_NET_SYS_PROCMAX 155

et_system_getprocsmax

Referenced by etr_system_getprocsmax().

#define ET_NET_SYS_STAT 152

et_system_getstations

Referenced by etr_system_getstations().

#define ET_NET_SYS_STATMAX 153

et_system_getstationsmax

Referenced by etr_system_getstationsmax().

#define ET_NET_SYS_TMP 150

et_system_gettemps

Referenced by etr_system_gettemps().

#define ET_NET_SYS_TMPMAX 151

et_system_gettempsmax

Referenced by etr_system_gettempsmax().

#define ET_NET_WAIT 41

et_wait_for_alive

Referenced by etr_wait_for_alive().

#define ET_NET_WAKE_ALL 45

et_wakeup_all

Referenced by etr_wakeup_all().

#define ET_NET_WAKE_ATT 44

et_wakeup_attachment

Referenced by etr_wakeup_attachment().

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

Macro to get pointer to event from system id and event place.

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

Macro to change data pointer from user space to ET system space.

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

Macro to change data pointer from ET system space to user space.

Referenced by et_event_get(), et_event_new(), et_events_get(), et_events_new(), and et_events_new_group().

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

Macro to change event pointer from user space to ET system space.

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

Macro to change event pointer from ET system space to user space.

#define ET_PROC_CLOSED 0

Process has closed ET systems (no access to mapped memory).

#define ET_PROC_ETDEAD 0

Process thinks ET system it is connected to is dead.

#define ET_PROC_ETOK 1

Process thinks ET system it is connected to is OK.

#define ET_PROC_OPEN 1

Process has opened ET system (has access to mapped memory).

#define ET_PROCESSES_MAX ET_ATTACHMENTS_MAX

Maximum number of local processes allowed to open the system.

Referenced by et_system_config_init(), and et_system_config_setprocs().

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

Macro to change station pointer from user space to ET system space.

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

Macro to change station pointer from ET system space to user space.

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

Set the bit in the bitInfo word identifying ET system's host as running a 64-bit OS.

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

Set the bit in the bitInfo word telling ET system to kill itself ASAP.

#define ET_STRUCT_NEW 0

Structure is newly created and not yet initialized.

#define ET_STRUCT_OK 1

Structure is initialized and ready for use.

#define ET_SYSTEM_TYPE_C 1

ET system implemented through C language library.

#define ET_SYSTEM_TYPE_JAVA 2

ET system implemented through Java language library.

#define ET_THREAD_KEEP 0

Keep thread around.

#define ET_THREAD_KILL 1

Kill thread.

Referenced by et_station_create_at(), et_station_remove(), and et_system_close().

#define ET_VERSION 15

Major version number.

#define ET_VERSION_MINOR 1

Minor version number.

Typedef Documentation

typedef struct et_bridge_config_t et_bridge_config

Structure to define configuration parameters used to bridge ET systems (transfer events between 2 systems).

typedef struct et_id_t et_id

Structure defining an ET system user id (one needed for each system in use) which contains pointers to key mem locations, config info, status info, node locality and remote node info.

typedef struct et_list_t et_list

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

typedef struct et_mem_t et_mem

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

typedef struct et_netthread_t et_netthread

Struct for passing data from system to network threads.

typedef struct et_open_config_t et_open_config

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

typedef struct et_response_t et_response

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

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

Defines event selection function.

typedef struct et_stat_config_t et_stat_config

Structure to hold parameters used to configure a station.

typedef struct et_stat_data_t et_stat_data

Structure to hold the current state of a station.

typedef struct et_station_t et_station

Structure defining a station.

typedef struct et_sys_config_t et_sys_config

Structure containing all info necessary to configure an ET system.

typedef struct et_system_t et_system

Structure containing all ET system information.

Function Documentation

void* et_cast_thread ( void * arg )

Referenced by et_system_start().

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-mutex-sharing operating system, or remotely.

Parameters:

	filename	name of ET system file.
	openconfig	ET system open configuration.

Returns:: ET_REMOTE if looking for a remote ET system.; ET_LOCAL if looking for a local ET system.; ET_LOCAL_NOSHARE if looking for a local ET system without pthread mutex sharing.

References ET_ERROR, ET_ERROR_TIMEOUT, ET_ERROR_TOOMANY, et_findserver2(), ET_HOST_ANYWHERE, ET_HOST_AS_REMOTE, ET_HOST_LOCAL, ET_HOST_REMOTE, ET_IPADDRSTRLEN, ET_LOCAL, ET_LOCAL_NOSHARE, et_logmsg(), ET_MUTEX_SHARE, ET_REMOTE, et_sharedmutex(), et_open_config_t::host, and et_open_config_t::mode.

Referenced by et_open().

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

Referenced by etr_open().

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

Referenced by et_station_detach().

void et_id_destroy ( et_sys_id id )

Referenced by et_open(), et_system_close(), et_system_start(), etr_close(), etr_forcedclose(), and etr_kill().

int et_id_init ( et_sys_id * id )

Referenced by et_open(), and et_system_start().

void et_init_attachment	(	et_system *	sys,
		et_att_id	id
	)

Referenced by et_station_attach().

void et_init_event ( et_event * pe )

Referenced by etr_event_get(), etr_event_new(), etr_events_get(), etr_events_new(), and etr_events_new_group().

void et_init_event_ ( et_event * pe )

Referenced by et_event_new(), et_events_new(), and et_events_new_group().

void et_init_histogram ( et_id * id )

Referenced by et_system_start().

void et_init_llist ( et_list * pl )

void et_init_process	(	et_system *	sys,
		et_proc_id	id
	)

void et_init_station ( et_station * ps )

Referenced by et_station_create_at().

void et_init_stats_all ( et_id * id )

void et_init_stats_allatts ( et_system * sys )

void et_init_stats_allstations ( et_id * id )

void et_init_stats_att	(	et_system *	sys,
		et_att_id	id
	)

void et_init_stats_station ( et_station * ps )

void et_llist_lock ( et_list * pl )

Referenced by et_station_setcue(), et_station_setprescale(), and et_station_setselectwords().

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

void et_llist_unlock ( et_list * pl )

Referenced by et_station_setcue(), et_station_setprescale(), and et_station_setselectwords().

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

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

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

Referenced by et_attach_geteventsdump(), et_attach_geteventsget(), et_attach_geteventsmake(), et_attach_geteventsput(), et_event_dump(), et_event_get(), et_event_new(), et_event_put(), et_event_setdatabuffer(), et_events_bridge(), et_events_dump(), et_events_get(), et_events_new(), et_events_new_group(), et_events_put(), et_findlocality(), et_open(), et_station_attach(), et_station_compare_parallel(), et_station_config_check(), et_station_create_at(), et_station_detach(), et_station_exists(), et_station_getattachments(), et_station_getblock(), et_station_getclass(), et_station_getcue(), et_station_getfunction(), et_station_getinputcount(), et_station_getlib(), et_station_getoutputcount(), et_station_getposition(), et_station_getprescale(), et_station_getrestore(), et_station_getselect(), et_station_getselectwords(), et_station_getstatus(), et_station_getuser(), et_station_isattached(), et_station_remove(), et_station_setblock(), et_station_setcue(), et_station_setposition(), et_station_setprescale(), et_station_setrestore(), et_station_setselectwords(), et_station_setuser(), et_system_close(), et_system_start(), et_wakeup_all(), et_wakeup_attachment(), etr_alive(), etr_close(), etr_event_dump(), etr_event_get(), etr_event_new(), etr_event_put(), etr_events_dump(), etr_events_get(), etr_events_new(), etr_events_new_group(), etr_events_put(), etr_forcedclose(), etr_kill(), etr_open(), etr_station_attach(), etr_station_create_at(), etr_station_detach(), etr_station_exists(), etr_station_getclass(), etr_station_getfunction(), etr_station_getlib(), etr_station_getposition(), etr_station_getselectwords(), etr_station_isattached(), etr_station_remove(), etr_station_setposition(), etr_station_setselectwords(), etr_wait_for_alive(), etr_wakeup_all(), and etr_wakeup_attachment().

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

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

Referenced by et_system_start().

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

Referenced by et_system_start().

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

Referenced by et_system_start().

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

void et_mem_unlock ( et_id * id )

Referenced by et_attach_geteventsdump(), et_attach_geteventsget(), et_attach_geteventsmake(), et_attach_geteventsput(), et_event_dump(), et_event_get(), et_event_new(), et_event_put(), et_events_dump(), et_events_get(), et_events_new(), et_events_new_group(), et_events_put(), et_station_attach(), et_station_create_at(), et_station_detach(), et_station_exists(), et_station_getattachments(), et_station_getblock(), et_station_getclass(), et_station_getcue(), et_station_getfunction(), et_station_getinputcount(), et_station_getlib(), et_station_getoutputcount(), et_station_getposition(), et_station_getprescale(), et_station_getrestore(), et_station_getselect(), et_station_getselectwords(), et_station_getstatus(), et_station_getuser(), et_station_isattached(), et_station_remove(), et_station_setblock(), et_station_setcue(), et_station_setposition(), et_station_setprescale(), et_station_setrestore(), et_station_setselectwords(), et_station_setuser(), et_wakeup_all(), and et_wakeup_attachment().

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

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
	)

Referenced by et_system_start().

void et_memRead_lock ( et_id * id )

Referenced by et_attach_geteventsdump(), et_attach_geteventsget(), et_attach_geteventsmake(), et_attach_geteventsput(), et_event_dump(), et_event_get(), et_event_new(), et_event_put(), et_events_dump(), et_events_get(), et_events_new(), et_events_new_group(), et_events_put(), et_station_attach(), et_station_create_at(), et_station_exists(), et_station_getattachments(), et_station_getblock(), et_station_getclass(), et_station_getcue(), et_station_getfunction(), et_station_getinputcount(), et_station_getlib(), et_station_getoutputcount(), et_station_getposition(), et_station_getprescale(), et_station_getrestore(), et_station_getselect(), et_station_getselectwords(), et_station_getstatus(), et_station_getuser(), et_station_isattached(), et_station_remove(), et_station_setblock(), et_station_setcue(), et_station_setposition(), et_station_setprescale(), et_station_setrestore(), et_station_setselectwords(), et_station_setuser(), et_wakeup_all(), and et_wakeup_attachment().

void et_memWrite_lock ( et_id * id )

Referenced by et_station_detach().

int et_mutex_locked ( pthread_mutex_t * pmutex )

void* et_netserver ( void * arg )

Referenced by et_system_start().

int et_repair_gc ( et_id * id )

int et_repair_station	(	et_id *	id,
		et_stat_id	stat_id
	)

int et_responds ( const char * etname )

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

Referenced by et_station_detach().

int et_sharedmutex ( void )

Referenced by et_findlocality(), and et_open().

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 compatible enough to belong in the same parallel station group.

Parameters:

	id	et system id.
	group	pointer to config of a station already in a parallel group.
	config	pointer to config of station to add to parallel group.

Returns:: 1 if compatible.; 0 if NOT compatible.

References et_stat_config_t::block_mode, et_id_t::debug, ET_DEBUG_ERROR, et_logmsg(), ET_STATION_SELECT_EQUALCUE, ET_STATION_SELECT_RROBIN, et_stat_config_t::flow_mode, et_stat_config_t::prescale, and et_stat_config_t::select_mode.

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.

Parameters:

	id	et system id.
	sc	station config pointer.

Returns:: ET_OK if successful.; ET_ERROR if there is an internal inconsistency or bad value in the configuration.

References et_stat_config_t::block_mode, et_system_t::config, et_stat_config_t::cue, et_id_t::debug, ET_DEBUG_ERROR, ET_ERROR, et_logmsg(), ET_OK, ET_STATION_BLOCKING, ET_STATION_NONBLOCKING, ET_STATION_PARALLEL, ET_STATION_RESTORE_GC, ET_STATION_RESTORE_IN, ET_STATION_RESTORE_OUT, ET_STATION_RESTORE_REDIST, ET_STATION_SELECT_ALL, ET_STATION_SELECT_EQUALCUE, ET_STATION_SELECT_MATCH, ET_STATION_SELECT_RROBIN, ET_STATION_SELECT_USER, ET_STATION_SERIAL, et_stat_config_t::flow_mode, et_stat_config_t::fname, et_stat_config_t::lib, et_sys_config_t::nattachments, et_sys_config_t::nevents, et_stat_config_t::prescale, et_stat_config_t::restore_mode, et_stat_config_t::select_mode, et_id_t::sys, and et_stat_config_t::user_mode.

Referenced by et_station_create_at().

int et_station_dump	(	et_id *	id,
		et_event *	pe
	)

Referenced by et_event_dump().

void et_station_lock ( et_system * sys )

Referenced by et_station_attach(), et_station_create_at(), et_station_detach(), et_station_getposition(), et_station_remove(), et_station_setblock(), et_station_setcue(), et_station_setposition(), et_station_setprescale(), et_station_setrestore(), et_station_setselectwords(), and et_station_setuser().

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

Referenced by et_events_dump().

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
	)

Referenced by et_events_get(), and et_events_new().

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
	)

Referenced by et_events_new_group().

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

Referenced by et_events_put().

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

Referenced by et_event_get(), and et_event_new().

void et_station_unlock ( et_system * sys )

Referenced by et_station_attach(), et_station_create_at(), et_station_detach(), et_station_getposition(), et_station_remove(), et_station_setblock(), et_station_setcue(), et_station_setposition(), et_station_setprescale(), et_station_setrestore(), et_station_setselectwords(), and et_station_setuser().

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

Referenced by et_event_put().

void et_system_lock ( et_system * sys )

Referenced by et_event_dump(), et_events_dump(), et_station_attach(), and et_station_detach().

void et_system_unlock ( et_system * sys )

Referenced by et_event_dump(), et_events_dump(), et_station_attach(), and et_station_detach().

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

Referenced by et_event_get(), and et_events_get().

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

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

Referenced by et_event_dump(), and et_events_dump().

void et_transfer_lock ( et_station * ps )

Referenced by et_station_remove().

void et_transfer_lock_all ( et_id * id )

Referenced by et_station_attach(), et_station_create_at(), et_station_detach(), et_station_getposition(), et_station_remove(), and et_station_setposition().

void et_transfer_unlock ( et_station * ps )

Referenced by et_station_remove().

void et_transfer_unlock_all ( et_id * id )

Referenced by et_station_attach(), et_station_create_at(), et_station_detach(), et_station_getposition(), et_station_remove(), and et_station_setposition().

int et_unlook ( et_sys_id id )

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

int etl_alive ( et_sys_id id )

Referenced by et_alive().

int etl_close ( et_sys_id id )

Referenced by et_close().

int etl_forcedclose ( et_sys_id id )

Referenced by et_forcedclose().

int etl_kill ( et_sys_id id )

Referenced by et_kill().

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

Referenced by et_open().

int etl_wait_for_alive ( et_sys_id id )

Referenced by et_wait_for_alive().

int etn_alive ( et_sys_id id )

Referenced by et_alive().

int etn_close ( et_sys_id id )

Referenced by et_close().

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

Referenced by et_event_dump().

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

Referenced by et_event_get().

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

Referenced by et_event_new().

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

Referenced by et_event_put().

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

Referenced by et_events_dump().

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

Referenced by et_events_get().

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
	)

Referenced by et_events_new().

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
	)

Referenced by et_events_new_group().

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

Referenced by et_events_put().

int etn_forcedclose ( et_sys_id id )

Referenced by et_forcedclose().

int etn_kill ( et_sys_id id )

Referenced by et_kill().

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

Referenced by et_open().

int etn_wait_for_alive ( et_sys_id id )

Referenced by et_wait_for_alive().

int etr_alive ( et_sys_id id )

References et_id_t::debug, ET_DEBUG_ERROR, et_logmsg(), ET_NET_ALIVE, et_tcp_lock(), et_tcp_unlock(), and et_id_t::sockfd.

Referenced by et_alive().

int etr_attach_geteventsdump	(	et_sys_id	id,
		et_att_id	att_id,
		uint64_t *	events
	)

References ET_NET_ATT_DUMP.

Referenced by et_attach_geteventsdump().

int etr_attach_geteventsget	(	et_sys_id	id,
		et_att_id	att_id,
		uint64_t *	events
	)

References ET_NET_ATT_GET.

Referenced by et_attach_geteventsget().

int etr_attach_geteventsmake	(	et_sys_id	id,
		et_att_id	att_id,
		uint64_t *	events
	)

References ET_NET_ATT_MAKE.

Referenced by et_attach_geteventsmake().

int etr_attach_geteventsput	(	et_sys_id	id,
		et_att_id	att_id,
		uint64_t *	events
	)

References ET_NET_ATT_PUT.

Referenced by et_attach_geteventsput().

int etr_close ( et_sys_id id )

References et_id_t::debug, ET_DEBUG_ERROR, et_id_destroy(), et_logmsg(), ET_NET_CLOSE, ET_OK, et_tcp_lock(), et_tcp_unlock(), and et_id_t::sockfd.

Referenced by et_close().

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

References et_id_t::debug, ET_DEBUG_ERROR, ET_ERROR_READ, ET_ERROR_WRITE, et_logmsg(), ET_NET_EV_DUMP, ET_OK, et_tcp_lock(), et_tcp_unlock(), et_event_t::modify, et_event_t::pdata, et_event_t::place, and et_id_t::sockfd.

Referenced by et_event_dump().

int etr_event_get	(	et_sys_id	id,
		et_att_id	att,
		et_event **	ev,
		int	wait,
		struct timespec *	deltatime
	)

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

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

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

References et_id_t::debug, ET_DEBUG_ERROR, ET_ERROR_READ, ET_ERROR_REMOTE, ET_ERROR_WRITE, et_logmsg(), ET_NET_EVS_DUMP, ET_OK, et_tcp_lock(), et_tcp_unlock(), and et_id_t::sockfd.

Referenced by et_events_dump().

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

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
	)

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
	)

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

int etr_forcedclose ( et_sys_id id )

References et_id_t::debug, ET_DEBUG_ERROR, et_id_destroy(), et_logmsg(), ET_NET_FCLOSE, ET_OK, et_tcp_lock(), et_tcp_unlock(), and et_id_t::sockfd.

Referenced by et_forcedclose().

int etr_kill ( et_sys_id id )

References et_id_t::debug, ET_DEBUG_ERROR, ET_ERROR_WRITE, et_id_destroy(), et_logmsg(), ET_NET_KILL, ET_OK, et_tcp_lock(), et_tcp_unlock(), and et_id_t::sockfd.

Referenced by et_kill().

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

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

References et_id_t::debug, ET_DEBUG_ERROR, ET_DEBUG_WARN, ET_ERROR_READ, ET_ERROR_REMOTE, ET_ERROR_WRITE, ET_IPADDRSTRLEN, et_logmsg(), ET_MAXHOSTNAMELEN, ET_NET_STAT_ATT, ET_OK, et_tcp_lock(), et_tcp_unlock(), and et_id_t::sockfd.

Referenced by et_station_attach().

int etr_station_create	(	et_sys_id	id,
		et_stat_id *	stat_id,
		const char *	stat_name,
		et_statconfig	sconfig
	)

References ET_END, and 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
	)

int etr_station_detach	(	et_sys_id	id,
		et_att_id	att
	)

References et_id_t::debug, ET_DEBUG_ERROR, ET_ERROR_READ, ET_ERROR_WRITE, et_logmsg(), ET_NET_STAT_DET, et_tcp_lock(), et_tcp_unlock(), and et_id_t::sockfd.

Referenced by et_station_detach().

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

References et_id_t::debug, ET_DEBUG_ERROR, ET_ERROR_READ, ET_ERROR_REMOTE, ET_ERROR_WRITE, et_logmsg(), ET_NET_STAT_EX, et_tcp_lock(), et_tcp_unlock(), and et_id_t::sockfd.

Referenced by et_station_exists().

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

References ET_NET_STAT_GATTS.

Referenced by et_station_getattachments().

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

References ET_NET_STAT_GBLOCK.

Referenced by et_station_getblock().

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

References et_id_t::debug, ET_DEBUG_ERROR, ET_ERROR_READ, ET_ERROR_WRITE, ET_FILENAME_LENGTH, et_logmsg(), ET_NET_STAT_CLASS, ET_OK, et_tcp_lock(), et_tcp_unlock(), and et_id_t::sockfd.

Referenced by et_station_getclass().

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

References ET_NET_STAT_GCUE.

Referenced by et_station_getcue().

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

References et_id_t::debug, ET_DEBUG_ERROR, ET_ERROR_READ, ET_ERROR_WRITE, ET_FUNCNAME_LENGTH, et_logmsg(), ET_NET_STAT_FUNC, ET_OK, et_tcp_lock(), et_tcp_unlock(), and et_id_t::sockfd.

Referenced by et_station_getfunction().

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

References ET_NET_STAT_INCNT.

Referenced by et_station_getinputcount().

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

References et_id_t::debug, ET_DEBUG_ERROR, ET_ERROR_READ, ET_ERROR_WRITE, ET_FILENAME_LENGTH, et_logmsg(), ET_NET_STAT_LIB, ET_OK, et_tcp_lock(), et_tcp_unlock(), and et_id_t::sockfd.

Referenced by et_station_getlib().

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

References ET_NET_STAT_OUTCNT.

Referenced by et_station_getoutputcount().

int etr_station_getposition	(	et_sys_id	id,
		et_stat_id	stat_id,
		int *	position,
		int *	parallelposition
	)

References et_id_t::debug, ET_DEBUG_ERROR, ET_ERROR_READ, ET_ERROR_WRITE, et_logmsg(), ET_NET_STAT_GPOS, ET_OK, et_tcp_lock(), et_tcp_unlock(), and et_id_t::sockfd.

Referenced by et_station_getposition().

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

References ET_NET_STAT_GPRE.

Referenced by et_station_getprescale().

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

References ET_NET_STAT_GRESTORE.

Referenced by et_station_getrestore().

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

References ET_NET_STAT_GSELECT.

Referenced by et_station_getselect().

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

References et_id_t::debug, ET_DEBUG_ERROR, ET_ERROR_READ, ET_ERROR_WRITE, et_logmsg(), ET_NET_STAT_GSW, ET_OK, ET_STATION_SELECT_INTS, et_tcp_lock(), et_tcp_unlock(), and et_id_t::sockfd.

Referenced by et_station_getselectwords().

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

References ET_NET_STAT_STATUS.

Referenced by et_station_getstatus().

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

References ET_NET_STAT_GUSER.

Referenced by et_station_getuser().

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

References et_id_t::debug, ET_DEBUG_ERROR, ET_ERROR_READ, ET_ERROR_WRITE, et_logmsg(), ET_NET_STAT_ISAT, et_tcp_lock(), et_tcp_unlock(), and et_id_t::sockfd.

Referenced by et_station_isattached().

int etr_station_remove	(	et_sys_id	id,
		et_stat_id	stat_id
	)

References et_id_t::debug, ET_DEBUG_ERROR, ET_ERROR_READ, ET_ERROR_WRITE, et_logmsg(), ET_NET_STAT_RM, et_tcp_lock(), et_tcp_unlock(), and et_id_t::sockfd.

Referenced by et_station_remove().

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

References ET_NET_STAT_SBLOCK.

Referenced by et_station_setblock().

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

References ET_NET_STAT_SCUE.

Referenced by et_station_setcue().

int etr_station_setposition	(	et_sys_id	id,
		et_stat_id	stat_id,
		int	position,
		int	parallelposition
	)

References et_id_t::debug, ET_DEBUG_ERROR, ET_ERROR_READ, ET_ERROR_WRITE, et_logmsg(), ET_NET_STAT_SPOS, et_tcp_lock(), et_tcp_unlock(), and et_id_t::sockfd.

Referenced by et_station_setposition().

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

References ET_NET_STAT_SPRE.

Referenced by et_station_setprescale().

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

References ET_NET_STAT_SRESTORE.

Referenced by et_station_setrestore().

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

References et_id_t::debug, ET_DEBUG_ERROR, ET_ERROR_READ, ET_ERROR_WRITE, et_logmsg(), ET_NET_STAT_SSW, ET_STATION_SELECT_INTS, et_tcp_lock(), et_tcp_unlock(), and et_id_t::sockfd.

Referenced by et_station_setselectwords().

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

References ET_NET_STAT_SUSER.

Referenced by et_station_setuser().

int etr_system_getattachments	(	et_sys_id	id,
		int *	atts
	)

References ET_NET_SYS_ATT.

Referenced by et_system_getattachments().

int etr_system_getattsmax	(	et_sys_id	id,
		int *	attsmax
	)

References ET_NET_SYS_ATTMAX.

Referenced by et_system_getattsmax().

int etr_system_getgroupcount	(	et_sys_id	id,
		int *	groupCnt
	)

References ET_NET_SYS_GRP.

Referenced by et_system_setgroup().

int etr_system_getheartbeat	(	et_sys_id	id,
		int *	heartbeat
	)

References ET_NET_SYS_HBEAT.

Referenced by et_system_getheartbeat().

int etr_system_getpid	(	et_sys_id	id,
		int *	pid
	)

References ET_NET_SYS_PID.

Referenced by et_system_getpid().

int etr_system_getprocs	(	et_sys_id	id,
		int *	procs
	)

References ET_NET_SYS_PROC.

Referenced by et_system_getprocs().

int etr_system_getprocsmax	(	et_sys_id	id,
		int *	procsmax
	)

References ET_NET_SYS_PROCMAX.

Referenced by et_system_getprocsmax().

int etr_system_getstations	(	et_sys_id	id,
		int *	stations
	)

References ET_NET_SYS_STAT.

Referenced by et_system_getstations().

int etr_system_getstationsmax	(	et_sys_id	id,
		int *	stationsmax
	)

References ET_NET_SYS_STATMAX.

Referenced by et_system_getstationsmax().

int etr_system_gettemps	(	et_sys_id	id,
		int *	temps
	)

References ET_NET_SYS_TMP.

Referenced by et_system_gettemps().

int etr_system_gettempsmax	(	et_sys_id	id,
		int *	tempsmax
	)

References ET_NET_SYS_TMPMAX.

Referenced by et_system_gettempsmax().

int etr_wait_for_alive ( et_sys_id id )

References et_id_t::debug, ET_DEBUG_ERROR, ET_ERROR_READ, ET_ERROR_WRITE, et_logmsg(), ET_NET_WAIT, ET_OK, et_tcp_lock(), et_tcp_unlock(), and et_id_t::sockfd.

Referenced by et_wait_for_alive().

int etr_wakeup_all	(	et_sys_id	id,
		et_stat_id	stat_id
	)

References et_id_t::debug, ET_DEBUG_ERROR, ET_ERROR_WRITE, et_logmsg(), ET_NET_WAKE_ALL, ET_OK, et_tcp_lock(), et_tcp_unlock(), and et_id_t::sockfd.

Referenced by et_wakeup_all().

int etr_wakeup_attachment	(	et_sys_id	id,
		et_att_id	att
	)

References et_id_t::debug, ET_DEBUG_ERROR, ET_ERROR_WRITE, et_logmsg(), ET_NET_WAKE_ATT, ET_OK, et_tcp_lock(), et_tcp_unlock(), and et_id_t::sockfd.

Referenced by et_wakeup_attachment().

et_private.h File Reference

Data Structures

Defines

Typedefs

Functions

Define Documentation

Typedef Documentation

Function Documentation