beacon/detail/signal_base.cpp

   1 /**
   2  * beacon
   3  * Author: Lukas Krejci <krejci.l@centrum.cz>, (C) 2008
   4  * Copyright: See COPYING file that comes with this distribution
   5  */
   6
   7 #include <beacon/detail/signal_base.hpp>
   8 #include <beacon/detail/connection_impl.hpp>
   9
  10 namespace beacon {
  11
  12 namespace detail {
  13
  14 //a helper function to signal_base::do_disconnect and signal_base::clear
  15 void invalidate_slot(signal_base::slot_list_type::iterator & pos) {
  16     if (pos->loop != 0) {
  17         pos->loop->dequeue(pos->connection->token());
  18     }
  19     delete pos->slot;
  20 }
  21
  22 //a helper for do_connect methods
  23 intrusive_ptr<connection_impl_base> signal_base::_init_connection(signal_base::slot_list_item & item) {
  24
  25     _slots.push_back(item);
  26
  27     connection_impl * inited = new connection_impl(this, --_slots.end());
  28
  29     intrusive_ptr<connection_impl_base> ip(inited);
  30
  31     slot_list_item & ret = _slots.back();
  32     ret.connection.swap(ip);
  33
  34     return intrusive_ptr<connection_impl_base>(ret.connection);
  35 }
  36
  37 intrusive_ptr<connection_impl_base> signal_base::do_connect(slot_base * slot, trackable * obj) {
  38
  39     slot_list_item item;
  40     item.slot = slot;
  41     if (obj != 0) {
  42         item.loop = obj->current_event_loop();
  43     }
  44
  45     wait(_slots_guard);
  46
  47     intrusive_ptr<connection_impl_base> ret = _init_connection(item);
  48
  49     //this must be inside lock so that we can be sure that
  50     //we do not disconnect the connection before it was inited
  51     //in the trackable, otherwise we could have races.
  52     if (obj != 0) {
  53         obj->add_connection(ret);
  54     }
  55
  56     notify(_slots_guard);
  57
  58     return ret;
  59 }
  60
  61 intrusive_ptr<connection_impl_base> signal_base::do_connect(slot_base * slot, event_loop & loop) {
  62     slot_list_item item;
  63     item.slot = slot;
  64     item.loop = &loop;
  65
  66     wait(_slots_guard);
  67
  68     intrusive_ptr<connection_impl_base> ret = _init_connection(item);
  69
  70     notify(_slots_guard);
  71
  72     return ret;
  73 }
  74
  75 void signal_base::do_disconnect(slot_list_type::iterator pos) {
  76     wait(_slots_guard);
  77     invalidate_slot(pos);
  78     _slots.erase(pos);
  79     notify(_slots_guard);
  80 }
  81
  82 void signal_base::clear() {
  83     wait(_slots_guard);
  84
  85     for(slot_list_type::iterator it = _slots.begin(); it != _slots.end(); ++it) {
  86         invalidate_slot(it);
  87     }
  88
  89     _slots.clear();
  90
  91     notify(_slots_guard);
  92 }
  93
  94 signal_base::slot_list_type signal_base::get_slots_copy() {
  95     wait(_slots_guard);
  96     slot_list_type ret = _slots;
  97     notify(_slots_guard);
  98     return ret;
  99 }
 100
 101 } //namespace detail
 102
 103 } //namespace beacon