f_evt.h File Reference

#include "typedefs.h"
#include "s_ve10_1.h"
#include "s_ves10_1.h"
#include "s_evhe.h"
#include "s_bufhe.h"

Go to the source code of this file.

Data Structures
struct	s_evt_channel
struct	s_tag
struct	s_taghe

Macros
#define	GETEVT__CLOSE_ERR   7
#define	GETEVT__EVENT   4
#define	GETEVT__FAILURE   1
#define	GETEVT__FILE   1
#define	GETEVT__FRAGMENT   2
#define	GETEVT__NOCHANNEL   8
#define	GETEVT__NOFILE   4
#define	GETEVT__NOLMDFILE   14
#define	GETEVT__NOMORE   3
#define	GETEVT__NOSERVER   5
#define	GETEVT__NOTAG   11
#define	GETEVT__NOTAGFILE   10
#define	GETEVT__RDERR   6
#define	GETEVT__REVSERV   5
#define	GETEVT__RFIO   6
#define	GETEVT__STREAM   2
#define	GETEVT__SUCCESS   0
#define	GETEVT__TAGINDEX   10
#define	GETEVT__TAGNUMBER   11
#define	GETEVT__TAGRDERR   12
#define	GETEVT__TAGWRERR   13
#define	GETEVT__TIMEOUT   9
#define	GETEVT__TRANS   3
#define	MAX_BUF_LGTH   32768
#define	MAX_BUFS_IN_STREAM   100 /* at a maximum, 100 buffers per stream */
#define	MAX_LONG   99999999 /* maximum long data */
#define	MIN_BUF_LGTH   512
#define	PUTEVT__CLOSE_ERR   105
#define	PUTEVT__FAILURE   102
#define	PUTEVT__FILE_EXIST   101
#define	PUTEVT__NOCHANNEL   107
#define	PUTEVT__SUCCESS   0
#define	PUTEVT__TOO_SMALLS   104
#define	PUTEVT__TOOBIG   103
#define	PUTEVT__WRERR   106

Functions
s_evt_channel *	f_evt_control (void)
INTS4	f_evt_cre_tagfile (CHARS *, CHARS *, INTS4(*)(s_ve10_1 *))
INTS4	f_evt_error (INTS4, CHARS *, INTS4)
INTS4	f_evt_get_buffer (s_evt_channel *, INTS4 *)
CHARS *	f_evt_get_buffer_ptr (s_evt_channel *)
INTS4	f_evt_get_close (s_evt_channel *)
INTS4	f_evt_get_event (s_evt_channel *, INTS4 **, INTS4 **)
INTS4	f_evt_get_open (INTS4, CHARS *, s_evt_channel *, CHARS **, INTS4, INTS4)
INTS4	f_evt_get_subevent (s_ve10_1 *, INTS4, INTS4 **, INTS4 **, INTS4 *)
INTS4	f_evt_get_tagclose (s_evt_channel *)
INTS4	f_evt_get_tagevent (s_evt_channel *, INTS4, INTS4, INTS4 **)
INTS4	f_evt_get_tagnext (s_evt_channel *, INTS4, INTS4 **)
INTS4	f_evt_get_tagopen (s_evt_channel *, CHARS *, CHARS *, CHARS **, INTS4)
INTS4	f_evt_put_buffer (s_evt_channel *, s_bufhe *)
INTS4	f_evt_put_close (s_evt_channel *)
INTS4	f_evt_put_event (s_evt_channel *, INTS4 *)
INTS4	f_evt_put_open (CHARS *, INTS4, INTS4, INTS4, INTS4, s_evt_channel *, CHARS *)
INTS4	f_evt_rev_port (INTS4)
INTS4	f_evt_skip_buffer (s_evt_channel *, INTS4)
INTS4	f_evt_source_port (INTS4 l_port)
INTS4	f_evt_swap (CHARS *, INTS4)
INTS4	f_evt_timeout (s_evt_channel *, INTS4)
INTS4	f_evt_type (s_bufhe *, s_evhe *, INTS4, INTS4, INTS4, INTS4)

Macro Definition Documentation

GETEVT__CLOSE_ERR

