et.h

Go to the documentation of this file.

/*----------------------------------------------------------------------------*
 *  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_H_
#define _ET_H_

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <pthread.h>
#include <stdint.h>


#define INET_ATON_ERR   0
#include <inttypes.h>


#ifdef  __cplusplus
extern "C" {
#endif


/*********************************************************************/
/*            The following default values may be changed            */
/*********************************************************************/
/* station stuff */
#define ET_STATION_CUE      10   
#define ET_STATION_PRESCALE 1    
/* system stuff */
#define ET_SYSTEM_EVENTS    300  
#define ET_SYSTEM_NTEMPS    300  
#define ET_SYSTEM_ESIZE     1000 
#define ET_SYSTEM_NSTATS    200  
/* network stuff */
#define ET_UDP_PORT        11111 
#define ET_SERVER_PORT     11111 
#define ET_MULTICAST_PORT  11111 
#define ET_BROADCAST_PORT  11111 
#define ET_MULTICAST_ADDR  "239.200.0.0"    
#define ET_EVENT_GROUPS_MAX 200 
/*********************************************************************/
/*                              WARNING                              */
/* Changing ET_STATION_SELECT_INTS requires a full recompile of all  */
/* ET libraries (local & remote) whose users interact in any way.    */
/*********************************************************************/

#define ET_STATION_SELECT_INTS 6

/*********************************************************************/
/*             DO NOT CHANGE ANYTHING BELOW THIS LINE !!!            */
/*********************************************************************/

#define ET_MULTICAST_TTL   32

/* ET server is on host that is ... */
#define ET_HOST_LOCAL      ".local"      
#define ET_HOST_REMOTE     ".remote"     
#define ET_HOST_ANYWHERE   ".anywhere"   
/* Treat local ET server as local or remote? */
#define ET_HOST_AS_LOCAL   1  
#define ET_HOST_AS_REMOTE  0  
/* Policy to pick a single responder from many after broad/multicast */
#define ET_POLICY_FIRST  0   
#define ET_POLICY_LOCAL  1   
#define ET_POLICY_ERROR  2   
/* Name lengths */
#define ET_FILENAME_LENGTH  100 
#define ET_FUNCNAME_LENGTH  48  
#define ET_STATNAME_LENGTH  48  
#define ET_TEMPNAME_LENGTH  (ET_FILENAME_LENGTH+12)

/*----------------*/
/* Station stuff. */
/*----------------*/

#define ET_GRANDCENTRAL 0  
/* Station status. */
#define ET_STATION_UNUSED   0            
#define ET_STATION_CREATING 1            
#define ET_STATION_IDLE     2            
#define ET_STATION_ACTIVE   3            
/* How many user process can attach */
#define ET_STATION_USER_MULTI  0         
#define ET_STATION_USER_SINGLE 1         
/* Can block for event flow or not */
#define ET_STATION_NONBLOCKING 0         
#define ET_STATION_BLOCKING    1         
/* Criterion for event selection */
#define ET_STATION_SELECT_ALL      1     
#define ET_STATION_SELECT_MATCH    2     
#define ET_STATION_SELECT_USER     3     
#define ET_STATION_SELECT_RROBIN   4     
#define ET_STATION_SELECT_EQUALCUE 5     
/* How to restore events in dead user process */
#define ET_STATION_RESTORE_OUT 0        
#define ET_STATION_RESTORE_IN  1        
#define ET_STATION_RESTORE_GC  2        
#define ET_STATION_RESTORE_REDIST 3     
/* How events flow through a (group of) station(s) */
#define ET_STATION_SERIAL        0      
#define ET_STATION_PARALLEL      1      
#define ET_STATION_PARALLEL_HEAD 2      
#define ET_OK              0   
#define ET_ERROR          -1   
#define ET_ERROR_TOOMANY  -2   
#define ET_ERROR_EXISTS   -3   
#define ET_ERROR_WAKEUP   -4   
#define ET_ERROR_TIMEOUT  -5   
#define ET_ERROR_EMPTY    -6   
#define ET_ERROR_BUSY     -7   
#define ET_ERROR_DEAD     -8   
#define ET_ERROR_READ     -9   
#define ET_ERROR_WRITE    -10  
#define ET_ERROR_REMOTE   -11  
#define ET_ERROR_NOREMOTE -12  
#define ET_ERROR_TOOBIG   -13  
#define ET_ERROR_NOMEM    -14  
#define ET_ERROR_BADARG   -15  
#define ET_ERROR_SOCKET   -16  
#define ET_ERROR_NETWORK  -17  
#define ET_ERROR_CLOSED   -18  
#define ET_ERROR_JAVASYS  -19  
/* Debug levels */
#define ET_DEBUG_NONE   0   
#define ET_DEBUG_SEVERE 1   
#define ET_DEBUG_ERROR  2   
#define ET_DEBUG_WARN   3   
#define ET_DEBUG_INFO   4   
/* Event priority */
#define ET_LOW  0           
#define ET_HIGH 1           
#define ET_PRIORITY_MASK 1  
#define ET_SYS -1

