TCPDummyHardware.hpp

Go to the documentation of this file.

/*
---------------------------------------------------------------------------

    This file is part of uHAL.

    uHAL is a hardware access library and programming framework
    originally developed for upgrades of the Level-1 trigger of the CMS
    experiment at CERN.

    uHAL is free software: you can redistribute it and/or modify
    it under the terms of the GNU General Public License as published by
    the Free Software Foundation, either version 3 of the License, or
    (at your option) any later version.

    uHAL is distributed in the hope that it will be useful,
    but WITHOUT ANY WARRANTY; without even the implied warranty of
    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
    GNU General Public License for more details.

    You should have received a copy of the GNU General Public License
    along with uHAL.  If not, see <http://www.gnu.org/licenses/>.

      Marc Magrans de Abril, CERN
      email: marc.magrans.de.abril <AT> cern.ch

      Andrew Rose, Imperial College, London
      email: awr01 <AT> imperial.ac.uk

---------------------------------------------------------------------------
*/

#ifndef _uhal_tests_TCPDummyHardware_hpp_
#define _uhal_tests_TCPDummyHardware_hpp_


#include <boost/asio.hpp>

#include "uhal/tests/DummyHardware.hpp"


namespace uhal {
  namespace tests {
  
    template< uint8_t IPbus_major , uint8_t IPbus_minor >
    class TCPDummyHardware : public DummyHardware< IPbus_major , IPbus_minor >
    {
      public:
        typedef DummyHardware< IPbus_major , IPbus_minor > base_type;
  
        TCPDummyHardware ( const uint16_t& aPort , const uint32_t& aReplyDelay, const bool& aBigEndianHack ) :
          DummyHardware< IPbus_major , IPbus_minor > ( aReplyDelay , aBigEndianHack ) ,
          mIOservice(),
          mAcceptor ( mIOservice , boost::asio::ip::tcp::endpoint ( boost::asio::ip::tcp::v4() , aPort ) ),
          mSocket ( mIOservice )
        {
          mAcceptor.listen();
        }
  
        ~TCPDummyHardware()
        {
        }
  
        void run();
  
        void stop();

      private:
        void handle_accept(const boost::system::error_code& aError);

        void handle_read_chunk_header(const boost::system::error_code& ec, std::size_t length);

        void handle_read_chunk_payload(const boost::system::error_code& ec, std::size_t length);

        boost::asio::io_service mIOservice;
        boost::asio::ip::tcp::acceptor mAcceptor;
        boost::asio::ip::tcp::socket mSocket;

        boost::asio::ip::tcp::endpoint mSenderEndpoint;
        uint32_t mByteCountHeader;
    };
  }
}

#endif