Subversion Repositories HomeAutomation

Rev

Rev 1593 | Go to most recent revision | Details | Last modification | View Log | SVN | RSS feed

Rev Author Line No. Line
1592 runge 1
/*
2
 *
3
 *  Copyright (C) 2010  Mattias Runge
4
 *
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
7
 *  the Free Software Foundation; either version 2 of the License, or
8
 *  (at your option) any later version.
9
 *
10
 *  This program is distributed in the hope that it will be useful,
11
 *  but WITHOUT ANY WARRANTY; without even the implied warranty of
12
 *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
13
 *  GNU General Public License for more details.
14
 *
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.,
17
 *  51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
18
 *
19
 */
20
 
21
#include "Client.h"
22
 
23
#include <iostream>
24
 
25
#include <boost/bind.hpp>
26
#include <boost/lexical_cast.hpp>
27
 
28
namespace atom {
29
namespace net {
30
 
31
Client::Client(boost::asio::io_service& io_service, ClientId id, ServerId server_id)
32
{
33
    this->server_id_ = server_id;
34
    this->id = id;
35
}
36
 
37
Client::~Client()
38
{
39
}
40
 
41
void Client::ConnectSlots(const SignalOnNewState::slot_type& slot_on_new_state, const SignalOnNewData::slot_type& slot_on_new_data)
42
{
43
    this->signal_on_new_state_.connect(slot_on_new_state);
44
    this->signal_on_new_data_.connect(slot_on_new_data);
45
}
46
 
47
ClientId Client::GetId()
48
{
49
    return this->id;
50
}
51
 
52
ServerId Client::GetServerId()
53
{
54
    return this->server_id_;
55
}
56
 
57
void Client::Read()
58
{
59
    this->buffer_.assign(0);
60
}
61
 
62
void Client::ReadHandler(const boost::system::error_code& error, size_t size)
63
{
64
    if (error)
65
    {
66
        this->Disconnect();
67
    }
68
    else if (size == 0)
69
    {
70
        this->Disconnect();
71
    }
72
    else
73
    {
74
        this->signal_on_new_data_(this->id, this->buffer_);
75
 
76
        this->Read();
77
    }
78
}
79
 
80
void Client::Disconnect()
81
{
82
    this->signal_on_new_state_(this->id, CLIENT_STATE_DISCONNECTED);
83
}
84
 
85
}; // namespace net
86
}; // namespace atom