WebSVN – HomeAutomation – Diff – /trunk/PcSoftware/Atom1.5/src/net/Client.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 "Client.h"
 
#include <iostream>
 
#include <boost/bind.hpp>
#include <boost/lexical_cast.hpp>
 
#include "common/log.h"
 
namespace atom {
namespace net {
 
static const std::string log_module_ = "net::client";
 
Client::Client(boost::asio::io_service& io_service, SocketId id, SocketId server_id) : buffer_(2048), io_service_(io_service)
{
  LOG_DEBUG_ENTER;
 
  this->server_id_ = server_id;
  this->id_ = id;
 
  LOG_DEBUG_EXIT;
}
 
Client::~Client()
{
  LOG_DEBUG_ENTER;
 
  this->Stop();
 
  LOG_DEBUG_EXIT;
}
 
void Client::ConnectSlots(const SignalOnNewState::slot_type& slot_on_new_state, const SignalOnNewData::slot_type& slot_on_new_data)
{
  LOG_DEBUG_ENTER;
 
  this->signal_on_new_state_.connect(slot_on_new_state);
  this->signal_on_new_data_.connect(slot_on_new_data);
 
  LOG_DEBUG_EXIT;
}
 
SocketId Client::GetId()
{
  LOG_DEBUG_ENTER;
  LOG_DEBUG_EXIT;
 
  return this->id_;
}
 
SocketId Client::GetServerId()
{
  LOG_DEBUG_ENTER;
  LOG_DEBUG_EXIT;
 
  return this->server_id_;
}
 
void Client::Read()
{
  LOG_DEBUG_ENTER;
 
  this->buffer_.Clear();
 
  LOG_DEBUG_EXIT;
}
 
void Client::ReadHandler(const boost::system::error_code& error, size_t size)
{
  LOG_DEBUG_ENTER;
 
 
  if (error)
  {
    log::Debug(log_module_, "error %d", error);
   
    if (boost::system::errc::operation_canceled != error)
    {
      this->Disconnect();
    }
  }
  else if (size == 0)
  {
    log::Debug(log_module_, "size 0");
   
    this->Disconnect();
  }
  else
  {
    this->buffer_.SetSize(size);
   
    this->signal_on_new_data_(this->id_, this->server_id_, this->buffer_);
   
    this->Read();
  }
 
  LOG_DEBUG_EXIT;
}
 
void Client::Stop()
{
  LOG_DEBUG_ENTER;
  LOG_DEBUG_EXIT;
}
 
void Client::Disconnect()
{
  LOG_DEBUG_ENTER;
 
  if (this->id_ != 0)
  {
    SocketId id = this->id_;
     
    this->Stop();
       
    this->id_ = 0;
       
    this->signal_on_new_state_(id, this->server_id_, CLIENT_STATE_DISCONNECTED);
  }
 
  LOG_DEBUG_EXIT;
}
   
}; // namespace net
}; // namespace atom
 