#define GETEVT__CLOSE_ERR   7

Definition at line 138 of file f_evt.h.

Referenced by f_evt_error(), and f_evt_get_close().

GETEVT__EVENT

#define GETEVT__EVENT   4

Definition at line 123 of file f_evt.h.

Referenced by TGo4MbsEventServer::TGo4MbsEventServer(), TGo4MbsEventServer::TGo4MbsEventServer(), f_evt_get_buffer(), f_evt_get_close(), f_evt_get_event(), f_evt_get_newbuf(), f_evt_get_open(), f_evt_skip_buffer(), TGo4MbsSource::NextEvent(), and TGo4MbsSource::Open().

GETEVT__FAILURE

#define GETEVT__FAILURE   1

Definition at line 132 of file f_evt.h.

Referenced by f_evt_error(), f_evt_get_buffer(), f_evt_get_event(), f_evt_get_newbuf(), f_evt_get_subevent(), and f_evt_skip_buffer().

GETEVT__FILE

#define GETEVT__FILE   1

Definition at line 120 of file f_evt.h.

Referenced by TGo4MbsFile::TGo4MbsFile(), TGo4MbsFile::TGo4MbsFile(), f_evt_get_buffer(), f_evt_get_close(), f_evt_get_event(), f_evt_get_newbuf(), f_evt_get_open(), f_evt_get_tagopen(), f_evt_skip_buffer(), and TGo4MbsSource::Open().

GETEVT__FRAGMENT

#define GETEVT__FRAGMENT   2

Definition at line 133 of file f_evt.h.

Referenced by f_evt_error(), and f_evt_get_event().

GETEVT__NOCHANNEL

#define GETEVT__NOCHANNEL   8

Definition at line 139 of file f_evt.h.

Referenced by f_evt_error().

GETEVT__NOFILE

#define GETEVT__NOFILE   4

Definition at line 135 of file f_evt.h.

Referenced by TGo4MbsFile::AddFileName(), f_evt_cre_tagfile(), f_evt_error(), f_evt_get_open(), f_evt_get_tagopen(), and TGo4MbsFile::NextFile().

GETEVT__NOLMDFILE

#define GETEVT__NOLMDFILE   14

Definition at line 145 of file f_evt.h.

Referenced by f_evt_cre_tagfile(), f_evt_error(), and f_evt_get_open().

GETEVT__NOMORE

#define GETEVT__NOMORE   3

Definition at line 134 of file f_evt.h.

Referenced by f_evt_error(), f_evt_get_buffer(), f_evt_get_event(), f_evt_get_newbuf(), f_evt_get_subevent(), f_evt_skip_buffer(), main(), TGo4MbsFile::NextEvent(), and TGo4MbsSource::NextEvent().

GETEVT__NOSERVER

#define GETEVT__NOSERVER   5

Definition at line 136 of file f_evt.h.

Referenced by f_evt_error(), and f_evt_get_open().

GETEVT__NOTAG

#define GETEVT__NOTAG   11

Definition at line 142 of file f_evt.h.

Referenced by f_evt_error(), and f_evt_get_tagevent().

GETEVT__NOTAGFILE

#define GETEVT__NOTAGFILE   10

Definition at line 141 of file f_evt.h.

Referenced by f_evt_error().

GETEVT__RDERR

#define GETEVT__RDERR   6

Definition at line 137 of file f_evt.h.

Referenced by f_evt_cre_tagfile(), f_evt_error(), f_evt_get_buffer(), f_evt_get_event(), f_evt_get_newbuf(), f_evt_get_open(), f_evt_get_tagevent(), and f_evt_get_tagopen().

GETEVT__REVSERV

#define GETEVT__REVSERV   5

Definition at line 124 of file f_evt.h.

Referenced by TGo4RevServ::TGo4RevServ(), TGo4RevServ::TGo4RevServ(), f_evt_get_buffer(), f_evt_get_close(), f_evt_get_event(), f_evt_get_newbuf(), f_evt_get_open(), f_evt_skip_buffer(), TGo4MbsSource::NextEvent(), and TGo4MbsSource::Open().

GETEVT__RFIO

