scu.pr.c

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

						}
						
						/*
						for(j = 0; j < node_num; j++)
						{
							if(j != userid)
							{
								temp_src_objid = op_id_from_userid (subnet_objid, OPC_OBJTYPE_NDFIX,userid);
								temp_dest_objid = op_id_from_userid (subnet_objid, OPC_OBJTYPE_NDFIX, j);
								if(op_topo_connect_count (temp_src_objid, temp_dest_objid,OPC_OBJMTYPE_LINK)==1)
								{
									link_num++;
									if( j == temp_userid)
									{
										link_objid = op_topo_connect (temp_src_objid, temp_dest_objid,OPC_OBJTYPE_LKDUP, 0);
										tx_objid = op_topo_assoc ( link_objid, OPC_TOPO_ASSOC_IN, OPC_OBJTYPE_PTTX, 0);
										if (op_topo_parent (tx_objid) != node_objid)
										{
											tx_objid = op_topo_assoc (link_objid, OPC_TOPO_ASSOC_IN,OPC_OBJTYPE_PTTX, 1);
										}
						
										strm_objid = op_topo_assoc (tx_objid, OPC_TOPO_ASSOC_IN,OPC_OBJTYPE_STRM, 0);
						
										op_ima_obj_attr_get (strm_objid, "src stream", &strm_num);
										temp_flag_tx=1;
									}
								}
							}
						}
						*/
						if(temp_flag_tx == 1)
						{	
							routing_table[i].output_tx = tx_objid;    //transmitter id of the output port
							routing_table[i].output_link = link_objid;    //transmitter id of the output port
							routing_table[i].strm_control = strm_num;   // strum number for bcp
						}
						else{}
					}
				}
				
				//printf("complete initize of routing table,op_time=%e\n",op_sim_time());
				//end of initilize the routing table
				/*
				for (i = 0; i < node_num; i++)
				{
					printf("SCU;source_id=%d,dest_id=%d,out_link=%d,out_tx=%d\n",userid,i,routing_table[i].output_link,routing_table[i].output_tx);
				}
				*/
				}


			/** state (R_T_init) exit executives **/
			FSM_STATE_EXIT_FORCED (4, "R_T_init", "scu () [R_T_init exit execs]")
				{
				}


			/** state (R_T_init) transition processing **/
			FSM_TRANSIT_FORCE (1, state1_enter_exec, ;, "default", "", "R_T_init", "wait")
				/*---------------------------------------------------------*/



			/** state (R_T_Update) enter executives **/
			FSM_STATE_ENTER_FORCED (5, state5_enter_exec, "R_T_Update", "scu () [R_T_Update enter execs]")
				{
				}


			/** state (R_T_Update) exit executives **/
			FSM_STATE_EXIT_FORCED (5, "R_T_Update", "scu () [R_T_Update exit execs]")
				{
				}


			/** state (R_T_Update) transition processing **/
			FSM_TRANSIT_FORCE (1, state1_enter_exec, ;, "default", "", "R_T_Update", "wait")
				/*---------------------------------------------------------*/



			/** state (Schuding_init) enter executives **/
			FSM_STATE_ENTER_FORCED (6, state6_enter_exec, "Schuding_init", "scu () [Schuding_init enter execs]")
				{
				self_objid = op_id_self ();
				node_objid = op_topo_parent (self_objid);
				subnet_objid = op_topo_parent (node_objid);
				//topo_objid = op_rte_topo_from_objids();
				//start of how many ER node
				/*
				total_node_num = op_topo_object_count (OPC_OBJTYPE_NDFIX);
				for (i = 0; i < total_node_num; i++)
				{	
					node_objid_ptr = op_topo_object (OPC_OBJTYPE_NDFIX, i);	
					op_ima_obj_attr_get (node_objid_ptr, "name", node_name);
					
					if (toupper(node_name[0]) == 'E'|| toupper(node_name[0] == 'C'))
						node_num++;
				}	
				//end of how many ER node
				*/
				
				//start of each wavelength information
				link_num = 0;
				channel_count = 0;
				for(i = 0; i <  node_num; i++)
				{
					if(i != userid)
					{
						temp_src_objid = op_id_from_userid (subnet_objid, OPC_OBJTYPE_NDFIX,userid);
						temp_dest_objid = op_id_from_userid (subnet_objid, OPC_OBJTYPE_NDFIX, i);
						if(op_topo_connect_count (temp_src_objid, temp_dest_objid,OPC_OBJMTYPE_LINK) == 1)
						{
							link_num++;
							op_ima_obj_attr_get (op_topo_connect (temp_src_objid, temp_dest_objid, OPC_OBJTYPE_LKDUP, 0), "channel count", &channel_count);
						}
					 }
				}
				
				
				node_for_schedule.port = (PORT *)malloc(sizeof(PORT )*link_num);
				for(i = 0; i < link_num; i++)
				{
					node_for_schedule.port[i].channel = (CHANNEL *)malloc(sizeof(CHANNEL )*channel_count);
					for(j = 0; j < channel_count; j++)
					{
						node_for_schedule.port[i].channel[j].horizon = op_sim_time();
						node_for_schedule.port[i].channel[j].gab_list = (List *)op_prg_mem_alloc(sizeof(List));
						node_for_schedule.port[i].channel[j].occupy_list = (List *)op_prg_mem_alloc(sizeof(List));
						op_prg_list_init(node_for_schedule.port[i].channel[j].gab_list);
						op_prg_list_init(node_for_schedule.port[i].channel[j].occupy_list);
					}
				}
				
				j=0;
				for(i = 0; i < node_num; i++)
				{
					if(i != userid)
					{	
						temp_src_objid = op_id_from_userid (subnet_objid, OPC_OBJTYPE_NDFIX,userid);
						temp_dest_objid = op_id_from_userid (subnet_objid, OPC_OBJTYPE_NDFIX, i);
				    	if(op_topo_connect_count (temp_src_objid, temp_dest_objid,OPC_OBJMTYPE_LINK) == 1)
						{
							node_for_schedule.port[j].next_nodeid = i;
							link_objid = op_topo_connect (temp_src_objid, temp_dest_objid,OPC_OBJTYPE_LKDUP, 0);
							
							op_ima_obj_attr_get(node_objid,"name",temp_char);			
							
							op_ima_obj_attr_get(link_objid,"transmitter a",temp_char1);
							op_ima_obj_attr_get(link_objid,"transmitter b",temp_char2);
							op_ima_obj_attr_get(link_objid,"data rate",&temp_data_rate);
										
							
							if(temp_char[0] == temp_char1[0] && temp_char[5] == temp_char1[5])
							{
								tx_objid = op_topo_assoc ( link_objid, OPC_TOPO_ASSOC_IN, OPC_OBJTYPE_PTTX, 0);			
							}	
							else if(temp_char[0] == temp_char2[0] && temp_char[5] == temp_char2[5])
							{
								tx_objid = op_topo_assoc (link_objid, OPC_TOPO_ASSOC_IN,OPC_OBJTYPE_PTTX, 1);			
							}
							else
							{
								printf("not find the tx_objid\n");
							}
							
							
							node_for_schedule.port[j].tx_objid = tx_objid;
							node_for_schedule.port[j].data_rate = temp_data_rate;
							j++;	
						}
					 }
				}
				
				
				//end of each wavelength information
				//printf("ch3\n");
				/*
				for (i = 0; i < j; i++)
				{
					printf("SCU;schedule:s_id=%d,link_obj=%d,out_tx=%d,link_num=%d\n",userid,link_objid,node_for_schedule.port[i].tx_objid,link_num);
				}	
				*/
				}


			/** state (Schuding_init) exit executives **/
			FSM_STATE_EXIT_FORCED (6, "Schuding_init", "scu () [Schuding_init exit execs]")
				{
				}


			/** state (Schuding_init) transition processing **/
			FSM_TRANSIT_FORCE (1, state1_enter_exec, ;, "default", "", "Schuding_init", "wait")
				/*---------------------------------------------------------*/



			}


		FSM_EXIT (0,scu)
		}
	}

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

	FIN (scu_init (gen_state_pptr))

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

		FRET (OPC_COMPCODE_SUCCESS)
		}
	}



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