Rev 1963	Rev 1971
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 "Client.h"	21	#include "Client.h"
22		22
23	#include <iostream>	23	#include <iostream>
24		24
25	#include <boost/bind.hpp>	25	#include <boost/bind.hpp>
26	#include <boost/lexical_cast.hpp>	26	#include <boost/lexical_cast.hpp>
27		27
28	#include "common/log.h"	28	#include "common/log.h"
29		29
30	namespace atom {	30	namespace atom {
31	namespace net {	31	namespace net {
32		32
33	static const std::string log_module_ = "net::client";	33	static const std::string log_module_ = "net::client";
34		34
35	Client::Client(boost::asio::io_service& io_service, SocketId id, SocketId server_id) : buffer_(2048), io_service_(io_service)	35	Client::Client(boost::asio::io_service& io_service, SocketId id, SocketId server_id) : buffer_(2048), io_service_(io_service)
36	{	36	{
37	LOG_DEBUG_ENTER;	37	LOG_DEBUG_ENTER;
38		38
39	this->server_id_ = server_id;	39	this->server_id_ = server_id;
40	this->id_ = id;	40	this->id_ = id;
41		41
42	LOG_DEBUG_EXIT;	42	LOG_DEBUG_EXIT;
43	}	43	}
44		44
45	Client::~Client()	45	Client::~Client()
46	{	46	{
47	LOG_DEBUG_ENTER;	47	LOG_DEBUG_ENTER;
48		48
49	this->Stop();	49	this->Stop();
50		50
51	LOG_DEBUG_EXIT;	51	LOG_DEBUG_EXIT;
52	}	52	}
53		53
54	void Client::ConnectSlots(const SignalOnNewState::slot_type& slot_on_new_state, const SignalOnNewData::slot_type& slot_on_new_data)	54	void Client::ConnectSlots(const SignalOnNewState::slot_type& slot_on_new_state, const SignalOnNewData::slot_type& slot_on_new_data)
55	{	55	{
56	LOG_DEBUG_ENTER;	56	LOG_DEBUG_ENTER;
57		57
58	this->signal_on_new_state_.connect(slot_on_new_state);	58	this->signal_on_new_state_.connect(slot_on_new_state);
59	this->signal_on_new_data_.connect(slot_on_new_data);	59	this->signal_on_new_data_.connect(slot_on_new_data);
60		60
61	LOG_DEBUG_EXIT;	61	LOG_DEBUG_EXIT;
62	}	62	}
63		63
64	SocketId Client::GetId()	64	SocketId Client::GetId()
65	{	65	{
66	LOG_DEBUG_ENTER;	66	LOG_DEBUG_ENTER;
67	LOG_DEBUG_EXIT;	67	LOG_DEBUG_EXIT;
68		68
69	return this->id_;	69	return this->id_;
70	}	70	}
71		71
72	SocketId Client::GetServerId()	72	SocketId Client::GetServerId()
73	{	73	{
74	LOG_DEBUG_ENTER;	74	LOG_DEBUG_ENTER;
75	LOG_DEBUG_EXIT;	75	LOG_DEBUG_EXIT;
76		76
77	return this->server_id_;	77	return this->server_id_;
78	}	78	}
79		79
80	void Client::Read()	80	void Client::Read()
81	{	81	{
82	LOG_DEBUG_ENTER;	82	LOG_DEBUG_ENTER;
83		83
84	this->buffer_.Clear();	84	this->buffer_.Clear();
85		85
86	LOG_DEBUG_EXIT;	86	LOG_DEBUG_EXIT;
87	}	87	}
88		88
89	void Client::ReadHandler(const boost::system::error_code& error, size_t size)	89	void Client::ReadHandler(const boost::system::error_code& error, size_t size)
90	{	90	{
91	LOG_DEBUG_ENTER;	91	LOG_DEBUG_ENTER;
-		92
92		93
93	if (error)	94	if (error)
-		95	{
-		96	log::Debug(log_module_, "error %d", error);
-		97
-		98	if (boost::system::errc::operation_canceled != error)
94	{	99	{
95	this->Disconnect();	100	this->Disconnect();
-		101	}
96	}	102	}
97	else if (size == 0)	103	else if (size == 0)
98	{	104	{
-		105	log::Debug(log_module_, "size 0");
-		106
99	this->Disconnect();	107	this->Disconnect();
100	}	108	}
101	else	109	else
102	{	110	{
103	this->buffer_.SetSize(size);	111	this->buffer_.SetSize(size);
104		112
105	this->signal_on_new_data_(this->id_, this->server_id_, this->buffer_);	113	this->signal_on_new_data_(this->id_, this->server_id_, this->buffer_);
106		114
107	this->Read();	115	this->Read();
108	}	116	}
109		117
110	LOG_DEBUG_EXIT;	118	LOG_DEBUG_EXIT;
111	}	119	}
112		120
113	void Client::Stop()	121	void Client::Stop()
114	{	122	{
115	LOG_DEBUG_ENTER;	123	LOG_DEBUG_ENTER;
116	LOG_DEBUG_EXIT;	124	LOG_DEBUG_EXIT;
117	}	125	}
118		126
119	void Client::Disconnect()	127	void Client::Disconnect()
120	{	128	{
121	LOG_DEBUG_ENTER;	129	LOG_DEBUG_ENTER;
122		130
123	if (this->id_ != 0)	131	if (this->id_ != 0)
124	{	132	{
125	SocketId id = this->id_;	133	SocketId id = this->id_;
126		134
127	this->Stop();	135	this->Stop();
128		136
129	this->id_ = 0;	137	this->id_ = 0;
130		138
131	this->signal_on_new_state_(id, this->server_id_, CLIENT_STATE_DISCONNECTED);	139	this->signal_on_new_state_(id, this->server_id_, CLIENT_STATE_DISCONNECTED);
132	}	140	}
133		141
134	LOG_DEBUG_EXIT;	142	LOG_DEBUG_EXIT;
135	}	143	}
136		144
137	}; // namespace net	145	}; // namespace net
138	}; // namespace atom	146	}; // namespace atom
139		147

Subversion Repositories HomeAutomation

(root)/trunk/PcSoftware/Atom1.5/src/net/Client.cpp – Rev 1963 → 1971