#define GETEVT__RFIO   6

Definition at line 125 of file f_evt.h.

Referenced by f_evt_get_buffer(), f_evt_get_close(), f_evt_get_newbuf(), f_evt_get_open(), and f_evt_skip_buffer().

GETEVT__STREAM

#define GETEVT__STREAM   2

Definition at line 121 of file f_evt.h.

Referenced by TGo4MbsStream::TGo4MbsStream(), TGo4MbsStream::TGo4MbsStream(), f_evt_get_buffer(), f_evt_get_close(), f_evt_get_event(), f_evt_get_newbuf(), f_evt_get_open(), f_evt_skip_buffer(), TGo4MbsSource::NextEvent(), and TGo4MbsSource::Open().

GETEVT__SUCCESS

#define GETEVT__SUCCESS   0

Definition at line 131 of file f_evt.h.

Referenced by TGo4MbsSource::BuildEvent(), TGo4MbsSource::BuildMbsEvent(), TGo4MbsFile::Close(), TGo4MbsSource::Close(), TGo4MbsFile::CloseFile(), f_evt_cre_tagfile(), f_evt_error(), f_evt_get_buffer(), f_evt_get_close(), f_evt_get_event(), f_evt_get_newbuf(), f_evt_get_open(), f_evt_get_subevent(), f_evt_get_tagclose(), f_evt_get_tagevent(), f_evt_get_tagnext(), f_evt_get_tagopen(), f_evt_skip_buffer(), f_evt_timeout(), TGo4MbsSource::Open(), and TGo4MbsFile::OpenFile().

GETEVT__TAGINDEX

#define GETEVT__TAGINDEX   10

Definition at line 126 of file f_evt.h.

GETEVT__TAGNUMBER

#define GETEVT__TAGNUMBER   11

Definition at line 127 of file f_evt.h.

GETEVT__TAGRDERR

#define GETEVT__TAGRDERR   12

Definition at line 143 of file f_evt.h.

Referenced by f_evt_error(), f_evt_get_tagevent(), and f_evt_get_tagopen().

GETEVT__TAGWRERR

#define GETEVT__TAGWRERR   13

Definition at line 144 of file f_evt.h.

Referenced by f_evt_cre_tagfile(), and f_evt_error().

GETEVT__TIMEOUT

#define GETEVT__TIMEOUT   9

Definition at line 140 of file f_evt.h.

Referenced by f_evt_error(), f_evt_get_buffer(), f_evt_get_event(), f_evt_get_newbuf(), f_evt_get_open(), and TGo4MbsSource::NextEvent().

GETEVT__TRANS

#define GETEVT__TRANS   3

Definition at line 122 of file f_evt.h.

Referenced by TGo4MbsTransport::TGo4MbsTransport(), TGo4MbsTransport::TGo4MbsTransport(), f_evt_get_buffer(), f_evt_get_close(), f_evt_get_event(), f_evt_get_newbuf(), f_evt_get_open(), f_evt_skip_buffer(), TGo4MbsSource::NextEvent(), and TGo4MbsSource::Open().

MAX_BUF_LGTH

#define MAX_BUF_LGTH   32768

Definition at line 26 of file f_evt.h.

MAX_BUFS_IN_STREAM

#define MAX_BUFS_IN_STREAM   100 /* at a maximum, 100 buffers per stream */

Definition at line 28 of file f_evt.h.

MAX_LONG

#define MAX_LONG   99999999 /* maximum long data */

Definition at line 29 of file f_evt.h.

Referenced by f_evt_get_event().

MIN_BUF_LGTH

#define MIN_BUF_LGTH   512

Definition at line 27 of file f_evt.h.

Referenced by f_evt_cre_tagfile(), and f_evt_get_open().

PUTEVT__CLOSE_ERR

#define PUTEVT__CLOSE_ERR   105

Definition at line 152 of file f_evt.h.

Referenced by f_evt_error(), and f_evt_put_close().

PUTEVT__FAILURE

#define PUTEVT__FAILURE   102

Definition at line 149 of file f_evt.h.

Referenced by f_evt_error(), and f_evt_put_open().

PUTEVT__FILE_EXIST

