📄 gpr_sink.pr.c
字号:
/* Process model C form file: gpr_sink.pr.c */
/* Portions of this file copyright 1992-2003 by OPNET Technologies, Inc. */
/* This variable carries the header into the object file */
const char gpr_sink_pr_c [] = "MIL_3_Tfile_Hdr_ 100A 30A modeler 7 436C3A5E 436C3A5E 1 zhangzhong jc 0 0 none none 0 0 none 0 0 0 0 0 0 0 0 8f3 1 ";
#include <string.h>
/* OPNET system definitions */
#include <opnet.h>
/* Header Block */
/* End of Header Block */
#if !defined (VOSD_NO_FIN)
#undef BIN
#undef BOUT
#define BIN FIN_LOCAL_FIELD(_op_last_line_passed) = __LINE__ - _op_block_origin;
#define BOUT BIN
#define BINIT FIN_LOCAL_FIELD(_op_last_line_passed) = 0; _op_block_origin = __LINE__;
#else
#define BINIT
#endif /* #if !defined (VOSD_NO_FIN) */
/* State variable definitions */
typedef struct
{
/* Internal state tracking for FSM */
FSM_SYS_STATE
/* State Variables */
Stathandle bits_rcvd_stathandle;
Stathandle bitssec_rcvd_stathandle;
Stathandle pkts_rcvd_stathandle;
Stathandle pktssec_rcvd_stathandle;
Stathandle ete_delay_stathandle;
Stathandle bits_rcvd_gstathandle;
Stathandle bitssec_rcvd_gstathandle;
Stathandle pkts_rcvd_gstathandle;
Stathandle pktssec_rcvd_gstathandle;
Stathandle ete_delay_gstathandle;
int iPackNum;
double mean_intvl;
} gpr_sink_state;
#define pr_state_ptr ((gpr_sink_state*) (OP_SIM_CONTEXT_PTR->mod_state_ptr))
#define bits_rcvd_stathandle pr_state_ptr->bits_rcvd_stathandle
#define bitssec_rcvd_stathandle pr_state_ptr->bitssec_rcvd_stathandle
#define pkts_rcvd_stathandle pr_state_ptr->pkts_rcvd_stathandle
#define pktssec_rcvd_stathandle pr_state_ptr->pktssec_rcvd_stathandle
#define ete_delay_stathandle pr_state_ptr->ete_delay_stathandle
#define bits_rcvd_gstathandle pr_state_ptr->bits_rcvd_gstathandle
#define bitssec_rcvd_gstathandle pr_state_ptr->bitssec_rcvd_gstathandle
#define pkts_rcvd_gstathandle pr_state_ptr->pkts_rcvd_gstathandle
#define pktssec_rcvd_gstathandle pr_state_ptr->pktssec_rcvd_gstathandle
#define ete_delay_gstathandle pr_state_ptr->ete_delay_gstathandle
#define iPackNum pr_state_ptr->iPackNum
#define mean_intvl pr_state_ptr->mean_intvl
/* These macro definitions will define a local variable called */
/* "op_sv_ptr" in each function containing a FIN statement. */
/* This variable points to the state variable data structure, */
/* and can be used from a C debugger to display their values. */
#undef FIN_PREAMBLE_DEC
#undef FIN_PREAMBLE_CODE
#if defined (OPD_PARALLEL)
# define FIN_PREAMBLE_DEC gpr_sink_state *op_sv_ptr; OpT_Sim_Context * tcontext_ptr;
# define FIN_PREAMBLE_CODE \
if (VosS_Mt_Perform_Lock) \
VOS_THREAD_SPECIFIC_DATA_GET (VosI_Globals.simi_mt_context_data_key, tcontext_ptr, SimT_Context *); \
else \
tcontext_ptr = VosI_Globals.simi_sequential_context_ptr; \
op_sv_ptr = ((gpr_sink_state *)(tcontext_ptr->mod_state_ptr));
#else
# define FIN_PREAMBLE_DEC gpr_sink_state *op_sv_ptr;
# define FIN_PREAMBLE_CODE op_sv_ptr = pr_state_ptr;
#endif
/* No Function Block */
#if !defined (VOSD_NO_FIN)
enum { _op_block_origin = __LINE__ };
#endif
/* Undefine optional tracing in FIN/FOUT/FRET */
/* The FSM has its own tracing code and the other */
/* functions should not have any tracing. */
#undef FIN_TRACING
#define FIN_TRACING
#undef FOUTRET_TRACING
#define FOUTRET_TRACING
#if defined (__cplusplus)
extern "C" {
#endif
void gpr_sink (OP_SIM_CONTEXT_ARG_OPT);
VosT_Obtype gpr_sink_init (int * init_block_ptr);
VosT_Address gpr_sink_alloc (VOS_THREAD_INDEX_ARG_COMMA VosT_Obtype, int);
void gpr_sink_diag (OP_SIM_CONTEXT_ARG_OPT);
void gpr_sink_terminate (OP_SIM_CONTEXT_ARG_OPT);
void gpr_sink_svar (void *, const char *, void **);
VosT_Fun_Status Vos_Define_Object (VosT_Obtype * obst_ptr, const char * name, unsigned int size, unsigned int init_obs, unsigned int inc_obs);
VosT_Address Vos_Alloc_Object_MT (VOS_THREAD_INDEX_ARG_COMMA VosT_Obtype ob_hndl);
VosT_Fun_Status Vos_Poolmem_Dealloc_MT (VOS_THREAD_INDEX_ARG_COMMA VosT_Address ob_ptr);
#if defined (__cplusplus)
} /* end of 'extern "C"' */
#endif
/* Process model interrupt handling procedure */
void
gpr_sink (OP_SIM_CONTEXT_ARG_OPT)
{
#if !defined (VOSD_NO_FIN)
int _op_block_origin = 0;
#endif
FIN_MT (gpr_sink ());
if (1)
{
Packet* pkptr;
double pk_size;
double ete_delay;
FSM_ENTER_NO_VARS ("gpr_sink")
FSM_BLOCK_SWITCH
{
/*---------------------------------------------------------*/
/** state (DISCARD) enter executives **/
FSM_STATE_ENTER_UNFORCED (0, "DISCARD", state0_enter_exec, "gpr_sink [DISCARD enter execs]")
FSM_PROFILE_SECTION_IN (gpr_sink [DISCARD enter execs], state0_enter_exec)
{
}
FSM_PROFILE_SECTION_OUT (gpr_sink [DISCARD enter execs], state0_enter_exec)
/** blocking after enter executives of unforced state. **/
FSM_EXIT (1,"gpr_sink")
/** state (DISCARD) exit executives **/
FSM_STATE_EXIT_UNFORCED (0, "DISCARD", "gpr_sink [DISCARD exit execs]")
FSM_PROFILE_SECTION_IN (gpr_sink [DISCARD exit execs], state0_exit_exec)
{
/* Obtain the incoming packet. */
pkptr = op_pk_get (op_intrpt_strm ());
op_prg_odb_bkpt("ztl_up");
/* Caclulate metrics to be updated. */
pk_size = (double) op_pk_total_size_get (pkptr);
ete_delay = op_sim_time () - op_pk_creation_time_get (pkptr);
mean_intvl=(mean_intvl*iPackNum+ete_delay)/++iPackNum;
/* Update local statistics. */
op_stat_write (bits_rcvd_stathandle, pk_size);
op_stat_write (pkts_rcvd_stathandle, 1.0);
op_stat_write (ete_delay_stathandle, mean_intvl);
op_stat_write (bitssec_rcvd_stathandle, pk_size);
op_stat_write (bitssec_rcvd_stathandle, 0.0);
op_stat_write (pktssec_rcvd_stathandle, 1.0);
op_stat_write (pktssec_rcvd_stathandle, 0.0);
/* Update global statistics. */
op_stat_write (bits_rcvd_gstathandle, pk_size);
op_stat_write (pkts_rcvd_gstathandle, 1.0);
op_stat_write (ete_delay_gstathandle, mean_intvl);
op_stat_write (bitssec_rcvd_gstathandle, pk_size);
op_stat_write (bitssec_rcvd_gstathandle, 0.0);
op_stat_write (pktssec_rcvd_gstathandle, 1.0);
op_stat_write (pktssec_rcvd_gstathandle, 0.0);
/* Destroy the received packet. */
op_pk_destroy (pkptr);
}
FSM_PROFILE_SECTION_OUT (gpr_sink [DISCARD exit execs], state0_exit_exec)
/** state (DISCARD) transition processing **/
FSM_TRANSIT_FORCE (0, state0_enter_exec, ;, "default", "", "DISCARD", "DISCARD")
/*---------------------------------------------------------*/
/** state (INIT) enter executives **/
FSM_STATE_ENTER_FORCED_NOLABEL (1, "INIT", "gpr_sink [INIT enter execs]")
FSM_PROFILE_SECTION_IN (gpr_sink [INIT enter execs], state1_enter_exec)
{
/* Initilaize the statistic handles to keep */
/* track of traffic sinked by this process. */
bits_rcvd_stathandle = op_stat_reg ("Traffic Sink.Traffic Received (bits)", OPC_STAT_INDEX_NONE, OPC_STAT_LOCAL);
bitssec_rcvd_stathandle = op_stat_reg ("Traffic Sink.Traffic Received (bits/sec)", OPC_STAT_INDEX_NONE, OPC_STAT_LOCAL);
pkts_rcvd_stathandle = op_stat_reg ("Traffic Sink.Traffic Received (packets)", OPC_STAT_INDEX_NONE, OPC_STAT_LOCAL);
pktssec_rcvd_stathandle = op_stat_reg ("Traffic Sink.Traffic Received (packets/sec)", OPC_STAT_INDEX_NONE, OPC_STAT_LOCAL);
ete_delay_stathandle = op_stat_reg ("Traffic Sink.End-to-End Delay (seconds)", OPC_STAT_INDEX_NONE, OPC_STAT_LOCAL);
bits_rcvd_gstathandle = op_stat_reg ("Traffic Sink.Traffic Received (bits)", OPC_STAT_INDEX_NONE, OPC_STAT_GLOBAL);
bitssec_rcvd_gstathandle = op_stat_reg ("Traffic Sink.Traffic Received (bits/sec)", OPC_STAT_INDEX_NONE, OPC_STAT_GLOBAL);
pkts_rcvd_gstathandle = op_stat_reg ("Traffic Sink.Traffic Received (packets)", OPC_STAT_INDEX_NONE, OPC_STAT_GLOBAL);
pktssec_rcvd_gstathandle = op_stat_reg ("Traffic Sink.Traffic Received (packets/sec)", OPC_STAT_INDEX_NONE, OPC_STAT_GLOBAL);
ete_delay_gstathandle = op_stat_reg ("Traffic Sink.End-to-End Delay (seconds)", OPC_STAT_INDEX_NONE, OPC_STAT_GLOBAL);
iPackNum=0;
mean_intvl=0;
}
FSM_PROFILE_SECTION_OUT (gpr_sink [INIT enter execs], state1_enter_exec)
/** state (INIT) exit executives **/
FSM_STATE_EXIT_FORCED (1, "INIT", "gpr_sink [INIT exit execs]")
FSM_PROFILE_SECTION_IN (gpr_sink [INIT exit execs], state1_exit_exec)
{
}
FSM_PROFILE_SECTION_OUT (gpr_sink [INIT exit execs], state1_exit_exec)
/** state (INIT) transition processing **/
FSM_TRANSIT_FORCE (0, state0_enter_exec, ;, "default", "", "INIT", "DISCARD")
/*---------------------------------------------------------*/
}
FSM_EXIT (1,"gpr_sink")
}
}
void
gpr_sink_diag (OP_SIM_CONTEXT_ARG_OPT)
{
/* No Diagnostic Block */
}
void
gpr_sink_terminate (OP_SIM_CONTEXT_ARG_OPT)
{
#if !defined (VOSD_NO_FIN)
int _op_block_origin = __LINE__;
#endif
FIN_MT (gpr_sink_terminate ())
Vos_Poolmem_Dealloc_MT (OP_SIM_CONTEXT_THREAD_INDEX_COMMA pr_state_ptr);
FOUT
}
/* Undefine shortcuts to state variables to avoid */
/* syntax error in direct access to fields of */
/* local variable prs_ptr in gpr_sink_svar function. */
#undef bits_rcvd_stathandle
#undef bitssec_rcvd_stathandle
#undef pkts_rcvd_stathandle
#undef pktssec_rcvd_stathandle
#undef ete_delay_stathandle
#undef bits_rcvd_gstathandle
#undef bitssec_rcvd_gstathandle
#undef pkts_rcvd_gstathandle
#undef pktssec_rcvd_gstathandle
#undef ete_delay_gstathandle
#undef iPackNum
#undef mean_intvl
#undef FIN_PREAMBLE_DEC
#undef FIN_PREAMBLE_CODE
#define FIN_PREAMBLE_DEC
#define FIN_PREAMBLE_CODE
VosT_Obtype
gpr_sink_init (int * init_block_ptr)
{
#if !defined (VOSD_NO_FIN)
int _op_block_origin = 0;
#endif
VosT_Obtype obtype = OPC_NIL;
FIN_MT (gpr_sink_init (init_block_ptr))
Vos_Define_Object (&obtype, "proc state vars (gpr_sink)",
sizeof (gpr_sink_state), 0, 20);
*init_block_ptr = 2;
FRET (obtype)
}
VosT_Address
gpr_sink_alloc (VOS_THREAD_INDEX_ARG_COMMA VosT_Obtype obtype, int init_block)
{
#if !defined (VOSD_NO_FIN)
int _op_block_origin = 0;
#endif
gpr_sink_state * ptr;
FIN_MT (gpr_sink_alloc (obtype))
ptr = (gpr_sink_state *)Vos_Alloc_Object_MT (VOS_THREAD_INDEX_COMMA obtype);
if (ptr != OPC_NIL)
ptr->_op_current_block = init_block;
FRET ((VosT_Address)ptr)
}
void
gpr_sink_svar (void * gen_ptr, const char * var_name, void ** var_p_ptr)
{
gpr_sink_state *prs_ptr;
FIN_MT (gpr_sink_svar (gen_ptr, var_name, var_p_ptr))
if (var_name == OPC_NIL)
{
*var_p_ptr = (void *)OPC_NIL;
FOUT
}
prs_ptr = (gpr_sink_state *)gen_ptr;
if (strcmp ("bits_rcvd_stathandle" , var_name) == 0)
{
*var_p_ptr = (void *) (&prs_ptr->bits_rcvd_stathandle);
FOUT
}
if (strcmp ("bitssec_rcvd_stathandle" , var_name) == 0)
{
*var_p_ptr = (void *) (&prs_ptr->bitssec_rcvd_stathandle);
FOUT
}
if (strcmp ("pkts_rcvd_stathandle" , var_name) == 0)
{
*var_p_ptr = (void *) (&prs_ptr->pkts_rcvd_stathandle);
FOUT
}
if (strcmp ("pktssec_rcvd_stathandle" , var_name) == 0)
{
*var_p_ptr = (void *) (&prs_ptr->pktssec_rcvd_stathandle);
FOUT
}
if (strcmp ("ete_delay_stathandle" , var_name) == 0)
{
*var_p_ptr = (void *) (&prs_ptr->ete_delay_stathandle);
FOUT
}
if (strcmp ("bits_rcvd_gstathandle" , var_name) == 0)
{
*var_p_ptr = (void *) (&prs_ptr->bits_rcvd_gstathandle);
FOUT
}
if (strcmp ("bitssec_rcvd_gstathandle" , var_name) == 0)
{
*var_p_ptr = (void *) (&prs_ptr->bitssec_rcvd_gstathandle);
FOUT
}
if (strcmp ("pkts_rcvd_gstathandle" , var_name) == 0)
{
*var_p_ptr = (void *) (&prs_ptr->pkts_rcvd_gstathandle);
FOUT
}
if (strcmp ("pktssec_rcvd_gstathandle" , var_name) == 0)
{
*var_p_ptr = (void *) (&prs_ptr->pktssec_rcvd_gstathandle);
FOUT
}
if (strcmp ("ete_delay_gstathandle" , var_name) == 0)
{
*var_p_ptr = (void *) (&prs_ptr->ete_delay_gstathandle);
FOUT
}
if (strcmp ("iPackNum" , var_name) == 0)
{
*var_p_ptr = (void *) (&prs_ptr->iPackNum);
FOUT
}
if (strcmp ("mean_intvl" , var_name) == 0)
{
*var_p_ptr = (void *) (&prs_ptr->mean_intvl);
FOUT
}
*var_p_ptr = (void *)OPC_NIL;
FOUT
}
⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -