Method open_bucket

src/connection.cxx:235–282

}

PyObject*
Connection::open_bucket(PyObject* kwargs)
{
  PyObject* pyObj_bucket_name = PyDict_GetItemString(kwargs, "bucket_name");
  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 {
    std::string bucket_name = std::string(PyUnicode_AsUTF8(pyObj_bucket_name));

    Py_BEGIN_ALLOW_THREADS
    {
      cluster_.open_bucket(
        bucket_name,
        [callback = pyObj_callback, errback = pyObj_errback, barrier, this](std::error_code ec) {
          handle_connection_operation_callback(ec, "open_bucket", callback, 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::close_bucket(PyObject* kwargs)