---

/MbsAPI/f_evt_old.h

Go to the documentation of this file.

//---------------------------------------------------------------
//        Go4 Release Package v2.10-5 (build 21005) 
//                      03-Nov-2005
//---------------------------------------------------------------
//       The GSI Online Offline Object Oriented (Go4) Project
//       Experiment Data Processing at DVEE department, GSI
//---------------------------------------------------------------
//
//Copyright (C) 2000- Gesellschaft f. Schwerionenforschung, GSI
//                    Planckstr. 1, 64291 Darmstadt, Germany
//Contact:            http://go4.gsi.de
//----------------------------------------------------------------
//This software can be used under the license agreements as stated
//in Go4License.txt file which is part of the distribution.
//----------------------------------------------------------------
/*****************  f_evt.h ******************************/
#include "typedefs.h"

#ifndef GETEVT
#define GETEVT


#ifdef GSI__WINNT
#include <stdio.h>
#include <stdlib.h>
#include <fcntl.h>
#include <string.h>
#include <memory.h>
#include <sys/timeb.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#define DEF_FILE_ACCE S_IREAD|S_IWRITE  /* rw */
#define GET__OPEN_FLAG O_RDONLY
#define PUT__OPEN_APD_FLAG O_RDWR|O_APPEND
#define PUT__CRT_FLAG O_CREAT|O_RDWR
#define PUT__CRT_OPT ""

#include <winsock.h>
#define    WS_VERSION_REQD     0x0101
#define    WS_VERSION_MAJOR    HIBYTE(WS_VERSION_REQD)
#define    WS_VERSION_MINOR    LOBYTE(WS_VERSION_REQD)
#define    MIN_SOCKETS_REQD    6
WSADATA    wsaData;
#endif




#ifdef Linux /* Linux */
#include <stdio.h>
#include <stdlib.h>
#include <fcntl.h>
#include <string.h>
#include <unistd.h>
#include <memory.h>
#include <pwd.h>
#include <sys/time.h>
#include <sys/timeb.h>
#include <sys/types.h>
#include <sys/stat.h>
#define DEF_FILE_ACCE S_IRUSR|S_IWUSR|S_IRGRP|S_IROTH  /* rw-r--r-- */
#define GET__OPEN_FLAG O_RDONLY
#define PUT__OPEN_APD_FLAG O_RDWR|O_APPEND
#define PUT__CRT_FLAG O_CREAT|O_RDWR
#define PUT__CRT_OPT ""
#endif

#ifdef _AIX
#include <stdio.h>
#include <stdlib.h>
#include <fcntl.h>
#include <string.h>
#include <unistd.h>
#include <memory.h>
#include <pwd.h>
#include <sys/time.h>
#include <sys/timeb.h>
#include <sys/types.h>
#include <sys/mode.h>
#define DEF_FILE_ACCE S_IRUSR|S_IWUSR|S_IRGRP|S_IROTH  /* rw-r--r-- */
#define GET__OPEN_FLAG O_RDONLY
#define PUT__OPEN_APD_FLAG O_RDWR|O_APPEND
#define PUT__CRT_FLAG O_CREAT|O_RDWR
#define PUT__CRT_OPT ""
#endif

#ifdef VMS
#include <unixio.h>
#include <unixlib.h>
#include <file.h>
#include <stdio.h>
#include <stdlib.h>
#include <fcntl.h>
#include <string.h>
#include <sys/time.h>
#include <sys/timeb.h>
#include <sys/types.h>
#include <unistd.h>
#define DEF_FILE_ACCE 644          /* rw-r--r-- */
#define GET__OPEN_FLAG O_RDONLY
#define PUT__OPEN_APD_FLAG O_RDWR|O_APPEND
#define PUT__CRT_FLAG O_CREAT|O_WRONLY
#define PUT__CRT_OPT "rfm=fix"
#endif

#define MAX_BUF_LGTH 32768
#define MIN_BUF_LGTH 512
#define MAX_BUFS_IN_STREAM 100    /* at a maximum, 100 buffers per stream */
#define MAX_LONG 99999999         /* maximum long data */

struct s_evt_channel
{
   INTS4    l_server_type;    /* number specifying input source */
   INTS4    l_buf_type;       /* buffer type number               */
   INTS4    l_buf_subtype;    /* buffer subtype number            */
   INTS4    l_channel_no;     /* file descripter or server No.    */
   INTS4    l_buf_size;       /* buffer size                      */
   INTS4    l_buf_no;
   INTS4    l_buf_posi;
   INTS4    l_buf_lmt;
   INTS4    l_bufs_in_stream; /* # of buffers per stream          */
   INTS4    l_stream_bufs;
   INTS4    l_io_buf_size;    /* I/O buffer size=l_buf_size*l_bufs_in_stream */
   INTS4    l_io_buf_posi;
   INTS4    l_evt_buf_size;   /* internal buffer size             */
   INTS4    l_evt_buf_posi;
   INTS4    l_evt_size;
   INTS4    l_events;         /* events since open             */
   INTS4    l_buffers;        /* buffers since open             */
   INTS4    l_kbytes;         /* kbytes since open             */
   INTS4    l_first_get;
   INTS4    l_first_put;
   INTS4    l_first_buf;
   INTS4    l_frag_len;
   CHARS    *pc_io_buf;       /* pointer to I/O buffer to server  */
   CHARS    *pc_evt_buf;      /* pointer to internal event buffer */
   s_bufhe  *ps_bufhe;
   s_ve10_1 *ps_ve10_1;
   CHARS    c_channel[128];   /* channel name */
} ;

INTS4 f_evt_get_open(INTS4, CHARS *, s_evt_channel *, CHARS **, INTS4, INTS4);
INTS4 f_evt_get_event(s_evt_channel *, INTS4 **, INTS4 **);
INTS4 f_evt_get_buffer(s_evt_channel *, INTS4 *);
INTS4 f_evt_get_close(s_evt_channel *);
INTS4 f_evt_put_open(CHARS *,INTS4,INTS4,INTS4,INTS4,s_evt_channel *,CHARS *);
INTS4 f_evt_put_event(s_evt_channel *, INTS4 *);
INTS4 f_evt_put_buffer(s_evt_channel *, s_bufhe *);
INTS4 f_evt_put_close(s_evt_channel *);
INTS4 f_evt_error( INTS4 , CHARS * , INTS4 );
INTS4 f_evt_swap(CHARS *, INTS4);

/* ******************************/
/*  Input selector              */
/* ******************************/
#define GETEVT__FILE     1
#define GETEVT__STREAM   2
#define GETEVT__TRANS    3
#define GETEVT__EVENT    4
#define GETEVT__REVSERV  5
/* ********************************************************************** */
/*                   error messages                                       */
/* ********************************************************************** */
#define GETEVT__SUCCESS     0
#define GETEVT__FAILURE     1
#define GETEVT__FRAGMENT    2
#define GETEVT__NOMORE      3
#define GETEVT__NOFILE      4
#define GETEVT__NOSERVER    5
#define GETEVT__RDERR       6
#define GETEVT__CLOSE_ERR   7
#define GETEVT__NOCHANNEL   8

#define PUTEVT__SUCCESS     0
#define PUTEVT__FILE_EXIST  11
#define PUTEVT__FAILURE     12
#define PUTEVT__TOOBIG      13
#define PUTEVT__TOO_SMALLS  14
#define PUTEVT__CLOSE_ERR   15
#define PUTEVT__WRERR       16
#define PUTEVT__NOCHANNEL   17

#endif
/*****************  End f_evt.h ******************************/


//----------------------------END OF GO4 SOURCE FILE ---------------------

---