detectors/slsDetectorPackage
25
0
Fork 0
mirror of https://github.com/slsdetectorgroup/slsDetectorPackage.git synced 2025-05-10 23:00:03 +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 13:14:25 +02:00
parent 28005b7875
commit 38b2a272ee
1 changed files with 3 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
slsReceiverSoftware/src/UDPStandardImplementation.cpp
View File

@ -2733,20 +2733,10 @@ void UDPStandardImplementation::handleWithoutDataCompression(int ithread, char*
return; return;
} }
//update current frame number
currentFrameNumber[ithread] = tempframenumber;
//set indices
pthread_mutex_lock(&progressMutex);
if((currentFrameNumber[ithread] - startAcquisitionIndex) > acquisitionIndex)
acquisitionIndex = currentFrameNumber[ithread] - startAcquisitionIndex;
if((currentFrameNumber[ithread] - startFrameIndex) > frameIndex[ithread])
frameIndex[ithread] = currentFrameNumber[ithread] - startFrameIndex;
pthread_mutex_unlock(&progressMutex);
//callback to write data //callback to write data
if (cbAction < DO_EVERYTHING) if (cbAction < DO_EVERYTHING)
rawDataReadyCallBack((int)currentFrameNumber[ithread], wbuffer + HEADER_SIZE_NUM_TOT_PACKETS, npackets * onePacketSize, rawDataReadyCallBack((int)tempframenumber, wbuffer + HEADER_SIZE_NUM_TOT_PACKETS, npackets * onePacketSize,
sfilefd[ithread], latestData[ithread],pRawDataReady);//know which thread from sfilefd sfilefd[ithread], latestData[ithread],pRawDataReady);//know which thread from sfilefd
@ -2852,6 +2842,8 @@ void UDPStandardImplementation::writeFileWithoutCompression(int ithread, char* w
totalPacketsCaught += packetsWritten; totalPacketsCaught += packetsWritten;
pthread_mutex_unlock(&writeMutex); pthread_mutex_unlock(&writeMutex);
currentFrameNumber[ithread] += lastFrameNumberInFile[ithread]; currentFrameNumber[ithread] += lastFrameNumberInFile[ithread];
} }
} }
} }