ier.pr.c

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

								tx_objid = op_topo_assoc ( link_objid, OPC_TOPO_ASSOC_IN, OPC_OBJTYPE_PTTX, 0);
								//printf("1\n");
							}	
							else if(temp_char[0] == temp_char2[0] && temp_char[5] == temp_char2[5])
							{
								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, 1);			
								//printf("2\n");
							}
							else
							{
								printf("not find the tx_objid\n");
							}	
							
							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;
							
							//printf("s=%d,d=%d,link=%e,tx=%e\n",userid,i,link_objid,tx_objid);
						}
						else
						{}	
							//printf("IER->R_T_init;not finding link,userid=%d\n",userid);
						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{}
					}
				}
				//getchar();
				//printf("complete initize of routing table,userid=%d,op_time=%e\n",userid,op_sim_time());
				//end of initilize the routing table
				/*
				for (i = 0; i < node_num; i++)
				{
					printf("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);
				}	
				getchar();
				*/
				}


			/** state (R_T_init) exit executives **/
			FSM_STATE_EXIT_FORCED (6, "R_T_init", "IER () [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 (7, state7_enter_exec, "R_T_Update", "IER () [R_T_Update enter execs]")
				{
				}


			/** state (R_T_Update) exit executives **/
			FSM_STATE_EXIT_FORCED (7, "R_T_Update", "IER () [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 (8, state8_enter_exec, "Schuding_init", "IER () [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
				
				//printf("IER-->S_init 1;userid=%d\n",userid);
				
				//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);
						}
					 }
				}
				
				//printf("userid=%d,link_num=%d\n",userid,link_num);
				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);
							//printf("userid=%d,name=%s\n",userid,temp_char);
							//printf("userid=%d,t_a=%s\n",userid,temp_char1);
							//printf("userid=%d,t_b=%s\n",userid,temp_char2);
							//printf("userid=%d,link_obj=%d,t_a=%s,t_b=%s,name=%s\n",userid,link_objid,temp_char1,temp_char2,temp_char);
							
							if(temp_char[0] == temp_char1[0] && temp_char[5] == temp_char1[5])
							{
								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);			
								//printf("1\n");
							}	
							else if(temp_char[0] == temp_char2[0] && temp_char[5] == temp_char2[5])
							{
								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, 1);			
								//printf("2\n");
							}
							else
							{
								printf("not find the tx_objid\n");
							}
							
						//	printf("schedule:s_id=%d,link_objid=%d,tx=%d,link_num=%d\n",userid,link_objid,tx_objid,link_num);
							
							node_for_schedule.port[j].tx_objid = tx_objid;
							node_for_schedule.port[j].link_objid = link_objid;
							node_for_schedule.port[j].data_rate = temp_data_rate;
							j++;	
						}
					 }
				}
				
				//printf("IER-->S_init;userid=%d\n",userid);
				//end of each wavelength information
				//printf("ch3\n");
				/*
				for (i = 0; i < j; i++)
				{
					printf("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);
				}	
				
				getchar();
				*/
				}


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


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



			}


		FSM_EXIT (0,IER)
		}
	}

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

	FIN (IER_init (gen_state_pptr))

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

		FRET (OPC_COMPCODE_SUCCESS)
		}
	}



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




void
IER_terminate (void)
	{
	int _block_origin = __LINE__;

	FIN (IER_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,difference_time,temp_difference_time ;
		CHANNEL_INFOR * temp_channel_infor;
		int temp_outstrm_num,cur_por,temp_occupy_count;
		int output_strm;
		Objid temp_src_objid, temp_dest_objid;
		Route_Set* temp_routeset;
		Route* temp_min_route;
		int temp_flag_tx, temp_userid,temp_flag_loop;
		double next_stime, next_dtime,temp_delay_time;
		char temp_char[20];
		char temp_char1[20];
		char temp_char2[20];
		char temp_char3[20];
		char temp_char4[20];
		
		
		
		Packet*		pkptr_burst;
		Packet*		pkptr;
		
		int			sequence_number_ack;
		int			sequence_number_rcv;
		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;
		double		offset_time;
		Objid		strm_objid;
		int 		channel_num;
		int			temp_code,temp_sub_queue_index;
		int			num_pks = 0;
		Objid		node_objid;
		double      temp_data_rate;
		
		
		FILE * in;
		char filename[20];
		char temp_file_name[20];
		
		
		

		/* 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 IER_svar function. */
#undef self_objid
#undef node_objid1
#undef subnet_objid
#undef userid
#undef routing_table
#undef node_for_schedule
#undef link_num
#undef channel_count
#undef node_num
#undef node_count
#undef topo_objid
#undef PROC_TIME
#undef RATE
#undef sub_queue_index



void
IER_svar (void * gen_ptr, const char * var_name, char ** var_p_ptr)
	{
	IER_state		*prs_ptr;

	FIN (IER_svar (gen_ptr, var_name, var_p_ptr))

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

	if (strcmp ("self_objid" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->self_objid);
		FOUT;
		}
	if (strcmp ("node_objid1" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->node_objid1);
		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 ("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 ("PROC_TIME" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->PROC_TIME);
		FOUT;
		}
	if (strcmp ("RATE" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->RATE);
		FOUT;
		}
	if (strcmp ("sub_queue_index" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->sub_queue_index);
		FOUT;
		}
	*var_p_ptr = (char *)OPC_NIL;

	FOUT;
	}