obs_proc.pr.c

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

				//printf("strm index in num = %d\n",op_strm_max_index_in());
				//printf("strm index out num = %d\n",op_strm_max_index_out());
				//jj=1;
				//}
				/*
				//op_pk_nfd_set(pkptr,"channel",op_dist_uniform(op_dist_uniform(op_topo_assoc_count(tx_objid, OPC_TOPO_ASSOC_IN,OPC_OBJTYPE_STRM)));
				channel_num = op_dist_uniform(2);
				op_pk_nfd_set(pkptr,"channel",channel_num);
				if(channel_num == 0)
				{
					pk_count_send_channel0++;
					pk_size_send_channel0 = op_pk_total_size_get (pkptr_burst);
					op_stat_write(pk_count_send_channel0_stathandle, pk_count_send_channel0);
					op_stat_write(pk_size_send_channel0_stathandle, pk_size_send_channel0);
				}
				else if(channel_num == 1)
				{
					pk_count_send_channel1++;
					pk_size_send_channel1 = op_pk_total_size_get (pkptr_burst);
					op_stat_write(pk_count_send_channel1_stathandle, pk_count_send_channel1);
					op_stat_write(pk_size_send_channel1_stathandle, pk_size_send_channel1);
				}
				*/
				}


			/** state (proc) exit executives **/
			FSM_STATE_EXIT_FORCED (2, "proc", "OBS_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", "OBS_proc () [end enter execs]")
				{
				
				}


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


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


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



			}


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

	FIN (OBS_proc_init (gen_state_pptr))

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

		FRET (OPC_COMPCODE_SUCCESS)
		}
	}



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




void
OBS_proc_terminate (void)
	{
	int _block_origin = __LINE__;

	FIN (OBS_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;
		int 		jj;
		int 		channel_num;
		double		temp_time;

		/* 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 OBS_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
#undef pk_size_total_send_stathandle
#undef pk_cnt_total_send_stathandle
#undef pk_avg_size_send
#undef pk_count_send_channel0
#undef pk_count_send_channel1
#undef pk_size_send_channel0
#undef pk_size_send_channel1
#undef pk_avg_size_send_stathandle
#undef pk_count_send_channel0_stathandle
#undef pk_size_send_channel0_stathandle
#undef pk_count_send_channel1_stathandle
#undef pk_size_send_channel1_stathandle
#undef pk_avg_total_size_send_stathandle
#undef id_number



void
OBS_proc_svar (void * gen_ptr, const char * var_name, char ** var_p_ptr)
	{
	OBS_proc_state		*prs_ptr;

	FIN (OBS_proc_svar (gen_ptr, var_name, var_p_ptr))

	if (var_name == OPC_NIL)
		{
		*var_p_ptr = (char *)OPC_NIL;
		FOUT;
		}
	prs_ptr = (OBS_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;
		}
	if (strcmp ("pk_size_total_send_stathandle" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->pk_size_total_send_stathandle);
		FOUT;
		}
	if (strcmp ("pk_cnt_total_send_stathandle" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->pk_cnt_total_send_stathandle);
		FOUT;
		}
	if (strcmp ("pk_avg_size_send" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->pk_avg_size_send);
		FOUT;
		}
	if (strcmp ("pk_count_send_channel0" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->pk_count_send_channel0);
		FOUT;
		}
	if (strcmp ("pk_count_send_channel1" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->pk_count_send_channel1);
		FOUT;
		}
	if (strcmp ("pk_size_send_channel0" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->pk_size_send_channel0);
		FOUT;
		}
	if (strcmp ("pk_size_send_channel1" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->pk_size_send_channel1);
		FOUT;
		}
	if (strcmp ("pk_avg_size_send_stathandle" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->pk_avg_size_send_stathandle);
		FOUT;
		}
	if (strcmp ("pk_count_send_channel0_stathandle" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->pk_count_send_channel0_stathandle);
		FOUT;
		}
	if (strcmp ("pk_size_send_channel0_stathandle" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->pk_size_send_channel0_stathandle);
		FOUT;
		}
	if (strcmp ("pk_count_send_channel1_stathandle" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->pk_count_send_channel1_stathandle);
		FOUT;
		}
	if (strcmp ("pk_size_send_channel1_stathandle" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->pk_size_send_channel1_stathandle);
		FOUT;
		}
	if (strcmp ("pk_avg_total_size_send_stathandle" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->pk_avg_total_size_send_stathandle);
		FOUT;
		}
	if (strcmp ("id_number" , var_name) == 0)
		{
		*var_p_ptr = (char *) (&prs_ptr->id_number);
		FOUT;
		}
	*var_p_ptr = (char *)OPC_NIL;

	FOUT;
	}