X-Git-Url: http://g0dil.de/git?a=blobdiff_plain;f=Examples%2Fpsi2tsModule%2Fpsi2ts.cc;h=2ff2538ba0f31818e66d255bc8805fdd3810374b;hb=7dffbd59c43b82572bad98d4c838b1ed368b9a14;hp=a41acbe8903c1a8520382366fe32269e4daebc17;hpb=784b5901486e0bcb0eb5dadd3a2f4fc31810bd66;p=senf.git diff --git a/Examples/psi2tsModule/psi2ts.cc b/Examples/psi2tsModule/psi2ts.cc index a41acbe..2ff2538 100644 --- 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);