server_sink.pr.c

基于OPNET的网络仿真程序,为Opnet网络仿真书籍的实例

/* Process model C form file: server_sink.pr.c */
/* Portions of this file copyright 1992-2000 by OPNET, Inc. */



/* This variable carries the header into the object file */
static const char server_sink_pr_c [] = "MIL_3_Tfile_Hdr_ 70B 30A modeler 7 3981C6B1 3981C6B1 1 wtn10047 wwhimpen 0 0 none none 0 0 none 0 0 0 0 0 0                                                                                                                                                                                                                                                                                                                                                                                                                    ";
#include <string.h>



/* OPNET system definitions */
#include <opnet.h>

#if defined (__cplusplus)
extern "C" {
#endif
FSM_EXT_DECS
#if defined (__cplusplus)
} /* end of 'extern "C"' */
#endif

#if !defined (VOSD_NO_FIN)
#undef	BIN
#undef	BOUT
#define	BIN		FIN_LOCAL_FIELD(last_line_passed) = __LINE__ - _block_origin;
#define	BOUT	BIN
#define	BINIT	FIN_LOCAL_FIELD(last_line_passed) = 0; _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	             		local_ETE_delay_stat;
	Stathandle	             		global_ETE_delay_stat;
	Stathandle	             		local_thruput_stat;
	Stathandle	             		global_thruput_stat;
	double	                 		bit_count;
	Stathandle	             		global_pkts_stat;
	} server_sink_state;

#define pr_state_ptr            		((server_sink_state*) SimI_Mod_State_Ptr)
#define local_ETE_delay_stat    		pr_state_ptr->local_ETE_delay_stat
#define global_ETE_delay_stat   		pr_state_ptr->global_ETE_delay_stat
#define local_thruput_stat      		pr_state_ptr->local_thruput_stat
#define global_thruput_stat     		pr_state_ptr->global_thruput_stat
#define bit_count               		pr_state_ptr->bit_count
#define global_pkts_stat        		pr_state_ptr->global_pkts_stat

/* This macro definition 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
#define FIN_PREAMBLE	server_sink_state *op_sv_ptr = pr_state_ptr;


/* No Function Block */

enum { _block_origin = __LINE__ };

#if defined (__cplusplus)
extern "C" {
#endif
	void server_sink (void);
	Compcode server_sink_init (void **);
	void server_sink_diag (void);
	void server_sink_terminate (void);
	void server_sink_svar (void *, const char *, char **);
#if defined (__cplusplus)
} /* end of 'extern "C"' */
#endif




/* Process model interrupt handling procedure */


void
server_sink (void)
	{
	int _block_origin = 0;
	FIN (server_sink ());
	if (1)
		{
		Packet* pkptr;
		double ETE_delay = 0.0;


		FSM_ENTER (server_sink)

		FSM_BLOCK_SWITCH
			{
			/*---------------------------------------------------------*/
			/** state (sink) enter executives **/
			FSM_STATE_ENTER_UNFORCED (0, state0_enter_exec, "sink", "server_sink () [sink enter execs]")
				{
				/* get packet from input stream */
				pkptr = op_pk_get(op_intrpt_strm());
				
				/* calculate global ETE delay */
				ETE_delay = op_sim_time()-op_pk_creation_time_get(pkptr);
				
				/* calculate throughput */
				bit_count = op_pk_total_size_get(pkptr);
				
				/* write stats */
				op_stat_write(local_ETE_delay_stat, (ETE_delay*1000));
				op_stat_write(global_ETE_delay_stat, (ETE_delay*1000));
				op_stat_write(local_thruput_stat, (bit_count));
				op_stat_write(global_thruput_stat, (bit_count));
				op_stat_write(global_pkts_stat, 1);
				
				/* destroy the packet */
				op_pk_destroy(pkptr);
				}


			/** blocking after enter executives of unforced state. **/
			FSM_EXIT (1,server_sink)


			/** state (sink) exit executives **/
			FSM_STATE_EXIT_UNFORCED (0, state0_exit_exec, "sink", "server_sink () [sink exit execs]")
				{
				
				}


			/** state (sink) transition processing **/
			FSM_TRANSIT_FORCE (0, state0_enter_exec, ;)
				/*---------------------------------------------------------*/



			/** state (init) enter executives **/
			FSM_STATE_ENTER_FORCED (1, state1_enter_exec, "init", "server_sink () [init enter execs]")
				{
				/* register stat handles */
				local_ETE_delay_stat = op_stat_reg("ETE Delay (msec)", OPC_STAT_INDEX_NONE, OPC_STAT_LOCAL);
				global_ETE_delay_stat = op_stat_reg("Global ETE Delay (msec)", OPC_STAT_INDEX_NONE, OPC_STAT_GLOBAL);
				local_thruput_stat = op_stat_reg("Throughput (bits/sec)", OPC_STAT_INDEX_NONE, OPC_STAT_LOCAL);
				global_thruput_stat = op_stat_reg("Global Throughput (bits/sec)", OPC_STAT_INDEX_NONE, OPC_STAT_GLOBAL);
				global_pkts_stat = op_stat_reg("Global Packets Received", OPC_STAT_INDEX_NONE, OPC_STAT_GLOBAL);
				}


			/** state (init) exit executives **/
			FSM_STATE_EXIT_FORCED (1, state1_exit_exec, "init", "server_sink () [init exit execs]")
				{
				}


			/** state (init) transition processing **/
			FSM_TRANSIT_FORCE (0, state0_enter_exec, ;)
				/*---------------------------------------------------------*/



			}


		FSM_EXIT (1,server_sink)
		}
	}

