networkrequestdispatcher.h

Go to the documentation of this file.

#ifndef ZYPP_NG_MEDIA_CURL_CURL_H_INCLUDED
#define ZYPP_NG_MEDIA_CURL_CURL_H_INCLUDED
 
#include <zypp-core/zyppng/base/zyppglobal.h>
#include <zypp-core/zyppng/base/Base>
#include <zypp-core/zyppng/base/signals.h>
#include <zypp-core/zyppng/core/Url>
#include <vector>
#include <unordered_map>
 
#include <zypp-curl/ng/network/networkrequesterror.h>
 
namespace zyppng {
 
  class NetworkRequestDispatcherPrivate;
  class NetworkRequest;
 
  class LIBZYPP_NG_EXPORT NetworkRequestDispatcher : public Base
  {
    ZYPP_DECLARE_PRIVATE(NetworkRequestDispatcher)
    public:
 
      using Ptr = std::shared_ptr<NetworkRequestDispatcher>;
      using WeakPtr = std::weak_ptr<NetworkRequestDispatcher>;
 
      NetworkRequestDispatcher ( );
 
      static bool supportsProtocol ( const Url &url );
 
      void setMaximumConcurrentConnections ( const int maxConn );
 
      int maximumConcurrentConnections () const;
 
      void enqueue ( const std::shared_ptr<NetworkRequest> &req );
 
      void setAgentString ( const std::string &agent );
 
      const std::string &agentString () const;
 
      void setHostSpecificHeader ( const std::string &host, const std::string &headerName, const std::string &value );
 
 
      using SpecificHeaderMap = std::unordered_map< std::string, std::unordered_map<std::string, std::string >>;
 
      const SpecificHeaderMap &hostSpecificHeaders() const;
 
 
      void cancel  ( NetworkRequest &req , std::string reason = std::string() );
 
      void cancel  ( NetworkRequest &req , const NetworkRequestError &err );
 
      void run ( );
 
      void reschedule ();
 
      size_t count ();
 
      const NetworkRequestError &lastError() const;
 
      SignalProxy<void ( NetworkRequestDispatcher &, NetworkRequest & )> sigDownloadStarted();
 
      SignalProxy<void ( NetworkRequestDispatcher &, NetworkRequest & )> sigDownloadFinished();
 
      SignalProxy<void ( NetworkRequestDispatcher & )> sigQueueFinished ();
 
      SignalProxy<void ( NetworkRequestDispatcher & )> sigError ();
   };
}
 
 
#endif