📄 aodv_app_manager.pr.c
字号:
/* Process model C form file: aodv_app_manager.pr.c */
/* Portions of this file copyright 1992-2003 by OPNET Technologies, Inc. */
/* This variable carries the header into the object file */
const char aodv_app_manager_pr_c [] = "MIL_3_Tfile_Hdr_ 100A 30A modeler 7 43C4D6A1 43C4D6A1 1 wind Administrator 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 */
#define TX_OUT_STRM 0
#define SRC_IN_STRM 0
#define RX_IN_STRM 1
#define RX_OUT_STRM 1
/* packet types definition */
#define DATA_PACKET_TYPE 5
#define REQUEST_PACKET_TYPE 7
#define REPLY_PACKET_TYPE 11
#define ERROR_PACKET_TYPE 13
/* transition macro */
#define SRC_ARVL ( op_intrpt_type () == OPC_INTRPT_STRM && op_intrpt_strm() == SRC_IN_STRM)
#define RCV_ARVL ( op_intrpt_type () == OPC_INTRPT_STRM && op_intrpt_strm() == RX_IN_STRM)
/* interlocutor values */
#define NONE -2
#define RANDOM -1
/* Global variable */
int num_nodes;
/* 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 */
int DEBUG;
int node_addr;
int node_id;
int INTERLOCUTOR;
int GRAT_RATIO;
Distribution * grat_dist;
Distribution * address_dist;
} aodv_app_manager_state;
#define pr_state_ptr ((aodv_app_manager_state*) (OP_SIM_CONTEXT_PTR->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
/* 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 aodv_app_manager_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 = ((aodv_app_manager_state *)(tcontext_ptr->mod_state_ptr));
#else
# define FIN_PREAMBLE_DEC aodv_app_manager_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 aodv_app_manager (OP_SIM_CONTEXT_ARG_OPT);
VosT_Obtype aodv_app_manager_init (int * init_block_ptr);
VosT_Address aodv_app_manager_alloc (VOS_THREAD_INDEX_ARG_COMMA VosT_Obtype, int);
void aodv_app_manager_diag (OP_SIM_CONTEXT_ARG_OPT);
void aodv_app_manager_terminate (OP_SIM_CONTEXT_ARG_OPT);
void aodv_app_manager_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
aodv_app_manager (OP_SIM_CONTEXT_ARG_OPT)
{
#if !defined (VOSD_NO_FIN)
int _op_block_origin = 0;
#endif
FIN_MT (aodv_app_manager ());
if (1)
{
/* Packet reception */
int pk_type;
/* Packet Transmission */
Packet *pkptr;
int dest,grat_outcome, g_flag;
FSM_ENTER ("aodv_app_manager")
FSM_BLOCK_SWITCH
{
/*---------------------------------------------------------*/
/** state (init) enter executives **/
FSM_STATE_ENTER_FORCED_NOLABEL (0, "init", "aodv_app_manager [init enter execs]")
FSM_PROFILE_SECTION_IN (aodv_app_manager [init enter execs], state0_enter_exec)
{
/* Load network parameters */
node_id = op_topo_parent (op_id_self());
op_ima_obj_attr_get(node_id,"wlan_mac.station_address",&node_addr);
op_ima_obj_attr_get(op_id_self(),"Interlocutor",&INTERLOCUTOR);
op_ima_obj_attr_get(node_id,"DEBUG",&DEBUG);
op_ima_obj_attr_get(op_id_self(),"GRAT_RATIO",&GRAT_RATIO);
num_nodes = op_topo_object_count (OPC_OBJTYPE_NDMOB);
address_dist = op_dist_load ("uniform_int", 0, (num_nodes-1));
grat_dist = op_dist_load ("uniform_int", 0,99);
}
FSM_PROFILE_SECTION_OUT (aodv_app_manager [init enter execs], state0_enter_exec)
/** state (init) exit executives **/
FSM_STATE_EXIT_FORCED (0, "init", "aodv_app_manager [init exit execs]")
FSM_PROFILE_SECTION_IN (aodv_app_manager [init exit execs], state0_exit_exec)
{
}
FSM_PROFILE_SECTION_OUT (aodv_app_manager [init exit execs], state0_exit_exec)
/** state (init) transition processing **/
FSM_TRANSIT_FORCE (1, state1_enter_exec, ;, "default", "", "init", "idle")
/*---------------------------------------------------------*/
/** state (idle) enter executives **/
FSM_STATE_ENTER_UNFORCED (1, "idle", state1_enter_exec, "aodv_app_manager [idle enter execs]")
FSM_PROFILE_SECTION_IN (aodv_app_manager [idle enter execs], state1_enter_exec)
{
}
FSM_PROFILE_SECTION_OUT (aodv_app_manager [idle enter execs], state1_enter_exec)
/** 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]")
FSM_PROFILE_SECTION_IN (aodv_app_manager [idle exit execs], state1_exit_exec)
{
}
FSM_PROFILE_SECTION_OUT (aodv_app_manager [idle exit execs], state1_exit_exec)
/** state (idle) transition processing **/
FSM_PROFILE_SECTION_IN (aodv_app_manager [idle trans conditions], state1_trans_conds)
FSM_INIT_COND (RCV_ARVL)
FSM_TEST_COND (SRC_ARVL)
FSM_DFLT_COND
FSM_TEST_LOGIC ("idle")
FSM_PROFILE_SECTION_OUT (aodv_app_manager [idle trans conditions], state1_trans_conds)
FSM_TRANSIT_SWITCH
{
FSM_CASE_TRANSIT (0, 2, state2_enter_exec, ;, "RCV_ARVL", "", "idle", "rx")
FSM_CASE_TRANSIT (1, 3, state3_enter_exec, ;, "SRC_ARVL", "", "idle", "tx")
FSM_CASE_TRANSIT (2, 1, state1_enter_exec, ;, "default", "", "idle", "idle")
}
/*---------------------------------------------------------*/
/** state (rx) enter executives **/
FSM_STATE_ENTER_FORCED (2, "rx", state2_enter_exec, "aodv_app_manager [rx enter execs]")
FSM_PROFILE_SECTION_IN (aodv_app_manager [rx enter execs], state2_enter_exec)
{
// Read packet from upcoming stream
pkptr = op_pk_get (RX_IN_STRM);
// Eventually count the number of received packets
// Hand over the packet to the upper layer
op_pk_nfd_get(pkptr, "Type", &pk_type);
if (pk_type == DATA_PACKET_TYPE)
{
if(DEBUG> 3) printf("<node %d @ app manager>: a data packet has been forwarded to the app_sink.\n", node_addr);
op_pk_send (pkptr, RX_OUT_STRM);
}
}
FSM_PROFILE_SECTION_OUT (aodv_app_manager [rx enter execs], state2_enter_exec)
/** state (rx) exit executives **/
FSM_STATE_EXIT_FORCED (2, "rx", "aodv_app_manager [rx exit execs]")
FSM_PROFILE_SECTION_IN (aodv_app_manager [rx exit execs], state2_exit_exec)
{
}
FSM_PROFILE_SECTION_OUT (aodv_app_manager [rx exit execs], state2_exit_exec)
/** state (rx) transition processing **/
FSM_TRANSIT_FORCE (1, state1_enter_exec, ;, "default", "", "rx", "idle")
/*---------------------------------------------------------*/
/** state (tx) enter executives **/
FSM_STATE_ENTER_FORCED (3, "tx", state3_enter_exec, "aodv_app_manager [tx enter execs]")
FSM_PROFILE_SECTION_IN (aodv_app_manager [tx enter execs], state3_enter_exec)
{
if(INTERLOCUTOR != NONE)
{
if(DEBUG> 4) printf("<node %d @ app manager>: a new data packet has been generated.\n", node_addr);
pkptr = op_pk_get (SRC_IN_STRM);
if(INTERLOCUTOR != RANDOM)
{
// node is in mono-interlocutor mode
// the value of Interlocutor must be a
// valid node address
dest = INTERLOCUTOR;
}
else
{
// compute randomly a dest and set DEST field
dest = (int)op_dist_outcome (address_dist);
while (node_addr == dest)
{
address_dist = op_dist_load ("uniform_int", 0, (num_nodes-1));
dest = (int)op_dist_outcome (address_dist);
}
}
if(DEBUG> 4) printf(" Destination is %d\n", dest);
// determine whether GRATUITOUS request or not
g_flag =0;
grat_outcome = (int) op_dist_outcome (grat_dist);
if(grat_outcome < GRAT_RATIO)
g_flag = 1;
// format the packet fields
op_pk_nfd_set(pkptr,"SRC",node_addr);
op_pk_nfd_set(pkptr,"DEST", dest);
op_pk_nfd_set(pkptr,"G", g_flag);
// Send packet to lower layer
op_pk_send (pkptr,TX_OUT_STRM);
}
}
FSM_PROFILE_SECTION_OUT (aodv_app_manager [tx enter execs], state3_enter_exec)
/** state (tx) exit executives **/
FSM_STATE_EXIT_FORCED (3, "tx", "aodv_app_manager [tx exit execs]")
FSM_PROFILE_SECTION_IN (aodv_app_manager [tx exit execs], state3_exit_exec)
{
}
FSM_PROFILE_SECTION_OUT (aodv_app_manager [tx exit execs], state3_exit_exec)
/** state (tx) transition processing **/
FSM_TRANSIT_FORCE (1, state1_enter_exec, ;, "default", "", "tx", "idle")
/*---------------------------------------------------------*/
}
FSM_EXIT (0,"aodv_app_manager")
}
}
void
aodv_app_manager_diag (OP_SIM_CONTEXT_ARG_OPT)
{
/* No Diagnostic Block */
}
void
aodv_app_manager_terminate (OP_SIM_CONTEXT_ARG_OPT)
{
#if !defined (VOSD_NO_FIN)
int _op_block_origin = __LINE__;
#endif
FIN_MT (aodv_app_manager_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 aodv_app_manager_svar function. */
#undef DEBUG
#undef node_addr
#undef node_id
#undef INTERLOCUTOR
#undef GRAT_RATIO
#undef grat_dist
#undef address_dist
#undef FIN_PREAMBLE_DEC
#undef FIN_PREAMBLE_CODE
#define FIN_PREAMBLE_DEC
#define FIN_PREAMBLE_CODE
VosT_Obtype
aodv_app_manager_init (int * init_block_ptr)
{
#if !defined (VOSD_NO_FIN)
int _op_block_origin = 0;
#endif
VosT_Obtype obtype = OPC_NIL;
FIN_MT (aodv_app_manager_init (init_block_ptr))
Vos_Define_Object (&obtype, "proc state vars (aodv_app_manager)",
sizeof (aodv_app_manager_state), 0, 20);
*init_block_ptr = 0;
FRET (obtype)
}
VosT_Address
aodv_app_manager_alloc (VOS_THREAD_INDEX_ARG_COMMA VosT_Obtype obtype, int init_block)
{
#if !defined (VOSD_NO_FIN)
int _op_block_origin = 0;
#endif
aodv_app_manager_state * ptr;
FIN_MT (aodv_app_manager_alloc (obtype))
ptr = (aodv_app_manager_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
aodv_app_manager_svar (void * gen_ptr, const char * var_name, void ** var_p_ptr)
{
aodv_app_manager_state *prs_ptr;
FIN_MT (aodv_app_manager_svar (gen_ptr, var_name, var_p_ptr))
if (var_name == OPC_NIL)
{
*var_p_ptr = (void *)OPC_NIL;
FOUT
}
prs_ptr = (aodv_app_manager_state *)gen_ptr;
if (strcmp ("DEBUG" , var_name) == 0)
{
*var_p_ptr = (void *) (&prs_ptr->DEBUG);
FOUT
}
if (strcmp ("node_addr" , var_name) == 0)
{
*var_p_ptr = (void *) (&prs_ptr->node_addr);
FOUT
}
if (strcmp ("node_id" , var_name) == 0)
{
*var_p_ptr = (void *) (&prs_ptr->node_id);
FOUT
}
if (strcmp ("INTERLOCUTOR" , var_name) == 0)
{
*var_p_ptr = (void *) (&prs_ptr->INTERLOCUTOR);
FOUT
}
if (strcmp ("GRAT_RATIO" , var_name) == 0)
{
*var_p_ptr = (void *) (&prs_ptr->GRAT_RATIO);
FOUT
}
if (strcmp ("grat_dist" , var_name) == 0)
{
*var_p_ptr = (void *) (&prs_ptr->grat_dist);
FOUT
}
if (strcmp ("address_dist" , var_name) == 0)
{
*var_p_ptr = (void *) (&prs_ptr->address_dist);
FOUT
}
*var_p_ptr = (void *)OPC_NIL;
FOUT
}
⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -