restoration_rte.pr.c

实验室前辈用OPNET做的光突发交换网络的仿真实验

				/*---------------------------------------------------------*/



			/** state (send) enter executives **/
			FSM_STATE_ENTER_FORCED (3, state3_enter_exec, "send", "Restoration_rte () [send enter execs]")
				{
				if(send_ok == 1)
				{	
					op_rte_pk_current_node(pkptr, &subnet_objid, &current_node_objid);
					op_ima_obj_attr_get (current_node_objid, "user id", &userid_c);	
					
					op_rte_pk_next_node (pkptr, &subnet_objid, &next_node_objid);
					op_ima_obj_attr_get (next_node_objid, "user id", &userid_n);
					
					/* advance the routing pointer */
					op_rte_pk_advance (pkptr);
				
					/* determine the objid of the next and the link joining it */
					link_objid = op_topo_connect (node_objid, next_node_objid,OPC_OBJTYPE_LKDUP, 0);
				
					/* determine the objid of the stream/tx attached to the link */
					tx_objid = op_topo_assoc ( link_objid, OPC_TOPO_ASSOC_IN, OPC_OBJTYPE_PTTX, 0);
				
					/* for a duplex link, there will be two tx's attached to this link, make sure that the tx that we picked is in the same node */
					if (op_topo_parent (tx_objid) != node_objid)
						{
						tx_objid = op_topo_assoc (link_objid, OPC_TOPO_ASSOC_IN,OPC_OBJTYPE_PTTX, 1);
						}
				
					/* get the stream id connecting to the transmitter */
					strm_objid = op_topo_assoc (tx_objid, OPC_TOPO_ASSOC_IN,OPC_OBJTYPE_STRM, 0);
				
					/* get the stream number */
					op_ima_obj_attr_get (strm_objid, "src stream", &strm_num);
				
					op_pk_nfd_get (pkptr, "start", &start_time);
					new_start_time = start_time - PROC_TIME;
					op_pk_nfd_set (pkptr, "start", new_start_time);
				
					op_pk_send_delayed (pkptr, strm_num, PROC_TIME);
				 }//if(s_f_flag == 0)
				
				
				}


			/** state (send) exit executives **/
			FSM_STATE_EXIT_FORCED (3, "send", "Restoration_rte () [send exit execs]")
				{
				}


			/** state (send) transition processing **/
			FSM_INIT_COND ((1))
			FSM_TEST_COND (END_SIM)
			FSM_TEST_LOGIC ("send")

			FSM_TRANSIT_SWITCH
				{
				FSM_CASE_TRANSIT (0, 1, state1_enter_exec, ;, "", "", "send", "wait")
				FSM_CASE_TRANSIT (1, 4, state4_enter_exec, ;, "END_SIM", "", "send", "end")
				}
				/*---------------------------------------------------------*/



			/** state (end) enter executives **/
			FSM_STATE_ENTER_UNFORCED (4, state4_enter_exec, "end", "Restoration_rte () [end enter execs]")
				{
				}


			/** blocking after enter executives of unforced state. **/
			FSM_EXIT (9,Restoration_rte)


			/** state (end) exit executives **/
			FSM_STATE_EXIT_UNFORCED (4, "end", "Restoration_rte () [end exit execs]")
				{
				}


			/** state (end) transition processing **/
			FSM_TRANSIT_MISSING ("end")
				/*---------------------------------------------------------*/



			}


		FSM_EXIT (0,Restoration_rte)
		}
	}

#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
Restoration_rte_init (void ** gen_state_pptr)
	{
	int _block_origin = 0;
	static VosT_Address	obtype = OPC_NIL;

	FIN (Restoration_rte_init (gen_state_pptr))

	if (obtype == OPC_NIL)
		{
		/* Initialize memory management */
		if (Vos_Catmem_Register ("proc state vars (Restoration_rte)",
			sizeof (Restoration_rte_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 */
		((Restoration_rte_state *)(*gen_state_pptr))->current_block = 0;

		FRET (OPC_COMPCODE_SUCCESS)
		}
	}



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




void
Restoration_rte_terminate (void)
	{
	int _block_origin = __LINE__;

	FIN (Restoration_rte_terminate (void))

	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;
		
		wavelength_info*	wavelength;
		wavelength_info*	wavelength_info_table;
		wavelength_info*	wavelength_free;
		
		
		int			lost_flag;
		int			backup_flag;
		int			need_schedule;
		int			include_flag;
		int			hop_num_back;
		
		
		double		wavelength_list_table[100][2];
		
		
		int 		wavelength_number;
		int			wavelength_num;
		int			wave_break;

		/* 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 Restoration_rte_svar function. */
#undef current_rptr
#undef subnet_id
#undef next_node_id
#undef rev_pk_count
#undef rev_pk_cnt_stathandle
#undef node_objid
#undef self_objid
#undef subnet_objid
#undef node_pk_count
#undef dst_node_id
#undef send_ok



void
Restoration_rte_svar (void * gen_ptr, const char * var_name, char ** var_p_ptr)
	{
	Restoration_rte_state		*prs_ptr;

	FIN (Restoration_rte_svar (gen_ptr, var_name, var_p_ptr))

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

	if (strcmp ("current_rptr" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->current_rptr);
		FOUT;
		}
	if (strcmp ("subnet_id" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->subnet_id);
		FOUT;
		}
	if (strcmp ("next_node_id" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->next_node_id);
		FOUT;
		}
	if (strcmp ("rev_pk_count" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->rev_pk_count);
		FOUT;
		}
	if (strcmp ("rev_pk_cnt_stathandle" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->rev_pk_cnt_stathandle);
		FOUT;
		}
	if (strcmp ("node_objid" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->node_objid);
		FOUT;
		}
	if (strcmp ("self_objid" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->self_objid);
		FOUT;
		}
	if (strcmp ("subnet_objid" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->subnet_objid);
		FOUT;
		}
	if (strcmp ("node_pk_count" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->node_pk_count);
		FOUT;
		}
	if (strcmp ("dst_node_id" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->dst_node_id);
		FOUT;
		}
	if (strcmp ("send_ok" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->send_ok);
		FOUT;
		}
	*var_p_ptr = (char *)OPC_NIL;

	FOUT;
	}