update ceph source to reef 18.1.2

[ceph.git] / ceph / src / crimson / os / alienstore / thread_pool.h

diff --git a/ceph/src/crimson/os/alienstore/thread_pool.h b/ceph/src/crimson/os/alienstore/thread_pool.h
index 8f3069af3a5a595291866beb76aaf3397da992b6..78e18219a88a7143a7a84bb777abd796ca32f7db 100644 (file)
--- a/ceph/src/crimson/os/alienstore/thread_pool.h
+++ b/ceph/src/crimson/os/alienstore/thread_pool.h
@@ -11,6 +11,7 @@
 #include <seastar/core/future.hh>
 #include <seastar/core/gate.hh>
 #include <seastar/core/reactor.hh>
+#include <seastar/core/resource.hh>
 #include <seastar/core/semaphore.hh>
 #include <seastar/core/sharded.hh>
 
@@ -125,7 +126,7 @@ public:
    * @note each @c Task has its own crimson::thread::Condition, which possesses
    * an fd, so we should keep the size of queue under a reasonable limit.
    */
-  ThreadPool(size_t n_threads, size_t queue_sz, std::vector<uint64_t> cpus);
+  ThreadPool(size_t n_threads, size_t queue_sz, const std::optional<seastar::resource::cpuset>& cpus);
   ~ThreadPool();
   seastar::future<> start();
   seastar::future<> stop();
@@ -163,7 +164,7 @@ private:
   bool is_stopping() const {
     return stopping.load(std::memory_order_relaxed);
   }
-  static void pin(const std::vector<uint64_t>& cpus);
+  static void pin(const seastar::resource::cpuset& cpus);
   static void block_sighup();
   seastar::semaphore& local_free_slots() {
     return submit_queue.local().free_slots;