control.pr.c

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

				*/	
				//node_objid_ptr = op_topo_object (OPC_OBJTYPE_NDFIX, i);	
				//op_ima_obj_attr_get (node_objid_ptr, "name", node_name);
				
				
				
				
				}


			/** state (init) exit executives **/
			FSM_STATE_EXIT_FORCED (0, "init", "CONTROL () [init exit execs]")
				{
				}


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



			/** state (wait) enter executives **/
			FSM_STATE_ENTER_UNFORCED (1, state1_enter_exec, "wait", "CONTROL () [wait enter execs]")
				{
				}


			/** blocking after enter executives of unforced state. **/
			FSM_EXIT (3,CONTROL)


			/** state (wait) exit executives **/
			FSM_STATE_EXIT_UNFORCED (1, "wait", "CONTROL () [wait exit execs]")
				{
				}


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



			}


		FSM_EXIT (0,CONTROL)
		}
	}

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

	FIN (CONTROL_init (gen_state_pptr))

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

		FRET (OPC_COMPCODE_SUCCESS)
		}
	}



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




void
CONTROL_terminate (void)
	{
	int _block_origin = __LINE__;

	FIN (CONTROL_terminate (void))

	if (1)
		{
		char		icon_name[20];
		Objid		simple_objid;
		Objid		rec_node_objid;
		Objid		dest_objid;
		Objid		src_objid;
		Objid		self_objid;
		
		
		Packet*		pkptr;
		Packet*		f_pkptr;
		
		Boolean		condition;
		Boolean		node_condition;
		Boolean		link_condition;
		Objid*		rand_node_objid_ptr;
		Packet*		rand_node_objid_ptr_1;
		Objid*		traffic_generate_objid_ptr;
		Objid*		rand_link_objid_ptr;
		char		node_name[255];
		char		node0_name[255];
		char		node1_name[255];
		char		link_name[255];
		char		script_filename[255];
		char		err_str[255];
		
		char		f_type[1],f_data[1];
		
		int			rand_num;
		int			num_nds_enabled;
		int			num_nds_disabled;
		int			num_links_enabled;
		int			num_links_disabled;
		int 		userid;
		
		int			i,j,k,l,m,x,y;
		int			comp_flag,exit_flag;
		
		Objid*		node_objid_ptr;
		Objid*		node0_objid_ptr;
		Objid*		node1_objid_ptr;
		
		Objid*		link_objid_ptr;
		int			interrupt_code;
		Objid		node0_objid;
		Objid		node1_objid;
		Objid		link_objid;
		Route_Link*	link_ptr;
		Objid		call_router_objid;
		char*		line;
		List*		field_list_ptr;
		double		node_mtbf;
		double		node_mttr;
		double		link_mtbf;
		double		link_mttr;
		double		link_cost;
		double		link_cost_default;
		
		int 		subnet_ids[16];
		int			node_ids[16];
		int			num_nodes;
		
		FILE 		*fp;
		char		f_name[50];
		int			userid0;
		int			userid1;
		int			userid2;
		int			hop_num[15][15];
		double		Average_hop_num;
		int			Hop_num;
		int			include_flag;
		
		Objid		temp_objid;
		int ef,eff;
		
		
		Objid	temp_src_objid,temp_dest_objid,rx_objid,rx1_objid,tx_objid,tx1_objid;
		Objid   link1_objid,link_objid1;
		int temp_link_count;
		
		int temp_hop_count = 0;
		//Objid temp_src_objid, temp_dest_objid;
		Route_Set* temp_routeset;
		Route* temp_min_route;
		int temp_strm_count;
		Objid temp_strm_objid;
		char temp_char1[20];char temp_char2[20];
		char temp_char3[20];char temp_char4[20];
		char temp_char5[20];char temp_char6[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 CONTROL_svar function. */
#undef num_fixed_nodes
#undef num_dup_links
#undef node_objid
#undef subnet_objid
#undef num_call_routers
#undef num_lines
#undef schedule_num
#undef fail_file_ptr
#undef fail_table_ptr
#undef schedule_ptr
#undef action_obj_type
#undef action_obj_index
#undef action
#undef remote_int_code
#undef fail_index
#undef mesh_node_objid_1
#undef mesh_process_objid_1
#undef mesh_node_objid_2
#undef mesh_process_objid_2



void
CONTROL_svar (void * gen_ptr, const char * var_name, char ** var_p_ptr)
	{
	CONTROL_state		*prs_ptr;

	FIN (CONTROL_svar (gen_ptr, var_name, var_p_ptr))

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

	if (strcmp ("num_fixed_nodes" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->num_fixed_nodes);
		FOUT;
		}
	if (strcmp ("num_dup_links" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->num_dup_links);
		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 ("num_call_routers" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->num_call_routers);
		FOUT;
		}
	if (strcmp ("num_lines" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->num_lines);
		FOUT;
		}
	if (strcmp ("schedule_num" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->schedule_num);
		FOUT;
		}
	if (strcmp ("fail_file_ptr" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->fail_file_ptr);
		FOUT;
		}
	if (strcmp ("fail_table_ptr" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->fail_table_ptr);
		FOUT;
		}
	if (strcmp ("schedule_ptr" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->schedule_ptr);
		FOUT;
		}
	if (strcmp ("action_obj_type" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->action_obj_type);
		FOUT;
		}
	if (strcmp ("action_obj_index" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->action_obj_index);
		FOUT;
		}
	if (strcmp ("action" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->action);
		FOUT;
		}
	if (strcmp ("remote_int_code" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->remote_int_code);
		FOUT;
		}
	if (strcmp ("fail_index" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->fail_index);
		FOUT;
		}
	if (strcmp ("mesh_node_objid_1" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->mesh_node_objid_1);
		FOUT;
		}
	if (strcmp ("mesh_process_objid_1" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->mesh_process_objid_1);
		FOUT;
		}
	if (strcmp ("mesh_node_objid_2" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->mesh_node_objid_2);
		FOUT;
		}
	if (strcmp ("mesh_process_objid_2" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->mesh_process_objid_2);
		FOUT;
		}
	*var_p_ptr = (char *)OPC_NIL;

	FOUT;
	}