networkrequestdispatcher_p.h

Go to the documentation of this file.

#ifndef ZYPP_NG_MEDIA_CURL_PRIVATE_CURL_P_H_INCLUDED
#define ZYPP_NG_MEDIA_CURL_PRIVATE_CURL_P_H_INCLUDED

#include <zypp/zyppng/media/network/networkrequestdispatcher.h>
#include <zypp/zyppng/base/private/base_p.h>
#include <curl/curl.h>
#include <deque>
#include <set>

namespace zyppng {

class Timer;
class SocketNotifier;

class NetworkRequestDispatcherPrivate : public BasePrivate
{
  ZYPP_DECLARE_PUBLIC(NetworkRequestDispatcher)
public:
  NetworkRequestDispatcherPrivate ( );
  virtual ~NetworkRequestDispatcherPrivate();

  size_t _maxConnections = 10;

  std::deque< std::shared_ptr<NetworkRequest> > _pendingDownloads;
  std::vector< std::shared_ptr<NetworkRequest> > _runningDownloads;

  std::shared_ptr<Timer> _timer;
  std::map< curl_socket_t, std::shared_ptr<SocketNotifier> > _socketHandler;

  bool  _isRunning = false;
  bool  _locked = false; //if set to true, no new requests will be dequeued
  CURLM *_multi = nullptr;

  NetworkRequestError _lastError;

  //signals
  signal<void ( NetworkRequestDispatcher &, NetworkRequest & )> _sigDownloadStarted;
  signal<void ( NetworkRequestDispatcher &, NetworkRequest & )> _sigDownloadFinished;
  signal<void ( NetworkRequestDispatcher & )> _sigQueueFinished;
  signal<void ( NetworkRequestDispatcher & )> _sigError;

private:
  static int multi_timer_cb ( CURLM *multi, long timeout_ms, void *g );
  static int static_socket_callback(CURL *easy, curl_socket_t s, int what, void *userp, SocketNotifier *socketp );

  void multiTimerTimout ( const Timer &t );
  int  socketCallback(CURL *easy, curl_socket_t s, int what, void * );

  void cancelAll ( NetworkRequestError result );
  void setFinished( NetworkRequest &req , NetworkRequestError result );

  void onSocketActivated  ( const SocketNotifier &listener, int events );

  void handleMultiSocketAction ( curl_socket_t nativeSocket, int evBitmask );
  void dequeuePending ();
};
}

#endif