restoration_control.pr.c

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

				
					/* if one of the two nodes is end nodes, insert to nonmesh node list */
					if (	(toupper(node0_name[0]) == 'N') || (toupper(node1_name[0]) == 'N')	)
						op_prg_list_insert (link_non_mesh_lptr, link_objid_ptr,	OPC_LISTPOS_TAIL);
				
					/* this link is not connected to an end node */
				    /* if this link is enabled */
					else if (link_condition)
						op_prg_list_insert (link_enabled_lptr, link_objid_ptr,OPC_LISTPOS_TAIL);
				
					/* if this link is disabled */
					else
						op_prg_list_insert (link_disabled_lptr, link_objid_ptr,OPC_LISTPOS_TAIL);
					}
				
				/* total number of end nodes */
				num_call_routers = op_prg_list_size (call_router_lptr);
				
				
				for(i=1;i<=num_fixed_nodes-1;i++) 
					{
					for(j=1;j<=num_fixed_nodes-1;j++) 
						{
						src_objid = op_id_from_userid (subnet_objid, OPC_OBJTYPE_NDFIX, i);
						dest_objid = op_id_from_userid (subnet_objid, OPC_OBJTYPE_NDFIX, j);
						rset_ptr[i][j] = op_rte_routeset_create (topo_ptr, subnet_objid, src_objid, subnet_objid, dest_objid, MAX_HOPS);
						
						if(i == j) 
							{
							min_rptr[i][j] = OPC_NIL;
							p_min_rptr[i][j] = OPC_NIL;
							primary_num_nodes[i][j] = 0;
							num_routes[i][j] = 0;
							}
						else 
							{
							num_routes[i][j] = op_rte_routeset_num_routes (rset_ptr[i][j]);
							min_rptr[i][j] = op_rte_routeset_mincost (rset_ptr[i][j]);
							p_min_rptr[i][j] = op_rte_route_copy(min_rptr[i][j]);
							
							op_rte_route_dump (min_rptr[i][j], subnet_ids, node_ids);
							primary_num_nodes[i][j] = op_rte_route_num_nodes (min_rptr[i][j]);
							
				//			printf("Primary_path[%d][%d] = \n",i,j);		
				
							for(k=0; k<primary_num_nodes[i][j]; k++)
								{
								Primary_path[i][j][k] = node_ids[k];
				//				printf("%d\t",Primary_path[i][j][k]);
								}
				//			printf("\n");
				//			getchar();
							}
						} // for j
					}// for i
				
					
				
				
				}


			/** state (init) exit executives **/
			FSM_STATE_EXIT_FORCED (0, "init", "Restoration_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", "Restoration_control () [wait enter execs]")
				{
				}


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


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


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



			}


		FSM_EXIT (0,Restoration_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
Restoration_control_init (void ** gen_state_pptr)
	{
	int _block_origin = 0;
	static VosT_Address	obtype = OPC_NIL;

	FIN (Restoration_control_init (gen_state_pptr))

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

		FRET (OPC_COMPCODE_SUCCESS)
		}
	}



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




void
Restoration_control_terminate (void)
	{
	int _block_origin = __LINE__;

	FIN (Restoration_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;

		/* 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_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
Restoration_control_svar (void * gen_ptr, const char * var_name, char ** var_p_ptr)
	{
	Restoration_control_state		*prs_ptr;

	FIN (Restoration_control_svar (gen_ptr, var_name, var_p_ptr))

	if (var_name == OPC_NIL)
		{
		*var_p_ptr = (char *)OPC_NIL;
		FOUT;
		}
	prs_ptr = (Restoration_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;
	}