#define ET_END -1

#define ET_NEWHEAD -2

/* Event is temporary or not */
#define ET_EVENT_TEMP   1    
#define ET_EVENT_NORMAL 0    
/* Event is new (obtained thru et_event(s)_new) or not */
#define ET_EVENT_NEW  1      
#define ET_EVENT_USED 0      
/* Event get/new routines' wait mode flags */
#define ET_SLEEP  0          
#define ET_TIMED  1          
#define ET_ASYNC  2          
#define ET_WAIT_MASK  3      
/* event get/new routines' event flow flags */
#define ET_MODIFY 4          
#define ET_MODIFY_HEADER 8   
#define ET_DUMP          16  
#define ET_NOALLOC       32  
/* et_open waiting modes */
#define ET_OPEN_NOWAIT 0    
#define ET_OPEN_WAIT   1    
/* Are we remote or local? */
#define ET_REMOTE        0  
#define ET_LOCAL         1  
#define ET_LOCAL_NOSHARE 2  
/* Use broadcast, multicast, both or direct connection to find server port */
#define ET_MULTICAST 0          
#define ET_BROADCAST 1          
#define ET_DIRECT    2          
#define ET_BROADANDMULTICAST 3  
/* Options for et_open_config_add(remove)broadcast */
#define ET_SUBNET_ALL  ".subnetsAll"     
/* Status of data in an event */
#define ET_DATA_OK               0  
#define ET_DATA_CORRUPT          1  
#define ET_DATA_POSSIBLY_CORRUPT 2  
#define ET_DATA_MASK         0x30   
#define ET_DATA_SHIFT        4      
/* Endian values */
#define ET_ENDIAN_BIG      0    
#define ET_ENDIAN_LITTLE   1    
#define ET_ENDIAN_LOCAL    2    
#define ET_ENDIAN_NOTLOCAL 3    
#define ET_ENDIAN_SWITCH   4    
/* do we swap data or not? */
#define ET_NOSWAP 0  
#define ET_SWAP   1  
/* Macros for swapping ints of various sizes */

#define ET_SWAP16(x) \
    ((uint16_t)((((uint16_t)(x)) >> 8) | \
                (((uint16_t)(x)) << 8)))

#define ET_SWAP32(x) \
    ((uint32_t)((((uint32_t)(x)) >> 24) | \
                (((uint32_t)(x) & 0x00ff0000) >>  8) | \
                (((uint32_t)(x) & 0x0000ff00) <<  8) | \
                (((uint32_t)(x)) << 24)))

#define ET_SWAP64(x) \
    ((uint64_t)((((uint64_t)(x)) >> 56) | \
                (((uint64_t)(x) & 0x00ff000000000000ULL) >> 40) | \
                (((uint64_t)(x) & 0x0000ff0000000000ULL) >> 24) | \
                (((uint64_t)(x) & 0x000000ff00000000ULL) >>  8) | \
                (((uint64_t)(x) & 0x00000000ff000000ULL) <<  8) | \
                (((uint64_t)(x) & 0x0000000000ff0000ULL) << 24) | \
                (((uint64_t)(x) & 0x000000000000ff00ULL) << 40) | \
                (((uint64_t)(x)) << 56)))



#define err_abort(code,text) do { \
    fprintf (stderr, "%s at \"%s\":%d: %s\n", \
        text, __FILE__, __LINE__, strerror (code)); \
    exit (-1); \
} while (0)


