線上opnet相關(guān)設(shè)計進(jìn)程說明

進(jìn)程說明

Broadcast01_xr：

仿真時間開始前200s廣播包

HB：

//headfile

#include<math.h>

//GV

intglobal_total_packet_load=0;

//Constants

#defineLOW_OUT_STRM0

//Macro

#definePKT_SENT(op_intrpt_type()==OPC_INTRPT_SELF)

//functiondeclaration

staticvoidsend_pk(void);

staticvoidschedule_next_send();

FB：

staticvoidschedule_next_send(void)

{

doublenext_creation_time;FIN(schedule_next_send())

next_creation_time=op_dist_outcome(ia_dist);op_intrpt_schedule_self(op_sim_time()+next_creation_time,0);

FOUT

}

staticvoidsend_pk(void)

{

Packet*pkptr;charmsg[256];FIN(send_pk())

if(op_sim_time()<200)

{

pkptr=op_pk_create_fmt("wireless_pk01_xr");if(pkptr==OPC_NIL)

{

sprintf(msg,"Unabletocreatepacket");op_sim_end(msg,OPC_NIL,OPC_NIL,OPC_NIL);

}

else

{

op_pk_bcast_general(pkptr);packet_load++;global_total_packet_load++;

op_stat_write(packet_load_lhndl,packet_load);op_stat_write(total_packet_load_ghndl,global_total_packet_load++);op_pk_send(pkptr,LOW_OUT_STRM);

schedule_next_send();

}

}FOUT

}

//init入口代碼

packet_load_lhndl=op_stat_reg("PacketLoad",OPC_STAT_INDEX_NONE,OPC_STAT_LOCAL);total_packet_load_ghndl=op_stat_reg("TotalLoad",OPC_STAT_INDEX_NONE,OPC_STAT_GLOBAL);

packet_load=0;

ia_dist=op_dist_load("exponential",30,0.0);

Packet

schedule_next_send();

Broadcast02_xr：

仿真時間開始廣播包，廣播時間可以由用戶通過節(jié)點(diǎn)屬性自行控制。

增加節(jié)點(diǎn)進(jìn)程屬性

TV：

Objidmy_id;

HB：同broadcast01_xr

//headfile

#include<math.h>

//GV

intglobal_total_packet_load=0;

//Constants

#defineLOW_OUT_STRM0

//Macro

#definePKT_SENT(op_intrpt_type()==OPC_INTRPT_SELF)

//functiondeclaration

staticvoidsend_pk(void);

staticvoidschedule_next_send();

FB：

staticvoidschedule_next_send(void)

{

doublenext_creation_time;FIN(schedule_next_send())

next_creation_time=op_dist_outcome(ia_dist);op_intrpt_schedule_self(op_sim_time()+next_creation_time,0);

FOUT

}

staticvoidsend_pk(void)

{

Packet*pkptr;charmsg[256];FIN(send_pk())

if(op_sim_time()<broadcast_time)

{

pkptr=op_pk_create_fmt("wireless_pk01_xr");if(pkptr==OPC_NIL)

{

sprintf(msg,"Unabletocreatepacket");op_sim_end(msg,OPC_NIL,OPC_NIL,OPC_NIL);

}

else

{

op_pk_bcast_general(pkptr);packet_load++;global_total_packet_load++;

op_stat_write(packet_load_lhndl,packet_load);op_stat_write(total_packet_load_ghndl,global_total_packet_load++);op_pk_send(pkptr,LOW_OUT_STRM);

schedule_next_send();

}

}FOUT

}

//init入口

packet_load_lhndl=op_stat_reg("PacketLoad",OPC_STAT_INDEX_NONE,OPC_STAT_LOCAL);total_packet_load_ghndl=op_stat_reg("TotalLoad",OPC_STAT_INDEX_NONE,OPC_STAT_GLOBAL);

packet_load=0;

ia_dist=op_dist_load("exponential",30,0.0);

Packet

my_id=op_id_self();

op_ima_obj_attr_get(my_id,"BroadcastTime",&broadcast_time);if(broadcast_time<=0)

broadcast_time=200;

schedule_next_send();

Broadcast03_xr：

保持broadcast02_xr的功能，并初始化需要廣播的包的各個字段。

進(jìn)程大致沒有什么變化，增加了局部統(tǒng)計量X，狀態(tài)變量x_stathandle并修改了函數(shù)send_pk()。函數(shù)如下：

