TCPTransport.hpp

Go to the documentation of this file.

#ifndef FIPA_SERVICES_TRANSPORTS_TCP_TCP_TRANSPORT_HPP
#define FIPA_SERVICES_TRANSPORTS_TCP_TCP_TRANSPORT_HPP

#include <fipa_services/MessageTransport.hpp>
#include <fipa_services/DistributedServiceDirectory.hpp>
#include <fipa_acl/fipa_acl.h>
#include "../Transport.hpp"

#include <boost/asio/io_service.hpp>
#include <boost/asio/ip/tcp.hpp>

namespace fipa {
namespace services {
namespace transports {
namespace tcp {

class TCPTransport : public Transport
{
    friend class OutgoingConnection;

    typedef boost::shared_ptr<boost::asio::ip::tcp::socket> SocketPtr;

    static boost::asio::io_service msIOService;
    boost::asio::ip::tcp::acceptor mAcceptor;

    // List of connected clients
    std::vector<SocketPtr> mClients;

    uint16_t getPort() const;

    void accept();

    /*
     * Reads from one socket, until the connection is closed by the other side.
     * All read envelopes are dispatched directly.
     * The read method deletes the socket after having finished.
     */
    bool read(SocketPtr socket);

protected:
    static boost::asio::io_service& getIOService();

public:
    TCPTransport();
    ~TCPTransport();

    virtual void start();

    void listen(uint16_t port = 0);

    void update(bool readAllMessages);

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

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

};

} // end namespace tcp
} // end namespace transports
} // end namespace services
} // end namespace fipa
#endif // FIPA_SERVICES_TRANSPORTS_TCP_TCP_TRANSPORT_HPP