aodv_app_manager.pr.c

opnet ad hoc adov routing

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



/* This variable carries the header into the object file */
static const char aodv_app_manager_pr_c [] = "MIL_3_Tfile_Hdr_ 80C 30A op_runsim 7 3C064A56 3C064A56 1 manet.antd.nist.gov lmiller 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


/* Header Block */

#define UPP_INPUT_STRM   0
#define LOW_INPUT_STRM   1
#define LOW_OUTPUT_STRM  0
#define UPP_OUTPUT_STRM  1

/* transition codes */
#define INIT_CODE        0
#define CHANGE_DEST_CODE 1
/* transition macro */
#define UPP_ARVL ( op_intrpt_type () == OPC_INTRPT_STRM && op_intrpt_strm() == UPP_INPUT_STRM)
#define LOW_ARVL ( op_intrpt_type () == OPC_INTRPT_STRM && op_intrpt_strm() == LOW_INPUT_STRM)
#define INIT     ( op_intrpt_type () == OPC_INTRPT_SELF && op_intrpt_code() == INIT_CODE)
#define CHANGE_DEST    ( op_intrpt_type () == OPC_INTRPT_SELF && op_intrpt_code() == CHANGE_DEST_CODE)
/* interlocutor values */
#define NONE -2
#define RANDOM -1
/* Global variable */
int num_nodes;
int NB_FLOWS_AVAIL = 15;
int NB_FLOWS       = 15;

/* End of Header Block */


#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 */
	int	                    		DEBUG;
	int	                    		node_addr;
	int	                    		node_id;
	int	                    		INTERLOCUTOR;
	int	                    		GRAT_RATIO;
	Distribution *	         		grat_dist;
	Distribution *	         		address_dist;
	int	                    		dest;
	int	                    		SRC_ACTIVE;
	} aodv_app_manager_state;

#define pr_state_ptr            		((aodv_app_manager_state*) SimI_Mod_State_Ptr)
#define DEBUG                   		pr_state_ptr->DEBUG
#define node_addr               		pr_state_ptr->node_addr
#define node_id                 		pr_state_ptr->node_id
#define INTERLOCUTOR            		pr_state_ptr->INTERLOCUTOR
#define GRAT_RATIO              		pr_state_ptr->GRAT_RATIO
#define grat_dist               		pr_state_ptr->grat_dist
#define address_dist            		pr_state_ptr->address_dist
#define dest                    		pr_state_ptr->dest
#define SRC_ACTIVE              		pr_state_ptr->SRC_ACTIVE

/* 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	aodv_app_manager_state *op_sv_ptr = pr_state_ptr;


/* No Function Block */

enum { _block_origin = __LINE__ };

/* 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 aodv_app_manager (void);
	Compcode aodv_app_manager_init (void **);
	void aodv_app_manager_diag (void);
	void aodv_app_manager_terminate (void);
	void aodv_app_manager_svar (void *, const char *, char **);
#if defined (__cplusplus)
} /* end of 'extern "C"' */
#endif




/* Process model interrupt handling procedure */


