restoration_fail.pr.c

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

									primary_num_nodes[userid][y] = op_rte_route_num_nodes (min_rptr[userid][y]);
							
									//Get Backup_path
									exit_flag = 0;
				
									for(k=0;k < primary_num_nodes[userid][y]-1;k++) 
										{
										if((Primary_path[userid][y][k] == notification_message->fail_link_node1 && Primary_path[userid][y][k+1] == notification_message->fail_link_node2) 
										  ||
										  (Primary_path[userid][y][k] == notification_message->fail_link_node2 && Primary_path[userid][y][k+1] == notification_message->fail_link_node1))
											{
											change_flag = 1;
											}
										else
											{
											change_flag = 0;
											}
										if(change_flag == 1) break;
										}
								
									if(change_flag == 1 ) 
										{
										for ( i = 1; i < num_routes[userid][y]; i++ )
											{
											comp_flag = 0;
											op_rte_route_dump ( op_rte_routeset_route_n (rset_ptr[userid][y], i), subnet_ids, node_ids );
											num_nodes = op_rte_route_num_nodes (op_rte_routeset_route_n (rset_ptr[userid][y], i));
							
											for (j = 0; j < num_nodes; j++)
												{
												Backup_path[userid][y][j] = node_ids[j];
												}
				
											// compare routine 
											for(k=1;k < primary_num_nodes[userid][y]-1;k++) 
												{
												for(l=1;l<num_nodes-1;l++)
													{
													if(Primary_path[userid][y][k] == Backup_path[userid][y][l]) 
														{
														comp_flag = 1;
														}
													if(comp_flag ==1) break;	
													}
												if(comp_flag == 1) break;
												}
								
											if(comp_flag == 0) 
												{
												exit_flag = 1;
												
												//printf("pri userid = %d y = %d \n",userid, y);
												//op_rte_route_print(min_rptr[userid][y]);
												min_rptr[userid][y] = op_rte_route_copy(op_rte_routeset_route_n (rset_ptr[userid][y], i));
												//printf("failure userid = %d y = %d \n",userid, y);
												//op_rte_route_print(min_rptr[userid][y]);
												//getchar();
												}						
				
											if(exit_flag == 1) break;
											} //for ( i = 1; i < num_routes[userid][y]; i++ )
										
										if(comp_flag == 1) min_rptr[userid][y] = OPC_NIL; // no backup path
										}//if(change_flag == 1 ) 
									} // if (userid != y)
								} // for y
							
							} //if(notification_message->fail_type == 3) 
				
						else if(notification_message->fail_type == 4) // recover
							{
							for(y=1;y<15;y++)
								{
								if(userid != y)
									{	
									for(k=0;k < primary_num_nodes[userid][y]-1;k++) 
										{
										if((Primary_path[userid][y][k] == notification_message->fail_link_node1 && Primary_path[userid][y][k+1] == notification_message->fail_link_node2) 
										  ||
										  (Primary_path[userid][y][k] == notification_message->fail_link_node2 && Primary_path[userid][y][k+1] == notification_message->fail_link_node1))
											{
											change_flag = 1;
											}
										else
											{
											change_flag = 0;
											}
										if(change_flag == 1) break;
										}
								
									if(change_flag == 1)
										{	
										min_rptr[userid][y] = op_rte_route_copy(p_min_rptr[userid][y]);
										//printf("recover userid = %d y = %d \n", userid, y);
										//op_rte_route_print(min_rptr[userid][y]);
										//getchar();
										}	
									}	
								}//for(y=1;y<15;y++)
							}//else if(notification_message->fail_type == 4)
						}//if((userid == notification_message->fail_link_node1) || (userid == notification_message->fail_link_node2))
				
					if(notification_message->fail_type == 3)
						{
						num1 = notification_message->fail_link_node1;
						num2 = notification_message->fail_link_node2;
						
						if(userid == num1)
							{	
							diff1 = link_send[num1][num2] - link_receive[num2][num1];
							fis_fail[num1][num2] = fis_fail[num1][num2] + diff1;
							back_fis_fail = back_fis_fail + diff1;
							}
						else if(userid == num2)
							{	
							diff2 = link_send[num2][num1] - link_receive[num1][num2];
							fis_fail[num2][num1] = fis_fail[num2][num1] + diff2;
							back_fis_fail = back_fis_fail + diff2;
							}
						}
						
					}
				//************************************************* Sub  *****************************************************
				
				
				
				
				
				
				//************************************************* link *****************************************************
				if(notification_message->restoration_type == LINK)
					{
					
					if(notification_message->fail_type == 3)
						{
					//op_rte_topo_print(topo_ptr);
					//getchar();
					
					if(userid == notification_message->fail_link_node1)
						{
						//printf("userid = %d fail_1 = %d fail_2 = %d\n", userid,notification_message->fail_link_node1,notification_message->fail_link_node2);
				
						//op_rte_route_print(min_rptr[userid][notification_message->fail_link_node2]);
						//min_rptr[userid][notification_message->fail_link_node2] = op_rte_routeset_mincost (rset_ptr[userid][notification_message->fail_link_node2]);
						min_rptr[userid][notification_message->fail_link_node2] = op_rte_route_copy(op_rte_routeset_route_n (rset_ptr[userid][notification_message->fail_link_node2], 1));
						//op_rte_route_print(min_rptr[userid][notification_message->fail_link_node2]);
						//getchar();
						}
				
					if(userid == notification_message->fail_link_node2)
						{
						//printf("userid = %d fail_1 = %d fail_2 = %d\n", userid,notification_message->fail_link_node1,notification_message->fail_link_node2);
				
						//op_rte_route_print(min_rptr[userid][notification_message->fail_link_node1]);
						//min_rptr[userid][notification_message->fail_link_node1] = op_rte_routeset_mincost (rset_ptr[userid][notification_message->fail_link_node1]);
						min_rptr[userid][notification_message->fail_link_node1] = op_rte_route_copy(op_rte_routeset_route_n (rset_ptr[userid][notification_message->fail_link_node1], 1));
						//op_rte_route_print(min_rptr[userid][notification_message->fail_link_node1]);
						//getchar();
						}
					}
					
					else if(notification_message->fail_type == 4)
						{
					//op_rte_topo_print(topo_ptr);
					//getchar();
					
					if(userid == notification_message->fail_link_node1)
						{
						//printf("userid = %d fail_1 = %d fail_2 = %d\n", userid,notification_message->fail_link_node1,notification_message->fail_link_node2);
				
						//op_rte_route_print(min_rptr[userid][notification_message->fail_link_node2]);
						min_rptr[userid][notification_message->fail_link_node2] = op_rte_routeset_mincost (rset_ptr[userid][notification_message->fail_link_node2]);
						//min_rptr[userid][notification_message->fail_link_node2] = op_rte_route_copy(op_rte_routeset_route_n (rset_ptr[userid][notification_message->fail_link_node2], 1));
						//op_rte_route_print(min_rptr[userid][notification_message->fail_link_node2]);
						//getchar();
						}
				
					if(userid == notification_message->fail_link_node2)
						{
						//printf("userid = %d fail_1 = %d fail_2 = %d\n", userid,notification_message->fail_link_node1,notification_message->fail_link_node2);
				
						//op_rte_route_print(min_rptr[userid][notification_message->fail_link_node1]);
						min_rptr[userid][notification_message->fail_link_node1] = op_rte_routeset_mincost (rset_ptr[userid][notification_message->fail_link_node1]);
						//min_rptr[userid][notification_message->fail_link_node1] = op_rte_route_copy(op_rte_routeset_route_n (rset_ptr[userid][notification_message->fail_link_node1], 1));
						//op_rte_route_print(min_rptr[userid][notification_message->fail_link_node1]);
						//getchar();
						}
					}
					
					if(notification_message->fail_type == 3)
						{
						num1 = notification_message->fail_link_node1;
						num2 = notification_message->fail_link_node2;
						
						if(userid == num1)
							{	
							diff1 = link_send[num1][num2] - link_receive[num2][num1];
							fis_fail[num1][num2] = fis_fail[num1][num2] + diff1;
							back_fis_fail = back_fis_fail + diff1;
							}
						else if(userid == num2)
							{	
							diff2 = link_send[num2][num1] - link_receive[num1][num2];
							fis_fail[num2][num1] = fis_fail[num2][num1] + diff2;
							back_fis_fail = back_fis_fail + diff2;
							}
						}
					
					}
				//************************************************* link *****************************************************
				}


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


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



			}


		FSM_EXIT (0,Restoration_fail)
		}
	}

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

	FIN (Restoration_fail_init (gen_state_pptr))

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

		FRET (OPC_COMPCODE_SUCCESS)
		}
	}



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