#define PUTEVT__FILE_EXIST   101

Definition at line 148 of file f_evt.h.

Referenced by f_evt_error(), and f_evt_put_open().

PUTEVT__NOCHANNEL

#define PUTEVT__NOCHANNEL   107

Definition at line 154 of file f_evt.h.

Referenced by f_evt_error().

PUTEVT__SUCCESS

#define PUTEVT__SUCCESS   0

Definition at line 147 of file f_evt.h.

Referenced by f_evt_check_buf(), f_evt_ini_bufhe(), f_evt_put_buffer(), f_evt_put_close(), f_evt_put_event(), and f_evt_put_open().

PUTEVT__TOO_SMALLS

#define PUTEVT__TOO_SMALLS   104

Definition at line 151 of file f_evt.h.

Referenced by f_evt_error(), and f_evt_put_event().

PUTEVT__TOOBIG

#define PUTEVT__TOOBIG   103

Definition at line 150 of file f_evt.h.

Referenced by f_evt_error(), f_evt_put_buffer(), f_evt_put_close(), f_evt_put_event(), and f_evt_put_open().

PUTEVT__WRERR

#define PUTEVT__WRERR   106

Definition at line 153 of file f_evt.h.

Referenced by f_evt_error(), f_evt_put_buffer(), f_evt_put_close(), f_evt_put_event(), and f_evt_put_open().

Function Documentation

f_evt_control()

s_evt_channel * f_evt_control

(

void

)

Definition at line 2819 of file f_evt.c.

Referenced by TGo4MbsSource::TGo4MbsSource(), TGo4MbsSource::TGo4MbsSource(), and TGo4MbsSource::TGo4MbsSource().

f_evt_cre_tagfile()

INTS4 f_evt_cre_tagfile	(	CHARS *	pc_lmd,
		CHARS *	pc_tag,
		INTS4(*	e_filter )(s_ve10_1 *) )

Definition at line 2206 of file f_evt.c.

References c_temp, f_evt_check_buf(), f_evt_swap(), GETEVT__NOFILE, GETEVT__NOLMDFILE, GETEVT__RDERR, GETEVT__SUCCESS, GETEVT__TAGWRERR, s_bufhe::h_begin, s_bufhe::h_end, s_ve10_1::i_subtype, s_ve10_1::i_trigger, s_ve10_1::i_type, s_taghe::l_buffers, s_taghe::l_bufsize, s_ve10_1::l_count, s_ve10_1::l_dlen, s_taghe::l_endian, s_tag::l_event, s_taghe::l_events, s_bufhe::l_evt, s_taghe::l_filesize, s_taghe::l_first, s_bufhe::l_free, s_taghe::l_last, s_taghe::l_linear, s_tag::l_offset, s_taghe::l_version, and MIN_BUF_LGTH.

f_evt_error()

INTS4 f_evt_error	(	INTS4	l_error,
		CHARS *	pc_dest,
		INTS4	l_out )

Definition at line 1586 of file f_evt.c.

References GETEVT__CLOSE_ERR, GETEVT__FAILURE, GETEVT__FRAGMENT, GETEVT__NOCHANNEL, GETEVT__NOFILE, GETEVT__NOLMDFILE, GETEVT__NOMORE, GETEVT__NOSERVER, GETEVT__NOTAG, GETEVT__NOTAGFILE, GETEVT__RDERR, GETEVT__SUCCESS, GETEVT__TAGRDERR, GETEVT__TAGWRERR, GETEVT__TIMEOUT, PUTEVT__CLOSE_ERR, PUTEVT__FAILURE, PUTEVT__FILE_EXIST, PUTEVT__NOCHANNEL, PUTEVT__TOO_SMALLS, PUTEVT__TOOBIG, and PUTEVT__WRERR.

Referenced by TGo4MbsFile::NextEvent(), TGo4MbsSource::NextEvent(), TGo4MbsSource::Open(), and TGo4MbsFile::OpenFile().

f_evt_get_buffer()

INTS4 f_evt_get_buffer	(	s_evt_channel *	ps_chan,
		INTS4 *	ps_buffer )

