progress also depends on listener index now

This commit is contained in:
maliakal_d 2022-01-26 17:35:31 +01:00
parent 0d0429983b
commit 28fe6eadb5
3 changed files with 9 additions and 4 deletions

View File

@ -462,13 +462,12 @@ double Implementation::getProgress() const {
uint64_t currentFrameIndex = -1; uint64_t currentFrameIndex = -1;
uint32_t flagsum = 0; uint32_t flagsum = 0;
for (const auto &it : dataProcessor) { for (const auto &it : listener) {
flagsum += it->GetStartedFlag(); flagsum += it->GetStartedFlag();
currentFrameIndex = currentFrameIndex = std::max(currentFrameIndex, it->GetListenedIndex());
std::min(currentFrameIndex, it->GetProcessedIndex());
} }
// no data processed // no data processed
if (flagsum != dataProcessor.size()) { if (flagsum != listener.size()) {
currentFrameIndex = -1; currentFrameIndex = -1;
} }

View File

@ -57,6 +57,10 @@ bool Listener::GetStartedFlag() { return startedFlag; }
uint64_t Listener::GetCurrentFrameIndex() { return currentFrameIndex; } uint64_t Listener::GetCurrentFrameIndex() { return currentFrameIndex; }
uint64_t Listener::GetListenedIndex() {
return currentFrameIndex_ - firstIndex_;
}
void Listener::SetFifo(Fifo *f) { fifo = f; } void Listener::SetFifo(Fifo *f) { fifo = f; }
void Listener::ResetParametersforNewAcquisition() { void Listener::ResetParametersforNewAcquisition() {

View File

@ -70,6 +70,8 @@ class Listener : private virtual slsDetectorDefs, public ThreadObject {
bool GetStartedFlag(); bool GetStartedFlag();
uint64_t GetCurrentFrameIndex(); uint64_t GetCurrentFrameIndex();
/** (-1 if no frames have been caught) */
uint64_t GetListenedIndex();
/** /**
* Set Fifo pointer to the one given * Set Fifo pointer to the one given