UDTTransport.hpp

Go to the documentation of this file.

#ifndef FIPA_SERVICES_TRANSPORTS_UDT_UDT_TRANSPORT_HPP
#define FIPA_SERVICES_TRANSPORTS_UDT_UDT_TRANSPORT_HPP

#include <vector>
#include <boost/shared_ptr.hpp>
#include <base-logging/Logging.hpp>
#include <fipa_services/ErrorHandling.hpp>

#include "../Transport.hpp"
#include "IncomingConnection.hpp"

namespace fipa {
namespace services {
namespace transports {
namespace udt {

extern const uint32_t MAX_MESSAGE_SIZE_BYTES;

class UDTTransport : public Transport
{
    static uint32_t msRefCount;

    UDTSOCKET mServerSocket;
    IncomingConnections mClients;

    Address mAddress;

    size_t mBufferSize;
    char* mpBuffer;

    bool accept();

    void listen(uint16_t port, uint32_t maxClients);
public:

    UDTTransport();
    ~UDTTransport();

    void start();

    virtual void update(bool readAllMessages = true);

    Address getAddress(const std::string& interfaceName = "eth0") const;

    virtual OutgoingConnection::Ptr establishOutgoingConnection(const Address& address);
};

} // end namespace udt
} // end namespace transports
} // end namespace services
} // end namespace fipa
#endif // FIPA_SERVICES_TRANSPORTS_UDT_UDT_TRANSPORT_HPP