Method handle_connection_operation_callback

src/connection.cxx:77–127

}

void
Connection::handle_connection_operation_callback(std::error_code ec,
                                                 const char* operation,
                                                 PyObject* pyObj_callback,
                                                 PyObject* pyObj_errback,
                                                 std::shared_ptr<std::promise<PyObject*>> barrier,
                                                 connection_state_action state_action)
{
  PyGILState_STATE state = PyGILState_Ensure();

  PyObject* result = nullptr;

  if (ec) {
    std::string msg = "Failed to ";
    msg += operation;
    result = build_exception(ec, __FILE__, __LINE__, msg.c_str());

    if (pyObj_errback != nullptr) {
      PyObject* ret = PyObject_CallFunctionObjArgs(pyObj_errback, result, nullptr);
      Py_XDECREF(ret);
      Py_XDECREF(result);
    } else if (barrier) {
      barrier->set_value(result);
    } else {
      Py_XDECREF(result);
    }
  } else {
    if (state_action == connection_state_action::set_connected) {
      connected_ = true;
    } else if (state_action == connection_state_action::set_disconnected) {
      connected_ = false;
    }

    Py_INCREF(Py_None);
    result = Py_None;

    if (pyObj_callback != nullptr) {
      PyObject* ret = PyObject_CallFunctionObjArgs(pyObj_callback, result, nullptr);
      Py_XDECREF(ret);
      Py_XDECREF(result);
    } else if (barrier) {
      barrier->set_value(result);
    } else {
      Py_XDECREF(result);
    }
  }

  Py_XDECREF(pyObj_callback);
  Py_XDECREF(pyObj_errback);
  PyGILState_Release(state);
}

PyObject*
Connection::connect(PyObject* kwargs)