/* STRUCTURES */

typedef struct et_event_t {
  struct et_event_t *next;  
  void    *tempdata;        
  void    *pdata;           
  char    *data;            
  uint64_t length;          
  uint64_t memsize;         
  /* for remote events */
  uint64_t pointer;        
  int      modify;         
  /* ----------------- */

  int     priority;        
  int     owner;           
  int     temp;            
  int     age;             
  int     datastatus;      
  int     byteorder;       
  int     group;           
  int     place;           
  int     control[ET_STATION_SELECT_INTS];  
  char    filename[ET_TEMPNAME_LENGTH];     
} et_event;

typedef int (*ET_SWAP_FUNCPTR) (et_event *, et_event*, int, int);

/* TYPES */
typedef void *et_sys_id;        
typedef void *et_statconfig;    
typedef void *et_sysconfig;     
typedef void *et_openconfig;    
typedef void *et_bridgeconfig;  
typedef int   et_stat_id;       
typedef int   et_proc_id;       
typedef int   et_att_id;        
/***********************/
/* Extern declarations */
/***********************/

/* event functions */
extern int  et_event_new(et_sys_id id, et_att_id att, et_event **pe,  
                         int mode, struct timespec *deltatime, size_t size);
extern int  et_events_new(et_sys_id id, et_att_id att, et_event *pe[], 
                          int mode, struct timespec *deltatime, size_t size, 
                          int num, int *nread);
extern int  et_event_new_group(et_sys_id id, et_att_id att, et_event **pe,
                               int mode, struct timespec *deltatime,
                               size_t size, int group);
extern int  et_events_new_group(et_sys_id id, et_att_id att, et_event *pe[],
                                int mode, struct timespec *deltatime,
                                size_t size, int num, int group, int *nread);

extern int  et_event_get(et_sys_id id, et_att_id att, et_event **pe,  
                         int mode, struct timespec *deltatime);
extern int  et_events_get(et_sys_id id, et_att_id att, et_event *pe[], 
                          int mode, struct timespec *deltatime, 
                          int num, int *nread);

extern int  et_event_put(et_sys_id id, et_att_id att, et_event *pe);
extern int  et_events_put(et_sys_id id, et_att_id att, et_event *pe[], 
                          int num);
               
extern int  et_event_dump(et_sys_id id, et_att_id att, et_event *pe);
extern int  et_events_dump(et_sys_id id, et_att_id att, et_event *pe[],
               int num);

extern int  et_event_getgroup(et_event *pe, int *grp);

extern int  et_event_setpriority(et_event *pe, int pri);
extern int  et_event_getpriority(et_event *pe, int *pri);

extern int  et_event_setlength(et_event *pe, size_t len);
extern int  et_event_getlength(et_event *pe, size_t *len);

extern int  et_event_setcontrol(et_event *pe, int con[], int num);
extern int  et_event_getcontrol(et_event *pe, int con[]);

extern int  et_event_setdatastatus(et_event *pe, int datastatus);
extern int  et_event_getdatastatus(et_event *pe, int *datastatus);

extern int  et_event_setendian(et_event *pe, int endian);
extern int  et_event_getendian(et_event *pe, int *endian);

extern int  et_event_getdata(et_event *pe, void **data);
extern int  et_event_setdatabuffer(et_sys_id id, et_event *pe, void *data);
extern int  et_event_needtoswap(et_event *pe, int *swap);

/* system functions */
extern int  et_open(et_sys_id* id, const char *filename, et_openconfig openconfig);
extern int  et_close(et_sys_id id);
extern int  et_forcedclose(et_sys_id id);
extern int  et_kill(et_sys_id id);
extern int  et_system_start(et_sys_id* id, et_sysconfig sconfig);
extern int  et_system_close(et_sys_id id);
extern int  et_alive(et_sys_id id);
extern int  et_wait_for_alive(et_sys_id id);
extern char* et_perror(int err);

/* attachment functions */
extern int  et_wakeup_attachment(et_sys_id id, et_att_id att);
extern int  et_wakeup_all(et_sys_id id, et_stat_id stat_id);
extern int  et_attach_geteventsput(et_sys_id id, et_att_id att_id,
                                   uint64_t *events);