void
aodv_app_manager (void)
	{
	int _block_origin = 0;
	FIN (aodv_app_manager ());
	if (1)
		{
		Objid	     			 params_comp_attr_objid;
		Objid                    params_attr_objid;
		/* Packet reception */
		int pk_type,dest_ip_addr;
		/* Packet Transmission */
		Packet *pkptr, *rx_pk_ptr;
		int   grat_outcome, g_flag;
		/* Service request to routing layer */
		Ici * ici_ptr, *rx_ici_ptr;
		int   segment_count;
		int   i;
		int   a_requested;
		double wait_time;


		FSM_ENTER (aodv_app_manager)

		FSM_BLOCK_SWITCH
			{
			/*---------------------------------------------------------*/
			/** state (init) enter executives **/
			FSM_STATE_ENTER_FORCED (0, state0_enter_exec, "init", "aodv_app_manager () [init enter execs]")
				{
				// Trace
				if(DEBUG > 0)
					{
					printf("\n<node %d @ app manager>  INIT ::\n", node_addr);
					printf("                         - Current time = %f\n", op_sim_time());
					printf("                         - Flows avail  = %d\n", NB_FLOWS_AVAIL);
					}
				// Proceed only if there is more than one node in the network, and if there is at least
				// a flow available
				if(num_nodes > 1 && NB_FLOWS_AVAIL > 0)
					{
					// If Interlocutor is different than random or none, then set the dest
					// variable to the specified destinatio address, and reserve a flow
					if(INTERLOCUTOR != RANDOM && INTERLOCUTOR != NONE)
						{		
						// Reserve a flow
						NB_FLOWS_AVAIL--;
						// Set destination
						dest = INTERLOCUTOR;
						}
					// If Interlocutor is set to none, then src is not active
					else if(INTERLOCUTOR == NONE)
						{
						// Set dest to none. Src will be silent
						dest = NONE;
						}
					// If Interlocutor is set to random, then pick up a random destination
					// and reserve a flow
					else if(INTERLOCUTOR == RANDOM)
						{
						// Reserve a flow
						NB_FLOWS_AVAIL--;		
						// Load distribution
						address_dist = op_dist_load ("uniform_int", 0, (num_nodes-1));
						// Pick a random destination
						dest = (int) op_dist_outcome (address_dist);
						// Repeat until dest is valid
						while (node_addr == dest)
							{
							dest = (int) op_dist_outcome (address_dist);
							}
						}
					}
				else 
					{
					if(NB_FLOWS_AVAIL < 1)
						if(DEBUG > 0) printf("                         - No more spot left (%d flows avail)\n", NB_FLOWS_AVAIL);
					// No more spots are left. source will be silent
					dest = NONE;
					}
				if(DEBUG > 0) printf("                         - Dest is      = %d (None = -2, Rand = -1)\n",dest);
				}


			/** state (init) exit executives **/
			FSM_STATE_EXIT_FORCED (0, "init", "aodv_app_manager () [init exit execs]")
				{
				}


			/** state (init) transition processing **/
			FSM_TRANSIT_FORCE (1, state1_enter_exec, ;, "default", "", "init", "idle")
				/*---------------------------------------------------------*/



			/** state (idle) enter executives **/
			FSM_STATE_ENTER_UNFORCED (1, state1_enter_exec, "idle", "aodv_app_manager () [idle enter execs]")
				{
				
				}


			/** blocking after enter executives of unforced state. **/
			FSM_EXIT (3,aodv_app_manager)


			/** state (idle) exit executives **/
			FSM_STATE_EXIT_UNFORCED (1, "idle", "aodv_app_manager () [idle exit execs]")
				{
				}


			/** state (idle) transition processing **/
			FSM_INIT_COND (LOW_ARVL)
			FSM_TEST_COND (UPP_ARVL)
			FSM_DFLT_COND
			FSM_TEST_LOGIC ("idle")

			FSM_TRANSIT_SWITCH
				{
				FSM_CASE_TRANSIT (0, 2, state2_enter_exec, ;, "LOW_ARVL", "", "idle", "rx")
				FSM_CASE_TRANSIT (1, 3, state3_enter_exec, ;, "UPP_ARVL", "", "idle", "tx")
				FSM_CASE_TRANSIT (2, 1, state1_enter_exec, ;, "default", "", "idle", "idle")
				}
				/*---------------------------------------------------------*/



			/** state (rx) enter executives **/
			FSM_STATE_ENTER_FORCED (2, state2_enter_exec, "rx", "aodv_app_manager () [rx enter execs]")
				{
				// Read associated ICI
				rx_ici_ptr = op_intrpt_ici();
				op_ici_attr_get(rx_ici_ptr,"Source",&dest_ip_addr);
				op_ici_destroy(rx_ici_ptr);
				
				// Destroy packet from upcoming stream
				rx_pk_ptr = op_pk_get (LOW_INPUT_STRM);
				op_pk_nfd_get(rx_pk_ptr, "A", &a_requested);
				op_pk_destroy(rx_pk_ptr);
				
				
				// Send a data packet back to the source, in order to 
				// fake a bi-directional comm.
				if(a_requested)
					{
					// Trace
					if(DEBUG > 2)
						{
						printf("\n<node %d @ app manager><Time = %f> Data pk rcvd from %d: Sending pk back.\n", node_addr,op_sim_time(),dest_ip_addr);
						}
				
					// Generate packet
					rx_pk_ptr = op_pk_create_fmt("AODV_DATA_PAYLOAD");
					// Set A to 0
					op_pk_nfd_set(rx_pk_ptr, "A", 0);
					// Request a service from the routing layer
					rx_ici_ptr = op_ici_create("service_req_routing");
					op_ici_attr_set(rx_ici_ptr,"Dest", dest_ip_addr);
					op_ici_attr_set(rx_ici_ptr,"G", 1);
					op_ici_install(rx_ici_ptr);
					// Send packet to lower layer
					op_pk_send (rx_pk_ptr,LOW_OUTPUT_STRM);
					}
				
				}