Method close

src/connection.cxx:186–233

}

PyObject*
Connection::close(PyObject* kwargs)
{
  PyObject* pyObj_callback = kwargs ? PyDict_GetItemString(kwargs, "callback") : nullptr;
  PyObject* pyObj_errback = kwargs ? PyDict_GetItemString(kwargs, "errback") : nullptr;

  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_.close([callback = pyObj_callback, errback = pyObj_errback, barrier, this]() {
        handle_connection_operation_callback(std::error_code{},
                                             "close",
                                             callback,
                                             errback,
                                             barrier,
                                             connection_state_action::set_disconnected);
      });
    }
    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::open_bucket(PyObject* kwargs)