tcpserver.h

Go to the documentation of this file.

 
#pragma once
 
#include <promeki/core/objectbase.h>
#include <promeki/core/error.h>
#include <promeki/network/socketaddress.h>
 
PROMEKI_NAMESPACE_BEGIN
 
class TcpSocket;
 
class TcpServer : public ObjectBase {
        PROMEKI_OBJECT(TcpServer, ObjectBase)
        public:
                TcpServer(ObjectBase *parent = nullptr);
 
                ~TcpServer() override;
 
                Error listen(const SocketAddress &address, int backlog = 50);
 
                void close();
 
                bool isListening() const { return _listening; }
 
                SocketAddress serverAddress() const { return _address; }
 
                TcpSocket *nextPendingConnection();
 
                bool hasPendingConnections() const;
 
                Error waitForNewConnection(unsigned int timeoutMs = 0);
 
                void setMaxPendingConnections(int count) { _maxPending = count; }
 
                PROMEKI_SIGNAL(newConnection);
 
        private:
                int             _fd = -1;
                bool            _listening = false;
                SocketAddress   _address;
                int             _maxPending = 50;
};
 
PROMEKI_NAMESPACE_END