Method ping

src/connection.cxx:420–476

}

PyObject*
Connection::ping(PyObject* kwargs)
{
  std::optional<std::string> report_id;
  extract_field<std::optional<std::string>>(kwargs, "report_id", report_id);
  std::optional<std::string> bucket_name;
  extract_field<std::optional<std::string>>(kwargs, "bucket_name", bucket_name);
  std::optional<std::chrono::milliseconds> timeout_ms;
  extract_field<std::optional<std::chrono::milliseconds>>(kwargs, "timeout", timeout_ms);
  std::set<couchbase::core::service_type> services;
  extract_field<std::set<couchbase::core::service_type>>(kwargs, "services", services);

  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_.ping(
        report_id,
        bucket_name,
        services,
        timeout_ms,
        [pyObj_callback, pyObj_errback, barrier, this](couchbase::core::diag::ping_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;
  }
}