void
scu_terminate (void)
	{
	int _block_origin = __LINE__;

	FIN (scu_terminate (void))

	if (1)
		{
		int total_node_num = 0;
		//int node_num = 0;
		//int link_num = 0;
		char node_name[20];
		int i,j,k;
		Objid node_objid_ptr, link_objid,tx_objid;
		Route* min_route;
		int subnet_id_ptr, node_id_ptr;
		int strm_num, channel_count1, link_count;
		double pk_size;
		Objid temp_tx_objid;
		int cur_port, reservation_flag, cur_channel;
		double d_time;
		double temp_difference_time,difference_time; 
		CHANNEL_INFOR * temp_channel_infor;
		int temp_outstrm_num,cur_por,temp_occupy_count;
		int output_strm;
		int pkptr_type;
		Objid temp_src_objid, temp_dest_objid;
		Route_Set* temp_routeset;
		Route* temp_min_route;
		int temp_userid, temp_flag_tx;
		double next_stime;
		int temp_prev_wave_num, temp_prev_userid,temp_output_strm_num;
		int temp_input_strm_num,bcp_intrup_strum ;
		Ici * iciptr;
		Objid * rx_objid;
		Objid * output_strm_objid;
		Packet * s_metrix_pkptr;
		int temp_flag_loop;
		
		
		char temp_char[20];
		char temp_char1[20];
		char temp_char2[20];
		char temp_char3[20];
		char temp_char4[20];
		char temp_c_data_rate[20];
		
		
		
		Packet*		pkptr_burst;
		Packet*		pkptr;
		
		int			source_address;
		int			destination_address;
		
		
		
		Route*		pk_rptr;
		double		start_time;
		double		dtime_time;
		double		cur_time;
		int			subnet_ids[10];
		int			node_ids[20];
		int			num_nodes;
		
		
		double 		EXTRA_TIME;
		Objid		strm_objid;
		int 		jj;
		int 		channel_num;
		int			temp_code;
		double		offset_time,cur_offset_time;
		double 		temp_data_rate, finsh_time;
		int n;
		//int temp_userid;
		
		FILE * in;
		char filename[20];
		char temp_file_name[20];
		CHANNEL_INFOR * channel_infor;
		CHANNEL_INFOR * channel_infor2;
		CHANNEL_INFOR * channel_infor3;
		CHANNEL_INFOR * channel_infor4;
		int selected_channel,list_element_num;

		/* 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 scu_svar function. */
#undef self_objid
#undef node_objid
#undef subnet_objid
#undef userid
#undef routing_table
#undef node_for_schedule
#undef link_num
#undef channel_count
#undef pk_type
#undef pkptr_state
#undef node_num
#undef node_count
#undef topo_objid
#undef temp_strm_num



void
scu_svar (void * gen_ptr, const char * var_name, char ** var_p_ptr)
	{
	scu_state		*prs_ptr;

	FIN (scu_svar (gen_ptr, var_name, var_p_ptr))

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

	if (strcmp ("self_objid" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->self_objid);
		FOUT;
		}
	if (strcmp ("node_objid" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->node_objid);
		FOUT;
		}
	if (strcmp ("subnet_objid" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->subnet_objid);
		FOUT;
		}
	if (strcmp ("userid" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->userid);
		FOUT;
		}
	if (strcmp ("routing_table" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->routing_table);
		FOUT;
		}
	if (strcmp ("node_for_schedule" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->node_for_schedule);
		FOUT;
		}
	if (strcmp ("link_num" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->link_num);
		FOUT;
		}
	if (strcmp ("channel_count" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->channel_count);
		FOUT;
		}
	if (strcmp ("pk_type" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->pk_type);
		FOUT;
		}
	if (strcmp ("pkptr_state" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->pkptr_state);
		FOUT;
		}
	if (strcmp ("node_num" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->node_num);
		FOUT;
		}
	if (strcmp ("node_count" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->node_count);
		FOUT;
		}
	if (strcmp ("topo_objid" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->topo_objid);
		FOUT;
		}
	if (strcmp ("temp_strm_num" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->temp_strm_num);
		FOUT;
		}
	*var_p_ptr = (char *)OPC_NIL;

	FOUT;
	}