WebSVN – HomeAutomation – Diff – /trunk/PcSoftware/Atom1.5/src/net/SerialClient.cpp


/*
 *
 *    Copyright (C) 2010  Mattias Runge
 *
 *    This program 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 2 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 General Public License for more details.
 *
 *    You should have received a copy of the GNU General Public License along
 *    with this program; if not, write to the Free Software Foundation, Inc.,
 *    51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
 *
 */
 
#include "SerialClient.h"
 
#include <boost/lexical_cast.hpp>
 
namespace atom {
namespace net {
 
SerialClient::SerialClient(boost::asio::io_service& io_service, ClientId id, ServerId server_id) : serial_port_(io_service), Client(io_service, id, server_id)
{
}
 
SerialClient::~SerialClient()
{
    if (this->serial_port_.is_open())
    {
        this->serial_port_.cancel();
        this->serial_port_.close();
    }
}
 
void SerialClient::Connect(std::string address, unsigned int baud)
{
    boost::asio::serial_port_base::baud_rate baud_option(baud);
   
    this->serial_port_.open(address);
   
    if (!this->serial_port_.is_open())
    {
        throw std::runtime_error("Error while opening " + address);
    }
   
    this->serial_port_.set_option(baud_option);
   
    this->Read();
}
 
void SerialClient::Disconnect()
{
    if (this->serial_port_.is_open())
    {
        this->serial_port_.cancel();
        this->serial_port_.close();
    }
   
    Client::Disconnect();
}
 
void SerialClient::Send(type::Byteset data)
{
    try
    {
        if (this->serial_port_.is_open())
        {
            this->serial_port_.write_some(boost::asio::buffer(data.Get(), data.GetMaxSize()));
        }
    }
    catch (std::exception& e)
    {
        this->Disconnect();
        //throw std::runtime_error(e.what());
    }
}
 
void SerialClient::Read()
{
    Client::Read();
   
    this->serial_port_.async_read_some(boost::asio::buffer(this->buffer_.Get(), this->buffer_.GetMaxSize()),
                                       boost::bind(&SerialClient::ReadHandler,
                                                   this,
                                                   boost::asio::placeholders::error,
                                                   boost::asio::placeholders::bytes_transferred));
}
 
 
}; // namespace net
}; // namespace atom
 

Subversion Repositories HomeAutomation

(root)/trunk/PcSoftware/Atom1.5/src/net/SerialClient.cpp – Rev 1596 → 1597

