mirror of
https://github.com/slsdetectorgroup/slsDetectorPackage.git
synced 2025-06-06 18:10:40 +02:00
used clang-formating
This commit is contained in:
parent
23aa9c2814
commit
8d87a6ee4e
@ -75,9 +75,7 @@ void DataProcessor::SetCtbDbitList(std::vector<int> value) {
|
|||||||
ctbDbitList = value;
|
ctbDbitList = value;
|
||||||
}
|
}
|
||||||
|
|
||||||
void DataProcessor::SetReorder(const bool value) {
|
void DataProcessor::SetReorder(const bool value) { reorder = value; }
|
||||||
reorder = value;
|
|
||||||
}
|
|
||||||
|
|
||||||
void DataProcessor::SetCtbDbitOffset(int value) { ctbDbitOffset = value; }
|
void DataProcessor::SetCtbDbitOffset(int value) { ctbDbitOffset = value; }
|
||||||
|
|
||||||
@ -536,9 +534,10 @@ void DataProcessor::PadMissingPackets(sls_receiver_header header, char *data) {
|
|||||||
|
|
||||||
/** ctb specific */
|
/** ctb specific */
|
||||||
void DataProcessor::ArrangeDbitData(size_t &size, char *data) {
|
void DataProcessor::ArrangeDbitData(size_t &size, char *data) {
|
||||||
size_t nAnalogDataBytes = generalData->GetNumberOfAnalogDatabytes();
|
size_t nAnalogDataBytes = generalData->GetNumberOfAnalogDatabytes();
|
||||||
size_t nDigitalDataBytes = generalData->GetNumberOfDigitalDatabytes();
|
size_t nDigitalDataBytes = generalData->GetNumberOfDigitalDatabytes();
|
||||||
size_t nTransceiverDataBytes = generalData->GetNumberOfTransceiverDatabytes();
|
size_t nTransceiverDataBytes =
|
||||||
|
generalData->GetNumberOfTransceiverDatabytes();
|
||||||
// TODO! (Erik) Refactor and add tests
|
// TODO! (Erik) Refactor and add tests
|
||||||
int ctbDigitalDataBytes = nDigitalDataBytes - ctbDbitOffset;
|
int ctbDigitalDataBytes = nDigitalDataBytes - ctbDbitOffset;
|
||||||
|
|
||||||
@ -553,18 +552,21 @@ void DataProcessor::ArrangeDbitData(size_t &size, char *data) {
|
|||||||
|
|
||||||
const int numDigitalSamples = (ctbDigitalDataBytes / sizeof(uint64_t));
|
const int numDigitalSamples = (ctbDigitalDataBytes / sizeof(uint64_t));
|
||||||
|
|
||||||
int totalNumBytes = 0; //number of bytes for selected digital data given by dtbDbitList
|
int totalNumBytes =
|
||||||
|
0; // number of bytes for selected digital data given by dtbDbitList
|
||||||
|
|
||||||
//store each selected bit from all samples consecutively
|
// store each selected bit from all samples consecutively
|
||||||
if(reorder) {
|
if (reorder) {
|
||||||
int numBitsPerDbit = numDigitalSamples; //num bits per selected digital Bit for all samples
|
int numBitsPerDbit = numDigitalSamples; // num bits per selected digital
|
||||||
|
// Bit for all samples
|
||||||
if ((numBitsPerDbit % 8) != 0)
|
if ((numBitsPerDbit % 8) != 0)
|
||||||
numBitsPerDbit += (8 - (numDigitalSamples % 8));
|
numBitsPerDbit += (8 - (numDigitalSamples % 8));
|
||||||
totalNumBytes = (numBitsPerDbit / 8) * ctbDbitList.size();
|
totalNumBytes = (numBitsPerDbit / 8) * ctbDbitList.size();
|
||||||
}
|
}
|
||||||
//store all selected bits from one sample consecutively
|
// store all selected bits from one sample consecutively
|
||||||
else {
|
else {
|
||||||
size_t numBitsPerSample = ctbDbitList.size(); //num bits for all selected bits per sample
|
size_t numBitsPerSample =
|
||||||
|
ctbDbitList.size(); // num bits for all selected bits per sample
|
||||||
if ((numBitsPerSample % 8) != 0)
|
if ((numBitsPerSample % 8) != 0)
|
||||||
numBitsPerSample += (8 - (numBitsPerSample % 8));
|
numBitsPerSample += (8 - (numBitsPerSample % 8));
|
||||||
totalNumBytes = (numBitsPerSample / 8) * numDigitalSamples;
|
totalNumBytes = (numBitsPerSample / 8) * numDigitalSamples;
|
||||||
@ -573,7 +575,7 @@ void DataProcessor::ArrangeDbitData(size_t &size, char *data) {
|
|||||||
std::vector<uint8_t> result(totalNumBytes, 0);
|
std::vector<uint8_t> result(totalNumBytes, 0);
|
||||||
uint8_t *dest = &result[0];
|
uint8_t *dest = &result[0];
|
||||||
|
|
||||||
if(reorder) {
|
if (reorder) {
|
||||||
// loop through digital bit enable vector
|
// loop through digital bit enable vector
|
||||||
int bitoffset = 0;
|
int bitoffset = 0;
|
||||||
for (auto bi : ctbDbitList) {
|
for (auto bi : ctbDbitList) {
|
||||||
@ -596,8 +598,7 @@ void DataProcessor::ArrangeDbitData(size_t &size, char *data) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
} else {
|
||||||
else {
|
|
||||||
// loop through the digital data
|
// loop through the digital data
|
||||||
int bitoffset = 0;
|
int bitoffset = 0;
|
||||||
for (auto *ptr = source; ptr < (source + numDigitalSamples); ++ptr) {
|
for (auto *ptr = source; ptr < (source + numDigitalSamples); ++ptr) {
|
||||||
@ -625,13 +626,15 @@ void DataProcessor::ArrangeDbitData(size_t &size, char *data) {
|
|||||||
// copy back to memory and update size
|
// copy back to memory and update size
|
||||||
memcpy(data + nAnalogDataBytes, result.data(),
|
memcpy(data + nAnalogDataBytes, result.data(),
|
||||||
totalNumBytes * sizeof(uint8_t));
|
totalNumBytes * sizeof(uint8_t));
|
||||||
|
|
||||||
size = totalNumBytes * sizeof(uint8_t) + nAnalogDataBytes +
|
size = totalNumBytes * sizeof(uint8_t) + nAnalogDataBytes +
|
||||||
nTransceiverDataBytes;
|
nTransceiverDataBytes;
|
||||||
|
|
||||||
//check if size changed, if so move transceiver data to avoid gap in memory
|
// check if size changed, if so move transceiver data to avoid gap in memory
|
||||||
if(size < nAnalogDataBytes + nDigitalDataBytes + nTransceiverDataBytes)
|
if (size < nAnalogDataBytes + nDigitalDataBytes + nTransceiverDataBytes)
|
||||||
memmove(data + nAnalogDataBytes + totalNumBytes * sizeof(uint8_t), data + nAnalogDataBytes + nDigitalDataBytes, nTransceiverDataBytes);
|
memmove(data + nAnalogDataBytes + totalNumBytes * sizeof(uint8_t),
|
||||||
|
data + nAnalogDataBytes + nDigitalDataBytes,
|
||||||
|
nTransceiverDataBytes);
|
||||||
|
|
||||||
LOG(logDEBUG1) << "totalNumBytes: " << totalNumBytes
|
LOG(logDEBUG1) << "totalNumBytes: " << totalNumBytes
|
||||||
<< " nAnalogDataBytes:" << nAnalogDataBytes
|
<< " nAnalogDataBytes:" << nAnalogDataBytes
|
||||||
|
@ -140,11 +140,11 @@ class DataProcessor : private virtual slsDetectorDefs, public ThreadObject {
|
|||||||
|
|
||||||
/**
|
/**
|
||||||
* Align corresponding digital bits together (CTB only if ctbDbitlist is not
|
* Align corresponding digital bits together (CTB only if ctbDbitlist is not
|
||||||
* empty)
|
* empty)
|
||||||
* set variable reorder to true if, data should be rearranged such that
|
* set variable reorder to true if, data should be rearranged such that
|
||||||
* individual digital bits from all samples are consecutive in memory
|
* individual digital bits from all samples are consecutive in memory
|
||||||
*/
|
*/
|
||||||
void ArrangeDbitData(size_t &size, char *data);
|
void ArrangeDbitData(size_t &size, char *data);
|
||||||
|
|
||||||
void CropImage(size_t &size, char *data);
|
void CropImage(size_t &size, char *data);
|
||||||
|
|
||||||
@ -168,7 +168,7 @@ class DataProcessor : private virtual slsDetectorDefs, public ThreadObject {
|
|||||||
struct timespec timerbegin {};
|
struct timespec timerbegin {};
|
||||||
bool framePadding;
|
bool framePadding;
|
||||||
std::vector<int> ctbDbitList;
|
std::vector<int> ctbDbitList;
|
||||||
bool reorder{false}; //true if data should be reordered TODO: add as mode
|
bool reorder{false}; // true if data should be reordered TODO: add as mode
|
||||||
int ctbDbitOffset;
|
int ctbDbitOffset;
|
||||||
std::atomic<bool> startedFlag{false};
|
std::atomic<bool> startedFlag{false};
|
||||||
std::atomic<uint64_t> firstIndex{0};
|
std::atomic<uint64_t> firstIndex{0};
|
||||||
|
@ -915,10 +915,10 @@ void Implementation::CreateUDPSockets() {
|
|||||||
}
|
}
|
||||||
|
|
||||||
void Implementation::SetupWriter() {
|
void Implementation::SetupWriter() {
|
||||||
|
|
||||||
try {
|
try {
|
||||||
//check if filePath empty and throw error
|
// check if filePath empty and throw error
|
||||||
if(filePath.empty()){
|
if (filePath.empty()) {
|
||||||
throw ReceiverError("File path cannot be empty");
|
throw ReceiverError("File path cannot be empty");
|
||||||
}
|
}
|
||||||
// check if folder exists and throw if it cant create
|
// check if folder exists and throw if it cant create
|
||||||
|
@ -3,10 +3,10 @@
|
|||||||
/** API versions */
|
/** API versions */
|
||||||
#define APILIB "developer 0x241122"
|
#define APILIB "developer 0x241122"
|
||||||
#define APIRECEIVER "developer 0x241122"
|
#define APIRECEIVER "developer 0x241122"
|
||||||
#define APICTB "developer 0x250310"
|
#define APICTB "developer 0x250310"
|
||||||
#define APIGOTTHARD2 "developer 0x250310"
|
#define APIGOTTHARD2 "developer 0x250310"
|
||||||
#define APIJUNGFRAU "developer 0x250310"
|
#define APIJUNGFRAU "developer 0x250310"
|
||||||
#define APIMYTHEN3 "developer 0x250310"
|
#define APIMYTHEN3 "developer 0x250310"
|
||||||
#define APIMOENCH "developer 0x250310"
|
#define APIMOENCH "developer 0x250310"
|
||||||
#define APIXILINXCTB "developer 0x250310"
|
#define APIXILINXCTB "developer 0x250310"
|
||||||
#define APIEIGER "developer 0x250310"
|
#define APIEIGER "developer 0x250310"
|
||||||
|
Loading…
x
Reference in New Issue
Block a user