GIT_REPOSITORIES/LPP/Users/mperrinel/SciQLop-fork Files · core/src/Network/NetworkController.cpp

Handles items with same names in the same node...

Handles items with same names in the same node This case is handled by adding suffix (plugin name) when displaying items in the widget

perrinel - - Load All Authors

File last commit:

r760:ba0e6f7d7791


                r1077:c90049fe7bc2

Download file

             NetworkController.cpp
        
                    148 lines
            
             | 5.5 KiB
            
                | text/x-c
            
             |
                CppLexer
            
             / core / src / Network / NetworkController.cpp
          
                    History
                
                 |
                  Source
                 | Raw
                 |Copy content
                 |Copy permalink

        perrinel
    
Intialization of network controller

              r339
            
      #include "Network/NetworkController.h"

      #include <QMutex>

        perrinel
    
Add execute skelleton Network

              r386
            
      #include <QNetworkAccessManager>

      #include <QNetworkReply>

        perrinel
    
Implement the network controller to permit the execution of a request...

              r389
            
      #include <QNetworkRequest>

        perrinel
    
Add thread protection on AbortDownload process

              r423
            
      #include <QReadWriteLock>

        perrinel
    
Intialization of network controller

              r339
            
      #include <QThread>

        perrinel
    
Implement the network controller to permit the execution of a request...

              r389
            
      #include <unordered_map>

        perrinel
    
Intialization of network controller

              r339
            
      Q_LOGGING_CATEGORY(LOG_NetworkController, "NetworkController")

      struct NetworkController::NetworkControllerPrivate {

        perrinel
    
Implement the network controller to permit the execution of a request...

              r389
            
          explicit NetworkControllerPrivate(NetworkController *parent) : m_WorkingMutex{} {}

        perrinel
    
Implementation of V5 acquisition

              r539
            
          void lockRead() { m_Lock.lockForRead(); }

          void lockWrite() { m_Lock.lockForWrite(); }

          void unlock() { m_Lock.unlock(); }

        perrinel
    
Intialization of network controller

              r339
            
          QMutex m_WorkingMutex;

        perrinel
    
Add execute skelleton Network

              r386
            
        perrinel
    
Add thread protection on AbortDownload process

              r423
            
          QReadWriteLock m_Lock;

        perrinel
    
Update networkcontroller for abort mechanism

              r755
            
          std::unordered_map<QNetworkReply *, QUuid> m_NetworkReplyToId;

        perrinel
    
Add execute skelleton Network

              r386
            
          std::unique_ptr<QNetworkAccessManager> m_AccessManager{nullptr};

        perrinel
    
Intialization of network controller

              r339
            
      };

      NetworkController::NetworkController(QObject *parent)

              : QObject(parent), impl{spimpl::make_unique_impl<NetworkControllerPrivate>(this)}

      {

        perrinel
    
Add execute skelleton Network

              r386
            
      }

        perrinel
    
request is now passed by shared pointer instead of const &

              r751
            
      void NetworkController::onProcessRequested(std::shared_ptr<QNetworkRequest> request,

                                                 QUuid identifier,

        perrinel
    
Implement the network controller to permit the execution of a request...

              r389
            
                                                 std::function<void(QNetworkReply *, QUuid)> callback)

        perrinel
    
