Inheritance diagram for Txc12:

We also collect basic statistics (min, max, mean, std.dev.) and histogram about the hop count which we'll print out at the end of the simulation.
Protected Member Functions | |
| virtual TicTocMsg12 * | generateMessage () |
| virtual void | forwardMessage (TicTocMsg12 *msg) |
| virtual void | initialize () |
| virtual void | handleMessage (cMessage *msg) |
| virtual void | finish () |
Private Attributes | |
| long | numSent |
| long | numReceived |
| cLongHistogram | hopCountStats |
| cOutVector | hopCountVector |
|
|
Reimplemented from cModule. 00131 {
00132 // This function is called by OMNeT++ at the end of the simulation.
00133 ev << "Sent: " << numSent << endl;
00134 ev << "Received: " << numReceived << endl;
00135 ev << "Hop count, min: " << hopCountStats.min() << endl;
00136 ev << "Hop count, max: " << hopCountStats.max() << endl;
00137 ev << "Hop count, mean: " << hopCountStats.mean() << endl;
00138 ev << "Hop count, stddev: " << hopCountStats.stddev() << endl;
00139
00140 recordScalar("#sent", numSent);
00141 recordScalar("#received", numReceived);
00142 hopCountStats.recordScalar("hop count");
00143 }
|
|
|
00118 {
00119 // Increment hop count.
00120 msg->setHopCount(msg->getHopCount()+1);
00121
00122 // Same routing as before: random gate.
00123 int n = gate("out")->size();
00124 int k = intuniform(0,n-1);
00125
00126 ev << "Forwarding message " << msg << " on port out[" << k << "]\n";
00127 send(msg, "out", k);
00128 }
|
|
|
00100 {
00101 // Produce source and destination addresses.
00102 int src = index();
00103 int n = size();
00104 int dest = intuniform(0,n-2);
00105 if (dest>=src) dest++;
00106
00107 char msgname[20];
00108 sprintf(msgname, "tic-%d-to-%d", src, dest);
00109
00110 // Create message object and set source and destination field.
00111 TicTocMsg12 *msg = new TicTocMsg12(msgname);
00112 msg->setSource(src);
00113 msg->setDestination(dest);
00114 return msg;
00115 }
|
|
|
Reimplemented from cSimpleModule. 00068 {
00069 TicTocMsg12 *ttmsg = check_and_cast<TicTocMsg12 *>(msg);
00070
00071 if (ttmsg->getDestination()==index())
00072 {
00073 // Message arrived
00074 int hopcount = ttmsg->getHopCount();
00075 ev << "Message " << ttmsg << " arrived after " << hopcount << " hops.\n";
00076 bubble("ARRIVED, starting new one!");
00077
00078 // update statistics.
00079 numReceived++;
00080 hopCountVector.record(hopcount);
00081 hopCountStats.collect(hopcount);
00082
00083 delete ttmsg;
00084
00085 // Generate another one.
00086 ev << "Generating another message: ";
00087 TicTocMsg12 *newmsg = generateMessage();
00088 ev << newmsg << endl;
00089 forwardMessage(newmsg);
00090 numSent++;
00091 }
00092 else
00093 {
00094 // We need to forward the message.
00095 forwardMessage(ttmsg);
00096 }
00097 }
|
|
|
Reimplemented from cModule. 00047 {
00048 // Initialize variables
00049 numSent = 0;
00050 numReceived = 0;
00051 WATCH(numSent);
00052 WATCH(numReceived);
00053
00054 hopCountStats.setName("hopCountStats");
00055 hopCountStats.setRangeAutoUpper(0, 10, 1.5);
00056 hopCountVector.setName("HopCount");
00057
00058 // Module 0 sends the first message
00059 if (index()==0)
00060 {
00061 // Boot the process scheduling the initial message as a self-message.
00062 TicTocMsg12 *msg = generateMessage();
00063 scheduleAt(0.0, msg);
00064 }
00065 }
|
|
|
|
|
|
|
|
|
|
|
|
|
1.4.1