From 75b94e661422f47387236806110c032028b6aced Mon Sep 17 00:00:00 2001 From: Dhanya Maliakal Date: Wed, 18 Oct 2017 12:29:46 +0200 Subject: [PATCH] fixed file write enable bug from the last patch --- slsReceiverSoftware/include/DataProcessor.h | 9 +++++---- .../include/UDPStandardImplementation.h | 6 ++++++ slsReceiverSoftware/src/DataProcessor.cpp | 17 +++++++++-------- .../src/UDPStandardImplementation.cpp | 19 +++++++++++++++++-- 4 files changed, 37 insertions(+), 14 deletions(-) diff --git a/slsReceiverSoftware/include/DataProcessor.h b/slsReceiverSoftware/include/DataProcessor.h index 668fdb2d4..b3ba0fabd 100644 --- a/slsReceiverSoftware/include/DataProcessor.h +++ b/slsReceiverSoftware/include/DataProcessor.h @@ -26,14 +26,14 @@ class DataProcessor : private virtual slsReceiverDefs, public ThreadObject { * Calls Base Class CreateThread(), sets ErrorMask if error and increments NumberofDataProcessors * @param f address of Fifo pointer * @param ftype pointer to file format type - * @param fwenable pointer to file writer enable + * @param fwenable file writer enable * @param dsEnable pointer to data stream enable * @param freq pointer to streaming frequency * @param timer pointer to timer if streaming frequency is random * @param dataReadycb pointer to data ready call back function * @param pDataReadycb pointer to arguments of data ready call back function */ - DataProcessor(Fifo*& f, fileFormat* ftype, bool* fwenable, bool* dsEnable, + DataProcessor(Fifo*& f, fileFormat* ftype, bool fwenable, bool* dsEnable, uint32_t* freq, uint32_t* timer, void (*dataReadycb)(uint64_t, uint32_t, uint32_t, uint64_t, uint64_t, uint16_t, uint16_t, uint16_t, uint16_t, uint32_t, uint16_t, uint8_t, uint8_t, char*, uint32_t, void*), @@ -156,6 +156,7 @@ class DataProcessor : private virtual slsReceiverDefs, public ThreadObject { /** * Set up file writer object and call backs + * @param fwe file write enable * @param nd pointer to number of detectors in each dimension * @param fname pointer to file name prefix * @param fpath pointer to file path @@ -169,7 +170,7 @@ class DataProcessor : private virtual slsReceiverDefs, public ThreadObject { * @param portno pointer to udp port number * @param g address of GeneralData (Detector Data) pointer */ - void SetupFileWriter(int* nd, char* fname, char* fpath, uint64_t* findex, + void SetupFileWriter(bool fwe, int* nd, char* fname, char* fpath, uint64_t* findex, bool* frindexenable, bool* owenable, int* dindex, int* nunits, uint64_t* nf, uint32_t* dr, uint32_t* portno, GeneralData* g = 0); @@ -297,7 +298,7 @@ class DataProcessor : private virtual slsReceiverDefs, public ThreadObject { fileFormat* fileFormatType; /** File Write Enable */ - bool* fileWriteEnable; + bool fileWriteEnable; /** Pointer to Streaming frequency, if 0, sending random images with a timer */ uint32_t* streamingFrequency; diff --git a/slsReceiverSoftware/include/UDPStandardImplementation.h b/slsReceiverSoftware/include/UDPStandardImplementation.h index 9f6fc73e2..86ffbf07c 100644 --- a/slsReceiverSoftware/include/UDPStandardImplementation.h +++ b/slsReceiverSoftware/include/UDPStandardImplementation.h @@ -59,6 +59,12 @@ class UDPStandardImplementation: private virtual slsReceiverDefs, public UDPBase */ void setFileFormat(slsReceiverDefs::fileFormat f); + /** + * Set File Write Enable + * @param b true for file write enable, else false + */ + void setFileWriteEnable(const bool b); + /** * Set Short Frame Enabled, later will be moved to getROI (so far only for gotthard) * @param i index of adc enabled, else -1 if all enabled diff --git a/slsReceiverSoftware/src/DataProcessor.cpp b/slsReceiverSoftware/src/DataProcessor.cpp index 00038a193..88c68e171 100644 --- a/slsReceiverSoftware/src/DataProcessor.cpp +++ b/slsReceiverSoftware/src/DataProcessor.cpp @@ -31,7 +31,7 @@ uint64_t DataProcessor::RunningMask(0x0); pthread_mutex_t DataProcessor::Mutex = PTHREAD_MUTEX_INITIALIZER; -DataProcessor::DataProcessor(Fifo*& f, fileFormat* ftype, bool* fwenable, bool* dsEnable, +DataProcessor::DataProcessor(Fifo*& f, fileFormat* ftype, bool fwenable, bool* dsEnable, uint32_t* freq, uint32_t* timer, void (*dataReadycb)(uint64_t, uint32_t, uint32_t, uint64_t, uint64_t, uint16_t, uint16_t, uint16_t, uint16_t, uint32_t, uint16_t, uint8_t, uint8_t, char*, uint32_t, void*), @@ -216,26 +216,27 @@ void DataProcessor::SetFileFormat(const fileFormat f) { bool* owenable=0; int* dindex=0; int* nunits=0; uint64_t* nf = 0; uint32_t* dr = 0; uint32_t* port = 0; file->GetMemberPointerValues(nd, fname, fpath, findex, frindexenable, owenable, dindex, nunits, nf, dr, port); //create file writer with same pointers - SetupFileWriter(nd, fname, fpath, findex, frindexenable, owenable, dindex, nunits, nf, dr, port); + SetupFileWriter(fileWriteEnable, nd, fname, fpath, findex, frindexenable, owenable, dindex, nunits, nf, dr, port); } } - -void DataProcessor::SetupFileWriter(int* nd, char* fname, char* fpath, uint64_t* findex, +void DataProcessor::SetupFileWriter(bool fwe, int* nd, char* fname, char* fpath, uint64_t* findex, bool* frindexenable, bool* owenable, int* dindex, int* nunits, uint64_t* nf, uint32_t* dr, uint32_t* portno, GeneralData* g) { + fileWriteEnable = fwe; if (g) generalData = g; - // fix xcoord as detector is not providing it right now xcoord = ((NumberofDataProcessors > (*nunits)) ? index : ((*dindex) * (*nunits)) + index); - if (file) - delete file; - if (*fileWriteEnable) { + if (file) { + delete file; file = 0; + } + + if (fileWriteEnable) { switch(*fileFormatType){ #ifdef HDF5C case HDF5: diff --git a/slsReceiverSoftware/src/UDPStandardImplementation.cpp b/slsReceiverSoftware/src/UDPStandardImplementation.cpp index 759dea8e9..eac50649c 100644 --- a/slsReceiverSoftware/src/UDPStandardImplementation.cpp +++ b/slsReceiverSoftware/src/UDPStandardImplementation.cpp @@ -129,6 +129,21 @@ void UDPStandardImplementation::setFileFormat(const fileFormat f){ } +void UDPStandardImplementation::setFileWriteEnable(const bool b){ + + if (fileWriteEnable != b){ + fileWriteEnable = b; + for (unsigned int i = 0; i < dataProcessor.size(); ++i) { + dataProcessor[i]->SetupFileWriter(fileWriteEnable, (int*)numDet, fileName, filePath, &fileIndex, &frameIndexEnable, + &overwriteEnable, &detID, &numThreads, &numberOfFrames, &dynamicRange, &udpPortNum[i], generalData); + } + } + + FILE_LOG(logINFO) << "File Write Enable: " << stringEnable(fileWriteEnable); +} + + + int UDPStandardImplementation::setShortFrameEnable(const int i) { if (myDetectorType != GOTTHARD) { @@ -315,7 +330,7 @@ int UDPStandardImplementation::setDetectorType(const detectorType d) { for ( int i=0; i < numThreads; ++i ) { listener.push_back(new Listener(myDetectorType, fifo[i], &status, &udpPortNum[i], eth, &activated, &numberOfFrames, &dynamicRange)); dataProcessor.push_back(new DataProcessor(fifo[i], &fileFormatType, - &fileWriteEnable, &dataStreamEnable, &frameToGuiFrequency, &frameToGuiTimerinMS, + fileWriteEnable, &dataStreamEnable, &frameToGuiFrequency, &frameToGuiTimerinMS, rawDataReadyCallBack,pRawDataReady)); if (Listener::GetErrorMask() || DataProcessor::GetErrorMask()) { FILE_LOG (logERROR) << "Error: Could not creates listener/dataprocessor threads (index:" << i << ")"; @@ -350,7 +365,7 @@ void UDPStandardImplementation::setDetectorPositionId(const int i){ detID = i; FILE_LOG(logINFO) << "Detector Position Id:" << detID; for (unsigned int i = 0; i < dataProcessor.size(); ++i) { - dataProcessor[i]->SetupFileWriter((int*)numDet, fileName, filePath, &fileIndex, &frameIndexEnable, + dataProcessor[i]->SetupFileWriter( fileWriteEnable, (int*)numDet, fileName, filePath, &fileIndex, &frameIndexEnable, &overwriteEnable, &detID, &numThreads, &numberOfFrames, &dynamicRange, &udpPortNum[i], generalData); } }