---

/MbsAPI/f_evt.c File Reference

Go to the source code of this file.

Defines
#define	RFIO_open   open
#define	RFIO_close   close
#define	RFIO_read   read
#define	RFIO_lseek   lseek
Functions
INTS4	f_evt_get_newbuf (s_evt_channel *)
INTS4	f_evt_check_buf (CHARS *, INTS4 *, INTS4 *, INTS4 *, INTS4 *)
INTS4	f_evt_ini_bufhe (s_evt_channel *ps_chan)
INTS4	f_evt_swap_filhe (s_bufhe *)
INTS4	f_ut_utime (INTS4, INTS4, CHARS *)
INTS4	f_evt_get_subevent (s_ve10_1 *ps_ve10_1, INTS4 l_subevent, INTS4 **pl_se, INTS4 **pl_d, INTS4 *pl_lwords)
INTS4	f_evt_type (s_bufhe *ps_bufhe, s_evhe *ps_evhe, INTS4 l_subid, INTS4 l_long, INTS4 l_hex, INTS4 l_data)
INTS4	f_evt_rev_port (INTS4 l_port)
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)
INTS4	f_evt_get_event (s_evt_channel *ps_chan, INTS4 **ppl_buffer, INTS4 **ppl_goobuf)
INTS4	f_evt_get_close (s_evt_channel *ps_chan)
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)
INTS4	f_evt_put_event (s_evt_channel *ps_chan, INTS4 *pl_evt_buf)
INTS4	f_evt_put_buffer (s_evt_channel *ps_chan, s_bufhe *ps_bufhe)
INTS4	f_evt_put_close (s_evt_channel *ps_chan)
INTS4	f_evt_error (INTS4 l_error, CHARS *pc_dest, INTS4 l_out)
INTS4	f_evt_get_buffer (s_evt_channel *ps_chan, INTS4 *ps_buffer)
INTS4	f_evt_skip_buffer (s_evt_channel *ps_chan, INTS4 l_buffer)
INTS4	f_evt_timeout (s_evt_channel *ps_chan, INTS4 l_sec)
INTS4	f_evt_swap (CHARS *pc_source, INTS4 l_length)
CHARS *	f_evt_get_buffer_ptr (s_evt_channel *ps_chan)
INTS4	f_evt_tag_filter (s_ve10_1 *ps_ve10_1)
INTS4	f_evt_cre_tagfile (CHARS *pc_lmd, CHARS *pc_tag, INTS4(*e_filter)())
INTS4	f_evt_get_tagopen (s_evt_channel *ps_chan, CHARS *pc_tag, CHARS *pc_lmd, CHARS **ps_head, INTS4 l_prihe)
INTS4	f_evt_get_tagnext (s_evt_channel *ps_chan, INTS4 l_skip, INTS4 **pl_event)
INTS4	f_evt_get_tagevent (s_evt_channel *ps_chan, INTS4 l_value, INTS4 l_type, INTS4 **pl_event)
INTS4	f_evt_get_tagclose (s_evt_channel *ps_chan)
Variables
s_tcpcomm	s_tcpcomm_st_evt
CHARS	c_temp [MAX_BUF_LGTH]
	l_gl_rev_port = PORT__EVENT_SERV
	l_gl_evt_check = 0

---

Define Documentation

#define RFIO_open   open

Definition at line 26 of file f_evt.c. Referenced by f_evt_get_open().

#define RFIO_close   close

Definition at line 27 of file f_evt.c. Referenced by f_evt_get_close(), and f_evt_get_open().

#define RFIO_read   read

Definition at line 28 of file f_evt.c. Referenced by f_evt_get_buffer(), f_evt_get_newbuf(), and f_evt_get_open().

#define RFIO_lseek   lseek

Definition at line 29 of file f_evt.c. Referenced by f_evt_get_open(), and f_evt_skip_buffer().

---

Function Documentation

