Next steps in fine tuning.

[bpdyndnsd] / src / net_helper.cpp

/** @file
 * @brief TcpIpHelper class implementation. This class represents a Helper to easily perform tcp/ip operations.
 *
 *
 *
 * @copyright Intra2net AG
 * @license GPLv2
*/

#include "net_helper.h"
#include "tcp_service.h"


using namespace std;


/**
 * Constructor.
 * @param _log Logger
 * @param _host Host
 * @param _port Port
 */
NetHelper::NetHelper( const Logger::Ptr _log )
    : Log(_log)
{
    IPService::Ptr _ip_service_ptr(new TCPService());
    IPServicePtr.swap(_ip_service_ptr);
}


/**
 * Default destructor
 */
NetHelper::~NetHelper()
{
}


/**
 * Open the connection to the peer.
 * @return 0 if all is fine, -1 on error.
 */
int NetHelper::open_connection(const string& hostname, const string& port)
{
    try
    {
        IPServicePtr->connect(hostname,port);
    }
    catch ( boost::system::system_error boost_exception )
    {
        ostringstream out;
        out << "NetHelper::open_connection(): " << boost_exception.what() << " Host: " << hostname << " Port: " << port;
        Log->print_network_error(out.str());
        return -1;
    }
    return 0;
}


/**
 * Send the given data
 * @param data Data to send
 * @return 0 if all is fine, -1 on error.
 */
int NetHelper::send_data(const std::string& data)
{
    try
    {
        IPServicePtr->write_to_socket(data);
    }
    catch ( boost::system::system_error boost_exception )
    {
        ostringstream out;
        out << "NetHelper::send_data(): " << boost_exception.what() << " Data to be send: " << data;
        Log->print_network_error(out.str());
        return -1;
    }
    return 0;
}


/**
 * Receive all available data from the peer.
 * @return The data received.
 */
std::string NetHelper::receive_data()
{
    string received_data;
    try
    {
        received_data = IPServicePtr->read_from_socket();
    }
    catch ( boost::system::system_error boost_exception )
    {
        ostringstream out;
        out << "NetHelper::receive_data(): " << boost_exception.what();
        Log->print_network_error(out.str());
        return "";
    }
    return received_data;
}


/**
 * Close the active session.
 * @return 0 if all is fine, -1 on error
 */
int NetHelper::close_connection()
{
    try
    {
        IPServicePtr->close();
    }
    catch ( boost::system::system_error boost_exception )
    {
        ostringstream out;
        out << "NetHelper::close_connection(): " << boost_exception.what();
        Log->print_network_error(out.str());
        return -1;
    }
    return 0;
}