Definition at line 1693 of file f_evt.c.

References f_evt_swap(), f_stc_read(), f_stc_write(), GETEVT__EVENT, GETEVT__FAILURE, GETEVT__FILE, GETEVT__NOMORE, GETEVT__RDERR, GETEVT__REVSERV, GETEVT__RFIO, GETEVT__STREAM, GETEVT__SUCCESS, GETEVT__TIMEOUT, GETEVT__TRANS, s_evt_channel::l_buf_size, s_evt_channel::l_bufs_in_stream, s_evt_channel::l_channel_no, s_evt_channel::l_io_buf_size, s_evt_channel::l_server_type, l_status, s_evt_channel::l_stream_bufs, s_evt_channel::l_timeout, RFIO_read, STC__SUCCESS, and STC__TIMEOUT.

f_evt_get_buffer_ptr()

CHARS * f_evt_get_buffer_ptr

(

s_evt_channel *

ps_chan

)

Definition at line 1928 of file f_evt.c.

References s_evt_channel::pc_io_buf.

Referenced by TGo4MbsSource::GetBufferHeader().

f_evt_get_close()

INTS4 f_evt_get_close

(

s_evt_channel *

ps_chan

)

Definition at line 1101 of file f_evt.c.

References f_evcli_close(), f_stc_close(), f_stc_discclient(), f_stc_write(), fLmdCloseMbs(), fLmdGetClose(), GETEVT__CLOSE_ERR, GETEVT__EVENT, GETEVT__FILE, GETEVT__REVSERV, GETEVT__RFIO, GETEVT__STREAM, GETEVT__SUCCESS, GETEVT__TRANS, s_evt_channel::l_channel_no, s_evt_channel::l_server_type, s_evt_channel::pc_evt_buf, s_evt_channel::pc_io_buf, s_evt_channel::pLmd, RFIO_close, s_tcpcomm_st_evt, and STC__SUCCESS.

Referenced by TGo4MbsSource::Close().

f_evt_get_event()

INTS4 f_evt_get_event	(	s_evt_channel *	ps_chan,
		INTS4 **	ppl_buffer,
		INTS4 **	ppl_goobuf )

Definition at line 909 of file f_evt.c.

References f_evcli_buf(), f_evcli_evt(), f_evt_get_newbuf(), fLmdGetElement(), fLmdGetMbsEvent(), GETEVT__EVENT, GETEVT__FAILURE, GETEVT__FILE, GETEVT__FRAGMENT, GETEVT__NOMORE, GETEVT__RDERR, GETEVT__REVSERV, GETEVT__STREAM, GETEVT__SUCCESS, GETEVT__TIMEOUT, GETEVT__TRANS, GETLMD__EOFILE, GETLMD__NOBUFFER, GETLMD__NOMORE, s_bufhe::h_begin, s_bufhe::h_end, s_bufhe::i_type, s_bufhe::i_used, s_bufhe::l_buf, s_evt_channel::l_buf_lmt, s_evt_channel::l_buf_no, s_evt_channel::l_buf_posi, s_evt_channel::l_buf_size, s_bufhe::l_dlen, s_ve10_1::l_dlen, s_evt_channel::l_evt_buf_posi, s_evt_channel::l_evt_buf_size, s_evt_channel::l_first_buf, s_evt_channel::l_first_get, s_evt_channel::l_frag_len, s_bufhe::l_free, s_evt_channel::l_io_buf_posi, s_evt_channel::l_io_buf_size, s_evt_channel::l_server_type, LMD__NO_INDEX, LMD__TIMEOUT, MAX__DLEN, MAX_LONG, s_evt_channel::pc_evt_buf, s_evt_channel::pc_io_buf, s_evt_channel::pLmd, s_evt_channel::ps_bufhe, s_evt_channel::ps_ve10_1, s_evt_channel::s_bufhe_1, STC__SUCCESS, and STC__TIMEOUT.

Referenced by TGo4MbsSource::NextEvent().

f_evt_get_open()

INTS4 f_evt_get_open	(	INTS4	l_mode,
		CHARS *	pc_server,
		s_evt_channel *	ps_chan,
		CHARS **	ps_info,
		INTS4	l_sample,
		INTS4	l_param )