Add execute skelleton Network

              r386
            
      {

        perrinel
    
request is now passed by shared pointer instead of const &

              r751
            
          qCDebug(LOG_NetworkController()) << tr("NetworkController onProcessRequested")

                                           << QThread::currentThread()->objectName() << &request;

          auto reply = impl->m_AccessManager->get(*request);

        perrinel
    
Implement the network controller to permit the execution of a request...

              r389
            
          // Store the couple reply id

        perrinel
    
Add thread protection on AbortDownload process

              r423
            
          impl->lockWrite();

        perrinel
    
Update networkcontroller for abort mechanism

              r755
            
          impl->m_NetworkReplyToId[reply] = identifier;

          qCDebug(LOG_NetworkController()) << tr("Store for reply: ") << identifier;

        perrinel
    
Add thread protection on AbortDownload process

              r423
            
          impl->unlock();

        perrinel
    
Implement the network controller to permit the execution of a request...

              r389
            
        perrinel
    
Implementation of progression

              r750
            
          auto onReplyFinished = [request, reply, this, identifier, callback]() {

        perrinel
    
Implement the network controller to permit the execution of a request...

              r389
            
        perrinel
    
Add thread protection on AbortDownload process

              r423
            
              qCDebug(LOG_NetworkController()) << tr("NetworkController onReplyFinished")

        perrinel
    
request is now passed by shared pointer instead of const &

              r751
            
                                               << QThread::currentThread() << request.get() << reply;

        perrinel
    
Add thread protection on AbortDownload process

              r423
            
              impl->lockRead();

        perrinel
    
Update networkcontroller for abort mechanism

              r755
            
              auto it = impl->m_NetworkReplyToId.find(reply);

              if (it != impl->m_NetworkReplyToId.cend()) {

        perrinel
    
Correction for MR

              r760
            
                  qCDebug(LOG_NetworkController()) << tr("Remove for reply: ") << it->second;

                  impl->unlock();

        perrinel
    
Add thread protection on AbortDownload process

              r423
            
                  impl->lockWrite();

        perrinel
    
Update networkcontroller for abort mechanism

              r755
            
                  impl->m_NetworkReplyToId.erase(reply);

        perrinel
    
Add thread protection on AbortDownload process

              r423
            
                  impl->unlock();

                  // Deletes reply

        perrinel
    
Implement the network controller to permit the execution of a request...

              r389
            
                  callback(reply, identifier);

        perrinel
    
Add thread protection on AbortDownload process

              r423
            
                  reply->deleteLater();

        perrinel
    
Implement the network controller to permit the execution of a request...

              r389
            
              }

        perrinel
    
Correction for MR

              r760
            
              else {

                  impl->unlock();

              }

        perrinel
    
Add thread protection on AbortDownload process

              r423
            
              qCDebug(LOG_NetworkController()) << tr("NetworkController onReplyFinished END")

                                               << QThread::currentThread() << reply;

        perrinel
    
Implement the network controller to permit the execution of a request...

              r389
            
          };

        perrinel
    
Implementation of progression

              r750
            
          auto onReplyProgress = [reply, request, this](qint64 bytesRead, qint64 totalBytes) {

        perrinel
    
Add execute skelleton Network

              r386
            
        perrinel
    
Update networkcontroller for abort mechanism

              r755
            
              // NOTE: a totalbytes of 0 can happened when a request has been aborted

              if (totalBytes > 0) {

                  double progress = (bytesRead * 100.0) / totalBytes;

                  qCDebug(LOG_NetworkController()) << tr("NetworkController onReplyProgress") << progress

        perrinel
    
See last commit

              r757
            
                                                   << QThread::currentThread() << request.get() << reply

                                                   << bytesRead << totalBytes;

        perrinel
    
Update networkcontroller for abort mechanism

              r755
            
                  impl->lockRead();

                  auto it = impl->m_NetworkReplyToId.find(reply);

                  if (it != impl->m_NetworkReplyToId.cend()) {

        perrinel
    
Correction for MR

              r760
            
                      auto id = it->second;

                      impl->unlock();

                      emit this->replyDownloadProgress(id, request, progress);

                  }

                  else {

                      impl->unlock();

        perrinel
    
Update networkcontroller for abort mechanism

              r755
            
                  }

        perrinel
    
Correction for MR

              r760
            
        perrinel
    
Update networkcontroller for abort mechanism

              r755
            
                  qCDebug(LOG_NetworkController()) << tr("NetworkController onReplyProgress END")

                                                   << QThread::currentThread() << reply;

        perrinel
    
Implement the network controller to permit the execution of a request...

              r389
            
              }

          };

        perrinel
    
Add execute skelleton Network

              r386
            
        perrinel
    
Implement the network controller to permit the execution of a request...

              r389
            
          connect(reply, &QNetworkReply::finished, this, onReplyFinished);

        perrinel
    
Add implementation of progress bar on variable inspector connected to...

              r401
            
          connect(reply, &QNetworkReply::downloadProgress, this, onReplyProgress);

        perrinel
    
Display errors of NetworkAcessManager

              r426
            
          qCDebug(LOG_NetworkController()) << tr("NetworkController registered END")

                                           << QThread::currentThread()->objectName() << reply;

        perrinel
    
Intialization of network controller

              r339
            
      }

      void NetworkController::initialize()

      {

          qCDebug(LOG_NetworkController()) << tr("NetworkController init") << QThread::currentThread();

          impl->m_WorkingMutex.lock();

        perrinel
    
Implement the network controller to permit the execution of a request...

              r389
            
          impl->m_AccessManager = std::make_unique<QNetworkAccessManager>();

        perrinel
    
Display errors of NetworkAcessManager

              r426
            
          auto onReplyErrors = [this](QNetworkReply *reply, const QList<QSslError> &errors) {

              qCCritical(LOG_NetworkController()) << tr("NetworkAcessManager errors: ") << errors;

          };

          connect(impl->m_AccessManager.get(), &QNetworkAccessManager::sslErrors, this, onReplyErrors);

        perrinel
    
Intialization of network controller

              r339
            
          qCDebug(LOG_NetworkController()) << tr("NetworkController init END");

      }

      void NetworkController::finalize()

      {

          impl->m_WorkingMutex.unlock();

      }

        perrinel
    
