Method dispatch_remote

src/mgr/ActivePyModule.cc:144–227

}

std::optional<std::vector<std::byte>> ActivePyModule::dispatch_remote(
    const std::string &method,
    std::span<std::byte const> pickled_args,
    std::span<std::byte const> pickled_kwargs,
    std::string *err)
{
  ceph_assert(err != nullptr);

  // deserialize arguments.

  Gil gil(py_module->pMyThreadState, true);

  auto pmodule = py_module->pPickleModule;
  auto pickled_args_bytes = py_bytes_from_span(pickled_args);
  auto args = PyObject_CallMethodObjArgs(
    pmodule,
    PyUnicode_FromString("loads"),
    pickled_args_bytes,
    nullptr);
  Py_DECREF(pickled_args_bytes);
  if (args == nullptr) {
    std::string caller = "ActivePyModule::dispatch_remote "s + method;
    *err = handle_pyerror(true, get_name(), caller);
    derr << "Failed to deserialize (pickle.loads) args: " << *err << dendl;
    return std::nullopt;
  }

  auto pickled_kwargs_bytes = py_bytes_from_span(pickled_kwargs);
  auto kwargs = PyObject_CallMethodObjArgs(
    pmodule,
    PyUnicode_FromString("loads"),
    pickled_kwargs_bytes,
    nullptr);
  Py_DECREF(pickled_kwargs_bytes);
  if (kwargs == nullptr) {
    std::string caller = "ActivePyModule::dispatch_remote "s + method;
    *err = handle_pyerror(true, get_name(), caller);
    derr << "Failed to deserialize (pickle.loads) kwargs: " << *err << dendl;

    Py_DECREF(args);
    return std::nullopt;
  }

  // Fire the receiving method
  auto boundMethod = PyObject_GetAttrString(pClassInstance, method.c_str());

  // Caller should have done method_exists check first!
  ceph_assert(boundMethod != nullptr);

  dout(20) << "Calling " << py_module->get_name()
           << "." << method << "..." << dendl;

  auto ret = PyObject_Call(boundMethod,
      args, kwargs);
  Py_DECREF(boundMethod);
  Py_DECREF(kwargs);
  Py_DECREF(args);
  if (ret == nullptr) {