c++|be| separate iouring options into its own header

Summary:
**WHAT**
moving options into it's own header file

**WHY**
cleaning up the iouringbackend. Between the header and cpp file it's over 3000 lines.

Reviewed By: spikeh

Differential Revision: D92347271

fbshipit-source-id: 72c93dd66bd2c6f9102046fe70f19a745ddde7a1

Author: Juanlu Herrero

folly/io/async/BUCK

@@ -896,6 +896,7 @@ fb_dirsync_cpp_library(
     headers = [
         "IoUringBackend.h",
         "IoUringBase.h",
+        "IoUringOptions.h",
     ],
     modular_headers = False,
     use_raw_headers = True,

folly/io/async/CMakeLists.txt

@@ -512,6 +512,7 @@ folly_add_library(
   HEADERS
     IoUringBackend.h
     IoUringBase.h
+    IoUringOptions.h
   DEPS
     folly_container_f14_hash
     folly_demangle

folly/io/async/IoUringBackend.h

@@ -40,6 +40,7 @@
 #include <folly/io/async/EventBase.h>
 #include <folly/io/async/EventBaseBackendBase.h>
 #include <folly/io/async/IoUringBase.h>
+#include <folly/io/async/IoUringOptions.h>
 #include <folly/io/async/IoUringProvidedBufferRing.h>
 #include <folly/io/async/IoUringZeroCopyBufferPool.h>
 #include <folly/io/async/Liburing.h>
@@ -64,298 +65,10 @@ class IoUringBackend : public EventBaseBackendBase {
     using std::runtime_error::runtime_error;
   };
 
-  using ResolveNapiIdCallback =
-      std::function<int(int ifindex, uint32_t queueId)>;
-  using SrcPortForQueueIdCallback = std::function<int(
-      const folly::IPAddress& destAddr,
-      uint16_t destPort,
-      int targetNapiId,
-      const char* ifname)>;
-
-  struct Options {
-    enum Flags {
-      POLL_SQ = 0x1,
-      POLL_CQ = 0x2,
-      POLL_SQ_IMMEDIATE_IO = 0x4, // do not enqueue I/O operations
-    };
-
-    Options() = default;
-    Options(const Options&) = delete;
-    Options& operator=(const Options&) = delete;
-    Options(Options&&) = default;
-    Options& operator=(Options&&) = default;
-    ~Options() = default;
-
-    Options& setCapacity(size_t v) {
-      capacity = v;
-      return *this;
-    }
-
-    Options& setMinCapacity(size_t v) {
-      minCapacity = v;
-
-      return *this;
-    }
-
-    Options& setMaxSubmit(size_t v) {
-      maxSubmit = v;
-
-      return *this;
-    }
-
-    Options& setSqeSize(size_t v) {
-      sqeSize = v;
-
-      return *this;
-    }
-
-    Options& setMaxGet(size_t v) {
-      maxGet = v;
-
-      return *this;
-    }
-
-    Options& setUseRegisteredFds(size_t v) {
-      registeredFds = v;
-      return *this;
-    }
-
-    Options& setFlags(uint32_t v) {
-      flags = v;
-
-      return *this;
-    }
-
-    Options& setSQIdle(std::chrono::milliseconds v) {
-      sqIdle = v;
-
-      return *this;
-    }
-
-    Options& setCQIdle(std::chrono::milliseconds v) {
-      cqIdle = v;
-
-      return *this;
-    }
-
-    // Set the CPU as preferred for submission queue poll thread.
-    //
-    // This only has effect if POLL_SQ flag is specified.
-    //
-    // Can call multiple times to specify multiple CPUs.
-    Options& setSQCpu(uint32_t v) {
-      sqCpus.insert(v);
-
-      return *this;
-    }
-
-    // Set the preferred CPUs for submission queue poll thread(s).
-    //
-    // This only has effect if POLL_SQ flag is specified.
-    Options& setSQCpus(std::set<uint32_t> const& cpus) {
-      sqCpus.insert(cpus.begin(), cpus.end());
-
-      return *this;
-    }
-
-    Options& setSQGroupName(const std::string& v) {
-      sqGroupName = v;
-
-      return *this;
-    }
-
-    Options& setSQGroupNumThreads(size_t v) {
-      sqGroupNumThreads = v;
-
-      return *this;
-    }
-
-    Options& setInitialProvidedBuffers(size_t eachSize, size_t count) {
-      initialProvidedBuffersCount = count;
-      initialProvidedBuffersEachSize = eachSize;
-      return *this;
-    }
-
-    constexpr bool isPow2(uint64_t n) noexcept {
-      return n > 0 && !((n - 1) & n);
-    }
-
-    Options& setProvidedBufRings(size_t v) {
-      if (!isPow2(v)) {
-        throw std::runtime_error(
-            folly::to<std::string>(
-                "number of provided buffer rings must be a power of 2"));
-      }
-      providedBufRings = v;
-      return *this;
-    }
-
-    Options& setRegisterRingFd(bool v) {
-      registerRingFd = v;
-
-      return *this;
-    }
-
-    Options& setTaskRunCoop(bool v) {
-      taskRunCoop = v;
-
-      return *this;
-    }
-
-    Options& setDeferTaskRun(bool v) {
-      deferTaskRun = v;
-
-      return *this;
-    }
-
-    Options& setTimeout(std::chrono::microseconds v) {
-      timeout = v;
-
-      return *this;
-    }
-
-    Options& setBatchSize(int v) {
-      batchSize = v;
-
-      return *this;
-    }
-
-    Options& setZeroCopyRx(bool v) {
-      zeroCopyRx = v;
-
-      return *this;
-    }
-
-    Options& setZeroCopyRxInterface(std::string v) {
-      zcRxIfname = std::move(v);
-      zcRxIfindex = ::if_nametoindex(zcRxIfname.c_str());
-      if (zcRxIfindex == 0) {
-        throw std::runtime_error(
-            folly::to<std::string>(
-                "invalid network interface name: ",
-                zcRxIfname,
-                ", errno: ",
-                errno));
-      }
-
-      return *this;
-    }
-
-    Options& setZeroCopyRxQueue(int queueId) {
-      zcRxQueueId = queueId;
-
-      return *this;
-    }
-
-    Options& setResolveNapiCallback(ResolveNapiIdCallback&& v) {
-      resolveNapiId = std::move(v);
-
-      return *this;
-    }
-
-    Options& setZcrxSrcPortCallback(SrcPortForQueueIdCallback&& v) {
-      srcPortQueueId = std::move(v);
-
-      return *this;
-    }
-
-    Options& setZeroCopyRxNumPages(int v) {
-      zcRxNumPages = v;
-
-      return *this;
-    }
-
-    Options& setZeroCopyRxRefillEntries(int v) {
-      zcRxRefillEntries = v;
-
-      return *this;
-    }
-
-    Options& setEnableIncrementalBuffers(bool v) {
-      enableIncrementalBuffers = v;
-
-      return *this;
-    }
-
-    Options& setUseHugePages(bool v) {
-      useHugePages = v;
-
-      return *this;
-    }
-
-    Options& setNativeAsyncSocketSupport(bool v) {
-      nativeAsyncSocketSupport = v;
-
-      return *this;
-    }
-
-    Options& setBufferPoolHandle(IoUringZeroCopyBufferPool::ExportHandle&& v) {
-      bufferPoolHandle = std::move(v);
-      return *this;
-    }
-
-    Options& setArenaRegion(void* base, size_t size, uint32_t index) {
-      arenaRegion.iov_base = base;
-      arenaRegion.iov_len = size;
-      arenaIndex = index;
-      return *this;
-    }
-
-    ssize_t sqeSize{-1};
-
-    size_t capacity{256};
-    size_t minCapacity{0};
-    size_t maxSubmit{128};
-    size_t maxGet{256};
-    size_t registeredFds{0};
-    size_t sqGroupNumThreads{1};
-    size_t initialProvidedBuffersCount{0};
-    size_t initialProvidedBuffersEachSize{0};
-    size_t providedBufRings{1};
-
-    uint32_t flags{0};
-
-    // Minimum number of requests (defined as sockets with data to read) to wait
-    // for per io_uring_enter
-    int batchSize{0};
-
-    bool registerRingFd{false};
-    bool taskRunCoop{false};
-    bool deferTaskRun{false};
-
-    // Maximum amount of time to wait (in microseconds) per io_uring_enter
-    // Both timeout _and_ batchSize must be set for io_uring_enter wait_nr to be
-    // set!
-    std::chrono::microseconds timeout{0};
-    std::chrono::milliseconds sqIdle{0};
-    std::chrono::milliseconds cqIdle{0};
-
-    std::set<uint32_t> sqCpus;
-
-    std::string sqGroupName;
-
-    // Zero copy receive
-    bool zeroCopyRx{false};
-    std::string zcRxIfname;
-    int zcRxQueueId{-1};
-    int zcRxIfindex{-1};
-    ResolveNapiIdCallback resolveNapiId;
-    SrcPortForQueueIdCallback srcPortQueueId;
-    int zcRxNumPages{-1};
-    int zcRxRefillEntries{-1};
-
-    // Incremental Buffers
-    bool enableIncrementalBuffers{false};
-    bool useHugePages{false};
-
-    bool nativeAsyncSocketSupport{false};
-
-    std::optional<IoUringZeroCopyBufferPool::ExportHandle> bufferPoolHandle =
-        std::nullopt;
-
-    struct iovec arenaRegion{};
-    uint32_t arenaIndex{0};
-  };
+  // Type aliases for backwards compatibility
+  using ResolveNapiIdCallback = IoUringResolveNapiIdCallback;
+  using SrcPortForQueueIdCallback = IoUringSrcPortForQueueIdCallback;
+  using Options = IoUringOptions;
 
   explicit IoUringBackend(Options options);
   ~IoUringBackend() override;