← Back to branch summary

~comnets/openwns-app/trunk

« back to all changes in this revision

Viewing changes to src/session/server/Email.cpp

  • Committer: Maciej Muehleisen
  • Date: 2011-09-22 18:56:33 UTC
  • Revision ID: mue@mue-laptop-20110922185633-1sgk3pxyyyybi8f7
Callback is used to probe PDU loss

Show diffs side-by-side

added added

removed removed

Lines of Context:
src/session/server/Email.cpp
158
158
          applications::session::PDU* applicationPDU = new applications::session::PDU(Bit(packetSize), pyco);
159
159
          applicationPDU->setCreationTime(wns::simulator::getEventScheduler()->getTime());
160
160
 
161
 
          applications::session::Session::outgoingProbesCalculation();
162
 
 
163
161
          ++packetNumber;
164
162
          applicationPDU->setPacketNumber(packetNumber, packetFrom);
165
163
          MESSAGE_SINGLE(NORMAL, logger, "APPL: PacketNumber = " << packetNumber << ".");
171
169
              /* sending last email */
172
170
              applicationPDU->setLastPacket(true);
173
171
              wns::osi::PDUPtr pdu(applicationPDU);
 
172
          applications::session::Session::outgoingProbesCalculation(pdu);
174
173
 
175
174
              connection->sendData(pdu);
176
175
 
180
179
            {
181
180
              numberOfEmails = numberOfEmails - 1;
182
181
              wns::osi::PDUPtr pdu(applicationPDU);
 
182
          applications::session::Session::outgoingProbesCalculation(pdu);
183
183
 
184
184
              connection->sendData(pdu);
185
185
            }
193
193
          applications::session::PDU* applicationPDU = new applications::session::PDU(Bit(packetSize), pyco);
194
194
          applicationPDU->setCreationTime(wns::simulator::getEventScheduler()->getTime());
195
195
 
196
 
          applications::session::Session::outgoingProbesCalculation();
197
 
 
198
196
          ++packetNumber;
199
197
          applicationPDU->setPacketNumber(packetNumber, packetFrom);
200
198
          MESSAGE_SINGLE(NORMAL, logger, "APPL: PacketNumber = " << packetNumber << ".");
201
199
 
202
200
          wns::osi::PDUPtr pdu(applicationPDU);
 
201
      applications::session::Session::outgoingProbesCalculation(pdu);
203
202
 
204
203
          connection->sendData(pdu);
205
204
 
215
214
          applications::session::PDU* applicationPDU = new applications::session::PDU(Bit(packetSize), pyco);
216
215
          applicationPDU->setCreationTime(wns::simulator::getEventScheduler()->getTime());
217
216
 
218
 
          applications::session::Session::outgoingProbesCalculation();
219
 
 
220
217
          ++packetNumber;
221
218
          applicationPDU->setPacketNumber(packetNumber, packetFrom);
222
219
          MESSAGE_SINGLE(NORMAL, logger, "APPL: PacketNumber = " << packetNumber << ".");
223
220
 
224
221
          wns::osi::PDUPtr pdu(applicationPDU);
 
222
      applications::session::Session::outgoingProbesCalculation(pdu);
225
223
 
226
224
          connection->sendData(pdu);
227
225
 
237
235
          applications::session::PDU* applicationPDU = new applications::session::PDU(Bit(packetSize), pyco);
238
236
          applicationPDU->setCreationTime(wns::simulator::getEventScheduler()->getTime());
239
237
 
240
 
          applications::session::Session::outgoingProbesCalculation();
241
 
 
242
238
          ++packetNumber;
243
239
          applicationPDU->setPacketNumber(packetNumber, packetFrom);
244
240
          MESSAGE_SINGLE(NORMAL, logger, "APPL: PacketNumber = " << packetNumber << ".");
245
241
 
246
242
          wns::osi::PDUPtr pdu(applicationPDU);
 
243
      applications::session::Session::outgoingProbesCalculation(pdu);
247
244
 
248
245
          connection->sendData(pdu);
249
246
 
260
257
      applications::session::PDU* applicationPDU = new applications::session::PDU(Bit(packetSize), pyco);
261
258
      applicationPDU->setCreationTime(wns::simulator::getEventScheduler()->getTime());
262
259
 
263
 
      applications::session::Session::outgoingProbesCalculation();
264
 
 
265
260
      packetNumber = 1;
266
261
      applicationPDU->setPacketNumber(packetNumber, packetFrom);
267
262
      MESSAGE_SINGLE(NORMAL, logger, "APPL: PacketNumber = " << packetNumber << ".");
269
264
      applicationPDU->setLastPacket(true);
270
265
 
271
266
      wns::osi::PDUPtr pdu(applicationPDU);
 
267
      applications::session::Session::outgoingProbesCalculation(pdu);
272
268
 
273
269
      connection->sendData(pdu);
274
270
      state = idle;