void
Restoration_fail_terminate (void)
	{
	int _block_origin = __LINE__;

	FIN (Restoration_fail_terminate (void))

	if (1)
		{
		Objid		dest_objid;
		Objid		src_objid;
		Objid		FIS_dest_objid;
		Objid		FIS_src_objid;
		Objid		src_node_objid;
		Objid		dst_node_objid;
		Objid		current_node_objid;
		Objid		next_node_objid;
		Objid		link_objid;
		Objid		tx_objid;
		Objid		strm_objid;
		int			destination_address;
		int			source_address;
		int			fail_name;
		int			strm_num;
		int			userid;
		int			flag,ppp;
		int			PK_type;
		
		Packet*		FIS_pkptr;
		Packet*		r_FIS_pkptr;
		Packet*		ack_pkptr;
		Route*		FIS_min_rptr_copy;
		Route*		FIS_current_rptr;
		Route*		FIS_rptr;
		double		link_cost;
		Route*		pk_rptr;
		Route*		pk_r;
		Route*		route_ptr;
		Route_Link*	link_ptr;
		Route*		min_rptr_copy;
		Route*		route_test;
		Route_Set* 	FIS_rset_ptr_t;
		Route* 		FIS_min_rptr_t;
		char		node_name[255];
		char		id[20];
		Objid*		node_objid_ptr;
		int			i, num_nodes;
		int			subnet_ids[10], node_ids[10];
		double		cur_time;
		Packet*		cp_pkptr;
		int			next_address;
		double		start_time, dtime_time;
		double		start_time_1, dtime_time_1;
		double		start_time_2, dtime_time_2;
		int			s_f, s_f_flag, num,FIS_s_f_flag;
		
		int 		j,k;
		
		int 		check_num, num1, num2,num3,num4;
		double		list_table[100][2];
		int			delete_num;
		
		int 		FIS_change_type;
		int 		FIS_node_link;
		int 		FIS_destination;
		int 		FIS_source[17][17];
		int 		x,y;
		int 		PK_source[17][17];
		int 		upstream_check;
		int			status_flag;
		int 		l;
		int			num_routes[17][17];
		int			exit_flag;
		int			comp_flag;
		int			diff1, diff2;
		int			change_flag;
		
		
		double	back_average_delay;
		double	back_average_hop;
		double	back_throughput;
		double	back_loss;
		double	back_utilization;

		/* 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_fail_svar function. */
#undef self_objid
#undef node_objid
#undef subnet_objid
#undef current_rptr
#undef subnet_id
#undef next_node_id
#undef rev_pk_count
#undef rev_pk_cnt_stathandle



void
Restoration_fail_svar (void * gen_ptr, const char * var_name, char ** var_p_ptr)
	{
	Restoration_fail_state		*prs_ptr;

	FIN (Restoration_fail_svar (gen_ptr, var_name, var_p_ptr))

	if (var_name == OPC_NIL)
		{
		*var_p_ptr = (char *)OPC_NIL;
		FOUT;
		}
	prs_ptr = (Restoration_fail_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 ("current_rptr" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->current_rptr);
		FOUT;
		}
	if (strcmp ("subnet_id" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->subnet_id);
		FOUT;
		}
	if (strcmp ("next_node_id" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->next_node_id);
		FOUT;
		}
	if (strcmp ("rev_pk_count" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->rev_pk_count);
		FOUT;
		}
	if (strcmp ("rev_pk_cnt_stathandle" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->rev_pk_cnt_stathandle);
		FOUT;
		}
	*var_p_ptr = (char *)OPC_NIL;

	FOUT;
	}