scu.pr.c

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

/* Process model C form file: scu.pr.c */
/* Portions of this file copyright 1992-2001 by OPNET Technologies, Inc. */



/* This variable carries the header into the object file */
static const char scu_pr_c [] = "MIL_3_Tfile_Hdr_ 80C 30A modeler 7 43F17FBD 43F17FBD 1 aurora aurora_plm 0 0 none none 0 0 none 0 0 0 0 0 0                                                                                                                                                                                                                                                                                                                                                                                                                    ";
#include <string.h>



/* OPNET system definitions */
#include <opnet.h>

#if defined (__cplusplus)
extern "C" {
#endif
FSM_EXT_DECS
#if defined (__cplusplus)
} /* end of 'extern "C"' */
#endif


/* Header Block */

#include <string.h>
#include <stdlib.h>
#include "header.h"

//#define PK_IN_STRM 			0
//#define PK_OUT_STRM_CONT	0

#define CONTORL_ACCESS		0
#define SUBQ_INDEX_0		0
#define SUBQ_INDEX_1		1
#define SUBQ_INDEX_2		2
#define SUBQ_INDEX_3		3
#define SUBQ_INDEX_4		4
#define SUBQ_INDEX_5		5

#define BEG_SIM (op_intrpt_type () == OPC_INTRPT_BEGSIM)
#define END_SIM	(op_intrpt_type () == OPC_INTRPT_ENDSIM)

#define CONTROL_ACCESS (op_intrpt_type() == OPC_INTRPT_STRM) 
#define R_T_INIT (op_intrpt_type() == OPC_INTRPT_SELF && op_intrpt_code()== 0)
#define R_T_UPDATE (op_intrpt_type() == OPC_INTRPT_SELF && op_intrpt_code()== 1)
#define SCHUDING_INIT (op_intrpt_type() == OPC_INTRPT_SELF && op_intrpt_code()== 2)



//start of sturct for routing table
typedef struct {
int source;
int destination;
int hop_count;
Objid output_link;
Objid output_tx;
int strm_control;
//int strm_data;
} ROUTING_TABLE;
//end of sturct for routing table





typedef struct {
	double start_time;     //offset time
	double duration_time;  // duration time of burst
	int source;
	int destination;
	int outstrm_num;
	int instrm_num;
} CHANNEL_INFOR;

typedef struct 
{
	double horizon;
	List * gab_list;
	List * occupy_list;
} CHANNEL;

typedef struct 
{
	CHANNEL * channel;
	int next_nodeid;
	Objid tx_objid;
	Objid link_objid;	
	double data_rate;
} PORT;

typedef struct 
{
	PORT * port;
} NODE;


int node_num = 0;
int node_count = 0;   

double PDTime_CC = (double)0.001;
int total_bcp_drop_count = 0;
FILE * in;
char filename[10];


/* End of Header Block */


#if !defined (VOSD_NO_FIN)
#undef	BIN
#undef	BOUT
#define	BIN		FIN_LOCAL_FIELD(last_line_passed) = __LINE__ - _block_origin;
#define	BOUT	BIN
#define	BINIT	FIN_LOCAL_FIELD(last_line_passed) = 0; _block_origin = __LINE__;
#else
#define	BINIT
#endif /* #if !defined (VOSD_NO_FIN) */



/* State variable definitions */
typedef struct
	{
	/* Internal state tracking for FSM */
	FSM_SYS_STATE
	/* State Variables */
	Objid	                  		self_objid;
	Objid	                  		node_objid;
	Objid	                  		subnet_objid;
	int	                    		userid;
	ROUTING_TABLE *	        		routing_table;
	NODE	                   		node_for_schedule;
	int	                    		link_num;
	int	                    		channel_count;
	int	                    		pk_type;
	Packet *	               		pkptr_state;
	int	                    		node_num;
	int	                    		node_count;
	Topology*	              		topo_objid;
	int	                    		temp_strm_num;
	} scu_state;