#if defined (__cplusplus)
	extern "C" { 
#endif
	extern VosT_Fun_Status Vos_Catmem_Register (const char * , int , VosT_Void_Null_Proc, VosT_Address *);
	extern VosT_Address Vos_Catmem_Alloc (VosT_Address, size_t);
	extern VosT_Fun_Status Vos_Catmem_Dealloc (VosT_Address);
#if defined (__cplusplus)
	}
#endif


Compcode
server_sink_init (void ** gen_state_pptr)
	{
	int _block_origin = 0;
	static VosT_Address	obtype = OPC_NIL;

	FIN (server_sink_init (gen_state_pptr))

	if (obtype == OPC_NIL)
		{
		/* Initialize memory management */
		if (Vos_Catmem_Register ("proc state vars (server_sink)",
			sizeof (server_sink_state), Vos_Vnop, &obtype) == VOSC_FAILURE)
			{
			FRET (OPC_COMPCODE_FAILURE)
			}
		}

	*gen_state_pptr = Vos_Catmem_Alloc (obtype, 1);
	if (*gen_state_pptr == OPC_NIL)
		{
		FRET (OPC_COMPCODE_FAILURE)
		}
	else
		{
		/* Initialize FSM handling */
		((server_sink_state *)(*gen_state_pptr))->current_block = 2;

		FRET (OPC_COMPCODE_SUCCESS)
		}
	}



void
server_sink_diag (void)
	{
	/* No Diagnostic Block */
	}




void
server_sink_terminate (void)
	{
	int _block_origin = __LINE__;

	FIN (server_sink_terminate (void))

	if (1)
		{
		Packet* pkptr;
		double ETE_delay = 0.0;

		/* No Termination Block */

		}
	Vos_Catmem_Dealloc (pr_state_ptr);

	FOUT;
	}


/* Undefine shortcuts to state variables to avoid */
/* syntax error in direct access to fields of */
/* local variable prs_ptr in server_sink_svar function. */
#undef local_ETE_delay_stat
#undef global_ETE_delay_stat
#undef local_thruput_stat
#undef global_thruput_stat
#undef bit_count
#undef global_pkts_stat



void
server_sink_svar (void * gen_ptr, const char * var_name, char ** var_p_ptr)
	{
	server_sink_state		*prs_ptr;

	FIN (server_sink_svar (gen_ptr, var_name, var_p_ptr))

	if (var_name == OPC_NIL)
		{
		*var_p_ptr = (char *)OPC_NIL;
		FOUT;
		}
	prs_ptr = (server_sink_state *)gen_ptr;

	if (strcmp ("local_ETE_delay_stat" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->local_ETE_delay_stat);
		FOUT;
		}
	if (strcmp ("global_ETE_delay_stat" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->global_ETE_delay_stat);
		FOUT;
		}
	if (strcmp ("local_thruput_stat" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->local_thruput_stat);
		FOUT;
		}
	if (strcmp ("global_thruput_stat" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->global_thruput_stat);
		FOUT;
		}
	if (strcmp ("bit_count" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->bit_count);
		FOUT;
		}
	if (strcmp ("global_pkts_stat" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->global_pkts_stat);
		FOUT;
		}
	*var_p_ptr = (char *)OPC_NIL;

	FOUT;
	}