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

added the print temp losses

Browse Source
This commit is contained in:
Dhanya Maliakal 2016-11-08 16:31:05 +01:00
parent 964c76ac60
commit 5f4a38416a
1 changed files with 27 additions and 30 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

57
slsReceiverSoftware/src/UDPStandardImplementation.cpp
View File

@ -1604,9 +1604,10 @@ int UDPStandardImplementation::createNewFile(int ithread){
if(totalWritingPacketCount[ithread]){ if(totalWritingPacketCount[ithread]){
frameNumberInPreviousFile[ithread] = currentFrameNumber[ithread]; frameNumberInPreviousFile[ithread] = currentFrameNumber[ithread];
totalPacketsInFile[ithread] = 0; totalPacketsInFile[ithread] = 0;
}else }else{
frameNumberInPreviousFile[ithread] = -1; frameNumberInPreviousFile[ithread] = -1;
frameNumberInPreviousCheck[ithread] = -1;
}
@ -2905,6 +2906,30 @@ void UDPStandardImplementation::handleWithoutMissingPackets(int ithread, char* w
fwrite(wbuffer + HEADER_SIZE_NUM_TOT_PACKETS, 1, oneDataSize*packetsPerFrame+fifoBufferHeaderSize-HEADER_SIZE_NUM_TOT_PACKETS, sfilefd[ithread]); fwrite(wbuffer + HEADER_SIZE_NUM_TOT_PACKETS, 1, oneDataSize*packetsPerFrame+fifoBufferHeaderSize-HEADER_SIZE_NUM_TOT_PACKETS, sfilefd[ithread]);
} }
//Print packet loss and filenames
if( (currentFrameNumber[ithread]%(maxFramesPerFile/10)) == 0){
printf("\nThread:%d"
"\t\tPackets Lost:%d"
"\tPacketsFromLastCheck:%lld"
"\tCurrentFrameNumber:%lld"
"\tPreviousFrameNumber:%lld\n",
ithread,
( ((int)(currentFrameNumber[ithread]-frameNumberInPreviousCheck[ithread])*packetsPerFrame) - totalWritingPacketCountFromLastCheck[ithread]),
totalWritingPacketCountFromLastCheck[ithread],
currentFrameNumber[ithread],
frameNumberInPreviousCheck[ithread]
);
//reset counters for each new file
frameNumberInPreviousCheck[ithread] = currentFrameNumber[ithread];
totalWritingPacketCountFromLastCheck[ithread] = 0;
}
if(npackets!=128) exit(-1);/******************/
totalWritingPacketCountFromLastCheck[ithread]+= npackets;
totalPacketsInFile[ithread] += npackets; totalPacketsInFile[ithread] += npackets;
totalWritingPacketCount[ithread] += npackets; totalWritingPacketCount[ithread] += npackets;
lastFrameNumberInFile[ithread] = tempframenumber; lastFrameNumberInFile[ithread] = tempframenumber;
@ -2923,34 +2948,6 @@ void UDPStandardImplementation::handleWithoutMissingPackets(int ithread, char* w
if(numberofWriterThreads > 1) if(numberofWriterThreads > 1)
pthread_mutex_unlock(&writeMutex); pthread_mutex_unlock(&writeMutex);
//Print packet loss and filenames
if(totalWritingPacketCountFromLastCheck[ithread] && (currentFrameNumber[ithread]%(maxFramesPerFile/10)) == 0){
printf("\nThread:%d"
"\t\tPackets Lost:%d"
"\tPacketsFromLastCheck:%lld"
"\tCurrentFrameNumber:%lld"
"\tPreviousFrameNumber:%lld\n",
ithread,
( ((int)(currentFrameNumber[ithread]-frameNumberInPreviousCheck[ithread])*packetsPerFrame) - totalWritingPacketCountFromLastCheck[ithread]),
totalWritingPacketCountFromLastCheck[ithread],
currentFrameNumber[ithread],
frameNumberInPreviousCheck[ithread]
);
//reset counters for each new file
if(totalWritingPacketCountFromLastCheck[ithread]){
frameNumberInPreviousCheck[ithread] = currentFrameNumber[ithread];
totalWritingPacketCountFromLastCheck[ithread] = 0;
}else
frameNumberInPreviousCheck[ithread] = -1;
}
if(npackets!=128) exit(-1);/******************/
totalWritingPacketCountFromLastCheck[ithread]+= npackets;
} }
#ifdef DEBUG4 #ifdef DEBUG4
cprintf(GREEN,"Writing_Thread: Writing done\nGoing to copy frame\n"); cprintf(GREEN,"Writing_Thread: Writing done\nGoing to copy frame\n");