Definition at line 552 of file f_evt.c.

References s_evt_channel::c_channel, c_temp, s_evt_channel::cb_polling, f_evcli_con(), f_evt_check_buf(), f_evt_swap(), f_evt_swap_filhe(), f_stc_connectserver(), f_stc_read(), fLmdAllocateControl(), fLmdGetOpen(), fLmdInitMbs(), GETEVT__EVENT, GETEVT__FILE, GETEVT__NOFILE, GETEVT__NOLMDFILE, GETEVT__NOSERVER, GETEVT__RDERR, GETEVT__REVSERV, GETEVT__RFIO, GETEVT__STREAM, GETEVT__SUCCESS, GETEVT__TIMEOUT, GETEVT__TRANS, s_evt_channel::l_buf_size, s_evt_channel::l_bufs_in_stream, s_evt_channel::l_channel_no, s_evt_channel::l_evt_buf_size, s_evt_channel::l_first_get, l_gl_source_port, s_evt_channel::l_io_buf_size, s_evt_channel::l_server_type, l_status, s_evt_channel::l_stream_bufs, s_evt_channel::l_timeout, LMD__BUFFER, LMD__NO_INDEX, LMD__TYPE_FILE_HEADER_101_1, MAX__DLEN, MIN_BUF_LGTH, s_evt_channel::pc_evt_buf, s_evt_channel::pc_io_buf, s_evt_channel::pLmd, PORT__EVENT_SERV, PORT__STREAM_SERV, PORT__TRANSPORT, sLmdControl::pTCP, RFIO_close, RFIO_lseek, RFIO_open, RFIO_read, s_tcpcomm_st_evt, STC__SUCCESS, and STC__TIMEOUT.

Referenced by TGo4MbsSource::Open().

f_evt_get_subevent()

INTS4 f_evt_get_subevent	(	s_ve10_1 *	ps_ve10_1,
		INTS4	l_subevent,
		INTS4 **	pl_se,
		INTS4 **	pl_d,
		INTS4 *	pl_lwords )

Definition at line 235 of file f_evt.c.

References GETEVT__FAILURE, GETEVT__NOMORE, GETEVT__SUCCESS, s_ve10_1::l_dlen, and s_ves10_1::l_dlen.

f_evt_get_tagclose()

INTS4 f_evt_get_tagclose

(

s_evt_channel *

ps_chan

)

Definition at line 2801 of file f_evt.c.

References f_evt_get_close(), GETEVT__SUCCESS, s_evt_channel::l_channel_no, s_evt_channel::l_tagfile_no, s_evt_channel::pc_evt_buf, s_evt_channel::ps_tag, and s_evt_channel::ps_taghe.

Referenced by TGo4MbsFile::CloseFile().

f_evt_get_tagevent()

INTS4 f_evt_get_tagevent	(	s_evt_channel *	ps_chan,
		INTS4	l_value,
		INTS4	l_type,
		INTS4 **	pl_event )

Definition at line 2643 of file f_evt.c.

References c_temp, f_evt_get_event(), f_evt_swap(), GETEVT__NOTAG, GETEVT__RDERR, GETEVT__SUCCESS, GETEVT__TAGRDERR, s_taghe::l_bufsize, s_evt_channel::l_channel_no, s_ve10_1::l_dlen, s_tag::l_event, s_taghe::l_events, s_evt_channel::l_evt_buf_size, s_taghe::l_first, s_bufhe::l_free, s_evt_channel::l_io_buf_posi, s_taghe::l_linear, s_evt_channel::l_lmdswap, s_tag::l_offset, s_evt_channel::l_tagfile_no, s_evt_channel::l_tagswap, s_evt_channel::pc_evt_buf, s_evt_channel::ps_tag, and s_evt_channel::ps_taghe.

f_evt_get_tagnext()

INTS4 f_evt_get_tagnext	(	s_evt_channel *	ps_chan,
		INTS4	l_skip,
		INTS4 **	pl_event )

Definition at line 2594 of file f_evt.c.