INTS4 f_evt_get_newbuf (  s_evt_channel *    )

Definition at line 1979 of file f_evt.c. References CHARS, f_evt_swap(), f_stc_read(), f_stc_write(), GETEVT__RFIO, i, INTS4, 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, s_evt_channel::l_timeout, s_evt_channel::pc_io_buf, RFIO_read, STC__SUCCESS, and STC__TIMEOUT. Referenced by f_evt_get_event().

INTS4 f_evt_check_buf (  CHARS *   , INTS4 *   , INTS4 *   , INTS4 *   , INTS4 *    )

Definition at line 2066 of file f_evt.c. References CHARS, f_evt_swap(), INTS4, and INTU4. Referenced by f_evt_cre_tagfile(), and f_evt_get_open().

INTS4 f_evt_ini_bufhe (  s_evt_channel *    ps_chan )

Definition at line 2155 of file f_evt.c. References s_bufhe::h_begin, s_bufhe::h_end, s_bufhe::i_subtype, s_bufhe::i_type, s_bufhe::i_used, INTS4, s_bufhe::l_buf, 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_bufhe::l_current_i, s_bufhe::l_dlen, s_bufhe::l_evt, s_bufhe::l_free, s_evt_channel::l_io_buf_size, s_bufhe::l_time, s_evt_channel::pc_io_buf, and s_evt_channel::ps_bufhe. Referenced by f_evt_put_event().

INTS4 f_evt_swap_filhe (  s_bufhe *    )

Definition at line 1918 of file f_evt.c. References CHARS, f_evt_swap(), s_filhe::filhe_exp_l, s_filhe::filhe_file_l, s_filhe::filhe_label_l, s_filhe::filhe_lines, s_filhe::filhe_run_l, s_filhe::filhe_user_l, s_bufhe::i_type, INTS2, INTS4, and s_filhe::s_strings. Referenced by f_evt_get_open(), and f_evt_get_tagopen().

INTS4 f_ut_utime (  INTS4   , INTS4   , CHARS *    )

Definition at line 64 of file f_ut_utime.c. References CHARS, and INTS4. Referenced by f_evt_type().

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 236 of file f_evt.c. References INTS4, s_ve10_1::l_dlen, and s_ves10_1::l_dlen. Referenced by 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 299 of file f_evt.c. References CHARS, 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_user, s_bufhe::h_begin, s_ves10_1::h_control, s_bufhe::h_end, s_ves10_1::h_subcrate, s_ves10_1::i_procid, s_bufhe::i_subtype, s_evhe::i_subtype, s_ve10_1::i_subtype, s_ves10_1::i_subtype, s_ve10_1::i_trigger, s_bufhe::i_type, s_evhe::i_type, s_ve10_1::i_type, s_ves10_1::i_type, INTS2, INTS4, s_bufhe::l_buf, s_ve10_1::l_count, s_bufhe::l_dlen, s_evhe::l_dlen, s_ve10_1::l_dlen, s_ves10_1::l_dlen, s_bufhe::l_evt, s_bufhe::l_free, s_bufhe::l_time, s_filhe::s_strings, and cv_string::string. Referenced by TGo4MbsSource::BuildMbsEvent(), and f_evt_get_tagopen().

INTS4 f_evt_rev_port (  INTS4    l_port )

Definition at line 483 of file f_evt.c. References INTS4, l_gl_rev_port, and l_port. Referenced by TGo4RevServ::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 525 of file f_evt.c. References s_evt_channel::c_channel, c_file, c_temp, CHARS, f_evcli_con(), f_evt_check_buf(), f_evt_swap(), f_evt_swap_filhe(), f_stc_connectserver(), f_stc_read(), GETEVT__RFIO, i, INTS2, INTS4, 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_rev_port, s_evt_channel::l_io_buf_size, s_evt_channel::l_server_type, s_evt_channel::l_stream_bufs, s_evt_channel::l_timeout, s_evt_channel::pc_evt_buf, s_evt_channel::pc_io_buf, PORT__STREAM_SERV, PORT__TRANSPORT, RFIO_close, RFIO_lseek, RFIO_open, RFIO_read, STC__SUCCESS, and STC__TIMEOUT. Referenced by f_evt_get_tagopen(), and TGo4MbsSource::Open().

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

