Subversion Repositories HomeAutomation

Rev

Rev 1592 | Rev 1594 | Go to most recent revision | Only display areas with differences | Regard whitespace | Details | Blame | Last modification | View Log | SVN | RSS feed

Rev 1592 Rev 1593
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 
namespace atom {
 28 
namespace atom {
29 
namespace net {
 29 
namespace net {
30 
 
 30 
 
31 
Client::Client(boost::asio::io_service& io_service, ClientId id, ServerId server_id)
 31 
Client::Client(boost::asio::io_service& io_service, ClientId id, ServerId server_id)
32 
{
 32 
{
33 
    this->server_id_ = server_id;
 33 
    this->server_id_ = server_id;
34 
    this->id = id;
 34 
    this->id_ = id;
35 
}
 35 
}
36 
 
 36 
 
37 
Client::~Client()
 37 
Client::~Client()
38 
{
 38 
{
39 
}
 39 
}
40 
 
 40 
 
41 
void Client::ConnectSlots(const SignalOnNewState::slot_type& slot_on_new_state, const SignalOnNewData::slot_type& slot_on_new_data)
 41 
void Client::ConnectSlots(const SignalOnNewState::slot_type& slot_on_new_state, const SignalOnNewData::slot_type& slot_on_new_data)
42 
{
 42 
{
43 
    this->signal_on_new_state_.connect(slot_on_new_state);
 43 
    this->signal_on_new_state_.connect(slot_on_new_state);
44 
    this->signal_on_new_data_.connect(slot_on_new_data);
 44 
    this->signal_on_new_data_.connect(slot_on_new_data);
45 
}
 45 
}
46 
 
 46 
 
47 
ClientId Client::GetId()
 47 
ClientId Client::GetId()
48 
{
 48 
{
49 
    return this->id;
 49 
    return this->id_;
50 
}
 50 
}
51 
 
 51 
 
52 
ServerId Client::GetServerId()
 52 
ServerId Client::GetServerId()
53 
{
 53 
{
54 
    return this->server_id_;
 54 
    return this->server_id_;
55 
}
 55 
}
56 
 
 56 
 
57 
void Client::Read()
 57 
void Client::Read()
58 
{
 58 
{
59 
    this->buffer_.assign(0);
 59 
    this->buffer_.assign(0);
60 
}
 60 
}
61 
 
 61 
 
62 
void Client::ReadHandler(const boost::system::error_code& error, size_t size)
 62 
void Client::ReadHandler(const boost::system::error_code& error, size_t size)
63 
{
 63 
{
64 
    if (error)
 64 
    if (error)
65 
    {
 65 
    {
66 
        this->Disconnect();
 66 
        this->Disconnect();
67 
    }
 67 
    }
68 
    else if (size == 0)
 68 
    else if (size == 0)
69 
    {
 69 
    {
70 
        this->Disconnect();
 70 
        this->Disconnect();
71 
    }
 71 
    }
72 
    else
 72 
    else
73 
    {
 73 
    {
74 
        this->signal_on_new_data_(this->id, this->buffer_);
 74 
        this->signal_on_new_data_(this->id_, this->server_id_, this->buffer_);
75 
       
 75 
       
76 
        this->Read();
 76 
        this->Read();
77 
    }
 77 
    }
78 
}
 78 
}
79 
 
 79 
 
80 
void Client::Disconnect()
 80 
void Client::Disconnect()
81 
{
 81 
{
82 
    this->signal_on_new_state_(this->id, CLIENT_STATE_DISCONNECTED);
 82 
    this->signal_on_new_state_(this->id_, this->server_id_, CLIENT_STATE_DISCONNECTED);
83 
}
 83 
}
84 
   
 84 
   
85 
}; // namespace net
 85 
}; // namespace net
86 
}; // namespace atom
 86 
}; // namespace atom
87 
 
 87