Implement the network controller to permit the execution of a request...

              r389
            
      void NetworkController::onReplyCanceled(QUuid identifier)

      {

          auto findReply = [identifier](const auto &entry) { return identifier == entry.second; };

        perrinel
    
Add thread protection on AbortDownload process

              r423
            
          qCDebug(LOG_NetworkController()) << tr("NetworkController onReplyCanceled")

        perrinel
    
See last commit

              r757
            
                                           << QThread::currentThread() << identifier;

        perrinel
    
Add thread protection on AbortDownload process

              r423
            
        perrinel
    
Implement the network controller to permit the execution of a request...

              r389
            
        perrinel
    
Add thread protection on AbortDownload process

              r423
            
          impl->lockRead();

        perrinel
    
Update networkcontroller for abort mechanism

              r755
            
          auto end = impl->m_NetworkReplyToId.cend();

          auto it = std::find_if(impl->m_NetworkReplyToId.cbegin(), end, findReply);

        perrinel
    
Add thread protection on AbortDownload process

              r423
            
          impl->unlock();

        perrinel
    
Implement the network controller to permit the execution of a request...

              r389
            
          if (it != end) {

        perrinel
    
Update networkcontroller for abort mechanism

              r755
            
              qCDebug(LOG_NetworkController()) << tr("NetworkController onReplyCanceled ABORT DONE")

        perrinel
    
See last commit

              r757
            
                                               << QThread::currentThread() << identifier;

        perrinel
    
Implement the network controller to permit the execution of a request...

              r389
            
              it->first->abort();

          }

        perrinel
    
Add thread protection on AbortDownload process

              r423
            
          qCDebug(LOG_NetworkController()) << tr("NetworkController onReplyCanceled END")

        perrinel
    
See last commit

              r757
            
                                           << QThread::currentThread();

        perrinel
    
Implement the network controller to permit the execution of a request...

              r389
            
      }

        perrinel
    
Intialization of network controller

              r339
            
      void NetworkController::waitForFinish()

      {

          QMutexLocker locker{&impl->m_WorkingMutex};

      }

	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

perrinel Intialization of network controller	r339	#include "Network/NetworkController.h"

		#include <QMutex>
perrinel Add execute skelleton Network	r386	#include <QNetworkAccessManager>
		#include <QNetworkReply>
perrinel Implement the network controller to permit the execution of a request...	r389	#include <QNetworkRequest>
perrinel Add thread protection on AbortDownload process	r423	#include <QReadWriteLock>
perrinel Intialization of network controller	r339	#include <QThread>

perrinel Implement the network controller to permit the execution of a request...	r389	#include <unordered_map>