References f_evt_get_event(), f_evt_get_tagevent(), GETEVT__SUCCESS, s_evt_channel::l_io_buf_posi, and s_evt_channel::ps_taghe.

Referenced by TGo4MbsFile::NextEvent().

f_evt_get_tagopen()

INTS4 f_evt_get_tagopen	(	s_evt_channel *	ps_chan,
		CHARS *	pc_tag,
		CHARS *	pc_lmd,
		CHARS **	ps_head,
		INTS4	l_prihe )

Definition at line 2470 of file f_evt.c.

References c_temp, f_evt_get_open(), f_evt_swap(), f_evt_swap_filhe(), f_evt_type(), GETEVT__FILE, GETEVT__NOFILE, GETEVT__RDERR, GETEVT__SUCCESS, GETEVT__TAGRDERR, s_bufhe::i_type, s_taghe::l_buffers, s_taghe::l_bufsize, s_evt_channel::l_channel_no, s_taghe::l_endian, s_taghe::l_events, s_evt_channel::l_evt_buf_size, s_taghe::l_filesize, s_taghe::l_first, s_bufhe::l_free, s_evt_channel::l_io_buf_posi, s_taghe::l_last, s_taghe::l_linear, s_evt_channel::l_lmdswap, s_evt_channel::l_tagfile_no, s_evt_channel::l_tagswap, s_evt_channel::pc_evt_buf, s_evt_channel::ps_tag, and s_evt_channel::ps_taghe.

Referenced by TGo4MbsFile::OpenFile().

f_evt_put_buffer()

INTS4 f_evt_put_buffer	(	s_evt_channel *	ps_chan,
		s_bufhe *	ps_bufhe )

Definition at line 1448 of file f_evt.c.

References fLmdPutBuffer(), s_evt_channel::l_buf_size, s_evt_channel::l_channel_no, s_bufhe::l_evt, s_evt_channel::l_io_buf_posi, s_evt_channel::l_io_buf_size, l_status, s_evt_channel::pLmd, PUTEVT__SUCCESS, PUTEVT__TOOBIG, and PUTEVT__WRERR.

f_evt_put_close()

INTS4 f_evt_put_close

(

s_evt_channel *

ps_chan

)

Definition at line 1493 of file f_evt.c.

References fLmdPutClose(), s_bufhe::h_begin, s_bufhe::h_end, s_bufhe::i_used, s_evt_channel::l_buf_size, s_evt_channel::l_channel_no, s_bufhe::l_dlen, s_evt_channel::l_first_put, s_evt_channel::l_io_buf_posi, s_evt_channel::l_io_buf_size, l_status, s_evt_channel::pc_io_buf, s_evt_channel::pLmd, s_evt_channel::ps_bufhe, PUTEVT__CLOSE_ERR, PUTEVT__SUCCESS, PUTEVT__TOOBIG, and PUTEVT__WRERR.

f_evt_put_event()

INTS4 f_evt_put_event	(	s_evt_channel *	ps_chan,
		INTS4 *	pl_evt_buf )

Definition at line 1305 of file f_evt.c.

References f_evt_ini_bufhe(), fLmdPutElement(), s_bufhe::h_begin, s_bufhe::h_end, s_ve10_1::i_subtype, s_ve10_1::i_type, s_bufhe::i_used, s_evt_channel::l_buf_no, s_evt_channel::l_buf_size, s_evt_channel::l_buf_subtype, s_evt_channel::l_buf_type, s_evt_channel::l_channel_no, s_ve10_1::l_dlen, s_bufhe::l_evt, s_evt_channel::l_evt_size, s_evt_channel::l_first_put, s_bufhe::l_free, s_evt_channel::l_io_buf_posi, s_evt_channel::l_io_buf_size, l_status, s_evt_channel::pc_io_buf, s_evt_channel::pLmd, s_evt_channel::ps_bufhe, s_evt_channel::ps_ve10_1, PUTEVT__SUCCESS, PUTEVT__TOO_SMALLS, PUTEVT__TOOBIG, and PUTEVT__WRERR.

f_evt_put_open()

