OutgoingConnection.hpp

Go to the documentation of this file.

#ifndef FIPA_SERVICES_TRANSPORTS_UDT_OUTGOING_CONNECTION_HPP
#define FIPA_SERVICES_TRANSPORTS_UDT_OUTGOING_CONNECTION_HPP

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

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

class OutgoingConnection : public fipa::services::transports::OutgoingConnection
{
    UDTSOCKET mSocket;

public:
    OutgoingConnection();

    OutgoingConnection(const std::string& ipaddress, uint16_t port);

    OutgoingConnection(const Address& address);

    virtual ~OutgoingConnection();

    virtual void connect(const std::string& ipaddress, uint16_t port);
    
    void sendData(const std::string& data, int ttl = -1, bool inorder = true) const;

    virtual void send(const std::string& data); 
};
} // end namespace udt
} // end namespace transport
} // end namespace services
} // end namespace fipa
#endif // FIPA_SERVICES_TRANSPORTS_UDT_OUTGOING_CONNECTION_HPP