Rev 1596		Rev 1597
1	/*	1	/*
2	*	2	*
3	* Copyright (C) 2010 Mattias Runge	3	* Copyright (C) 2010 Mattias Runge
4	*	4	*
5	* This program is free software; you can redistribute it and/or modify	5	* This program is free software; you can redistribute it and/or modify
6	* it under the terms of the GNU General Public License as published by	6	* it under the terms of the GNU General Public License as published by
7	* the Free Software Foundation; either version 2 of the License, or	7	* the Free Software Foundation; either version 2 of the License, or
8	* (at your option) any later version.	8	* (at your option) any later version.
9	*	9	*
10	* This program is distributed in the hope that it will be useful,	10	* This program is distributed in the hope that it will be useful,
11	* but WITHOUT ANY WARRANTY; without even the implied warranty of	11	* but WITHOUT ANY WARRANTY; without even the implied warranty of
12	* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the	12	* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
13	* GNU General Public License for more details.	13	* GNU General Public License for more details.
14	*	14	*
15	* You should have received a copy of the GNU General Public License along	15	* You should have received a copy of the GNU General Public License along
16	* with this program; if not, write to the Free Software Foundation, Inc.,	16	* with this program; if not, write to the Free Software Foundation, Inc.,
17	* 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.	17	* 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
18	*	18	*
19	*/	19	*/
20		20
21	#include "SerialClient.h"	21	#include "SerialClient.h"
22		22
23	#include <boost/lexical_cast.hpp>	23	#include <boost/lexical_cast.hpp>
24		24
25	namespace atom {	25	namespace atom {
26	namespace net {	26	namespace net {
27		27
28	SerialClient::SerialClient(boost::asio::io_service& io_service, ClientId id, ServerId server_id) : serial_port_(io_service), Client(io_service, id, server_id)	28	SerialClient::SerialClient(boost::asio::io_service& io_service, ClientId id, ServerId server_id) : serial_port_(io_service), Client(io_service, id, server_id)
29	{	29	{
30	}	30	}
31		31
32	SerialClient::~SerialClient()	32	SerialClient::~SerialClient()
33	{	33	{
34	if (this->serial_port_.is_open())	34	if (this->serial_port_.is_open())
35	{	35	{
36	this->serial_port_.cancel();	36	this->serial_port_.cancel();
37	this->serial_port_.close();	37	this->serial_port_.close();
38	}	38	}
39	}	39	}
40		40
41	void SerialClient::Connect(std::string address, unsigned int baud)	41	void SerialClient::Connect(std::string address, unsigned int baud)
42	{	42	{
43	boost::asio::serial_port_base::baud_rate baud_option(baud);	43	boost::asio::serial_port_base::baud_rate baud_option(baud);
44		44
45	this->serial_port_.open(address);	45	this->serial_port_.open(address);
46		46
47	if (!this->serial_port_.is_open())	47	if (!this->serial_port_.is_open())
48	{	48	{
49	throw std::runtime_error("Error while opening " + address);	49	throw std::runtime_error("Error while opening " + address);
50	}	50	}
51		51
52	this->serial_port_.set_option(baud_option);	52	this->serial_port_.set_option(baud_option);
53		53
54	this->Read();	54	this->Read();
55	}	55	}
56		56
57	void SerialClient::Disconnect()	57	void SerialClient::Disconnect()
58	{	58	{
59	if (this->serial_port_.is_open())	59	if (this->serial_port_.is_open())
60	{	60	{
61	this->serial_port_.cancel();	61	this->serial_port_.cancel();
62	this->serial_port_.close();	62	this->serial_port_.close();
63	}	63	}
64		64
65	Client::Disconnect();	65	Client::Disconnect();
66	}	66	}
67		67
68	void SerialClient::Send(type::Byteset data)	68	void SerialClient::Send(type::Byteset data)
-		69	{
-		70	try
69	{	71	{
70	if (this->serial_port_.is_open())	72	if (this->serial_port_.is_open())
71	{	73	{
72	this->serial_port_.write_some(boost::asio::buffer(data.Get(), data.GetMaxSize()));	74	this->serial_port_.write_some(boost::asio::buffer(data.Get(), data.GetMaxSize()));
73	}	75	}
74	~~else~~	76	}
-		77	catch (std::exception& e)
75	{	78	{
76	this->Disconnect();	79	this->Disconnect();
-		80	//throw std::runtime_error(e.what());
77	}	81	}
78	}	82	}
79		83
80	void SerialClient::Read()	84	void SerialClient::Read()
81	{	85	{
82	Client::Read();	86	Client::Read();
83		87
84	this->serial_port_.async_read_some(boost::asio::buffer(this->buffer_.Get(), this->buffer_.GetMaxSize()),	88	this->serial_port_.async_read_some(boost::asio::buffer(this->buffer_.Get(), this->buffer_.GetMaxSize()),
85	boost::bind(&SerialClient::ReadHandler,	89	boost::bind(&SerialClient::ReadHandler,
86	this,	90	this,
87	boost::asio::placeholders::error,	91	boost::asio::placeholders::error,
88	boost::asio::placeholders::bytes_transferred));	92	boost::asio::placeholders::bytes_transferred));
89	}	93	}
90		94
91		95
92	}; // namespace net	96	}; // namespace net
93	}; // namespace atom	97	}; // namespace atom
94		98