socket.h

Go to the documentation of this file.

/*---------------------------------------------------------------------\
|                          ____ _   __ __ ___                          |
|                         |__  / \ / / . \ . \                         |
|                           / / \ V /|  _/  _/                         |
|                          / /__ | | | | | |                           |
|                         /_____||_| |_| |_|                           |
|                                                                      |
\----------------------------------------------------------------------/
*
* This file contains private API, this might break at any time between releases.
* You have been warned!
*
*/
 
#ifndef ZYPPNG_IO_SOCKET_DEFINED
#define ZYPPNG_IO_SOCKET_DEFINED
 
#include <zypp-core/zyppng/io/IODevice>
#include <zypp-core/zyppng/io/SockAddr>
#include <zypp-core/zyppng/base/Signals>
 
namespace zyppng {
 
  class SocketPrivate;

  class Socket : public IODevice
  {
    ZYPP_DECLARE_PRIVATE(Socket)
  public:
 
    enum SocketError {
      NoError,
      UnknownSocketError,
      InsufficientPermissions,
      InvalidSocketOptions,
      InsufficientRessources,
      UnsupportedSocketOptions,
      FailedSocketOperation,
      SocketAlreadyBound,
      SocketNotListening,
      AddressInUse,
      AddressNotAvailable,
      AddressIssue,
      OperationNotSupported,
      ConnectionTimeout,
      ConnectionDelayed,
      ConnectionRefused,
      ConnectionClosedByRemote,
      NetworkUnreachable,
      InternalError
    };
 
    enum SocketState {
      InitialState,
      ConnectingState,
      ConnectedState,
      ListeningState,
      ClosingState,
      ClosedState
    };
 
    using Ptr = std::shared_ptr<Socket>;

    static Ptr create ( int domain, int type, int protocol );
    ~Socket() override;

    void close() override;

    int64_t bytesPending() const override;

    SocketState state () const;

    bool bind ( const std::shared_ptr<SockAddr> &addr );

    bool listen ( int backlog = 50 );

    Ptr accept ();

    bool setBlocking ( const bool set = true );
 

    void disconnect ();

    void abort ();

    bool connect ( std::shared_ptr<SockAddr> addr );

    bool waitForConnected ( int timeout = -1 );

    bool waitForAllBytesWritten ( int timeout = -1 );

    bool waitForReadyRead ( uint channel, int timeout = -1 ) override;

    int nativeSocket () const;

    int releaseSocket ();

    SocketError lastError () const;

    SignalProxy<void ()> sigIncomingConnection ();

    SignalProxy<void ()> sigConnected ();

    SignalProxy<void ()> sigDisconnected ();

    SignalProxy<void (Socket::SocketError)> sigError ();
 

    static Ptr fromSocket ( int fd, SocketState state );
 
  protected:
    Socket ( int domain, int type, int protocol );
 
 
    // IODevice interface
  protected:
    int64_t rawBytesAvailable( uint channel = 0 ) const override;
    int64_t writeData(const char *data, int64_t count) override;
    int64_t readData( uint channel, char *buffer, int64_t bufsize ) override;
    void  readChannelChanged ( uint channel ) override;
  };
}
#endif