perrinel Intialization of network controller	r339	Q_LOGGING_CATEGORY(LOG_NetworkController, "NetworkController")

		struct NetworkController::NetworkControllerPrivate {
perrinel Implement the network controller to permit the execution of a request...	r389	explicit NetworkControllerPrivate(NetworkController *parent) : m_WorkingMutex{} {}
perrinel Implementation of V5 acquisition	r539
		void lockRead() { m_Lock.lockForRead(); }
		void lockWrite() { m_Lock.lockForWrite(); }
		void unlock() { m_Lock.unlock(); }

perrinel Intialization of network controller	r339	QMutex m_WorkingMutex;
perrinel Add execute skelleton Network	r386
perrinel Add thread protection on AbortDownload process	r423	QReadWriteLock m_Lock;
perrinel Update networkcontroller for abort mechanism	r755	std::unordered_map<QNetworkReply *, QUuid> m_NetworkReplyToId;
perrinel Add execute skelleton Network	r386	std::unique_ptr<QNetworkAccessManager> m_AccessManager{nullptr};
perrinel Intialization of network controller	r339	};

		NetworkController::NetworkController(QObject *parent)
		: QObject(parent), impl{spimpl::make_unique_impl<NetworkControllerPrivate>(this)}
		{
perrinel Add execute skelleton Network	r386	}

perrinel request is now passed by shared pointer instead of const &	r751	void NetworkController::onProcessRequested(std::shared_ptr<QNetworkRequest> request,
		QUuid identifier,
perrinel Implement the network controller to permit the execution of a request...	r389	std::function<void(QNetworkReply *, QUuid)> callback)
perrinel Add execute skelleton Network	r386	{
perrinel request is now passed by shared pointer instead of const &	r751	qCDebug(LOG_NetworkController()) << tr("NetworkController onProcessRequested")
		<< QThread::currentThread()->objectName() << &request;
		auto reply = impl->m_AccessManager->get(*request);
perrinel Implement the network controller to permit the execution of a request...	r389
		// Store the couple reply id
perrinel Add thread protection on AbortDownload process	r423	impl->lockWrite();
perrinel Update networkcontroller for abort mechanism	r755	impl->m_NetworkReplyToId[reply] = identifier;
		qCDebug(LOG_NetworkController()) << tr("Store for reply: ") << identifier;
perrinel Add thread protection on AbortDownload process	r423	impl->unlock();
perrinel Implement the network controller to permit the execution of a request...	r389
perrinel Implementation of progression	r750	auto onReplyFinished = [request, reply, this, identifier, callback]() {
perrinel Implement the network controller to permit the execution of a request...	r389
perrinel Add thread protection on AbortDownload process	r423	qCDebug(LOG_NetworkController()) << tr("NetworkController onReplyFinished")
perrinel request is now passed by shared pointer instead of const &	r751	<< QThread::currentThread() << request.get() << reply;
perrinel Add thread protection on AbortDownload process	r423	impl->lockRead();
perrinel Update networkcontroller for abort mechanism	r755	auto it = impl->m_NetworkReplyToId.find(reply);
		if (it != impl->m_NetworkReplyToId.cend()) {
perrinel Correction for MR	r760	qCDebug(LOG_NetworkController()) << tr("Remove for reply: ") << it->second;
		impl->unlock();
perrinel Add thread protection on AbortDownload process	r423	impl->lockWrite();
perrinel Update networkcontroller for abort mechanism	r755	impl->m_NetworkReplyToId.erase(reply);
perrinel Add thread protection on AbortDownload process	r423	impl->unlock();
		// Deletes reply
perrinel Implement the network controller to permit the execution of a request...	r389	callback(reply, identifier);
perrinel Add thread protection on AbortDownload process	r423	reply->deleteLater();
perrinel Implement the network controller to permit the execution of a request...	r389	}
perrinel Correction for MR	r760	else {
		impl->unlock();
		}
perrinel Add thread protection on AbortDownload process	r423
		qCDebug(LOG_NetworkController()) << tr("NetworkController onReplyFinished END")
		<< QThread::currentThread() << reply;
perrinel Implement the network controller to permit the execution of a request...	r389	};

perrinel Implementation of progression	r750	auto onReplyProgress = [reply, request, this](qint64 bytesRead, qint64 totalBytes) {
perrinel Add execute skelleton Network	r386
perrinel Update networkcontroller for abort mechanism	r755	// NOTE: a totalbytes of 0 can happened when a request has been aborted
		if (totalBytes > 0) {
		double progress = (bytesRead * 100.0) / totalBytes;
		qCDebug(LOG_NetworkController()) << tr("NetworkController onReplyProgress") << progress
perrinel See last commit	r757	<< QThread::currentThread() << request.get() << reply
		<< bytesRead << totalBytes;
perrinel Update networkcontroller for abort mechanism	r755	impl->lockRead();
		auto it = impl->m_NetworkReplyToId.find(reply);
		if (it != impl->m_NetworkReplyToId.cend()) {
perrinel Correction for MR	r760	auto id = it->second;
		impl->unlock();
		emit this->replyDownloadProgress(id, request, progress);
		}
		else {
		impl->unlock();
perrinel Update networkcontroller for abort mechanism	r755	}
perrinel Correction for MR	r760
perrinel Update networkcontroller for abort mechanism	r755	qCDebug(LOG_NetworkController()) << tr("NetworkController onReplyProgress END")
		<< QThread::currentThread() << reply;
perrinel Implement the network controller to permit the execution of a request...	r389	}
		};
perrinel Add execute skelleton Network	r386
perrinel Implement the network controller to permit the execution of a request...	r389
		connect(reply, &QNetworkReply::finished, this, onReplyFinished);
perrinel Add implementation of progress bar on variable inspector connected to...	r401	connect(reply, &QNetworkReply::downloadProgress, this, onReplyProgress);
perrinel Display errors of NetworkAcessManager	r426	qCDebug(LOG_NetworkController()) << tr("NetworkController registered END")
		<< QThread::currentThread()->objectName() << reply;
perrinel Intialization of network controller	r339	}

		void NetworkController::initialize()
		{
		qCDebug(LOG_NetworkController()) << tr("NetworkController init") << QThread::currentThread();
		impl->m_WorkingMutex.lock();
perrinel Implement the network controller to permit the execution of a request...	r389	impl->m_AccessManager = std::make_unique<QNetworkAccessManager>();
perrinel Display errors of NetworkAcessManager	r426

		auto onReplyErrors = [this](QNetworkReply *reply, const QList<QSslError> &errors) {
		qCCritical(LOG_NetworkController()) << tr("NetworkAcessManager errors: ") << errors;

		};


		connect(impl->m_AccessManager.get(), &QNetworkAccessManager::sslErrors, this, onReplyErrors);

perrinel Intialization of network controller	r339	qCDebug(LOG_NetworkController()) << tr("NetworkController init END");
		}

		void NetworkController::finalize()
		{
		impl->m_WorkingMutex.unlock();
		}