extern int  et_attach_geteventsget(et_sys_id id, et_att_id att_id,
                                   uint64_t *events);
extern int  et_attach_geteventsdump(et_sys_id id, et_att_id att_id,
                                    uint64_t *events);
extern int  et_attach_geteventsmake(et_sys_id id, et_att_id att_id,
                                    uint64_t *events);

/* station manipulation */
extern int  et_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  et_station_create(et_sys_id id, et_stat_id *stat_id,
                  const char *stat_name, et_statconfig sconfig);
extern int  et_station_remove(et_sys_id id, et_stat_id stat_id);
extern int  et_station_attach(et_sys_id id, et_stat_id stat_id,
                              et_att_id *att);
extern int  et_station_detach(et_sys_id id, et_att_id att);
extern int  et_station_setposition(et_sys_id id, et_stat_id stat_id, int position,
                                   int parallelposition);
extern int  et_station_getposition(et_sys_id id, et_stat_id stat_id, int *position,
                                   int *parallelposition);

/***************************************************************/
/* routines to store and read station config parameters used  */
/* to define a station upon its creation.                     */
/***************************************************************/
extern int et_station_config_init(et_statconfig* sconfig);
extern int et_station_config_destroy(et_statconfig sconfig);

extern int et_station_config_setblock(et_statconfig sconfig, int val);
extern int et_station_config_getblock(et_statconfig sconfig, int *val);

extern int et_station_config_setflow(et_statconfig sconfig, int val);
extern int et_station_config_getflow(et_statconfig sconfig, int *val);

extern int et_station_config_setselect(et_statconfig sconfig, int val);
extern int et_station_config_getselect(et_statconfig sconfig, int *val);

extern int et_station_config_setuser(et_statconfig sconfig, int val);
extern int et_station_config_getuser(et_statconfig sconfig, int *val);

extern int et_station_config_setrestore(et_statconfig sconfig, int val);
extern int et_station_config_getrestore(et_statconfig sconfig, int *val);

extern int et_station_config_setcue(et_statconfig sconfig, int val);
extern int et_station_config_getcue(et_statconfig sconfig, int *val);

extern int et_station_config_setprescale(et_statconfig sconfig, int val);
extern int et_station_config_getprescale(et_statconfig sconfig, int *val);

extern int et_station_config_setselectwords(et_statconfig sconfig, int val[]);
extern int et_station_config_getselectwords(et_statconfig sconfig, int val[]);

extern int et_station_config_setfunction(et_statconfig sconfig, const char *val);
extern int et_station_config_getfunction(et_statconfig sconfig, char *val);

extern int et_station_config_setlib(et_statconfig sconfig, const char *val);
extern int et_station_config_getlib(et_statconfig sconfig, char *val);

extern int et_station_config_setclass(et_statconfig sconfig, const char *val);
extern int et_station_config_getclass(et_statconfig sconfig, char *val);

/**************************************************************/
/*     routines to get & set existing station's parameters    */
/**************************************************************/
extern int et_station_isattached(et_sys_id id, et_stat_id stat_id, et_att_id att);
extern int et_station_exists(et_sys_id id, et_stat_id *stat_id, const char *stat_name);
extern int et_station_name_to_id(et_sys_id id, et_stat_id *stat_id, const char *stat_name);

extern int et_station_getattachments(et_sys_id id, et_stat_id stat_id, int *numatts);
extern int et_station_getstatus(et_sys_id id, et_stat_id stat_id, int *status);
extern int et_station_getinputcount(et_sys_id id, et_stat_id stat_id, int *cnt);
extern int et_station_getoutputcount(et_sys_id id, et_stat_id stat_id, int *cnt);
extern int et_station_getselect(et_sys_id id, et_stat_id stat_id, int *select);
extern int et_station_getlib(et_sys_id id, et_stat_id stat_id, char *lib);
extern int et_station_getclass(et_sys_id id, et_stat_id stat_id, char *classs);
extern int et_station_getfunction(et_sys_id id, et_stat_id stat_id, 
                                  char *function);

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

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

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

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

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

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


