mirror of
https://github.com/slsdetectorgroup/slsDetectorPackage.git
synced 2025-06-13 13:27:14 +02:00
empty fifo at receiver start and comment waiting for packet
This commit is contained in:
@ -956,7 +956,9 @@ void UDPStandardImplementation::startReadout(){
|
|||||||
prev = -1;
|
prev = -1;
|
||||||
//wait as long as there is change from prev totalP
|
//wait as long as there is change from prev totalP
|
||||||
while(prev != totalP){
|
while(prev != totalP){
|
||||||
|
#ifdef DEBUG5
|
||||||
cprintf(MAGENTA,"waiting for all packets totalP:%d\n",totalP);
|
cprintf(MAGENTA,"waiting for all packets totalP:%d\n",totalP);
|
||||||
|
#endif
|
||||||
usleep(5000);/* Need to find optimal time (exposure time and acquisition period) **/
|
usleep(5000);/* Need to find optimal time (exposure time and acquisition period) **/
|
||||||
prev = totalP;
|
prev = totalP;
|
||||||
totalP=0;
|
totalP=0;
|
||||||
@ -2240,6 +2242,13 @@ void UDPStandardImplementation::waitWritingBufferForNextAcquisition(int ithread)
|
|||||||
#endif
|
#endif
|
||||||
|
|
||||||
|
|
||||||
|
//pop fifo so that its empty
|
||||||
|
char* temp;
|
||||||
|
while(!fifo[ithread]->isEmpty()){
|
||||||
|
cout << ithread << ":emptied buffer in fifo" << endl;
|
||||||
|
fifo[ithread]->pop(temp);
|
||||||
|
}
|
||||||
|
|
||||||
//create file
|
//create file
|
||||||
if((1<<ithread)&createFileMask){
|
if((1<<ithread)&createFileMask){
|
||||||
if(dataCompressionEnable){
|
if(dataCompressionEnable){
|
||||||
|
Reference in New Issue
Block a user