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

Creates constructor for ScalarSeries that directly takes vectors...

Creates constructor for ScalarSeries that directly takes vectors It is used in Amda result parser to avoid an extra loop

perrinel - - Load All Authors

File last commit:

r389:13937fa7979a


                r392:cae900f78dff

Download file

             NetworkController.cpp
        
                    88 lines
            
             | 2.9 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
    
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
    
Intialization of network controller

              r339
            
          QMutex m_WorkingMutex;

        perrinel
    
Add execute skelleton Network

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

              r389
            
          std::unordered_map<QNetworkReply *, QUuid> m_NetworkReplyToVariableId;

        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
    
Implement the network controller to permit the execution of a request...

              r389
            
      void NetworkController::onProcessRequested(const QNetworkRequest &request, QUuid identifier,

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

        perrinel
    
Add execute skelleton Network

              r386
            
      {

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

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

                                           << QThread::currentThread();

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

          // Store the couple reply id

          impl->m_NetworkReplyToVariableId[reply] = identifier;

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

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

                                               << QThread::currentThread();

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

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

                  callback(reply, identifier);

              }

          };

          auto onReplyDownloadProgress = [reply, this]() {

        perrinel
    
Add execute skelleton Network

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

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

                                               << QThread::currentThread();

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

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

                  emit this->replyDownloadProgress(it->second);

              }

          };

        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);

          connect(reply, &QNetworkReply::downloadProgress, this, onReplyDownloadProgress);

        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
    
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; };

          auto end = impl->m_NetworkReplyToVariableId.cend();

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

          if (it != end) {

              it->first->abort();

          }

      }

        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 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 Intialization of network controller	r339	QMutex m_WorkingMutex;
perrinel Add execute skelleton Network	r386
perrinel Implement the network controller to permit the execution of a request...	r389	std::unordered_map<QNetworkReply *, QUuid> m_NetworkReplyToVariableId;
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 Implement the network controller to permit the execution of a request...	r389	void NetworkController::onProcessRequested(const QNetworkRequest &request, QUuid identifier,
		std::function<void(QNetworkReply *, QUuid)> callback)
perrinel Add execute skelleton Network	r386	{
perrinel Implement the network controller to permit the execution of a request...	r389	qCDebug(LOG_NetworkController()) << tr("NetworkController registered")
		<< QThread::currentThread();
		auto reply = impl->m_AccessManager->get(request);

		// Store the couple reply id
		impl->m_NetworkReplyToVariableId[reply] = identifier;

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

		qCDebug(LOG_NetworkController()) << tr("NetworkController onReplyFinished")
		<< QThread::currentThread();
		auto it = impl->m_NetworkReplyToVariableId.find(reply);
		if (it != impl->m_NetworkReplyToVariableId.cend()) {
		callback(reply, identifier);
		}
		};

		auto onReplyDownloadProgress = [reply, this]() {
perrinel Add execute skelleton Network	r386
perrinel Implement the network controller to permit the execution of a request...	r389	qCDebug(LOG_NetworkController()) << tr("NetworkController onReplyDownloadProgress")
		<< QThread::currentThread();
		auto it = impl->m_NetworkReplyToVariableId.find(reply);
		if (it != impl->m_NetworkReplyToVariableId.cend()) {
		emit this->replyDownloadProgress(it->second);
		}
		};
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);
		connect(reply, &QNetworkReply::downloadProgress, this, onReplyDownloadProgress);
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 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; };

		auto end = impl->m_NetworkReplyToVariableId.cend();
		auto it = std::find_if(impl->m_NetworkReplyToVariableId.cbegin(), end, findReply);
		if (it != end) {
		it->first->abort();
		}
		}

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