abstractsocket.h

Go to the documentation of this file.

 
#pragma once
 
#include <promeki/core/iodevice.h>
#include <promeki/core/error.h>
#include <promeki/network/socketaddress.h>
 
PROMEKI_NAMESPACE_BEGIN
 
class AbstractSocket : public IODevice {
        PROMEKI_OBJECT(AbstractSocket, IODevice)
        public:
                enum SocketType {
                        TcpSocketType,  
                        UdpSocketType,  
                        RawSocketType   
                };
 
                enum SocketState {
                        Unconnected,    
                        Connecting,     
                        Connected,      
                        Bound,          
                        Closing,        
                        Listening       
                };
 
                AbstractSocket(SocketType type, ObjectBase *parent = nullptr);
 
                virtual ~AbstractSocket();
 
                SocketType socketType() const { return _type; }
 
                SocketState state() const { return _state; }
 
                Error bind(const SocketAddress &address);
 
                Error connectToHost(const SocketAddress &address);
 
                void disconnectFromHost();
 
                SocketAddress localAddress() const { return _localAddress; }
 
                SocketAddress peerAddress() const { return _peerAddress; }
 
                Error waitForConnected(unsigned int timeoutMs = 0);
 
                int socketDescriptor() const { return _fd; }
 
                void setSocketDescriptor(int fd);
 
                Error setSocketOption(int level, int option, int value);
 
                Result<int> socketOption(int level, int option) const;
 
                bool isSequential() const override { return true; }
 
                PROMEKI_SIGNAL(connected);
 
                PROMEKI_SIGNAL(disconnected);
 
                PROMEKI_SIGNAL(stateChanged, SocketState);
 
        protected:
                Error createSocket(int domain, int type, int protocol = 0);
 
                void closeSocket();
 
                Error setNonBlocking(bool enable);
 
                void updateLocalAddress();
 
                void setState(SocketState state);
 
                int             _fd = -1;               
                SocketState     _state = Unconnected;    
                SocketType      _type;                   
                SocketAddress   _localAddress;           
                SocketAddress   _peerAddress;            
};
 
PROMEKI_NAMESPACE_END