Method diagnostics

src/connection.cxx:370–418

}

PyObject*
Connection::diagnostics(PyObject* kwargs)
{
  std::optional<std::string> report_id;
  extract_field<std::optional<std::string>>(kwargs, "report_id", report_id);

  PyObject* pyObj_callback = PyDict_GetItemString(kwargs, "callback");
  PyObject* pyObj_errback = PyDict_GetItemString(kwargs, "errback");

  if (!validate_and_incref_callbacks(pyObj_callback, pyObj_errback)) {
    return nullptr;
  }

  std::shared_ptr<std::promise<PyObject*>> barrier = nullptr;
  std::future<PyObject*> fut;
  if (nullptr == pyObj_callback && nullptr == pyObj_errback) {
    barrier = std::make_shared<std::promise<PyObject*>>();
    fut = barrier->get_future();
  }

  try {
    Py_BEGIN_ALLOW_THREADS
    {
      cluster_.diagnostics(report_id,
                           [pyObj_callback, pyObj_errback, barrier, this](
                             couchbase::core::diag::diagnostics_result resp) {
                             handle_cluster_operation_callback(
                               resp, pyObj_callback, pyObj_errback, barrier);
                           });
    }
    Py_END_ALLOW_THREADS

      if (barrier)
    {
      PyObject* result = nullptr;
      Py_BEGIN_ALLOW_THREADS result = fut.get();
      Py_END_ALLOW_THREADS return result;
    }
    Py_RETURN_NONE;
  } catch (const std::exception& e) {
    if (barrier) {
      barrier->set_value(nullptr);
    }
    PyErr_SetString(PyExc_RuntimeError, e.what());
    Py_XDECREF(pyObj_callback);
    Py_XDECREF(pyObj_errback);
    return nullptr;
  }
}

PyObject*
Connection::ping(PyObject* kwargs)