📄 restoration_rte_bak.pr.c
字号:
/* Process model C form file: Restoration_rte_bak.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 Restoration_rte_bak_pr_c [] = "MIL_3_Tfile_Hdr_ 80C 30A modeler 7 3E5CB6F6 3E5CB6F6 1 WS ADCAN 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 */
#include "route.h"
#define BEG_SIM (op_intrpt_type () == OPC_INTRPT_BEGSIM)
#define END_SIM (op_intrpt_type () == OPC_INTRPT_ENDSIM)
#define MAX_HOPS 15
#define PK_ARRIVAL (op_intrpt_type () == OPC_INTRPT_STRM)
#define PK_OUT_STRM 4
extern Topology* topo_ptr;
double gap[NODE_NUM][NODE_NUM][WAVE_NUM];
Packet* pkptr;
FILE *fp;
typedef struct {
double start;
double dtime;
} wave_info;
/* 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 */
Route* current_rptr;
Objid subnet_id;
Objid next_node_id;
int rev_pk_count;
Stathandle rev_pk_cnt_stathandle;
Objid node_objid;
Objid self_objid;
Objid subnet_objid;
int node_pk_count;
Objid dst_node_id;
} Restoration_rte_bak_state;
#define pr_state_ptr ((Restoration_rte_bak_state*) SimI_Mod_State_Ptr)
#define current_rptr pr_state_ptr->current_rptr
#define subnet_id pr_state_ptr->subnet_id
#define next_node_id pr_state_ptr->next_node_id
#define rev_pk_count pr_state_ptr->rev_pk_count
#define rev_pk_cnt_stathandle pr_state_ptr->rev_pk_cnt_stathandle
#define node_objid pr_state_ptr->node_objid
#define self_objid pr_state_ptr->self_objid
#define subnet_objid pr_state_ptr->subnet_objid
#define node_pk_count pr_state_ptr->node_pk_count
#define dst_node_id pr_state_ptr->dst_node_id
/* 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 Restoration_rte_bak_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 Restoration_rte_bak (void);
Compcode Restoration_rte_bak_init (void **);
void Restoration_rte_bak_diag (void);
void Restoration_rte_bak_terminate (void);
void Restoration_rte_bak_svar (void *, const char *, char **);
#if defined (__cplusplus)
} /* end of 'extern "C"' */
#endif
/* Process model interrupt handling procedure */
void
Restoration_rte_bak (void)
{
int _block_origin = 0;
FIN (Restoration_rte_bak ());
if (1)
{
Objid dest_objid;
Objid src_objid;
Objid FIS_dest_objid;
Objid FIS_src_objid;
Objid src_node_objid;
Objid dst_node_objid;
Objid current_node_objid;
Objid next_node_objid;
Objid link_objid;
Objid tx_objid;
Objid strm_objid;
int destination_address;
int source_address;
int fail_name;
int strm_num;
int dst_address;
int wave_count;
int userid;//init
char name_id[10];
int fis_gen_userid;//fis_gen
char fis_gen_name_id[10];
int next_userid;//send
int current_userid;
int same_userid;//same
char same_name_id[10];
int rte_userid;//all
char rte_name_id[10];
int flag;
int PK_type;
Packet* FIS_pkptr;
Packet* r_FIS_pkptr;
Packet* ack_pkptr;
Route* FIS_min_rptr_copy;
Route* FIS_current_rptr;
Route* FIS_rptr;
double link_cost;
Route* pk_rptr;
Route* pk_r;
Route* route_ptr;
Route_Link* link_ptr;
Route* min_rptr_copy;
Route* route_test;
Route_Set* FIS_rset_ptr_t;
Route* FIS_min_rptr_t;
char node_name[255];
char id[20];
Objid* node_objid_ptr;
int i, num_nodes;
int subnet_ids[10], node_ids[10];
double cur_time;
Packet* cp_pkptr;
int next_address;
double start_time, dtime_time;
double n_start_time;
double o_start_time;
double start_time_1, dtime_time_1;
double start_time_2, dtime_time_2;
int s_f, num;
int j,k;
int check_num, num1, num2,num3,num4;
double list_table[100][2];
double dtime;
double stime;
int delete_num;
int FIS_fail_type;
int FIS_node_link;
int FIS_destination;
int FIS_source[17][17];
int x,y;
int PK_source[17][17];
int check, s_f_flag, FIS_s_f_flag ;
int send_check;
char file_name[10];
int num_routes[17][17];
int exit_flag;
int l;
int comp_flag;
int change_flag;
int pk_type;
int hop;
int bef_address;
int reserved_wave;
int temp_wave;
double temp_gap;
int insert_flag;
double offset_time;
double old_offset_time;
int loop_stop;
double new_start_time;
int route_flag;
int userid_c;
int userid_n;
int userid_d;
int restoration_flag;
wave_info* wave;
wave_info* wave_info_table;
wave_info* wave_free;
int lost_flag;
int backup_flag;
int need_schedule;
int include_flag;
FSM_ENTER (Restoration_rte_bak)
FSM_BLOCK_SWITCH
{
/*---------------------------------------------------------*/
/** state (init) enter executives **/
FSM_STATE_ENTER_FORCED_NOLABEL (0, "init", "Restoration_rte_bak () [init enter execs]")
{
self_objid = op_id_self ();
node_objid = op_topo_parent (self_objid);
subnet_objid = op_topo_parent (node_objid);
op_ima_obj_attr_get(node_objid, "user id", &userid);
for(j=0;j<=14;j++)
{
burst_time[userid][j] = 0.0;
}
for(i=1;i<=14;i++)
{
fail[userid][i] = 0;
fis_fail[userid][i] = 0;
link_send[userid][i] = 0;
link_receive[userid][i] = 0;
}
for(j=0;j<15;j++)
{
for(k=0;k<15;k++)
{
gap[userid][j][k] = -1;
}
}
//rev_pk_count = 0;
//rev_pk_cnt_stathandle = op_stat_reg("rev packet count", OPC_STAT_INDEX_NONE, OPC_STAT_LOCAL);
//node_pk_count = 0;
//allocate a list
for(j=0;j<=14;j++)
{
for(k=0;k<WAVE_NUM;k++)
{
wave_lptr[userid][j][k] = (List *) op_prg_mem_alloc (sizeof (List));
op_prg_list_init (wave_lptr[userid][j][k]);
}
}
}
/** state (init) exit executives **/
FSM_STATE_EXIT_FORCED (0, "init", "Restoration_rte_bak () [init exit execs]")
{
}
/** state (init) transition processing **/
FSM_TRANSIT_ONLY ((BEG_SIM), 1, state1_enter_exec, ;, "init", "BEG_SIM", "", "init", "wait")
/*---------------------------------------------------------*/
/** state (wait) enter executives **/
FSM_STATE_ENTER_UNFORCED (1, state1_enter_exec, "wait", "Restoration_rte_bak () [wait enter execs]")
{
}
/** blocking after enter executives of unforced state. **/
FSM_EXIT (3,Restoration_rte_bak)
/** state (wait) exit executives **/
FSM_STATE_EXIT_UNFORCED (1, "wait", "Restoration_rte_bak () [wait exit execs]")
{
}
/** state (wait) transition processing **/
FSM_INIT_COND (END_SIM)
FSM_TEST_COND (PK_ARRIVAL)
FSM_TEST_LOGIC ("wait")
FSM_TRANSIT_SWITCH
{
FSM_CASE_TRANSIT (0, 4, state4_enter_exec, ;, "END_SIM", "", "wait", "end")
FSM_CASE_TRANSIT (1, 2, state2_enter_exec, ;, "PK_ARRIVAL", "", "wait", "get_rte")
}
/*---------------------------------------------------------*/
/** state (get_rte) enter executives **/
FSM_STATE_ENTER_FORCED (2, state2_enter_exec, "get_rte", "Restoration_rte_bak () [get_rte enter execs]")
{
self_objid = op_id_self ();
node_objid = op_topo_parent (self_objid);
subnet_objid = op_topo_parent (node_objid);
op_ima_obj_attr_get(node_objid, "user id", &userid);
need_schedule = 0; // No schedule, init value
FIS_s_f_flag = 1;
s_f_flag = 1;
strm_num = op_intrpt_strm ();
pkptr = op_pk_get(strm_num);
op_pk_nfd_get (pkptr, "PK_type", &PK_type);
//****************************** PK *****************************************************************
if(PK_type == 1)
{
FIS_s_f_flag = 1;
op_pk_nfd_get (pkptr, "destination address", &destination_address);
op_pk_nfd_get (pkptr, "source address", &source_address);
dest_objid = op_id_from_userid (subnet_objid, OPC_OBJTYPE_NDFIX, destination_address);
src_objid = op_id_from_userid (subnet_objid, OPC_OBJTYPE_NDFIX, source_address);
op_pk_nfd_get (pkptr, "start", &old_offset_time);
if(
(notification_message->restoration_type == SUB || notification_message->restoration_type == LINK) &&
(notification_message->fail_type == 3)
)
{
op_pk_nfd_set (pkptr, "restoration_flag", notification_message->restoration_type);
}
op_pk_nfd_get (pkptr, "restoration_flag", &restoration_flag);
//************************* sub *****************************
if(restoration_flag == SUB)
{
if(old_offset_time > 0)
{
if(userid != source_address)
{
op_pk_nfd_get(pkptr, "bef", &bef_address);
link_receive[userid][bef_address]++;
//node_pk_count++;
}
if(userid != destination_address)
{
op_rte_pk_next_node (pkptr, &subnet_id, &next_node_id);
op_ima_obj_attr_get (next_node_id, "user id", &next_address);
if (
(userid == notification_message->fail_link_node1 && next_address == notification_message->fail_link_node2) ||
(userid == notification_message->fail_link_node2 && next_address == notification_message->fail_link_node1)
)
{
min_rptr_copy = op_rte_route_copy (min_rptr[userid][destination_address]);
current_rptr = min_rptr_copy;
pk_rptr = op_rte_route_copy (current_rptr);
op_rte_pk_route_insert (pkptr, pk_rptr);
op_pk_nfd_set (pkptr, "flag", 1);
op_pk_nfd_set (pkptr, "route_flag", 1); //use backup path
gen_backup_bcp++;
/*
num_nodes = op_rte_route_num_nodes (pk_rptr);
start_time = (PROC_TIME + LINK_DELAY)*num_nodes;
op_pk_nfd_set (pkptr, "start", start_time);
*/
}
//rev_pk_count++;
//op_stat_write(rev_pk_cnt_stathandle, rev_pk_count);
//****** need schedule **********
need_schedule = 1;
//****** need schedule **********
}
else //this node is the packet's destination
{
op_pk_nfd_get(pkptr, "route_flag", &route_flag);
if(route_flag==1)
{
back_succ++;
}
s_f_flag = 1;
op_pk_send (pkptr, PK_OUT_STRM); //sink
}
}// if(old_offset_time > 0)
else if(old_offset_time <= 0)
{
if(op_sim_time() >= s_time)
{
op_pk_nfd_get(pkptr, "route_flag", &route_flag);
if(route_flag==1)
{
⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -