ready signal for cluster announce and publish

include/cocaine/context.hpp

@@ -92,6 +92,9 @@ class context_t {
  // Fired first thing on context shutdown. This is a very good time to cleanup persistent
  // connections, synchronize disk state and so on.
  context_signals_t shutdown;
+
+ // Fired on all static service creation.
+ context_signals_t ready;
  };
 
  // Lifecycle management signals.

src/cluster/multicast.cpp

@@ -135,8 +135,8 @@ multicast_t::multicast_t(context_t& context, interface& locator, const std::stri
  std::bind(&multicast_t::on_receive, this, ph::_1, ph::_2, announce)
  );
 
- m_timer.expires_from_now(m_cfg.interval);
- m_timer.async_wait(std::bind(&multicast_t::on_publish, this, ph::_1));
+ //First publish right after all service are started.
+ context.signals.ready.connect(std::bind(&multicast_t::on_publish, this, std::error_code()));
 }
 
 multicast_t::~multicast_t() {

src/cluster/predefine.cpp

@@ -106,8 +106,8 @@ predefine_t::predefine_t(context_t& context, interface& locator, const std::stri
  );
  }
 
- m_timer.expires_from_now(m_cfg.interval);
- m_timer.async_wait(std::bind(&predefine_t::on_announce, this, ph::_1));
+ //First announce right after all service are started.
+ context.signals.ready.connect(std::bind(&predefine_t::on_announce, this, std::error_code()));
 }
 
 predefine_t::~predefine_t() {

src/context.cpp

@@ -260,6 +260,8 @@ context_t::bootstrap() {
  }
  }
 
+ signals.ready();
+
  if(!errored.empty()) {
  std::ostringstream stream;
  std::ostream_iterator<char> builder(stream);