Method init

src/mgr/PyModuleRegistry.cc:45–133

};

void PyModuleRegistry::init()
{
  std::lock_guard locker(lock);

  // Set up global python interpreter
#define WCHAR(s) L ## #s
  PyConfig py_config;
  // do not enable isolated mode, otherwise we would not be able to have access
  // to the site packages. since we cannot import any module before initializing
  // the interpreter, we would not be able to use "site" module for retrieving
  // the path to site packager. we import "site" module for retrieving
  // sitepackages in Python < 3.8 though, this does not apply to the
  // initialization with PyConfig.
  PyConfig_InitPythonConfig(&py_config);
  BOOST_SCOPE_EXIT_ALL(&py_config) {
    PyConfig_Clear(&py_config);
  };
#if PY_VERSION_HEX >= 0x030b0000
  py_config.safe_path = 0;
#endif
  py_config.parse_argv = 0;
  py_config.configure_c_stdio = 0;
  py_config.install_signal_handlers = 0;
  py_config.pathconfig_warnings = 0;

  PyStatus status;
  status = PyConfig_SetString(&py_config, &py_config.program_name, WCHAR(MGR_PYTHON_EXECUTABLE));
  ceph_assertf(!PyStatus_Exception(status), "PyConfig_SetString: %s:%s", status.func, status.err_msg);
  // Some python modules do not cope with an unpopulated argv, so lets
  // fake one.  This step also picks up site-packages into sys.path.
  const wchar_t* argv[] = {L"ceph-mgr"};
  status = PyConfig_SetArgv(&py_config, 1, (wchar_t *const *)argv);
  ceph_assertf(!PyStatus_Exception(status), "PyConfig_SetArgv: %s:%s", status.func, status.err_msg);
  // Add more modules
  if (g_conf().get_val<bool>("daemonize")) {
    PyImport_AppendInittab("ceph_logger", PyModule::init_ceph_logger);
  }
  PyImport_AppendInittab("ceph_module", PyModule::init_ceph_module);
  // Configure sys.path to include mgr_module_path
  auto pythonpath_env = g_conf().get_val<std::string>("mgr_module_path");
  if (const char* pythonpath = getenv("PYTHONPATH")) {
    pythonpath_env += ":";
    pythonpath_env += pythonpath;
  }
  status = PyConfig_SetBytesString(&py_config, &py_config.pythonpath_env, pythonpath_env.data());
  ceph_assertf(!PyStatus_Exception(status), "PyConfig_SetBytesString: %s:%s", status.func, status.err_msg);
  dout(10) << "set PYTHONPATH to " << std::quoted(pythonpath_env) << dendl;
  status = Py_InitializeFromConfig(&py_config);
  ceph_assertf(!PyStatus_Exception(status), "Py_InitializeFromConfig: %s:%s", status.func, status.err_msg);
#undef WCHAR

  // Drop the GIL and remember the main thread state (current
  // thread state becomes NULL)
  pMainThreadState = PyEval_SaveThread();
  ceph_assert(pMainThreadState != nullptr);

  std::list<std::string> failed_modules;
  thread_monitor->start_monitoring();