Method start_one

src/mgr/ActivePyModules.cc:556–602

}

void ActivePyModules::start_one(PyModuleRef py_module)
{
  std::lock_guard l(lock);

  const auto name = py_module->get_name();
  auto active_module = std::make_shared<ActivePyModule>(py_module, clog, m_thread_monitor);

  pending_modules.insert(name);
  // Send all python calls down a Finisher to avoid blocking
  // C++ code, and avoid any potential lock cycles.
  finisher.queue(new LambdaContext([this, active_module, name, py_module](int) {
    // Delay loading in testing scenarios
    auto delay = g_conf().get_val<std::chrono::milliseconds>("mgr_module_load_delay");
    std::string delayed_module = g_conf().get_val<std::string>("mgr_module_load_delay_name");
    if ((name == delayed_module) && (delay > std::chrono::milliseconds{0})) {
      dout(4) << "Delaying load time for module '" << name
              << "' by " << delay << "..." << dendl;
      std::this_thread::sleep_for(delay);
    }
    int r = active_module->load(this);
    std::lock_guard l(lock);
    pending_modules.erase(name);
    if (r != 0) {
      derr << "Failed to run module in active mode ('" << name << "')"
           << dendl;
    } else {
      auto em = modules.emplace(name, active_module);
      ceph_assert(em.second); // actually inserted
      active_module->thread.create(active_module->get_thread_name());
      py_module->perf_counter_build(g_ceph_context);
      active_module->finisher.start();
      active_module->finisher.on_started().wait();
      active_module->set_native_tid(active_module->finisher.get_tid());
      if (m_thread_monitor) {
        m_thread_monitor->register_thread(active_module->get_native_tid(), 
          active_module->thread.get_tid(),
          name, py_module);
      }
    }

    // Signal when we're finally done starting up modules
    if (pending_modules.empty() && recheck_modules_start) {
      finisher.queue(recheck_modules_start);
      recheck_modules_start = nullptr;
    }
  }));
}

void ActivePyModules::notify_all(const std::string &notify_type,
                     const std::string &notify_id)