00001
00002
00003
00004
00005
00006
00007
00008
00009
00010
00011
00012
00013
00014
00015
00016
00017
00018
00019
00020
00021
00022
00023
00024
00025
00026
00027
00028
00029
00030
00031
00032
00033
00034
00035
00036
00037
00038 #include "SimpleNode.h"
00039
00040 namespace dtnsim {
00041
00042 SimpleNode::SimpleNode( int id, const char* logpath)
00043 : Node(id,logpath),msgq_(0)
00044 {
00045 }
00046
00047 SimpleNode::~SimpleNode() {}
00048
00049
00050 void
00051 SimpleNode::chewing_complete(SimContact* c, double size, Message* msg)
00052 {
00053
00054 if (msg->size() != size){
00055
00062 log_info("ChXXX for msg %d, frac %f",msg->id(),size*1.0/msg->size());
00063 if (size != 0) {
00064 msg = (Message* )msg->clone();
00065 msg->rm_bytes(size);
00066 }
00067
00068 forward(msg);
00069 }
00070 else {
00071 log_info("ChC for msg %d",msg->id());
00072 }
00073 }
00074
00081 bool
00082 is_relevant(SimContact* c, Message* m)
00083 {
00084 if (m->src() == c->dst()->id()) return false;
00085 return true;
00086 }
00087
00091 void
00092 SimpleNode::forward(Message* msg)
00093 {
00094 for(int i=0;i<Topology::contacts();i++){
00095 SimContact *c = Topology::contact(i);
00096 if (c->is_open() && (c->src()->id() == id() )) {
00097
00098 if (is_relevant(c,msg)) {
00099 c->chew_message(msg);
00100 return;
00101 }
00102 }
00103 }
00104
00105 msgq_.push_back(msg);
00106 }
00107
00111 void
00112 SimpleNode::open_contact(SimContact* ct)
00113 {
00114 for(u_int i=0;i<msgq_.size();i++) {
00115 Message* msg = msgq_[i];
00116 if (is_relevant(ct,msg)) {
00117
00118 log_debug("contact is open and valid for messaged %d",msg->id());
00119 std::vector<Message*>::iterator rmv = msgq_.begin() + i - 1;
00120
00121
00122 msgq_.erase(rmv);
00123 ct->chew_message(msg);
00124 return;
00125 }
00126 }
00127
00128 }
00129
00130 void
00131 SimpleNode::close_contact(SimContact* c)
00132 {
00133
00134 }
00135
00136
00137 void
00138 SimpleNode::message_received(Message* msg)
00139 {
00140 if (msg->dst() == id()) {
00141
00142 log_info("Rc msg at node %d, id %d, size-rcv %f",
00143 id(),msg->id(),msg->size());
00144 }
00145 else {
00146
00147 log_info("Fw msg at node %d, id %d, size-rcv %f",
00148 id(),msg->id(),msg->size());
00149 forward(msg);
00150 }
00151 }
00152
00153
00154 void
00155 SimpleNode::process(Event* e)
00156 {
00157
00158 if (e->type() == MESSAGE_RECEIVED) {
00159
00160 Event_message_received* e1 = (Event_message_received*)e;
00161 Message* msg = e1->msg_;
00162 log_info("received msg (%d) size %3f",msg->id(),msg->size());
00163
00164
00165 msg->set_size(e1->sizesent_);
00166 message_received(msg);
00167
00168 }
00169 else
00170 PANIC("unimplemented action code");
00171 }
00172
00173 }