perrinel Implement the network controller to permit the execution of a request...	r389	void NetworkController::onReplyCanceled(QUuid identifier)
		{
		auto findReply = [identifier](const auto &entry) { return identifier == entry.second; };
perrinel Add thread protection on AbortDownload process	r423	qCDebug(LOG_NetworkController()) << tr("NetworkController onReplyCanceled")
perrinel See last commit	r757	<< QThread::currentThread() << identifier;
perrinel Add thread protection on AbortDownload process	r423
perrinel Implement the network controller to permit the execution of a request...	r389
perrinel Add thread protection on AbortDownload process	r423	impl->lockRead();
perrinel Update networkcontroller for abort mechanism	r755	auto end = impl->m_NetworkReplyToId.cend();
		auto it = std::find_if(impl->m_NetworkReplyToId.cbegin(), end, findReply);
perrinel Add thread protection on AbortDownload process	r423	impl->unlock();
perrinel Implement the network controller to permit the execution of a request...	r389	if (it != end) {
perrinel Update networkcontroller for abort mechanism	r755	qCDebug(LOG_NetworkController()) << tr("NetworkController onReplyCanceled ABORT DONE")
perrinel See last commit	r757	<< QThread::currentThread() << identifier;
perrinel Implement the network controller to permit the execution of a request...	r389	it->first->abort();
		}
perrinel Add thread protection on AbortDownload process	r423	qCDebug(LOG_NetworkController()) << tr("NetworkController onReplyCanceled END")
perrinel See last commit	r757	<< QThread::currentThread();
perrinel Implement the network controller to permit the execution of a request...	r389	}

perrinel Intialization of network controller	r339	void NetworkController::waitForFinish()
		{
		QMutexLocker locker{&impl->m_WorkingMutex};
		}