GIT_REPOSITORIES/LPP/Users/mperrinel/SCIQLOP-Initialisation Files · core/src/Network/NetworkController.cpp

See last commit

perrinel - - Load All Authors

File last commit:

r700:bef126514bff


                r700:bef126514bff

Download file

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

        perrinel
    
Intialization of network controller

              r313
            
      #include "Network/NetworkController.h"

      #include <QMutex>

        perrinel
    
Add execute skelleton Network

              r356
            
      #include <QNetworkAccessManager>

      #include <QNetworkReply>

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

              r359
            
      #include <QNetworkRequest>

        perrinel
    
Add thread protection on AbortDownload process

              r389
            
      #include <QReadWriteLock>

        perrinel
    
Intialization of network controller

              r313
            
      #include <QThread>

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

              r359
            
      #include <unordered_map>

        perrinel
    
Intialization of network controller

              r313
            
      Q_LOGGING_CATEGORY(LOG_NetworkController, "NetworkController")

      struct NetworkController::NetworkControllerPrivate {

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

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

        perrinel
    
Implementation of V5 acquisition

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

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

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

        perrinel
    
Intialization of network controller

              r313
            
          QMutex m_WorkingMutex;

        perrinel
    
Add execute skelleton Network

              r356
            
        perrinel
    
Add thread protection on AbortDownload process

              r389
            
          QReadWriteLock m_Lock;

        perrinel
    
Update networkcontroller for abort mechanism

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

        perrinel
    
Add execute skelleton Network

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

        perrinel
    
Intialization of network controller

              r313
            
      };

      NetworkController::NetworkController(QObject *parent)

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

      {

        perrinel
    
Add execute skelleton Network

              r356
            
      }

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

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

                                                 QUuid identifier,

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

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

        perrinel
    
Add execute skelleton Network

              r356
            
      {

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

              r694
            
          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...

              r359
            
          // Store the couple reply id

        perrinel
    
Add thread protection on AbortDownload process

              r389
            
          impl->lockWrite();

        perrinel
    
Update networkcontroller for abort mechanism

              r698
            
          impl->m_NetworkReplyToId[reply] = identifier;

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

        perrinel
    
Add thread protection on AbortDownload process

              r389
            
          impl->unlock();

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

              r359
            
        perrinel
    
Implementation of progression

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

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

              r359
            
        perrinel
    
Add thread protection on AbortDownload process

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

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

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

        perrinel
    
Add thread protection on AbortDownload process

              r389
            
              impl->lockRead();

        perrinel
    
Update networkcontroller for abort mechanism

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

        perrinel
    
Add thread protection on AbortDownload process

              r389
            
              impl->unlock();

        perrinel
    
Update networkcontroller for abort mechanism

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

        perrinel
    
Add thread protection on AbortDownload process

              r389
            
                  impl->lockWrite();

        perrinel
    
Update networkcontroller for abort mechanism

              r698
            
                  qCDebug(LOG_NetworkController()) << tr("Remove for reply: ")

        perrinel
    
See last commit

              r700
            
                                                   << impl->m_NetworkReplyToId[reply];

        perrinel
    
Update networkcontroller for abort mechanism

              r698
            
                  impl->m_NetworkReplyToId.erase(reply);

        perrinel
    
Add thread protection on AbortDownload process

              r389
            
                  impl->unlock();

                  // Deletes reply

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

              r359
            
                  callback(reply, identifier);

        perrinel
    
Add thread protection on AbortDownload process

              r389
            
                  reply->deleteLater();

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

              r359
            
              }

        perrinel
    
Add thread protection on AbortDownload process

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

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

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

              r359
            
          };

        perrinel
    
Implementation of progression

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

        perrinel
    
Add execute skelleton Network

              r356
            
        perrinel
    
Update networkcontroller for abort mechanism

              r698
            
              // 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

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

                                                   << bytesRead << totalBytes;

        perrinel
    
Update networkcontroller for abort mechanism

              r698
            
                  impl->lockRead();

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

                  impl->unlock();

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

                      emit this->replyDownloadProgress(it->second, request, progress);

                  }

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

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

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

              r359
            
              }

          };

        perrinel
    
Add execute skelleton Network

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

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

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

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

        perrinel
    
Display errors of NetworkAcessManager

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

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

        perrinel
    
Intialization of network controller

              r313
            
      }

      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...

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

        perrinel
    
Display errors of NetworkAcessManager

              r392
            
          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

              r313
            
          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...

              r359
            
      void NetworkController::onReplyCanceled(QUuid identifier)

      {

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

        perrinel
    
Add thread protection on AbortDownload process

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

        perrinel
    
See last commit

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

        perrinel
    
Add thread protection on AbortDownload process

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

              r359
            
        perrinel
    
Add thread protection on AbortDownload process

              r389
            
          impl->lockRead();

        perrinel
    
Update networkcontroller for abort mechanism

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

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

        perrinel
    
Add thread protection on AbortDownload process

              r389
            
          impl->unlock();

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

              r359
            
          if (it != end) {

        perrinel
    
Update networkcontroller for abort mechanism

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

        perrinel
    
See last commit

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

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

              r359
            
              it->first->abort();

          }

        perrinel
    
Add thread protection on AbortDownload process

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

        perrinel
    
See last commit

              r700
            
                                           << QThread::currentThread();

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

              r359
            
      }

        perrinel
    
