Method serve

src/mgr/PyModuleRunner.cc:40–81

}

int PyModuleRunner::serve()
{
  ceph_assert(pClassInstance != nullptr);

  // This method is called from a separate OS thread (i.e. a thread not
  // created by Python), so tell Gil to wrap this in a new thread state.
  Gil gil(py_module->pMyThreadState, true);
  if (py_module->perfcounter) {
    py_module->perfcounter->set(py_module->l_pym_alive, 1);
  }
  auto pValue = PyObject_CallMethod(pClassInstance,
      const_cast<char*>("serve"), nullptr);

  int r = 0;
  if (pValue != NULL) {
    Py_DECREF(pValue);
  } else {
    // This is not a very informative log message because it's an
    // unknown/unexpected exception that we can't say much about.


    // Get short exception message for the cluster log, before
    // dumping the full backtrace to the local log.
    std::string exc_msg = peek_pyerror();
    
    clog->error() << "Unhandled exception from module '" << get_name()
                  << "' while running on mgr." << g_conf()->name.get_id()
                  << ": " << exc_msg;
    derr << get_name() << ".serve:" << dendl;
    derr << handle_pyerror(true, get_name(), "PyModuleRunner::serve") << dendl;

    py_module->fail(exc_msg);

    return -EINVAL;
  }

  if (py_module->perfcounter) {
    py_module->perfcounter->set(py_module->l_pym_alive, 0);
  }

  return r;
}

void PyModuleRunner::shutdown()
{