diff options
Diffstat (limited to 'cpp/src/qpid/sys/rdma')
| -rw-r--r-- | cpp/src/qpid/sys/rdma/rdma_factories.h | 4 | ||||
| -rw-r--r-- | cpp/src/qpid/sys/rdma/rdma_wrap.cpp | 7 | ||||
| -rw-r--r-- | cpp/src/qpid/sys/rdma/rdma_wrap.h | 2 |
3 files changed, 11 insertions, 2 deletions
diff --git a/cpp/src/qpid/sys/rdma/rdma_factories.h b/cpp/src/qpid/sys/rdma/rdma_factories.h index b568cadc7b..8d024f37aa 100644 --- a/cpp/src/qpid/sys/rdma/rdma_factories.h +++ b/cpp/src/qpid/sys/rdma/rdma_factories.h @@ -38,8 +38,8 @@ namespace Rdma { void destroyQp(::ibv_qp* qp) throw (); inline boost::shared_ptr< ::rdma_event_channel > mkEChannel() { - return - boost::shared_ptr< ::rdma_event_channel >(::rdma_create_event_channel(), destroyEChannel); + ::rdma_event_channel* c = CHECK_NULL(::rdma_create_event_channel()); + return boost::shared_ptr< ::rdma_event_channel >(c, destroyEChannel); } inline boost::shared_ptr< ::rdma_cm_id > diff --git a/cpp/src/qpid/sys/rdma/rdma_wrap.cpp b/cpp/src/qpid/sys/rdma/rdma_wrap.cpp index ac0813ffd6..9e249210d5 100644 --- a/cpp/src/qpid/sys/rdma/rdma_wrap.cpp +++ b/cpp/src/qpid/sys/rdma/rdma_wrap.cpp @@ -10,6 +10,13 @@ namespace Rdma { 5, // .retry_count 7 // .rnr_retry_count }; + + // This is moderately inefficient so don't use in a critical path + int deviceCount() { + int count; + ::ibv_free_device_list(::ibv_get_device_list(&count)); + return count; + } ::rdma_conn_param ConnectionEvent::getConnectionParam() const { // It's badly documented, but it seems from the librdma source code that all the following diff --git a/cpp/src/qpid/sys/rdma/rdma_wrap.h b/cpp/src/qpid/sys/rdma/rdma_wrap.h index 61d8281cee..7812a02532 100644 --- a/cpp/src/qpid/sys/rdma/rdma_wrap.h +++ b/cpp/src/qpid/sys/rdma/rdma_wrap.h @@ -47,6 +47,8 @@ namespace Rdma { const int DEFAULT_WR_ENTRIES = 64; extern const ::rdma_conn_param DEFAULT_CONNECT_PARAM; + int deviceCount(); + struct Buffer { friend class QueuePair; |