localsocket.h

Go to the documentation of this file.

 
#pragma once
 
 
#include <promeki/config.h>
#if PROMEKI_ENABLE_NETWORK
#include <promeki/iodevice.h>
#include <promeki/error.h>
#include <promeki/string.h>
#include <promeki/uniqueptr.h>
 
PROMEKI_NAMESPACE_BEGIN
 
class LocalSocket : public IODevice {
                PROMEKI_OBJECT(LocalSocket, IODevice)
        public:
                using UPtr = UniquePtr<LocalSocket>;
 
                static constexpr unsigned int DefaultReceiveTimeoutMs = 5000;
 
                static constexpr unsigned int DefaultSendTimeoutMs = 5000;
 
                static bool isSupported();
 
                LocalSocket(ObjectBase *parent = nullptr);
 
                ~LocalSocket() override;
 
                Error open(OpenMode mode) override;
 
                Error close() override;
 
                Error connectTo(const String &path, unsigned int timeoutMs = 0);
 
                bool isOpen() const override { return _fd >= 0; }
 
                bool isConnected() const { return _fd >= 0 && _connected; }
 
                int64_t read(void *data, int64_t maxSize) override;
 
                int64_t write(const void *data, int64_t maxSize) override;
 
                int64_t bytesAvailable() const override;
 
                bool isSequential() const override { return true; }
 
                int socketDescriptor() const { return _fd; }
 
                void setSocketDescriptor(int fd, const String &peerPath = String());
 
                const String &peerPath() const { return _peerPath; }
 
                Error setReceiveTimeout(unsigned int timeoutMs);
 
                Error setSendTimeout(unsigned int timeoutMs);
 
                PROMEKI_SIGNAL(connected);
 
                PROMEKI_SIGNAL(disconnected);
 
        private:
                int    _fd = -1;
                bool   _connected = false;
                String _peerPath;
};
 
PROMEKI_NAMESPACE_END
 
#endif // PROMEKI_ENABLE_NETWORK