added error message on receiver side, throw error

This commit is contained in:
mazzol_a 2025-04-30 10:54:34 +02:00
parent 98b1e287a4
commit 062002243e
3 changed files with 4 additions and 4 deletions

View File

@ -295,7 +295,9 @@ void DataProcessor::ThreadExecution() {
memImage->data); memImage->data);
} catch (const std::exception &e) { } catch (const std::exception &e) {
fifo->FreeAddress(buffer); fifo->FreeAddress(buffer);
return; LOG(logERROR) << "DataProcessor " << index << ": Failed to Process. "
<< e.what() << std::endl;
throw RuntimeError(e.what());
} }
// stream (if time/freq to stream) or free // stream (if time/freq to stream) or free

View File

@ -52,7 +52,7 @@ class GeneralData {
uint32_t nAnalogSamples{0}; uint32_t nAnalogSamples{0};
uint32_t nDigitalSamples{0}; uint32_t nDigitalSamples{0};
uint32_t nTransceiverSamples{0}; uint32_t nTransceiverSamples{0};
std::vector<int> ctbDbitList; std::vector<int> ctbDbitList{};
int ctbDbitOffset{0}; int ctbDbitOffset{0};
bool ctbDbitReorder{false}; bool ctbDbitReorder{false};
slsDetectorDefs::readoutMode readoutType{slsDetectorDefs::ANALOG_ONLY}; slsDetectorDefs::readoutMode readoutType{slsDetectorDefs::ANALOG_ONLY};

View File

@ -73,8 +73,6 @@ class DataProcessorTestFixture {
dataprocessor = new DataProcessorTest; dataprocessor = new DataProcessorTest;
generaldata = new GeneralDataTest; generaldata = new GeneralDataTest;
// set_num_samples(num_samples);
generaldata->SetNumberOfAnalogDatabytes(num_analog_bytes); generaldata->SetNumberOfAnalogDatabytes(num_analog_bytes);
generaldata->SetNumberOfTransceiverDatabytes(num_transceiver_bytes); generaldata->SetNumberOfTransceiverDatabytes(num_transceiver_bytes);
generaldata->SetNumberOfDigitalDatabytes(num_digital_bytes + generaldata->SetNumberOfDigitalDatabytes(num_digital_bytes +