staticvoidsend_pk(void)

{

Packet*pkptr;charmsg[256];doublex;doubley;

Objidmodule_id;

Objidnode_id;

FIN(send_pk())

if(op_sim_time()<broadcast_time)

{

pkptr=op_pk_create_fmt("wireless_pk01_xr");if(pkptr==OPC_NIL)

{

sprintf(msg,"Unabletocreatepacket");op_sim_end(msg,OPC_NIL,OPC_NIL,OPC_NIL);

}

else

{

module_id=op_id_self();node_id=op_topo_parent(module_id);op_ima_obj_attr_get(node_id,"xposition",&x);

op_ima_obj_attr_get(node_id,"yposition",&y);

op_pk_nfd_set(pkptr,"x_pos",x);

op_pk_nfd_set(pkptr,"y_pos",y);op_pk_nfd_set(pkptr,"hop",1);op_pk_nfd_set(pkptr,"ave",0);

op_pk_nfd_set(pkptr,"packet_type",0);

op_pk_bcast_general(pkptr);

packet_load++;global_total_packet_load++;

op_stat_write(packet_load_lhndl,packet_load);op_stat_write(total_packet_load_ghndl,global_total_packet_load++);op_pk_send(pkptr,LOW_OUT_STRM);

schedule_next_send();

}

}

FOUT

}

Br_rv01:

保持broadcast03的發(fā)送功能，并增加接收其它節(jié)點(diǎn)傳來的包的功能，對傳來的包進(jìn)行銷毀。節(jié)

點(diǎn)屬性

TV：

Objidmy_id;

HB：

//頭文件

#include<math.h>

//全局變量

intglobal_total_packet_load=0;

intglobal_total_r_packet_load=0;

//常量

#defineLOW_OUT_STRM0

//宏

#definePKT_SENT(op_intrpt_type()==OPC_INTRPT_SELF)

#definePKT_RECEIVE(op_intrpt_type()==OPC_INTRPT_STRM)

//函數(shù)聲明

staticvoidsend_pk(void);

staticvoidschedule_next_send();staticvoidreceive_pk(void);

staticvoidschedule_next_send(void)

{

doublenext_creation_time;FIN(schedule_next_send())

next_creation_time=op_dist_outcome(ia_dist);

op_intrpt_schedule_self(op_sim_time()+next_creation_time,0);

FOUT

}

staticvoidsend_pk(void)

{

Packet*pkptr;charmsg[256];doublex;doubley;

Objidmodule_id;

Objidnode_id;

FIN(send_pk())

if(op_sim_time()<broadcast_time)

{

pkptr=op_pk_create_fmt("wireless_pk01_xr");if(pkptr==OPC_NIL)

{

sprintf(msg,"Unabletocreatepacket");op_sim_end(msg,OPC_NIL,OPC_NIL,OPC_NIL);

}

else

{

module_id=op_id_self();node_id=op_topo_parent(module_id);op_ima_obj_attr_get(node_id,"xposition",&x);

op_ima_obj_attr_get(node_id,"yposition",&y);

op_pk_nfd_set(pkptr,"x_pos",x);

op_pk_nfd_set(pkptr,"y_pos",y);op_pk_nfd_set(pkptr,"hop",1);op_pk_nfd_set(pkptr,"ave",0);

op_pk_nfd_set(pkptr,"packet_type",0);

op_pk_bcast_general(pkptr);

packet_load++;global_total_packet_load++;

op_stat_write(packet_load_lhndl,packet_load);op_stat_write(total_packet_load_ghndl,global_total_packet_load);op_pk_send(pkptr,LOW_OUT_STRM);

schedule_next_send();

}

}

FOUT

}

staticvoidreceive_pk(void)

{

Packet*pkptr;charmsg[256];FIN(receive_pk())

pkptr=op_pk_get(op_intrpt_strm());if(pkptr==OPC_NIL)

{

sprintf(msg,"Unabletopickapacket");op_sim_end(msg,OPC_NIL,OPC_NIL,OPC_NIL);

}

else

{

global_total_r_packet_load++;r_packet_load++;

op_stat_write(r_packet_load_lhndl,r_packet_load);

op_stat_write(total_r_packet_load_ghndl,global_total_r_packet_load);

op_pk_destroy(pkptr);

}

FOU