/*************************************************************/
/* routines to store and read system config parameters used  */
/* to define a system upon its creation.                     */
/*************************************************************/
extern int et_system_config_init(et_sysconfig *sconfig);
extern int et_system_config_destroy(et_sysconfig sconfig);

extern int et_system_config_setevents(et_sysconfig sconfig, int val);
extern int et_system_config_getevents(et_sysconfig sconfig, int *val);

extern int et_system_config_setsize(et_sysconfig sconfig, size_t val);
extern int et_system_config_getsize(et_sysconfig sconfig, size_t *val);

extern int et_system_config_settemps(et_sysconfig sconfig, int val);
extern int et_system_config_gettemps(et_sysconfig sconfig, int *val);

extern int et_system_config_setstations(et_sysconfig sconfig, int val);
extern int et_system_config_getstations(et_sysconfig sconfig, int *val);

extern int et_system_config_setprocs(et_sysconfig sconfig, int val);
extern int et_system_config_getprocs(et_sysconfig sconfig, int *val);

extern int et_system_config_setattachments(et_sysconfig sconfig, int val);
extern int et_system_config_getattachments(et_sysconfig sconfig, int *val);

extern int et_system_config_setgroups(et_sysconfig sconfig, int groups[], int size);

extern int et_system_config_setfile(et_sysconfig sconfig, const char *val);
extern int et_system_config_getfile(et_sysconfig sconfig, char *val);

/* does nothing, only here for backwards compatibility
extern int et_system_config_setcast(et_sysconfig sconfig, int val);
extern int et_system_config_getcast(et_sysconfig sconfig, int *val);
*/

extern int et_system_config_setport(et_sysconfig sconfig, int val);
extern int et_system_config_getport(et_sysconfig sconfig, int *val);

extern int et_system_config_setserverport(et_sysconfig sconfig, int val);
extern int et_system_config_getserverport(et_sysconfig sconfig, int *val);

/* deprecated, use ...addmulticast and ...removemulticast instead
extern int et_system_config_setaddress(et_sysconfig sconfig, const char *val);
extern int et_system_config_getaddress(et_sysconfig sconfig, char *val);
*/

extern int et_system_config_addmulticast(et_sysconfig sconfig, const char *val);
extern int et_system_config_removemulticast(et_sysconfig sconfig, const char *val);

extern int et_system_config_settcp(et_sysconfig sconfig, int rBufSize, int sBufSize, int noDelay);
extern int et_system_config_gettcp(et_sysconfig sconfig, int *rBufSize, int *sBufSize, int *noDelay);

/*************************************************************/
/*      routines to store & read system information          */
/*************************************************************/
extern int et_system_setgroup(et_sys_id id, int  group);
extern int et_system_getgroup(et_sys_id id, int *group);
extern int et_system_setdebug(et_sys_id id, int  debug);
extern int et_system_getdebug(et_sys_id id, int *debug);
extern int et_system_getlocality(et_sys_id id, int *locality);
extern int et_system_getnumevents(et_sys_id id, int *numevents);
extern int et_system_geteventsize(et_sys_id id, size_t *eventsize);
extern int et_system_gettempsmax(et_sys_id id, int *tempsmax);
extern int et_system_getstationsmax(et_sys_id id, int *stationsmax);
extern int et_system_getprocsmax(et_sys_id id, int *procsmax);
extern int et_system_getattsmax(et_sys_id id, int *attsmax);
extern int et_system_getheartbeat(et_sys_id id, int *heartbeat);
extern int et_system_getpid(et_sys_id id, pid_t *pid);
extern int et_system_getprocs(et_sys_id id, int *procs);
extern int et_system_getattachments(et_sys_id id, int *atts);
extern int et_system_getstations(et_sys_id id, int *stations);
extern int et_system_gettemps(et_sys_id id, int *temps);
extern int et_system_getserverport(et_sys_id id, int *port);
extern int et_system_gethost(et_sys_id id, char *host);
extern int et_system_getlocaladdress(et_sys_id id, char *address);

/*************************************************************/
/* routines to store and read system config parameters used  */
/* to open an ET system                                      */
/*************************************************************/
extern int et_open_config_init(et_openconfig *sconfig);
extern int et_open_config_destroy(et_openconfig sconfig);

