Subversion Repositories HomeAutomation

Rev

Rev 1963 | Show entire file | Regard whitespace | Details | Blame | Last modification | View Log | SVN | RSS feed

Rev 1963 Rev 1986
Line 32... Line 32...
32 
 
 32 
 
33 
Subscriber::Subscriber()
 33 
Subscriber::Subscriber()
34 
{
 34 
{
35 
  LOG_DEBUG_ENTER;
 35 
  LOG_DEBUG_ENTER;
36 
 
 36 
 
37 
  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).track(this->tracker_),
- 
 
 38 
                                    Manager::SignalOnNewClient::slot_type(&Subscriber::SlotOnNewClient, this, _1, _2).track(this->tracker_),
38 
                                    Manager::SignalOnNewData::slot_type(&Subscriber::SlotOnNewData, this, _1, _2, _3).track(this->tracker_));
 39 
                                    Manager::SignalOnNewData::slot_type(&Subscriber::SlotOnNewData, this, _1, _2).track(this->tracker_));
39 
 
 40 
 
40 
  LOG_DEBUG_EXIT;
 41 
  LOG_DEBUG_EXIT;
41 
}
 42 
}
42 
 
 43 
 
43 
Subscriber::~Subscriber()
 44 
Subscriber::~Subscriber()
44 
{
 45 
{
45 
  LOG_DEBUG_ENTER;
 46 
  LOG_DEBUG_ENTER;
46 
  LOG_DEBUG_EXIT;
 47 
  LOG_DEBUG_EXIT;
47 
}
 48 
}
48 
 
 49 
 
49 
void Subscriber::SlotOnNewData(SocketId client_id, SocketId server_id, common::Byteset data)
 50 
void Subscriber::SlotOnNewData(SocketId id, common::Byteset data)
50 
{
 51 
{
51 
  LOG_DEBUG_ENTER;
 52 
  LOG_DEBUG_ENTER;
52 
 
 53 
 
53 
  this->io_service_.post(boost::bind(&Subscriber::SlotOnNewDataHandler, this, client_id, server_id, data));
 54 
  this->io_service_.post(boost::bind(&Subscriber::SlotOnNewDataHandler, this, id, data));
54 
 
 55 
 
55 
  LOG_DEBUG_EXIT;
 56 
  LOG_DEBUG_EXIT;
56 
}
 57 
}
57 
 
 58 
 
58 
void Subscriber::SlotOnNewState(SocketId client_id, SocketId server_id, ClientState client_state)
 59 
void Subscriber::SlotOnNewClient(SocketId id, SocketId server_id)
59 
{
 60 
{
60 
  LOG_DEBUG_ENTER;
 61 
  LOG_DEBUG_ENTER;
61 
 
 62 
 
- 
 
 63 
  this->io_service_.post(boost::bind(&Subscriber::SlotOnNewClientHandler, this, id, server_id));
- 
 
 64 
 
- 
 
 65 
  LOG_DEBUG_EXIT;
- 
 
 66 
}
- 
 
 67 
 
- 
 
 68 
 
- 
 
 69 
void Subscriber::SlotOnNewState(SocketId id, ClientState client_state)
- 
 
 70 
{
- 
 
 71 
  LOG_DEBUG_ENTER;
- 
 
 72 
 
62 
  this->io_service_.post(boost::bind(&Subscriber::SlotOnNewStateHandler, this, client_id, server_id, client_state));
 73 
  this->io_service_.post(boost::bind(&Subscriber::SlotOnNewStateHandler, this, id, client_state));
63 
 
 74 
 
64 
  LOG_DEBUG_EXIT;
 75 
  LOG_DEBUG_EXIT;
65 
}
 76 
}
66 
 
 77 
 
67 
 
 78