asyncdatasource.h

Go to the documentation of this file.

#ifndef ASYNCDATASOURCE_H
#define ASYNCDATASOURCE_H
 
#include <zypp-core/zyppng/base/Base>
#include <zypp-core/zyppng/io/IODevice>
 
namespace zyppng {
 
  class AsyncDataSourcePrivate;
 
  class AsyncDataSource : public IODevice
  {
    ZYPP_DECLARE_PRIVATE(AsyncDataSource)
  public:
 
    enum ChannelCloseReason {
      RemoteClose,    // the other side of the fd was closed
      AccessError,    // we got an EACCESS when polling the fd
      InternalError,  // we got a unexpected errno when polling the fd
      UserRequest     // channel were closed because close() was called
    };
 
    using Ptr     = std::shared_ptr<AsyncDataSource>;
    using WeakPtr = std::weak_ptr<AsyncDataSource>;
 
    static Ptr create ();

    bool openFds ( const std::vector<int>& readFds, int writeFd = -1 );

    void close () override;
 
    using IODevice::waitForReadyRead;
 
    virtual void closeWriteChannel ();

    bool waitForReadyRead(uint channel, int timeout) override;

    void flush ();

    SignalProxy<void( AsyncDataSource::ChannelCloseReason )> sigWriteFdClosed();

    SignalProxy<void( uint, AsyncDataSource::ChannelCloseReason )> sigReadFdClosed();

    bool readFdOpen () const;

    bool readFdOpen ( uint channel ) const;

    int64_t bytesPending() const override;
 
  protected:
    AsyncDataSource (  );
    AsyncDataSource( AsyncDataSourcePrivate &d );
    int64_t writeData(const char *data, int64_t count) override;
 
  private:
    using IODevice::open;
 
    int64_t readData( uint channel, char *buffer, int64_t bufsize ) override;
    int64_t rawBytesAvailable( uint channel ) const override;
    void readChannelChanged ( uint channel ) override;
  };
}
 
 
#endif // ASYNCDATASOURCE_H