/home/tobi/workspace/solarpowerlog/src/Connections/CConnectSerialAsio.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 CCONNCECTSERIALASIO_H_
#define CCONNCECTSERIALASIO_H_

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

#ifdef HAVE_COMMS_ASIOSERIAL

#include <boost/asio/serial_port.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)
#define TCP_ASIO_DEFAULT_INTERBYTETIMEOUT (50UL)

using namespace std;

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

public:
     virtual ~CConnectSerialAsio();

     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::serial_port *port;
     boost::asio::streambuf *data;

     char characterlen;
     boost::asio::serial_port_base::parity parity;
     boost::asio::serial_port_base::stop_bits stopbits;
     boost::asio::serial_port_base::flow_control flowctrl;
     unsigned int baudrate;

     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_ASIOSERIAL */

#endif /* CONNECTIONTCP_H_ */