diff --git a/slsReceiverSoftware/src/UDPStandardImplementation.cpp b/slsReceiverSoftware/src/UDPStandardImplementation.cpp index df0b7ccf9..4ba857b2c 100644 --- a/slsReceiverSoftware/src/UDPStandardImplementation.cpp +++ b/slsReceiverSoftware/src/UDPStandardImplementation.cpp @@ -1660,7 +1660,7 @@ int UDPStandardImplementation::prepareAndListenBuffer(int ithread, int cSize, ch totalListeningPacketCount[ithread] += (receivedSize/onePacketSize); -#ifdef MANUALDEBUG +//#ifdef MANUALDEBUG if(receivedSize>0){ if(myDetectorType == JUNGFRAU){ jfrau_packet_header_t* header; @@ -1681,7 +1681,7 @@ int UDPStandardImplementation::prepareAndListenBuffer(int ithread, int cSize, ch (uint32_t)(*( (uint64_t*) footer))); } } -#endif +//#endif #ifdef DEBUG cprintf(BLUE, "Listening_Thread %d : Received bytes: %d. Expected bytes: %d\n", ithread, receivedSize, bufferSize * numberofJobsPerBuffer-cSize); #endif @@ -2309,20 +2309,20 @@ void UDPStandardImplementation::writeFileWithoutCompression(int ithread, char* w int offset = HEADER_SIZE_NUM_TOT_PACKETS; uint64_t nextFileFrameNumber; int packetsWritten = 0; - + //if(ithread) cout<<"numpackets:"<=0)){ //get start frame (required to create new file at the right juncture) uint64_t startframe =-1; - //cout<<"getting start frame number"<push(wbuffer)); return; } - //cout<<"done getting start frame number"<push(wbuffer)); @@ -2748,7 +2748,7 @@ int UDPStandardImplementation::writeUptoFrameNumber(int ithread, char* wbuffer, while(tempframenumber>=nextFrameNumber){ offset -= bigIncrements; if(offsetpush(wbuffer)); @@ -2756,7 +2756,7 @@ int UDPStandardImplementation::writeUptoFrameNumber(int ithread, char* wbuffer, } } if(offsetpush(wbuffer)); @@ -2764,7 +2764,7 @@ int UDPStandardImplementation::writeUptoFrameNumber(int ithread, char* wbuffer, } } while(tempframenumberpush(wbuffer)); @@ -2778,7 +2778,7 @@ int UDPStandardImplementation::writeUptoFrameNumber(int ithread, char* wbuffer, while(tempframenumberendoffset) - break;//cout<<"frame number at going forwards fast"<push(wbuffer)); @@ -2786,7 +2786,7 @@ int UDPStandardImplementation::writeUptoFrameNumber(int ithread, char* wbuffer, } } if(offset>endoffset){ - offset = endoffset;//cout<<"frame number at offset>endoffset"<endoffset f#:"<push(wbuffer)); @@ -2794,7 +2794,7 @@ int UDPStandardImplementation::writeUptoFrameNumber(int ithread, char* wbuffer, } } while(tempframenumber>nextFrameNumber){ - offset -= onePacketSize;//cout<<"frame number at going bacckwards slow"<push(wbuffer)); @@ -2810,7 +2810,7 @@ int UDPStandardImplementation::writeUptoFrameNumber(int ithread, char* wbuffer, fwrite(wbuffer + startoffset, 1, offset-startoffset, sfilefd[ithread]); numPacketsWritten += ((offset-startoffset)/onePacketSize); lastFrameNumberInFile[ithread] = frameNumberWritten; - //cout<<"done with writeUptoFrameNumber" << endl; + //if(ithread) cout<<"done with writeUptoFrameNumber" << endl; return OK; }