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

Subversion Repositories HomeAutomation

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