线上opnet相关设计进程说明

进程说明

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：

仿真时间开始广播包，广播时间可以由用户通过节点属性自行控制。

增加节点进程属性

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的功能，并初始化需要广播的包的各个字段。

进程大致没有什么变化，增加了局部统计量X，状态变量x_stathandle并修改了函数send_pk()。函数如下：

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的发送功能，并增加接收其它节点传来的包的功能，对传来的包进行销毁。节

点属性

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)

//函数声明

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