update source to Ceph Pacific 16.2.2

[ceph.git] / ceph / src / msg / async / rdma / Infiniband.h

diff --git a/ceph/src/msg/async/rdma/Infiniband.h b/ceph/src/msg/async/rdma/Infiniband.h
index 3af89f304fe1e4cda94e985aa28b5682ebdb7013..f18442e4e6929d0108261267ba4d8b76532ae20d 100644 (file)
--- a/ceph/src/msg/async/rdma/Infiniband.h
+++ b/ceph/src/msg/async/rdma/Infiniband.h
@@ -251,6 +251,9 @@ class Infiniband {
         return c >= base && c < end;
       }
 
+      bool is_valid_chunk(const Chunk* c) const {
+        return c >= chunk_base && c < chunk_base + num_chunk;
+      }
       MemoryManager& manager;
       uint32_t buffer_size;
       uint32_t num_chunk = 0;
@@ -346,6 +349,7 @@ class Infiniband {
     void return_tx(std::vector<Chunk*> &chunks);
     int get_send_buffers(std::vector<Chunk*> &c, size_t bytes);
     bool is_tx_buffer(const char* c) { return send->is_my_buffer(c); }
+    bool is_valid_chunk(const Chunk* c) { return send->is_valid_chunk(c); }
     Chunk *get_tx_chunk_by_buffer(const char *c) {
       return send->get_chunk_by_buffer(c);
     }
@@ -549,7 +553,7 @@ class Infiniband {
     uint32_t     max_recv_wr;
     uint32_t     q_key;
     bool dead;
-    vector<Chunk*> recv_queue;
+    std::vector<Chunk*> recv_queue;
     ceph::mutex lock = ceph::make_mutex("queue_pair_lock");
   };