#include "typedefs.h"#include "f_stccomm.h"#include "s_filhe.h"#include "fLmd.h"#include "gps_sc_def.h"#include "f_evt.h"#include "f_evcli.h"#include "portnum_def.h"Go to the source code of this file.
| #define RFIO_close close |
Definition at line 160 of file f_evt.c.
Referenced by f_evt_get_close(), and f_evt_get_open().
| #define RFIO_lseek lseek |
Definition at line 162 of file f_evt.c.
Referenced by f_evt_get_open(), and f_evt_skip_buffer().
| #define RFIO_open open |
Definition at line 159 of file f_evt.c.
Referenced by f_evt_get_open().
| #define RFIO_read read |
Definition at line 161 of file f_evt.c.
Referenced by f_evt_get_buffer(), f_evt_get_newbuf(), and f_evt_get_open().
| INTS4 f_evt_check_buf | ( | CHARS * | pc_head, | |
| INTS4 * | pl_size, | |||
| INTS4 * | pl_is_goosybuf, | |||
| INTS4 * | pl_swap, | |||
| INTS4 * | pl_filehead | |||
| ) |
Definition at line 2068 of file f_evt.c.
References f_evt_swap(), and PUTEVT__SUCCESS.
Referenced by f_evt_cre_tagfile(), and f_evt_get_open().
| s_evt_channel* f_evt_control | ( | ) |
Definition at line 2845 of file f_evt.c.
Referenced by TGo4MbsSource::TGo4MbsSource().
Definition at line 2233 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_ve10_1::l_count, s_ve10_1::l_dlen, s_tag::l_event, s_bufhe::l_evt, s_bufhe::l_free, s_tag::l_offset, and MIN_BUF_LGTH.
Definition at line 1610 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 TGo4MbsSource::NextEvent(), TGo4MbsFile::NextEvent(), TGo4MbsSource::Open(), and TGo4MbsFile::OpenFile().
| INTS4 f_evt_get_buffer | ( | s_evt_channel * | ps_chan, | |
| INTS4 * | ps_buffer | |||
| ) |
Definition at line 1717 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, s_evt_channel::pc_io_buf, RFIO_read, STC__SUCCESS, and STC__TIMEOUT.
| CHARS* f_evt_get_buffer_ptr | ( | s_evt_channel * | ps_chan | ) |
Definition at line 1955 of file f_evt.c.
References s_evt_channel::pc_io_buf.
Referenced by TGo4MbsSource::GetBufferHeader().
| INTS4 f_evt_get_close | ( | s_evt_channel * | ps_chan | ) |
Definition at line 1113 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__TRANS, s_evt_channel::l_channel_no, s_evt_channel::l_server_type, l_status, 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_newbuf(), and f_evt_get_tagclose().
| INTS4 f_evt_get_event | ( | s_evt_channel * | ps_chan, | |
| INTS4 ** | ppl_buffer, | |||
| INTS4 ** | ppl_goobuf | |||
| ) |
Definition at line 923 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__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_ve10_1::l_dlen, s_bufhe::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, 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 f_evt_get_tagevent(), f_evt_get_tagnext(), and TGo4MbsSource::NextEvent().
| INTS4 f_evt_get_newbuf | ( | s_evt_channel * | ps_chan | ) |
Definition at line 1976 of file f_evt.c.
References f_evt_get_close(), 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_timeout, s_evt_channel::pc_io_buf, RFIO_read, STC__SUCCESS, and STC__TIMEOUT.
Referenced by f_evt_get_event().
| 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 561 of file f_evt.c.
References s_evt_channel::c_channel, c_temp, 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__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__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 f_evt_get_tagopen(), and TGo4MbsSource::Open().
| 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 243 of file f_evt.c.
References GETEVT__FAILURE, GETEVT__NOMORE, GETEVT__SUCCESS, l, s_ves10_1::l_dlen, s_ve10_1::l_dlen, and l_status.
Referenced by f_evt_type().
| INTS4 f_evt_get_tagclose | ( | s_evt_channel * | ps_chan | ) |
Definition at line 2828 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().
| INTS4 f_evt_get_tagevent | ( | s_evt_channel * | ps_chan, | |
| INTS4 | l_value, | |||
| INTS4 | l_type, | |||
| INTS4 ** | pl_event | |||
| ) |
Definition at line 2668 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.
Referenced by f_evt_get_tagnext().
| INTS4 f_evt_get_tagnext | ( | s_evt_channel * | ps_chan, | |
| INTS4 | l_skip, | |||
| INTS4 ** | pl_event | |||
| ) |
Definition at line 2619 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().
| 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 2495 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().
| INTS4 f_evt_ini_bufhe | ( | s_evt_channel * | ps_chan | ) |
Definition at line 2159 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, 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, s_evt_channel::ps_bufhe, and PUTEVT__SUCCESS.
Referenced by f_evt_put_event().
| INTS4 f_evt_put_buffer | ( | s_evt_channel * | ps_chan, | |
| s_bufhe * | ps_bufhe | |||
| ) |
Definition at line 1470 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__TOOBIG, and PUTEVT__WRERR.
| INTS4 f_evt_put_close | ( | s_evt_channel * | ps_chan | ) |
Definition at line 1516 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__TOOBIG, and PUTEVT__WRERR.
| INTS4 f_evt_put_event | ( | s_evt_channel * | ps_chan, | |
| INTS4 * | pl_evt_buf | |||
| ) |
Definition at line 1327 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.
| 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 1205 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, s_evt_channel::pc_io_buf, s_evt_channel::pLmd, PUTEVT__FAILURE, PUTEVT__FILE_EXIST, PUTEVT__SUCCESS, PUTEVT__TOOBIG, and PUTEVT__WRERR.
Definition at line 518 of file f_evt.c.
References l_gl_source_port.
| INTS4 f_evt_skip_buffer | ( | s_evt_channel * | ps_chan, | |
| INTS4 | l_buffer | |||
| ) |
Definition at line 1803 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, l_status, s_evt_channel::pc_io_buf, and RFIO_lseek.
Definition at line 495 of file f_evt.c.
References l_gl_source_port.
Referenced by TGo4MbsSource::Open().
Definition at line 1878 of file f_evt.c.
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().
Definition at line 1915 of file f_evt.c.
References 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, and s_filhe::s_strings.
Referenced by f_evt_get_open(), and f_evt_get_tagopen().
| INTS4 f_evt_timeout | ( | s_evt_channel * | ps_chan, | |
| INTS4 | l_sec | |||
| ) |
Definition at line 1858 of file f_evt.c.
References GETEVT__SUCCESS, and s_evt_channel::l_timeout.
Referenced by TGo4MbsSource::Open().
| 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 306 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_ve10_1::i_subtype, s_evhe::i_subtype, s_bufhe::i_subtype, s_ve10_1::i_trigger, s_ve10_1::i_type, s_evhe::i_type, s_bufhe::i_type, s_bufhe::i_used, l, s_bufhe::l_buf, s_ve10_1::l_count, s_ve10_1::l_dlen, s_evhe::l_dlen, s_bufhe::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(), and f_evt_get_tagopen().
Definition at line 63 of file f_ut_utime.c.
Referenced by f_evt_type(), TGo4MbsEvent::PrintMbsBufferHeader(), and TGo4MbsEvent::PrintMbsEvent().
Definition at line 183 of file f_evt.c.
Referenced by f_evt_cre_tagfile(), f_evt_get_open(), f_evt_get_tagevent(), and f_evt_get_tagopen().
int l_gl_evt_check = 0 [static] |
int l_gl_source_port = 0 [static] |
Definition at line 184 of file f_evt.c.
Referenced by f_evt_get_open(), f_evt_rev_port(), and f_evt_source_port().
struct s_tcpcomm s_tcpcomm_st_evt [static] |
Definition at line 182 of file f_evt.c.
Referenced by f_evt_get_close(), and f_evt_get_open().
1.7.1