HG_REPOSITORIES/LPP/SciQLOP_Repos/SciQLop Commit - r758:87c4dffdd5b8

Fix progression bug when aborting a request for Amda plugin

perrinel -

r758:87c4dffdd5b8

parent child

Context file:

r758:87c4dffdd5b8

core/src/Variable/VariableAcquisitionWorker.cpp +7 -28

              void VariableAcquisitionWorker::abortProgressRequested(QUuid vIdentifier)
              {
-                 // TODO
                  impl->lockRead();
                  auto it = impl->m_VIdentifierToCurrrentAcqIdNextIdPairMap.find(vIdentifier);
              void VariableAcquisitionWorker::onVariableRetrieveDataInProgress(QUuid acqIdentifier,
                                                                               double progress)
              {
+                 qCDebug(LOG_VariableAcquisitionWorker()) << tr("TORM: onVariableRetrieveDataInProgress ")
+                                                          << acqIdentifier << progress;
                  impl->lockRead();
                  auto aIdToARit = impl->m_AcqIdentifierToAcqRequestMap.find(acqIdentifier);
                  if (aIdToARit != impl->m_AcqIdentifierToAcqRequestMap.cend()) {
                      auto finalProgression = currentAlreadyProgress + currentPartProgress;
                      emit variableRequestInProgress(aIdToARit->second.m_vIdentifier, finalProgression);
+                     qCDebug(LOG_VariableAcquisitionWorker())
+                         << tr("TORM: onVariableRetrieveDataInProgress ") << aIdToARit->second.m_vIdentifier
+                         << currentPartSize << currentAlreadyProgress << currentPartProgress << finalProgression;
                      if (finalProgression == 100.0) {
                          emit variableRequestInProgress(aIdToARit->second.m_vIdentifier, 0.0);
                      }
                                                acqRequest.m_CacheRangeRequested, aIdToADPVit->second);
                          }
-                         // Execute the next one
-                         auto it
-                             = impl->m_VIdentifierToCurrrentAcqIdNextIdPairMap.find(acqRequest.m_vIdentifier);
-                         if (it != impl->m_VIdentifierToCurrrentAcqIdNextIdPairMap.cend()) {
-                             if (it->second.second.isNull()) {
-                                 // There is no next request, we can remove the variable request
-                                 impl->removeVariableRequest(acqRequest.m_vIdentifier);
+                             }
-                             else {
-                                 auto acqIdentifierToRemove = it->second.first;
-                                 // Move the next request to the current request
-                                 it->second.first = it->second.second;
-                                 it->second.second = QUuid();
-                                 // Remove AcquisitionRequest and results;
-                                 impl->m_AcqIdentifierToAcqRequestMap.erase(acqIdentifierToRemove);
-                                 impl->m_AcqIdentifierToAcqDataPacketVectorMap.erase(acqIdentifierToRemove);
-                                 // Execute the current request
-                                 QMetaObject::invokeMethod(this, "onExecuteRequest", Qt::QueuedConnection,
-                                                           Q_ARG(QUuid, it->second.first));
+                             }
+                         }
-                         else {
-                             qCCritical(LOG_VariableAcquisitionWorker())
-                                 << tr("Impossible to execute the acquisition on an unfound variable ");
+                         }
+                         // Update to the next request
+                         impl->updateToNextRequest(acqRequest.m_vIdentifier);
                      }
                  }
                  else {

plugins/amda/src/AmdaProvider.cpp +14 -5

                                                         std::shared_ptr<QNetworkRequest> networkRequest,
                                                         double progress)
              {
-                 qCDebug(LOG_AmdaProvider()) << tr("onReplyDownloadProgress") << acqIdentifier
-                                             << networkRequest.get() << progress;
+                 qCInfo(LOG_AmdaProvider()) << tr("onReplyDownloadProgress") << acqIdentifier
+                                            << networkRequest.get() << progress;
                  auto acqIdToRequestProgressMapIt = m_AcqIdToRequestProgressMap.find(acqIdentifier);
                  if (acqIdToRequestProgressMapIt != m_AcqIdToRequestProgressMap.end()) {
                          requestProgressMapIt->second = progress;
                      }
                      else {
-                         qCCritical(LOG_AmdaProvider()) << tr("Can't retrieve Request in progress")
-                                                        << acqIdentifier << networkRequest.get() << progress;
+                         // This case can happened when a progression is send after the request has been
+                         // finished.
+                         // Generaly the case when aborting a request
+                         qCWarning(LOG_AmdaProvider()) << tr("Can't retrieve Request in progress")
+                                                       << acqIdentifier << networkRequest.get() << progress;
                      }
                  }
                      emit dataProvidedProgress(acqIdentifier, finalProgress);
                  }
                  else {
-                     emit dataProvidedProgress(acqIdentifier, 0.0);
+                     // This case can happened when a progression is send after the request has been finished.
+                     // Generaly the case when aborting a request
+                     emit dataProvidedProgress(acqIdentifier, 100.0);
                  }
              }
                                  /// @todo ALX : debug
                              }
                          }
+                         qCDebug(LOG_AmdaProvider()) << tr("acquisition requests erase because of finishing")
+                                                     << dataId;
                          m_AcqIdToRequestProgressMap.erase(dataId);
                      }
                                }
                            }
                            else {
+                               qCDebug(LOG_AmdaProvider())
+                                   << tr("acquisition requests erase because of aborting") << dataId;
                                m_AcqIdToRequestProgressMap.erase(dataId);
                            }
                        };

General Comments 0

Write
Preview

You need to be logged in to leave comments. Login now

No TODOs yet

	Site-wide shortcuts
/	Use quick search box
g h	Goto home page
g g	Goto my private gists page
g G	Goto my public gists page
g 0-9	Goto bookmarked items from 0-9
n r	New repository page
n g	New gist page

	Repositories
g s	Goto summary page
g c	Goto changelog page
g f	Goto files page
g F	Goto files page with file search activated
g p	Goto pull requests page
g o	Goto repository settings
g O	Goto repository access permissions settings
t s	Toggle sidebar on some pages