/home/tobi/workspace/solarpowerlog/src/Connections/CConnectTCPAsio.h

Go to the documentation of this file.

/* ----------------------------------------------------------------------------
 solarpowerlog
 Copyright (C) 2009  Tobias Frost

 This file is part of solarpowerlog.

 Solarpowerlog is free software; However, it is dual-licenced
 as described in the file "COPYING".

 For this file (ConnectionTCP.h), the license terms are:

 You can redistribute it and/or  modify it under the terms of the GNU Lesser
 General Public License (LGPL) as published by the Free Software Foundation;
 either version 3 of the License, or (at your option) any later version.

 This program 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
 Lesser General Public License for more details.

 You should have received a copy of the GNU Library General Public
 License along with this proramm; if not, see
 <http://www.gnu.org/licenses/>.
 ----------------------------------------------------------------------------
 */

#ifndef CONNECTIONTCPASIO_H_
#define CONNECTIONTCPASIO_H_

#ifdef HAVE_CONFIG_H
#include "config.h"
#include "porting.h"
#endif

#ifdef HAVE_COMMS_ASIOTCPIO

#include <boost/asio/ip/tcp.hpp>
#include <boost/asio/streambuf.hpp>
#include <semaphore.h>

#include "interfaces/IConnect.h"
#include "interfaces/CWorkScheduler.h"
#include "configuration/Registry.h"
#include "patterns/ICommand.h"
#include "Connections/CAsyncCommand.h"

#define TCP_ASIO_DEFAULT_TIMEOUT (3000UL)

using namespace std;

class CConnectTCPAsio: public IConnect
{
protected:
     friend class IConnectFactory;
     CConnectTCPAsio( const string & configurationname );

public:
     virtual ~CConnectTCPAsio();

     virtual bool Connect( ICommand *callback );

     virtual bool Disconnect( ICommand *callback );

     virtual void SetupLogger( const string& parentlogger, const string & = "" )
     {
          IConnect::SetupLogger(parentlogger, "Comms_TCP_ASIO");
     }

     virtual bool Send( const char *tosend, unsigned int len,
               ICommand *callback = NULL );

     virtual bool Send( const string& tosend, ICommand *callback = NULL );

     virtual bool Receive( ICommand *callback );

     virtual bool CheckConfig( void );

     virtual bool IsConnected( void );

private:
     boost::asio::io_service *ioservice;
     boost::asio::ip::tcp::socket *sockt;
     boost::asio::streambuf *data;

     time_t timer;

     // async patch
     virtual void _main( void );

     bool PushWork( CAsyncCommand *cmd );

     //void CancelWork( void );

     bool HandleConnect( CAsyncCommand *cmd );

     bool HandleDisConnect( CAsyncCommand *cmd );

     bool HandleReceive( CAsyncCommand *cmd );

     bool HandleSend( CAsyncCommand *cmd );

     list<CAsyncCommand*> cmds;
     sem_t cmdsemaphore;

};

#endif /* HAVE_COMMS_ASIOTCPIO */
#endif /* CONNECTIONTCP_H_ */