Subversion Repositories HomeAutomation

Rev

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

Rev 1959 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 "Subscriber.h"
 21 
#include "Subscriber.h"
22 
 
 22 
 
23 
#include <boost/bind.hpp>
 23 
#include <boost/bind.hpp>
24 
 
 24 
 
25 
#include "Manager.h"
 25 
#include "Manager.h"
- 
 
 26 
#include "common/log.h"
26 
 
 27 
 
27 
namespace atom {
 28 
namespace atom {
28 
namespace net {
 29 
namespace net {
- 
 
 30 
 
- 
 
 31 
static const std::string log_module_ = "net::subscriber";
29 
 
 32 
 
30 
Subscriber::Subscriber()
 33 
Subscriber::Subscriber()
31 
{
 34 
{
- 
 
 35 
  LOG_DEBUG_ENTER;
- 
 
 36 
 
32 
    Manager::Instance()->ConnectSlots(Manager::SignalOnNewState::slot_type(&Subscriber::SlotOnNewState, this, _1, _2, _3).track(this->tracker_),
 37 
  Manager::Instance()->ConnectSlots(Manager::SignalOnNewState::slot_type(&Subscriber::SlotOnNewState, this, _1, _2, _3).track(this->tracker_),
33 
                                      Manager::SignalOnNewData::slot_type(&Subscriber::SlotOnNewData, this, _1, _2, _3).track(this->tracker_));
 38 
                                    Manager::SignalOnNewData::slot_type(&Subscriber::SlotOnNewData, this, _1, _2, _3).track(this->tracker_));
- 
 
 39 
 
- 
 
 40 
  LOG_DEBUG_EXIT;
34 
}
 41 
}
35 
 
 42 
 
36 
Subscriber::~Subscriber()
 43 
Subscriber::~Subscriber()
37 
{
 44 
{
- 
 
 45 
  LOG_DEBUG_ENTER;
- 
 
 46 
  LOG_DEBUG_EXIT;
38 
}
 47 
}
39 
 
 48 
 
40 
void Subscriber::SlotOnNewData(SocketId client_id, SocketId server_id, common::Byteset data)
 49 
void Subscriber::SlotOnNewData(SocketId client_id, SocketId server_id, common::Byteset data)
41 
{
 50 
{
42 
    common::Byteset temp_buffer(data);
 51 
  LOG_DEBUG_ENTER;
- 
 
 52 
 
43 
    this->io_service_.post(boost::bind(&Subscriber::SlotOnNewDataHandler, this, client_id, server_id, temp_buffer));
 53 
  this->io_service_.post(boost::bind(&Subscriber::SlotOnNewDataHandler, this, client_id, server_id, data));
- 
 
 54 
 
- 
 
 55 
  LOG_DEBUG_EXIT;
44 
}
 56 
}
45 
 
 57 
 
46 
void Subscriber::SlotOnNewState(SocketId client_id, SocketId server_id, ClientState client_state)
 58 
void Subscriber::SlotOnNewState(SocketId client_id, SocketId server_id, ClientState client_state)
47 
{
 59 
{
- 
 
 60 
  LOG_DEBUG_ENTER;
- 
 
 61 
 
48 
    this->io_service_.post(boost::bind(&Subscriber::SlotOnNewStateHandler, this, client_id, server_id, client_state));
 62 
  this->io_service_.post(boost::bind(&Subscriber::SlotOnNewStateHandler, this, client_id, server_id, client_state));
- 
 
 63 
 
- 
 
 64 
  LOG_DEBUG_EXIT;
49 
}
 65 
}
- 
 
 66 
 
50 
 
 67 
 
51 
}; // namespace net
 68 
}; // namespace net
52 
}; // namespace atom
 69 
}; // namespace atom
53 
 
 70