#define pr_state_ptr            		((scu_state*) SimI_Mod_State_Ptr)
#define self_objid              		pr_state_ptr->self_objid
#define node_objid              		pr_state_ptr->node_objid
#define subnet_objid            		pr_state_ptr->subnet_objid
#define userid                  		pr_state_ptr->userid
#define routing_table           		pr_state_ptr->routing_table
#define node_for_schedule       		pr_state_ptr->node_for_schedule
#define link_num                		pr_state_ptr->link_num
#define channel_count           		pr_state_ptr->channel_count
#define pk_type                 		pr_state_ptr->pk_type
#define pkptr_state             		pr_state_ptr->pkptr_state
#define node_num                		pr_state_ptr->node_num
#define node_count              		pr_state_ptr->node_count
#define topo_objid              		pr_state_ptr->topo_objid
#define temp_strm_num           		pr_state_ptr->temp_strm_num

/* This macro definition will define a local variable called	*/
/* "op_sv_ptr" in each function containing a FIN statement.	*/
/* This variable points to the state variable data structure,	*/
/* and can be used from a C debugger to display their values.	*/
#undef FIN_PREAMBLE
#define FIN_PREAMBLE	scu_state *op_sv_ptr = pr_state_ptr;


/* Function Block */

enum { _block_origin = __LINE__ };
int list_compare (CHANNEL_INFOR * a,CHANNEL_INFOR * b)
{
	if (a->start_time < b->start_time) return 1;
	else if (a->start_time >= b->start_time) return -1;
	else return 0;
};

void difference_fuction(double * difference_time, double *	temp_difference_time,int * selected_channel,int * current_channel)
{
//	printf("difference_fuction;d_t=%d,t_d_t=%d,s_ch=%d,cur_ch=%d\n",*difference_time,*temp_difference_time,*selected_channel,
//		*current_channel);
	if( (*temp_difference_time)*(*difference_time) < 0 )
	{
		if( *temp_difference_time >= *difference_time)
		{
			*difference_time = *temp_difference_time;
			*selected_channel = *current_channel;
//			printf("differen_f;1\n");
		}
		else
		{
//			printf("differen_f;else 1\n");
		}
	}
	else if( *temp_difference_time > 0 && *difference_time > 0 )
	{
		if( *temp_difference_time <= *difference_time)
		{
			*difference_time = *temp_difference_time;
			*selected_channel = *current_channel;
//			printf("differen_f;2\n");
		}
		else
		{
//				printf("differen_f;else 2\n");	
		}
	}
	else if( *temp_difference_time < 0 && *difference_time < 0 )
	{
		if( *temp_difference_time <= *difference_time)
		{
			*difference_time = *temp_difference_time;
			*selected_channel = *current_channel;
//			printf("differen_f;3\n");		
		}
		else
		{
//					printf("differen_f;else 3\n");
		}

	}
	else
	{	
//		printf("differen_f;4\n");
	}	
//	printf("difference_fuction2\n");
//	printf("fuc selec_chan = %d\n",*selected_channel);
};
/*
int find_outstrm_number(Packet* pkptr)
{
	op_rte_pk_current_node(pkptr, &subnet_objid, &current_node_objid);
	op_ima_obj_attr_get (current_node_objid, "user id", &userid_c);	
	op_rte_pk_next_node (pkptr, &subnet_objid, &next_node_objid);
	op_ima_obj_attr_get (next_node_objid, "user id", &userid_n);
	// determine the objid of the next and the link joining it 
	//link_objid = op_topo_connect (node_objid, next_node_objid,OPC_OBJTYPE_LKDUP, 0);
	link_objid = op_topo_connect (current_node_objid, next_node_objid,OPC_OBJTYPE_LKDUP, 0);
	// determine the objid of the stream/tx attached to the link 
	tx_objid = op_topo_assoc ( link_objid, OPC_TOPO_ASSOC_IN, OPC_OBJTYPE_PTTX, 0);
	// for a duplex link, there will be two tx's attached to this link, make sure that the tx that we picked is in the same node 
	if (op_topo_parent (tx_objid) != node_objid)
	{
		tx_objid = op_topo_assoc (link_objid, OPC_TOPO_ASSOC_IN,OPC_OBJTYPE_PTTX, 1);
	}
	// get the stream id connecting to the transmitter 
	strm_objid = op_topo_assoc (tx_objid, OPC_TOPO_ASSOC_IN,OPC_OBJTYPE_STRM, 0);
	// get the stream number 
	op_ima_obj_attr_get (strm_objid, "src stream", &strm_num);
	
}	
*/
void List_Print(List * list)
{
	int num; int i;CHANNEL_INFOR * channel_infor5;
	num = op_prg_list_size(list);
	printf("list_cont=%d\n",num);
	for(i=0;i<num;i++)
	{
		channel_infor5 = (CHANNEL_INFOR *)op_prg_list_access(list,i);
		printf("start=%f,dtime=%f,source=%d,outstrm=%d,list_num=%d,\n",channel_infor5->start_time,channel_infor5->duration_time,
																		   channel_infor5->source,channel_infor5->outstrm_num,i);
	
	}
	//getchar();
}
void Cur_Port_List_Print()
{
	int k;int i;

	for(k=0;k<link_num;k++)
	{
		for(i=1;i<channel_count;i++)
		{
			List_Print(node_for_schedule.port[k].channel[i].occupy_list);
		}
	}
	getchar();
}
/*
void All_List_Print()
{
	int i;int j
	for(i=1;i<7;i++)
	{
		for(j=1;j<7;j++)
		{
			if( i != j )
			{
				Cur_Port_List_Print()
			}
		}	
	}	
}
*/

