restoration_proc.pr.c

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

					//printf("test21\n");
					op_pk_send (pkptr, PK_OUT_STRM);
					}
					else
					{
					//printf("test3\n");
					op_pk_destroy(pkptr);
					}
				}
				getchar();
				
				
				
				
				
				}


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


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



			/** state (end) enter executives **/
			FSM_STATE_ENTER_UNFORCED (3, state3_enter_exec, "end", "Restoration_proc () [end enter execs]")
				{
				
				}


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


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


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



			}


		FSM_EXIT (0,Restoration_proc)
		}
	}

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

	FIN (Restoration_proc_init (gen_state_pptr))

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

		FRET (OPC_COMPCODE_SUCCESS)
		}
	}



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




void
Restoration_proc_terminate (void)
	{
	int _block_origin = __LINE__;

	FIN (Restoration_proc_terminate (void))

	if (1)
		{
		Packet*		pkptr_burst;
		Packet*		pkptr;
		
		int			sequence_number_ack;
		int			sequence_number_rcv;
		int			source_address;
		int			destination_address;
		
		
		int 		i,j,k;
		Route*		pk_rptr;
		Route*		p_min_rptr_copy;
		double		start_time;
		double		dtime_time;
		double		cur_time;
		int			subnet_ids[10];
		int			node_ids[20];
		int			num_nodes;
		int			userid;
		
		double 		EXTRA_TIME;
		int			ok_flag;
		int			wavelength_number;
		int 		u_id;
		Objid		strm_objid;

		/* Termination Block */


		BINIT
		

		/* End of 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_proc_svar function. */
#undef sequence_number_wait
#undef sequence_number_current
#undef node_address
#undef nodes_total
#undef queue_size
#undef pk_rcvd
#undef address_dist
#undef sar_mod_objid
#undef node_id
#undef subnet_id
#undef next_node_id
#undef num_pk_gen_gsh
#undef dup_pk_gsh
#undef current_rptr
#undef pk_count
#undef pk_cnt_stathandle
#undef start_dist
#undef dtime_dist
#undef dest_node_objid
#undef node_objid
#undef self_objid
#undef wave_dist
#undef pk_size_temp
#undef pk_size
#undef pik_count
#undef pk_cnt_no1_stathandle
#undef pk_size_no1_stathandle



void
Restoration_proc_svar (void * gen_ptr, const char * var_name, char ** var_p_ptr)
	{
	Restoration_proc_state		*prs_ptr;

	FIN (Restoration_proc_svar (gen_ptr, var_name, var_p_ptr))

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

	if (strcmp ("sequence_number_wait" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->sequence_number_wait);
		FOUT;
		}
	if (strcmp ("sequence_number_current" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->sequence_number_current);
		FOUT;
		}
	if (strcmp ("node_address" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->node_address);
		FOUT;
		}
	if (strcmp ("nodes_total" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->nodes_total);
		FOUT;
		}
	if (strcmp ("queue_size" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->queue_size);
		FOUT;
		}
	if (strcmp ("pk_rcvd" , var_name) == 0)
		{
		*var_p_ptr = (char *) (prs_ptr->pk_rcvd);
		FOUT;
		}
	if (strcmp ("address_dist" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->address_dist);
		FOUT;
		}
	if (strcmp ("sar_mod_objid" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->sar_mod_objid);
		FOUT;
		}
	if (strcmp ("node_id" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->node_id);
		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 ("num_pk_gen_gsh" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->num_pk_gen_gsh);
		FOUT;
		}
	if (strcmp ("dup_pk_gsh" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->dup_pk_gsh);
		FOUT;
		}
	if (strcmp ("current_rptr" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->current_rptr);
		FOUT;
		}
	if (strcmp ("pk_count" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->pk_count);
		FOUT;
		}
	if (strcmp ("pk_cnt_stathandle" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->pk_cnt_stathandle);
		FOUT;
		}
	if (strcmp ("start_dist" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->start_dist);
		FOUT;
		}
	if (strcmp ("dtime_dist" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->dtime_dist);
		FOUT;
		}
	if (strcmp ("dest_node_objid" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->dest_node_objid);
		FOUT;
		}
	if (strcmp ("node_objid" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->node_objid);
		FOUT;
		}
	if (strcmp ("self_objid" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->self_objid);
		FOUT;
		}
	if (strcmp ("wave_dist" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->wave_dist);
		FOUT;
		}
	if (strcmp ("pk_size_temp" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->pk_size_temp);
		FOUT;
		}
	if (strcmp ("pk_size" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->pk_size);
		FOUT;
		}
	if (strcmp ("pik_count" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->pik_count);
		FOUT;
		}
	if (strcmp ("pk_cnt_no1_stathandle" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->pk_cnt_no1_stathandle);
		FOUT;
		}
	if (strcmp ("pk_size_no1_stathandle" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->pk_size_no1_stathandle);
		FOUT;
		}
	*var_p_ptr = (char *)OPC_NIL;

	FOUT;
	}