Definition at line 907 of file f_evt.c. References CHARS, f_evcli_buf(), f_evcli_evt(), f_evt_get_newbuf(), s_bufhe::h_begin, s_bufhe::h_end, s_bufhe::i_type, s_bufhe::i_used, INTS4, 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_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_evt_channel::l_io_buf_posi, s_evt_channel::l_io_buf_size, s_evt_channel::l_server_type, s_evt_channel::pc_evt_buf, s_evt_channel::pc_io_buf, s_evt_channel::ps_bufhe, s_evt_channel::ps_ve10_1, s_evt_channel::s_bufhe_1, STC__SUCCESS, and STC__TIMEOUT. Referenced by f_evt_get_tagevent(), f_evt_get_tagnext(), and TGo4MbsSource::NextEvent().

INTS4 f_evt_get_close (  s_evt_channel *    ps_chan )

Definition at line 1073 of file f_evt.c. References f_evcli_close(), f_stc_close(), f_stc_discclient(), GETEVT__RFIO, i, INTS4, s_evt_channel::l_channel_no, s_evt_channel::l_server_type, s_evt_channel::pc_evt_buf, s_evt_channel::pc_io_buf, RFIO_close, and STC__SUCCESS. Referenced by TGo4MbsSource::Close(), and f_evt_get_tagclose().

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 1159 of file f_evt.c. References c_file, CHARS, 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, i, INTS2, INTS4, 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, and s_evt_channel::pc_io_buf.

INTS4 f_evt_put_event (  s_evt_channel *    ps_chan, INTS4 *    pl_evt_buf )

Definition at line 1306 of file f_evt.c. References CHARS, f_evt_ini_bufhe(), s_bufhe::h_begin, s_bufhe::h_end, i, s_ve10_1::i_subtype, s_ve10_1::i_type, s_bufhe::i_used, INTS4, 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, s_evt_channel::pc_io_buf, s_evt_channel::ps_bufhe, and s_evt_channel::ps_ve10_1.

INTS4 f_evt_put_buffer (  s_evt_channel *    ps_chan, s_bufhe *    ps_bufhe )

Definition at line 1448 of file f_evt.c. References CHARS, i, INTS4, s_evt_channel::l_buf_size, s_evt_channel::l_channel_no, s_evt_channel::l_io_buf_posi, and s_evt_channel::l_io_buf_size.

INTS4 f_evt_put_close (  s_evt_channel *    ps_chan )

Definition at line 1493 of file f_evt.c. References CHARS, s_bufhe::h_begin, s_bufhe::h_end, i, s_bufhe::i_used, INTS4, 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, s_evt_channel::pc_io_buf, and s_evt_channel::ps_bufhe.

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

Definition at line 1594 of file f_evt.c. References CHARS, GETEVT__NOLMDFILE, GETEVT__NOTAG, GETEVT__NOTAGFILE, GETEVT__TAGRDERR, GETEVT__TAGWRERR, GETEVT__TIMEOUT, and INTS4. Referenced by TGo4MbsFile::NextEvent(), TGo4MbsSource::NextEvent(), TGo4MbsSource::Open(), TGo4RevServ::Open(), and TGo4MbsFile::OpenFile().

INTS4 f_evt_get_buffer (  s_evt_channel *    ps_chan, INTS4 *    ps_buffer )

Definition at line 1701 of file f_evt.c. References CHARS, f_evt_swap(), f_stc_read(), f_stc_write(), GETEVT__RFIO, i, INTS4, 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, s_evt_channel::l_stream_bufs, s_evt_channel::l_timeout, s_evt_channel::pc_io_buf, RFIO_read, STC__SUCCESS, and STC__TIMEOUT.

