asioconnector.h

// Copyright (C) 2008,2009,2010 by Philipp Münzel. All rights reserved.
// Released under the terms of the license described in license.txt

#ifndef ASIOCONNECTOR_H
#define ASIOCONNECTOR_H

#include "dllexport.h"

#include <string>
#include <memory>
#include <boost/asio.hpp>
#include <boost/thread.hpp>

#include "canaerotypes.h"
#include "connector.h"
#include "udpsender.h"
#include "udpreceiver.h"

namespace SCS {

class DLL_PUBLIC ASIOConnector: public NetworkConnector<can_t>
{
public:
    ASIOConnector(const std::string& host_addr,
                  int incoming_port,
                  int outgoing_port);

    ~ASIOConnector();

    void setListener(BusConnector<can_t>* listener);

    void send(const void* msg, std::size_t bytes);


private:
    void runIService();

    void runOService();

    void receive(void* msg, std::size_t bytes_recvd);

private:
    boost::asio::io_service m_o_service;
    boost::asio::io_service m_i_service;
    std::auto_ptr<UDPSender> m_sender;
    std::auto_ptr<UDPReceiver> m_receiver;
    std::auto_ptr<boost::asio::io_service::work> m_o_work;
    std::auto_ptr<boost::asio::io_service::work> m_i_work;
    boost::thread m_sender_thread;
    boost::thread m_receiver_thread;
    BusConnector<can_t>* m_connector;
};

}

#endif // ASIOCONNECTOR_H