core.pr.c

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

					//getchar();
						
					op_pk_destroy(pkptr_burst);
					total_burst_drop_count++;
				}	
				
				//printf("S_M->data_recieve; end \n");
				
				
				}


			/** state (data_recieve) exit executives **/
			FSM_STATE_EXIT_FORCED (2, "data_recieve", "CORE () [data_recieve exit execs]")
				{
				}


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



			/** state (end) enter executives **/
			FSM_STATE_ENTER_UNFORCED (3, state3_enter_exec, "end", "CORE () [end enter execs]")
				{
				self_objid = op_id_self ();
				node_objid = op_topo_parent (self_objid);
				op_ima_obj_attr_get(self_objid, "filename", &filename);
				
				
				if(userid==0)
				{	
				printf("total_burst_drop_count=%d,userid=%d,not_strm=%d\n",	total_burst_drop_count,userid,not_strm);
				
				strcpy(temp_file_name,"D:/result/");
				strcat(temp_file_name,filename);
				in = fopen(temp_file_name,"a");
				fprintf(in,"total_burst_drop_count = %d \n",total_burst_drop_count);
				fclose(in);
				}
				}


			/** blocking after enter executives of unforced state. **/
			FSM_EXIT (7,CORE)


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


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



			/** state (S_M_init) enter executives **/
			FSM_STATE_ENTER_FORCED (4, state4_enter_exec, "S_M_init", "CORE () [S_M_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();
				
				
				
				s_metrix_list = (List *)op_prg_mem_alloc(sizeof(List));
				op_prg_list_init(s_metrix_list);
				}


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


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



			/** state (S_M_Update) enter executives **/
			FSM_STATE_ENTER_FORCED (5, state5_enter_exec, "S_M_Update", "CORE () [S_M_Update 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();
				
				
				//printf("S_M-->S_M_Update 0;userid=%d\n",userid);
				//getchar();	
				
				/*
				temp_ici = op_intrpt_ici();
				temp_s_metrix = (S_METRIX *)op_prg_mem_alloc(sizeof(S_METRIX));
				op_ici_attr_get(temp_ici,"s_time",temp_s_metrix->s_time);
				op_ici_attr_get(temp_ici,"d_time",&temp_s_metrix->d_time);
				op_ici_attr_get(temp_ici,"input_strum",&temp_s_metrix->input_strum);
				op_ici_attr_get(temp_ici,"output_strum",&temp_s_metrix->output_strum);
				*/
				
				s_metrix_pkptr = op_pk_get(0);
				
				temp_s_metrix = (S_METRIX *)op_prg_mem_alloc(sizeof(S_METRIX));
				
				op_pk_nfd_get (s_metrix_pkptr, "s_time", &temp_s_metrix->s_time);
				op_pk_nfd_get (s_metrix_pkptr, "d_time", &temp_s_metrix->d_time);
				op_pk_nfd_get (s_metrix_pkptr, "input_strum", &temp_s_metrix->input_strum);
				op_pk_nfd_get (s_metrix_pkptr, "output_strum", &temp_s_metrix->output_strum);
				
				
				op_prg_list_insert(s_metrix_list,temp_s_metrix,OPC_LISTPOS_TAIL);
				
				
				
				temp_occupy_count = op_prg_list_size(s_metrix_list);
				//printf("S_M-->S_M_Update 1;userid=%d,temp_occupy_count=%d\n",userid,temp_occupy_count);
				i=0;
				while(i<temp_occupy_count)// && temp_flag_loop == 1)	
				{
				
					temp_s_metrix = op_prg_list_access(s_metrix_list, i);
					if(op_sim_time() > temp_s_metrix->s_time + temp_s_metrix->d_time)
					{	
						temp_s_metrix = op_prg_list_remove(s_metrix_list, i);
						op_prg_mem_free(temp_s_metrix);
						//temp_flag_loop = 0;
						temp_occupy_count = op_prg_list_size(s_metrix_list);
					}
					else
						i++;
				}		
				
				//printf("S_M-->S_M_Update 2;userid=%d\n",userid);
				op_pk_destroy(s_metrix_pkptr);
				
				}


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


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



			}


		FSM_EXIT (0,CORE)
		}
	}

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

	FIN (CORE_init (gen_state_pptr))

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

		FRET (OPC_COMPCODE_SUCCESS)
		}
	}



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




void
CORE_terminate (void)
	{
	int _block_origin = __LINE__;

	FIN (CORE_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, difference_time, reservation_flag, cur_channel;
		double d_time, temp_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;
		Ici* temp_ici;
		S_METRIX *temp_s_metrix;
		int intrupt_strum,temp_flag_success,temp_flag_loop;
		Packet* s_metrix_pkptr;
		
		
		
		
		
		
		
		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;
		
		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 CORE_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
#undef s_metrix_list



void
CORE_svar (void * gen_ptr, const char * var_name, char ** var_p_ptr)
	{
	CORE_state		*prs_ptr;

	FIN (CORE_svar (gen_ptr, var_name, var_p_ptr))

	if (var_name == OPC_NIL)
		{
		*var_p_ptr = (char *)OPC_NIL;
		FOUT;
		}
	prs_ptr = (CORE_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;
		}
	if (strcmp ("s_metrix_list" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->s_metrix_list);
		FOUT;
		}
	*var_p_ptr = (char *)OPC_NIL;

	FOUT;
	}