INTS4 f_evt_skip_buffer (  s_evt_channel *    ps_chan, INTS4    l_buffer )

Definition at line 1797 of file f_evt.c. References CHARS, GETEVT__RFIO, i, INTS4, s_evt_channel::l_buf_size, s_evt_channel::l_channel_no, s_evt_channel::l_first_get, s_evt_channel::l_io_buf_size, s_evt_channel::l_server_type, s_evt_channel::pc_io_buf, and RFIO_lseek.

INTS4 f_evt_timeout (  s_evt_channel *    ps_chan, INTS4    l_sec )

Definition at line 1861 of file f_evt.c. References INTS4, and s_evt_channel::l_timeout. Referenced by TGo4MbsSource::Open().

INTS4 f_evt_swap (  CHARS *    pc_source, INTS4    l_length )

Definition at line 1881 of file f_evt.c. References CHARS, and INTS4. Referenced by f_evt_check_buf(), f_evt_cre_tagfile(), f_evt_get_buffer(), f_evt_get_newbuf(), f_evt_get_open(), f_evt_get_tagevent(), f_evt_get_tagopen(), and f_evt_swap_filhe().

CHARS* f_evt_get_buffer_ptr (  s_evt_channel *    ps_chan )

Definition at line 1958 of file f_evt.c. References CHARS, and s_evt_channel::pc_io_buf. Referenced by TGo4MbsSource::GetBufferHeader().

INTS4 f_evt_tag_filter (  s_ve10_1 *    ps_ve10_1 )

Definition at line 2211 of file f_evt.c. References s_ve10_1::i_subtype, s_ve10_1::i_trigger, s_ve10_1::i_type, INTS4, s_ve10_1::l_count, and s_ve10_1::l_dlen.

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

Definition at line 2229 of file f_evt.c. References c_temp, CHARS, f_evt_check_buf(), f_evt_swap(), s_bufhe::h_begin, s_bufhe::h_end, s_ve10_1::i_subtype, s_ve10_1::i_trigger, s_ve10_1::i_type, INTS2, INTS4, INTU4, 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, and s_taghe::l_version.

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 2491 of file f_evt.c. References c_temp, CHARS, f_evt_get_open(), f_evt_swap(), f_evt_swap_filhe(), f_evt_type(), s_bufhe::i_type, INTS4, 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().

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

Definition at line 2608 of file f_evt.c. References f_evt_get_event(), f_evt_get_tagevent(), INTS4, s_evt_channel::l_io_buf_posi, and s_evt_channel::ps_taghe. Referenced by TGo4MbsFile::NextEvent().

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

Definition at line 2657 of file f_evt.c. References c_temp, CHARS, f_evt_get_event(), f_evt_swap(), INTS4, s_taghe::l_bufsize, s_evt_channel::l_channel_no, s_ve10_1::l_count, 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. Referenced by f_evt_get_tagnext().

INTS4 f_evt_get_tagclose (  s_evt_channel *    ps_chan )

Definition at line 2817 of file f_evt.c. References f_evt_get_close(), INTS4, 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().

---

Variable Documentation

struct s_tcpcomm s_tcpcomm_st_evt [static]

Definition at line 175 of file f_evt.c.

CHARS c_temp[MAX_BUF_LGTH] [static]

Definition at line 176 of file f_evt.c. Referenced by f_evt_cre_tagfile(), f_evt_get_open(), f_evt_get_tagevent(), and f_evt_get_tagopen().

l_gl_rev_port = PORT__EVENT_SERV [static]

Definition at line 177 of file f_evt.c. Referenced by f_evt_get_open(), and f_evt_rev_port().

l_gl_evt_check = 0 [static]

Definition at line 178 of file f_evt.c.

---