minor steps for the psi2ts module

[senf.git] / Examples / psi2tsModule / psi2ts.cc

diff --git a/Examples/psi2tsModule/psi2ts.cc b/Examples/psi2tsModule/psi2ts.cc
index a41acbe..2ff2538 100644 (file)
--- a/Examples/psi2tsModule/psi2ts.cc
+++ b/Examples/psi2tsModule/psi2ts.cc
@@ -29,6 +29,7 @@
 // Custom includes
 
 //#include "psi2ts.cc.mpp"
+
 #define prefix_
 ///////////////////////////////cc.p////////////////////////////////////////
 
@@ -59,14 +60,18 @@ prefix_ void Psi2TsModule::onRequest()
     advance_max( end, 184, sec_end);
     
     do {
-        senf::TransportPacket tsPacket (senf::TransportPacket::create());
+        senf::TransportPacket tsPacket (senf::TransportPacket::create(188));
         tsPacket->continuity_counter() = next_continuity_counter();
         if (state_ == IDLE) {
             state_ = PROC;
             tsPacket->pusi() = true;
         }
-        senf::DataPacket::createAfter( tsPacket, boost::make_iterator_range(begin, end));
+        senf::PacketData & payloadData (tsPacket.next().data());
+        std::copy( begin, end, payloadData.begin() );
         tsPacket.finalize();
+        
+        output.write( tsPacket);
+        
         advance_max( begin, 184, sec_end);
         advance_max( end,   184, sec_end);
     } while (begin != end);