loopbacktransport.h

Go to the documentation of this file.

 
#pragma once
 
 
#include <promeki/config.h>
#if PROMEKI_ENABLE_NETWORK
#include <promeki/namespace.h>
#include <promeki/packettransport.h>
#include <promeki/buffer.h>
#include <promeki/list.h>
#include <promeki/mutex.h>
#include <promeki/pair.h>
 
PROMEKI_NAMESPACE_BEGIN
 
class LoopbackTransport : public PacketTransport {
        public:
                LoopbackTransport();
 
                ~LoopbackTransport() override;
 
                static void pair(LoopbackTransport *a, LoopbackTransport *b);
 
                Error open() override;
 
                void close() override;
 
                bool isOpen() const override { return _open; }
 
                ssize_t sendPacket(const void *data, size_t size, const SocketAddress &dest) override;
 
                int sendPackets(const DatagramList &datagrams) override;
 
                ssize_t receivePacket(void *data, size_t maxSize, SocketAddress *sender = nullptr) override;
 
                Error setPacingRate(uint64_t bytesPerSec) override;
 
                Error setTxTime(bool enable) override;
 
                size_t pendingPackets() const {
                        Mutex::Locker locker(_queueMutex);
                        return _recvQueue.size();
                }
 
        private:
                struct QueueEntry {
                                Buffer        data;   
                                SocketAddress sender; 
                };
 
                void deliver(const void *data, size_t size, const SocketAddress &sender);
 
                LoopbackTransport *_peer = nullptr;
                mutable Mutex      _queueMutex;
                List<QueueEntry>   _recvQueue;
                bool               _open = false;
};
 
PROMEKI_NAMESPACE_END
 
#endif // PROMEKI_ENABLE_NETWORK