ACE/protocols/ace/RMCast/Fragment.cpp

   1 // author    : Boris Kolpackov <boris@kolpackov.net>
   2 #include "Fragment.h"
   3
   4 /*
   5 #include <iostream>
   6 using std::cerr;
   7 using std::endl;
   8 */
   9
  10 namespace ACE_RMCast
  11 {
  12   Fragment::
  13   Fragment (Parameters const& params)
  14       : params_ (params),
  15         sn_ (1)
  16   {
  17   }
  18
  19   void Fragment::send (Message_ptr m)
  20   {
  21     if (Data const* data = static_cast<Data const*> (m->find (Data::id)))
  22     {
  23       size_t max_payload_size (
  24         params_.max_packet_size () - max_service_size);
  25
  26       if (data->size () <= max_payload_size)
  27       {
  28         u64 sn;
  29         {
  30           Lock l (mutex_);
  31           sn = sn_++;
  32         }
  33
  34         m->add (Profile_ptr (new SN (sn)));
  35
  36         out_->send (m);
  37         return;
  38       }
  39
  40       char const* p = data->buf ();
  41       size_t size (data->size ());
  42
  43       // Need fragmentation.
  44       //
  45       u32 packets (size / max_payload_size + (size % max_payload_size ? 1 : 0));
  46
  47       // cerr << "size : " << size << endl
  48       //      << "packs: " << packets << endl;
  49
  50       for (u32 i (1); i <= packets; ++i)
  51       {
  52         Message_ptr part (new Message);
  53
  54         size_t s (i == packets ? size % max_payload_size : max_payload_size);
  55
  56         // cerr << "pack: " << s << endl;
  57
  58         u64 sn;
  59         {
  60           Lock l (mutex_);
  61           sn = sn_++;
  62         }
  63
  64         part->add (Profile_ptr (new SN (sn)));
  65         part->add (Profile_ptr (new Part (i, packets, size)));
  66         part->add (Profile_ptr (new Data (p, s)));
  67
  68         out_->send (part);
  69
  70         p += s;
  71       }
  72     }
  73   }
  74 }