detectors/slsDetectorPackage
25
0
Fork 0
mirror of https://github.com/slsdetectorgroup/slsDetectorPackage.git synced 2025-04-22 03:40:04 +02:00
Code Issues Actions Packages Releases Activity

trying to fix packetloss print

Browse Source
This commit is contained in:
Dhanya Maliakal 2016-10-25 12:26:53 +02:00
parent 39b9fcba43
commit b38d71b298
1 changed files with 16 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
slsReceiverSoftware/src/UDPStandardImplementation.cpp
View File

@ -1575,18 +1575,25 @@ int UDPStandardImplementation::createNewFile(int ithread){
if(frameNumberInPreviousFile[ithread] == -1) if(frameNumberInPreviousFile[ithread] == -1)
frameNumberInPreviousFile[ithread] = startFrameIndex; frameNumberInPreviousFile[ithread] = startFrameIndex;
cout printf("\nThread %d\tFile:%s\n"
"\tPackets Lost:%d\tCurrentFrameNumber:%lld\tPreviousFrameNumber:%lld\n",
ithread,completeFileName[ithread],
( ((int)(currentFrameNumber[ithread]-frameNumberInPreviousFile[ithread])*packetsPerFrame) - totalPacketsInFile[ithread]),
currentFrameNumber[ithread],frameNumberInPreviousFile[ithread]);
/*
cout << "\nThread " << ithread << "\tFile:" << completeFileName[ithread] <<endl;
//<< "Packet Loss:" << //<< "Packet Loss:" <<
//setw(4)<<fixed << setprecision(4) << //setw(4)<<fixed << setprecision(4) <<
//dec << (int)((( (currentFrameNumber-1-previousFrameNumber) - ((packetsInFile-numTotMissingPacketsInFile)/packetsPerFrame))/ //dec << (int)((( (currentFrameNumber-1-previousFrameNumber) - ((packetsInFile-numTotMissingPacketsInFile)/packetsPerFrame))/
// (double)(currentFrameNumber-1-previousFrameNumber))*100.000) // (double)(currentFrameNumber-1-previousFrameNumber))*100.000)
//<< "%\t" //<< "%\t"
<< "\tPackets Lost:" << dec << ( ((int)(currentFrameNumber[ithread]-frameNumberInPreviousFile[ithread])*packetsPerFrame) - cout<< "\tPackets Lost:" << dec << ( ((int)(currentFrameNumber[ithread]-frameNumberInPreviousFile[ithread])*packetsPerFrame) -
totalPacketsInFile[ithread]) totalPacketsInFile[ithread])
<< "\tCurrentFrameNumber:" << currentFrameNumber[ithread] << "\tCurrentFrameNumber:" << currentFrameNumber[ithread]
<< "\tPreviousFrameNumber:" << frameNumberInPreviousFile[ithread] << "\tPreviousFrameNumber:" << frameNumberInPreviousFile[ithread]
//<< "\tIndex:" << dec << index //<< "\tIndex:" << dec << index
<< endl; << endl;
*/
} }
//write file header //write file header
@ -2633,6 +2640,12 @@ void UDPStandardImplementation::stopWriting(int ithread, char* wbuffer){
if(totalWritingPacketCount[ithread]){ if(totalWritingPacketCount[ithread]){
if(frameNumberInPreviousFile[ithread]==-1) if(frameNumberInPreviousFile[ithread]==-1)
frameNumberInPreviousFile[ithread] = startFrameIndex; frameNumberInPreviousFile[ithread] = startFrameIndex;
printf("\nThread %d\tFile:%s\n"
"\tPackets Lost:%d\tCurrentFrameNumber:%lld\tPreviousFrameNumber:%lld\n",
ithread,completeFileName[ithread],
( ((int)(currentFrameNumber[ithread]-frameNumberInPreviousFile[ithread])*packetsPerFrame) - totalPacketsInFile[ithread]),
currentFrameNumber[ithread],frameNumberInPreviousFile[ithread]);
/*
cout << "\nThread " << ithread << "\tFile:" << completeFileName[ithread] <<endl; cout << "\nThread " << ithread << "\tFile:" << completeFileName[ithread] <<endl;
//<< "Packet Loss:" << //<< "Packet Loss:" <<
//setw(4)<<fixed << setprecision(4) << //setw(4)<<fixed << setprecision(4) <<
@ -2645,6 +2658,7 @@ void UDPStandardImplementation::stopWriting(int ithread, char* wbuffer){
<< "\tPreviousFrameNumber:" << frameNumberInPreviousFile[ithread] << "\tPreviousFrameNumber:" << frameNumberInPreviousFile[ithread]
//<< "\tIndex:" << dec << index //<< "\tIndex:" << dec << index
<< endl; << endl;
*/
} }
closeFile(ithread); closeFile(ithread);
pthread_mutex_lock(&statusMutex); pthread_mutex_lock(&statusMutex);