?? aodv_app_manager.pr.c
字號:
/* Process model C form file: aodv_app_manager.pr.c */
/* Portions of this file copyright 1992-2002 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_ 81A 30A modeler 7 47F08A47 47F08A47 1 jujumao Administrator 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 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(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;
} 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
/* 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)
{
/* 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]")
{
/* 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);
}
/** 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 (RCV_ARVL)
FSM_TEST_COND (SRC_ARVL)
FSM_DFLT_COND
FSM_TEST_LOGIC ("idle")
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, state2_enter_exec, "rx", "aodv_app_manager () [rx enter execs]")
{
// 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);
}
}
/** state (rx) exit executives **/
FSM_STATE_EXIT_FORCED (2, "rx", "aodv_app_manager () [rx exit execs]")
{
}
/** state (rx) transition processing **/
FSM_TRANSIT_FORCE (1, state1_enter_exec, ;, "default", "", "rx", "idle")
/*---------------------------------------------------------*/
/** state (tx) enter executives **/
FSM_STATE_ENTER_FORCED (3, state3_enter_exec, "tx", "aodv_app_manager () [tx enter execs]")
{
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);
}
}
/** state (tx) exit executives **/
FSM_STATE_EXIT_FORCED (3, "tx", "aodv_app_manager () [tx exit execs]")
{
}
/** state (tx) transition processing **/
FSM_TRANSIT_FORCE (1, state1_enter_exec, ;, "default", "", "tx", "idle")
/*---------------------------------------------------------*/
}
FSM_EXIT (0,aodv_app_manager)
}
}
#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
aodv_app_manager_init (void ** gen_state_pptr)
{
int _block_origin = 0;
static VosT_Address obtype = OPC_NIL;
FIN (aodv_app_manager_init (gen_state_pptr))
if (obtype == OPC_NIL)
{
/* Initialize memory management */
if (Vos_Catmem_Register ("proc state vars (aodv_app_manager)",
sizeof (aodv_app_manager_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 */
((aodv_app_manager_state *)(*gen_state_pptr))->current_block = 0;
FRET (OPC_COMPCODE_SUCCESS)
}
}
void
aodv_app_manager_diag (void)
{
/* No Diagnostic Block */
}
void
aodv_app_manager_terminate (void)
{
int _block_origin = __LINE__;
FIN (aodv_app_manager_terminate (void))
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 aodv_app_manager_svar function. */
#undef DEBUG
#undef node_addr
#undef node_id
#undef INTERLOCUTOR
#undef GRAT_RATIO
#undef grat_dist
#undef address_dist
void
aodv_app_manager_svar (void * gen_ptr, const char * var_name, char ** var_p_ptr)
{
aodv_app_manager_state *prs_ptr;
FIN (aodv_app_manager_svar (gen_ptr, var_name, var_p_ptr))
if (var_name == OPC_NIL)
{
*var_p_ptr = (char *)OPC_NIL;
FOUT;
}
prs_ptr = (aodv_app_manager_state *)gen_ptr;
if (strcmp ("DEBUG" , var_name) == 0)
{
*var_p_ptr = (char *) (&prs_ptr->DEBUG);
FOUT;
}
if (strcmp ("node_addr" , var_name) == 0)
{
*var_p_ptr = (char *) (&prs_ptr->node_addr);
FOUT;
}
if (strcmp ("node_id" , var_name) == 0)
{
*var_p_ptr = (char *) (&prs_ptr->node_id);
FOUT;
}
if (strcmp ("INTERLOCUTOR" , var_name) == 0)
{
*var_p_ptr = (char *) (&prs_ptr->INTERLOCUTOR);
FOUT;
}
if (strcmp ("GRAT_RATIO" , var_name) == 0)
{
*var_p_ptr = (char *) (&prs_ptr->GRAT_RATIO);
FOUT;
}
if (strcmp ("grat_dist" , var_name) == 0)
{
*var_p_ptr = (char *) (&prs_ptr->grat_dist);
FOUT;
}
if (strcmp ("address_dist" , var_name) == 0)
{
*var_p_ptr = (char *) (&prs_ptr->address_dist);
FOUT;
}
*var_p_ptr = (char *)OPC_NIL;
FOUT;
}
?? 快捷鍵說明
復制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號
Ctrl + =
減小字號
Ctrl + -