/*
void function_link_utilization(int userid,int userid_next,double pk_size)
{
	total_pk_size[userid-1][userid_next-1] = total_pk_size[userid-1][userid_next-1] + pk_size;
}
void function_link_utilization_print()
{
	int i,j;
	printf("sim_time=%f\n",op_sim_time());
	for(i=0;i<6;i++)
	{
		for(j=0;j<6;j++)
		{
			printf("total_pk_size[%d][%d]=%f\n",i+1,j+1,total_pk_size[i][j]);
		}	
	}	
}	
*/

/* End of Function Block */

/* Undefine optional tracing in FIN/FOUT/FRET */
/* The FSM has its own tracing code and the other */
/* functions should not have any tracing.		  */
#undef FIN_TRACING
#define FIN_TRACING

#undef FOUTRET_TRACING
#define FOUTRET_TRACING

#if defined (__cplusplus)
extern "C" {
#endif
	void scu (void);
	Compcode scu_init (void **);
	void scu_diag (void);
	void scu_terminate (void);
	void scu_svar (void *, const char *, char **);
#if defined (__cplusplus)
} /* end of 'extern "C"' */
#endif




/* Process model interrupt handling procedure */


void
scu (void)
	{
	int _block_origin = 0;
	FIN (scu ());
	if (1)
		{
		int total_node_num = 0;
		//int node_num = 0;
		//int link_num = 0;
		char node_name[20];
		int i,j,k;
		Objid node_objid_ptr, link_objid,tx_objid;
		Route* min_route;
		int subnet_id_ptr, node_id_ptr;
		int strm_num, channel_count1, link_count;
		double pk_size;
		Objid temp_tx_objid;
		int cur_port, reservation_flag, cur_channel;
		double d_time;
		double temp_difference_time,difference_time; 
		CHANNEL_INFOR * temp_channel_infor;
		int temp_outstrm_num,cur_por,temp_occupy_count;
		int output_strm;
		int pkptr_type;
		Objid temp_src_objid, temp_dest_objid;
		Route_Set* temp_routeset;
		Route* temp_min_route;
		int temp_userid, temp_flag_tx;
		double next_stime;
		int temp_prev_wave_num, temp_prev_userid,temp_output_strm_num;
		int temp_input_strm_num,bcp_intrup_strum ;
		Ici * iciptr;
		Objid * rx_objid;
		Objid * output_strm_objid;
		Packet * s_metrix_pkptr;
		int temp_flag_loop;
		
		
		char temp_char[20];
		char temp_char1[20];
		char temp_char2[20];
		char temp_char3[20];
		char temp_char4[20];
		char temp_c_data_rate[20];
		
		
		
		Packet*		pkptr_burst;
		Packet*		pkptr;
		
		int			source_address;
		int			destination_address;
		
		
		
		Route*		pk_rptr;
		double		start_time;
		double		dtime_time;
		double		cur_time;
		int			subnet_ids[10];
		int			node_ids[20];
		int			num_nodes;
		
		
		double 		EXTRA_TIME;
		Objid		strm_objid;
		int 		jj;
		int 		channel_num;
		int			temp_code;
		double		offset_time,cur_offset_time;
		double 		temp_data_rate, finsh_time;
		int n;
		//int temp_userid;
		
		FILE * in;
		char filename[20];
		char temp_file_name[20];
		CHANNEL_INFOR * channel_infor;
		CHANNEL_INFOR * channel_infor2;
		CHANNEL_INFOR * channel_infor3;
		CHANNEL_INFOR * channel_infor4;
		int selected_channel,list_element_num;


		FSM_ENTER (scu)

		FSM_BLOCK_SWITCH
			{
			/*---------------------------------------------------------*/
			/** state (init) enter executives **/
			FSM_STATE_ENTER_FORCED_NOLABEL (0, "init", "scu () [init enter execs]")
				{
				self_objid = op_id_self ();
				node_objid = op_topo_parent (self_objid);
				//subnet_objid = op_topo_parent (node_objid);
				//topo_objid = op_rte_topo_from_objids();
				
				op_ima_obj_attr_get(node_objid, "user id", &userid);
				
				node_num = op_topo_object_count (OPC_OBJTYPE_NDFIX)-1;
				
				op_intrpt_schedule_self(op_sim_time(), 0);
				op_intrpt_schedule_self(op_sim_time(), 2);
				/*
				n=2.333;
				printf("n=%d\n",n);
				printf("n=%f\n",n);
				printf("n=%e\n",n);
				
				printf("SCU:userid=%d,node_objid=%d\n",userid,op_id_from_userid(subnet_objid,OPC_OBJTYPE_NDFIX,userid));
				printf("SCU:userid=%d,node_objid=%d\n",userid,node_objid);
				printf("scu;userid=%d,node_objid=%d,pt_objid=%d\n",userid,node_objid, op_id_from_name(node_objid,OPC_OBJTYPE_PTTX,"pt_0"));
				printf("SCU:userid=%d,node_objid=%d\n",userid,node_objid);
				printf("scu;userid=%d,node_objid=%d,pt_objid=%d\n",userid,node_objid, op_id_from_name(node_objid,OPC_OBJTYPE_PTTX,"pt_1"));
				printf("SCU:userid=%d,node_objid=%d\n",userid,node_objid);
				printf("scu;userid=%d,node_objid=%d,pt_objid=%d\n",userid,node_objid, op_id_from_name(node_objid,OPC_OBJTYPE_PTTX,"pt_2"));
				printf("SCU:userid=%d,node_objid=%d\n",userid,node_objid);
				printf("scu;userid=%d,node_objid=%d,pt_objid=%d\n",userid,node_objid, op_id_from_name(node_objid,OPC_OBJTYPE_PTTX,"pt_3"));
				printf("SCU:userid=%d,node_objid=%d\n",userid,node_objid);
				printf("scu;userid=%d,node_objid=%d,pt_objid=%d\n\n",userid,node_objid, op_id_from_name(node_objid,OPC_OBJTYPE_PTTX,"pt_4"));