extern int et_open_config_setwait(et_openconfig sconfig, int val);
extern int et_open_config_getwait(et_openconfig sconfig, int *val);

extern int et_open_config_setcast(et_openconfig sconfig, int val);
extern int et_open_config_getcast(et_openconfig sconfig, int *val);

extern int et_open_config_setTTL(et_openconfig sconfig, int val);
extern int et_open_config_getTTL(et_openconfig sconfig, int *val);

extern int et_open_config_setmode(et_openconfig sconfig, int val);
extern int et_open_config_getmode(et_openconfig sconfig, int *val);

extern int et_open_config_setdebugdefault(et_openconfig sconfig, int val);
extern int et_open_config_getdebugdefault(et_openconfig sconfig, int *val);

extern int et_open_config_setport(et_openconfig sconfig, int val);
extern int et_open_config_getport(et_openconfig sconfig, int *val);

extern int et_open_config_setserverport(et_openconfig sconfig, int val);
extern int et_open_config_getserverport(et_openconfig sconfig, int *val);

extern int et_open_config_settimeout(et_openconfig sconfig, struct timespec val);
extern int et_open_config_gettimeout(et_openconfig sconfig, struct timespec *val);

/* deprecated, use ...addbroadcast, ...addmulticast, etc. instead */
extern int et_open_config_setaddress(et_openconfig sconfig, const char *val);
extern int et_open_config_getaddress(et_openconfig sconfig, char *val);

extern int et_open_config_sethost(et_openconfig sconfig, const char *val);
extern int et_open_config_gethost(et_openconfig sconfig, char *val);

extern int et_open_config_addbroadcast(et_openconfig sconfig, const char *val);
extern int et_open_config_removebroadcast(et_openconfig sconfig, const char *val);

extern int et_open_config_addmulticast(et_openconfig sconfig, const char *val);
extern int et_open_config_removemulticast(et_openconfig sconfig, const char *val);

extern int et_open_config_setpolicy(et_openconfig sconfig, int val);
extern int et_open_config_getpolicy(et_openconfig sconfig, int *val);

extern int et_open_config_setinterface(et_openconfig sconfig, const char *val);
extern int et_open_config_getinterface(et_openconfig sconfig, char *val);

extern int et_open_config_settcp(et_openconfig sconfig, int rBufSize, int sBufSize, int noDelay);
extern int et_open_config_gettcp(et_openconfig sconfig, int *rBufSize, int *sBufSize, int *noDelay);


/*************************************************************
 * routines to store and read system bridge parameters used  *
 * to bridge (transfer events between) 2 ET systems          *
 *************************************************************/
extern int et_bridge_config_init(et_bridgeconfig *config);
extern int et_bridge_config_destroy(et_bridgeconfig sconfig);

extern int et_bridge_config_setmodefrom(et_bridgeconfig config, int val);
extern int et_bridge_config_getmodefrom(et_bridgeconfig config, int *val);

extern int et_bridge_config_setmodeto(et_bridgeconfig config, int val);
extern int et_bridge_config_getmodeto(et_bridgeconfig config, int *val);

extern int et_bridge_config_setchunkfrom(et_bridgeconfig config, int val);
extern int et_bridge_config_getchunkfrom(et_bridgeconfig config, int *val);

extern int et_bridge_config_setchunkto(et_bridgeconfig config, int val);
extern int et_bridge_config_getchunkto(et_bridgeconfig config, int *val);

extern int et_bridge_config_settimeoutfrom(et_bridgeconfig config, struct timespec val);
extern int et_bridge_config_gettimeoutfrom(et_bridgeconfig config, struct timespec *val);

extern int et_bridge_config_settimeoutto(et_bridgeconfig config, struct timespec val);
extern int et_bridge_config_gettimeoutto(et_bridgeconfig config, struct timespec *val);

extern int et_bridge_config_setfunc(et_bridgeconfig config, ET_SWAP_FUNCPTR func);

extern int et_events_bridge(et_sys_id id_from, et_sys_id id_to,
             et_att_id att_from, et_att_id att_to,
             et_bridgeconfig bconfig,
             int num, int *ntransferred);

#ifdef  __cplusplus
}
#endif

#endif