IncomingConnection.hpp

Go to the documentation of this file.

#ifndef FIPA_SERVICES_TRANSPORTS_UDT_INCOMING_CONNECTION_HPP
#define FIPA_SERVICES_TRANSPORTS_UDT_INCOMING_CONNECTION_HPP

#include <stdexcept>
#include <boost/shared_ptr.hpp>
#include <udt/udt.h>
#include <base-logging/Logging.hpp>
#include <fipa_services/transports/Connection.hpp>

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

class IncomingConnection : public fipa::services::transports::Connection
{
    UDTSOCKET mSocket;

public:
    typedef boost::shared_ptr<IncomingConnection> Ptr;

    IncomingConnection();
    ~IncomingConnection();
    IncomingConnection(const UDTSOCKET& socket, const std::string& ip, uint16_t port);

    const UDTSOCKET& getSocket() const { return mSocket; }

    bool operator==(const IncomingConnection& connection) const { return Connection::operator==(connection); }

    int receiveMessage(char* buffer, size_t size) const;
};

typedef std::vector<IncomingConnection::Ptr> IncomingConnections;

} // end namespace udt
} // end namespace transport
} // end namespace services
} // end namespace fipa
#endif // FIPA_SERVICES_TRANSPORTS_UDT_INCOMING_CONNECTION_HPP