@@ -309,7 +309,8 @@ int main(int argc, const char** argv)
309309 unsigned long long nMsgParts = 0 ;
310310 unsigned long long nBytes = 0 ;
311311 unsigned long long nTF = 0 ;
312- unsigned long long lastTFid = 0 ;
312+ unsigned long long lastTFid = undefinedTimeframeId;
313+ bool flagLastTFMessage = 0 ;
313314 bool isMultiPart = false ;
314315
315316 double copyRatio = 0 ;
@@ -382,12 +383,18 @@ int main(int argc, const char** argv)
382383 }
383384 }
384385 if (stf->timeframeId != lastTFid) {
385- if ((lastTFid) && (stf->timeframeId != lastTFid + 1 )) {
386- theLog.log (LogWarningSupport_ (3237 ), " Non-continuous TF id ordering: was %d now %d" , (int )lastTFid, (int )stf->timeframeId );
387- }
386+ if (lastTFid != undefinedTimeframeId) {
387+ if ((lastTFid) && (stf->timeframeId != lastTFid + 1 )) {
388+ theLog.log (LogWarningSupport_ (3237 ), " Non-continuous TF id ordering: was %d now %d" , (int )lastTFid, (int )stf->timeframeId );
389+ }
390+ if (flagLastTFMessage != 1 ) {
391+ theLog.log (LogWarningSupport_ (3237 ), " TF id changed without lastTFMessage set in TF %d" , (int )lastTFid);
392+ }
393+ }
388394 lastTFid = stf->timeframeId ;
389395 nTF++;
390396 }
397+ flagLastTFMessage = stf->lastTFMessage ;
391398 } else {
392399 if ((numberOfHBF != 0 ) && (stf->isRdhFormat )) {
393400 // then we have 1 part per HBF
@@ -402,7 +409,7 @@ int main(int argc, const char** argv)
402409 RdhHandle h (((uint8_t *)data) + pageOffset);
403410
404411 if (dumpNext) {
405- printf (" Receiving TF %d CRU %d.%d link %d : %d HBf\n " , (int )stf->timeframeId , (int )h.getCruId (), (int )h.getEndPointId (), (int )stf->linkId , numberOfHBF);
412+ printf (" Receiving TF %d CRU %d.%d link %d : %d HBf %c \n " , (int )stf->timeframeId , (int )h.getCruId (), (int )h.getEndPointId (), (int )stf->linkId , numberOfHBF, ( int )stf-> lastTFMessage ? ' * ' : ' . ' );
406413 dumpNext = false ;
407414 }
408415
0 commit comments