update sources to ceph Nautilus 14.2.1

[ceph.git] / ceph / src / msg / async / dpdk / UserspaceEvent.cc

diff --git a/ceph/src/msg/async/dpdk/UserspaceEvent.cc b/ceph/src/msg/async/dpdk/UserspaceEvent.cc
index 25b082d613bb73a4446fae08bf0fb90573877b46..282dcef12f60d570156266df15f263309fe43c67 100644 (file)
--- a/ceph/src/msg/async/dpdk/UserspaceEvent.cc
+++ b/ceph/src/msg/async/dpdk/UserspaceEvent.cc
@@ -16,7 +16,7 @@
 #include "UserspaceEvent.h"
 
 #include "common/dout.h"
-#include "include/assert.h"
+#include "include/ceph_assert.h"
 
 #define dout_subsys ceph_subsys_dpdk
 #undef dout_prefix
@@ -34,7 +34,7 @@ int UserspaceEventManager::get_eventfd()
   }
 
   Tub<UserspaceFDImpl> &impl = fds[fd];
-  assert(!impl);
+  ceph_assert(!impl);
   impl.construct();
   ldout(cct, 20) << __func__ << " fd=" << fd << dendl;
   return fd;
@@ -88,7 +88,7 @@ void UserspaceEventManager::close(int fd)
 
   if (impl->activating_mask) {
     if (waiting_fds[max_wait_idx] == fd) {
-      assert(impl->waiting_idx == max_wait_idx);
+      ceph_assert(impl->waiting_idx == max_wait_idx);
       --max_wait_idx;
     }
     waiting_fds[impl->waiting_idx] = -1;
@@ -101,7 +101,7 @@ int UserspaceEventManager::poll(int *events, int *masks, int num_events, struct
   int fd;
   uint32_t i = 0;
   int count = 0;
-  assert(num_events);
+  ceph_assert(num_events);
   // leave zero slot for waiting_fds
   while (i < max_wait_idx) {
     fd = waiting_fds[++i];
@@ -110,9 +110,9 @@ int UserspaceEventManager::poll(int *events, int *masks, int num_events, struct
 
     events[count] = fd;
     Tub<UserspaceFDImpl> &impl = fds[fd];
-    assert(impl);
+    ceph_assert(impl);
     masks[count] = impl->listening_mask & impl->activating_mask;
-    assert(masks[count]);
+    ceph_assert(masks[count]);
     ldout(cct, 20) << __func__ << " fd=" << fd << " mask=" << masks[count] << dendl;
     impl->activating_mask &= (~masks[count]);
     impl->waiting_idx = 0;