INTS4 f_evt_put_open	(	CHARS *	pc_file,
		INTS4	l_size,
		INTS4	l_stream,
		INTS4	l_type,
		INTS4	l_subtype,
		s_evt_channel *	ps_chan,
		CHARS *	ps_filhe )

Definition at line 1192 of file f_evt.c.

References s_filhe::filhe_dlen, s_filhe::filhe_file, s_filhe::filhe_file_l, s_filhe::filhe_free, s_filhe::filhe_run, s_filhe::filhe_run_l, s_filhe::filhe_stime, s_filhe::filhe_subtype, s_filhe::filhe_time, s_filhe::filhe_type, s_filhe::filhe_user, s_filhe::filhe_user_l, fLmdAllocateControl(), fLmdPutOpen(), s_evt_channel::l_buf_size, s_evt_channel::l_buf_subtype, s_evt_channel::l_buf_type, s_evt_channel::l_bufs_in_stream, s_evt_channel::l_channel_no, s_evt_channel::l_first_put, s_evt_channel::l_io_buf_size, l_status, LMD__INDEX, LMD__LARGE_FILE, LMD__NO_OVERWRITE, own_getpid, s_evt_channel::pc_io_buf, s_evt_channel::pLmd, PUTEVT__FAILURE, PUTEVT__FILE_EXIST, PUTEVT__SUCCESS, PUTEVT__TOOBIG, and PUTEVT__WRERR.

f_evt_rev_port()

INTS4 f_evt_rev_port

(

INTS4

l_port

)

Definition at line 509 of file f_evt.c.

References l_gl_source_port.

f_evt_skip_buffer()

INTS4 f_evt_skip_buffer	(	s_evt_channel *	ps_chan,
		INTS4	l_buffer )

Definition at line 1779 of file f_evt.c.

References GETEVT__EVENT, GETEVT__FAILURE, GETEVT__FILE, GETEVT__NOMORE, GETEVT__REVSERV, GETEVT__RFIO, GETEVT__STREAM, GETEVT__SUCCESS, GETEVT__TRANS, s_evt_channel::l_buf_size, s_evt_channel::l_channel_no, s_evt_channel::l_first_get, s_evt_channel::l_server_type, and RFIO_lseek.

f_evt_source_port()

INTS4 f_evt_source_port

(

INTS4

l_port

)

Definition at line 486 of file f_evt.c.

References l_gl_source_port.

Referenced by TGo4MbsSource::Open().

f_evt_swap()

INTS4 f_evt_swap	(	CHARS *	pc_source,
		INTS4	l_length )

Definition at line 1853 of file f_evt.c.

f_evt_timeout()

INTS4 f_evt_timeout	(	s_evt_channel *	ps_chan,
		INTS4	l_sec )

Definition at line 1833 of file f_evt.c.

References GETEVT__SUCCESS, and s_evt_channel::l_timeout.

Referenced by TGo4MbsSource::Open().

f_evt_type()

INTS4 f_evt_type	(	s_bufhe *	ps_bufhe,
		s_evhe *	ps_evhe,
		INTS4	l_subid,
		INTS4	l_long,
		INTS4	l_hex,
		INTS4	l_data )

Definition at line 298 of file f_evt.c.

References f_evt_get_subevent(), f_ut_utime(), s_filhe::filhe_dlen, s_filhe::filhe_exp, s_filhe::filhe_file, s_filhe::filhe_label, s_filhe::filhe_lines, s_filhe::filhe_run, s_filhe::filhe_time, s_filhe::filhe_used, s_filhe::filhe_user, s_bufhe::h_begin, s_bufhe::h_end, s_bufhe::i_subtype, s_evhe::i_subtype, s_ve10_1::i_subtype, s_ve10_1::i_trigger, s_bufhe::i_type, s_evhe::i_type, s_ve10_1::i_type, s_bufhe::i_used, l, s_bufhe::l_buf, s_ve10_1::l_count, s_bufhe::l_dlen, s_evhe::l_dlen, s_ve10_1::l_dlen, s_bufhe::l_evt, s_bufhe::l_free, l_status, s_bufhe::l_time, MAX__DLEN, s_filhe::s_strings, and cv_string::string.

Referenced by TGo4MbsSource::BuildMbsEvent().