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/ng/base/zyppglobal.h>
#include <zypp-core/ng/base/Base>
#include <zypp-core/ng/base/signals.h>
#include <zypp-core/ng/core/Url>
#include <vector>
#include <unordered_map>
 
#include <zypp-curl/ng/network/networkrequesterror.h>
#include <zypp-curl/ng/network/HttpHeader>
 
namespace zyppng {
 
  class NetworkRequestDispatcherPrivate;
  class NetworkRequest;

  class  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 );
      void setHostSpecificHeader ( const std::string &host_r, const HttpHeader & header_r )
      { setHostSpecificHeader( host_r, header_r.key(), header_r.value() ); }

      void unsetHostSpecificHeader( const std::string &host, const std::string &headerName );
 
      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 cancelAll  ( std::string reason = std::string() );

      void cancelAll  ( 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