Intialization of network controller

              r313
            
      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	r313	#include "Network/NetworkController.h"

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

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

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

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

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

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

perrinel request is now passed by shared pointer instead of const &	r694	void NetworkController::onProcessRequested(std::shared_ptr<QNetworkRequest> request,
		QUuid identifier,
perrinel Implement the network controller to permit the execution of a request...	r359	std::function<void(QNetworkReply *, QUuid)> callback)
perrinel Add execute skelleton Network	r356	{
perrinel request is now passed by shared pointer instead of const &	r694	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...	r359
		// Store the couple reply id
perrinel Add thread protection on AbortDownload process	r389	impl->lockWrite();
perrinel Update networkcontroller for abort mechanism	r698	impl->m_NetworkReplyToId[reply] = identifier;
		qCDebug(LOG_NetworkController()) << tr("Store for reply: ") << identifier;
perrinel Add thread protection on AbortDownload process	r389	impl->unlock();
perrinel Implement the network controller to permit the execution of a request...	r359
perrinel Implementation of progression	r693	auto onReplyFinished = [request, reply, this, identifier, callback]() {
perrinel Implement the network controller to permit the execution of a request...	r359
perrinel Add thread protection on AbortDownload process	r389	qCDebug(LOG_NetworkController()) << tr("NetworkController onReplyFinished")
perrinel request is now passed by shared pointer instead of const &	r694	<< QThread::currentThread() << request.get() << reply;
perrinel Add thread protection on AbortDownload process	r389	impl->lockRead();
perrinel Update networkcontroller for abort mechanism	r698	auto it = impl->m_NetworkReplyToId.find(reply);
perrinel Add thread protection on AbortDownload process	r389	impl->unlock();
perrinel Update networkcontroller for abort mechanism	r698	if (it != impl->m_NetworkReplyToId.cend()) {
perrinel Add thread protection on AbortDownload process	r389	impl->lockWrite();
perrinel Update networkcontroller for abort mechanism	r698	qCDebug(LOG_NetworkController()) << tr("Remove for reply: ")
perrinel See last commit	r700	<< impl->m_NetworkReplyToId[reply];
perrinel Update networkcontroller for abort mechanism	r698	impl->m_NetworkReplyToId.erase(reply);
perrinel Add thread protection on AbortDownload process	r389	impl->unlock();
		// Deletes reply
perrinel Implement the network controller to permit the execution of a request...	r359	callback(reply, identifier);
perrinel Add thread protection on AbortDownload process	r389	reply->deleteLater();
perrinel Implement the network controller to permit the execution of a request...	r359	}
perrinel Add thread protection on AbortDownload process	r389
		qCDebug(LOG_NetworkController()) << tr("NetworkController onReplyFinished END")
		<< QThread::currentThread() << reply;
perrinel Implement the network controller to permit the execution of a request...	r359	};

perrinel Implementation of progression	r693	auto onReplyProgress = [reply, request, this](qint64 bytesRead, qint64 totalBytes) {
perrinel Add execute skelleton Network	r356
perrinel Update networkcontroller for abort mechanism	r698	// 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	r700	<< QThread::currentThread() << request.get() << reply
		<< bytesRead << totalBytes;
perrinel Update networkcontroller for abort mechanism	r698	impl->lockRead();
		auto it = impl->m_NetworkReplyToId.find(reply);
		impl->unlock();
		if (it != impl->m_NetworkReplyToId.cend()) {
		emit this->replyDownloadProgress(it->second, request, progress);
		}
		qCDebug(LOG_NetworkController()) << tr("NetworkController onReplyProgress END")
		<< QThread::currentThread() << reply;
perrinel Implement the network controller to permit the execution of a request...	r359	}
		};
perrinel Add execute skelleton Network	r356
perrinel Implement the network controller to permit the execution of a request...	r359
		connect(reply, &QNetworkReply::finished, this, onReplyFinished);
perrinel Add implementation of progress bar on variable inspector connected to...	r369	connect(reply, &QNetworkReply::downloadProgress, this, onReplyProgress);
perrinel Display errors of NetworkAcessManager	r392	qCDebug(LOG_NetworkController()) << tr("NetworkController registered END")
		<< QThread::currentThread()->objectName() << reply;
perrinel Intialization of network controller	r313	}

		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...	r359	impl->m_AccessManager = std::make_unique<QNetworkAccessManager>();
perrinel Display errors of NetworkAcessManager	r392

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

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