detectors/slsDetectorPackage
25
0
Fork 0
mirror of https://github.com/slsdetectorgroup/slsDetectorPackage.git synced 2025-06-09 11:30:43 +02:00
Code Issues Actions Packages Releases Activity

startframeindex corrected

Browse Source
This commit is contained in:
Dhanya Maliakal 2016-11-02 15:56:10 +01:00
parent b8187a5bf2
commit 8eb91bc46d
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
slsReceiverSoftware/src/UDPStandardImplementation.cpp
View File

@ -2161,17 +2161,17 @@ int UDPStandardImplementation::prepareAndListenBuffer(int ithread, int cSize, ch
//wrong packet //wrong packet
else{ else{
cprintf(RED,"wrong packet\n"); cprintf(RED,"wrong packet fnum of last good one:%d\n",(*((uint32_t*)(buffer[ithread]+8))));
pnum = packetsPerFrame-1; pnum = packetsPerFrame-1;
offset = fifoBufferHeaderSize; offset = fifoBufferHeaderSize;
//find the start of next image //find the start of next image
while(currentpnum != (packetsPerFrame-1)){ while(currentpnum != pnum){
receivedSize = udpSocket[ithread]->ReceiveDataOnly(buffer[ithread] + offset, onePacketSize); receivedSize = udpSocket[ithread]->ReceiveDataOnly(buffer[ithread] + offset, onePacketSize);
if(!receivedSize) return 0; if(!receivedSize) return 0;
header = (jfrau_packet_header_t*)(buffer[ithread] + offset); header = (jfrau_packet_header_t*)(buffer[ithread] + offset);
currentpnum = (*( (uint8_t*) header->packetNumber)); currentpnum = (*( (uint8_t*) header->packetNumber));
//cout<<"trying to find currentpnum:"<<currentpnum<<endl; //cout<<"trying to find: currentpnum:"<<currentpnum<<endl;
} }
} }
}//----- got a whole frame ------- }//----- got a whole frame -------
@ -2871,6 +2871,7 @@ void UDPStandardImplementation::handleWithoutMissingPackets(int ithread, char* w
if(npackets > 0){ if(npackets > 0){
if((fileWriteEnable) && (sfilefd[ithread])){ if((fileWriteEnable) && (sfilefd[ithread])){
if(tempframenumber && (tempframenumber%maxFramesPerFile) == 0){ if(tempframenumber && (tempframenumber%maxFramesPerFile) == 0){
cout<<"going to create new file: frame number:"<<tempframenumber<<endl;
createNewFile(ithread); createNewFile(ithread);
} }
fwrite(wbuffer, 1, oneDataSize*packetsPerFrame+fifoBufferHeaderSize, sfilefd[ithread]); fwrite(wbuffer, 1, oneDataSize*packetsPerFrame+fifoBufferHeaderSize, sfilefd[ithread]);