Improve backwards compatibility

CMakeLists.txt

@@ -9,10 +9,10 @@ if(HUNTER_ENABLED)
   # Workaround hunter hideing system libs
   set(HUNTER_LIBPATH $ENV{PKG_CONFIG_LIBDIR})
   unset(ENV{PKG_CONFIG_LIBDIR})
-  pkg_search_module(URING REQUIRED NO_CMAKE_PATH liburing>=2.3 uring>=2.3)
+  pkg_search_module(URING REQUIRED NO_CMAKE_PATH liburing uring)
   set(ENV{PKG_CONFIG_LIBDIR} ${HUNTER_LIBPATH})
 else()
-  pkg_search_module(URING REQUIRED NO_CMAKE_PATH liburing>=2.3 uring>=2.3)
+  pkg_search_module(URING REQUIRED NO_CMAKE_PATH liburing uring)
 endif()
 
 option(ASYNCPP_BUILD_TEST "Enable test builds" ON)
@@ -26,12 +26,19 @@ else()
   include(cmake/Fetch_asyncpp.cmake)
 endif()
 
+try_run(OP_LAST OP_LAST_COMPILE_RESULT SOURCES
+        ${CMAKE_CURRENT_SOURCE_DIR}/cmake/detect-max-op.c)
+
 add_library(asyncpp_uring INTERFACE)
 target_link_libraries(asyncpp_uring INTERFACE asyncpp Threads::Threads
                                               ${URING_LIBRARIES})
 target_include_directories(asyncpp_uring
                            INTERFACE ${CMAKE_CURRENT_SOURCE_DIR}/include)
 target_compile_features(asyncpp_uring INTERFACE cxx_std_20)
+if(OP_LAST_COMPILE_RESULT)
+  target_compile_definitions(asyncpp_uring
+                             INTERFACE ASYNCPP_URING_OP_LAST=${OP_LAST})
+endif()
 
 if(ASYNCPP_BUILD_TEST)
   enable_testing()

cmake/detect-max-op.c

@@ -0,0 +1,3 @@
+#include <liburing.h>
+
+int main() { return IORING_OP_LAST - 1; }

examples/echo-client.cpp

@@ -19,10 +19,14 @@ int main() {
 	io_service io{p};
 	buffer_group buffers{io, 32 * 1024, 32};
 	io.launch([](io_service& io, buffer_group& buffers) -> task<> {
-		// Try create a socket and fallback to sync if unsupported
+	// Try create a socket and fallback to sync if unsupported
+#if ASYNCPP_URING_OP_LAST >= 45
 		int sock = io.has_capability(IORING_OP_SOCKET)					//
 					   ? co_await io.socket(AF_INET, SOCK_STREAM, 0, 0) //
 					   : socket(AF_INET, SOCK_STREAM, 0);
+#else
+		int sock = socket(AF_INET, SOCK_STREAM, 0);
+#endif
 		if (sock < 0) {
 			std::cout << "failed to create socket: " << strerror(-sock) << std::endl;
 			co_return;

examples/echo-server.cpp

@@ -52,10 +52,14 @@ int main() {
 	}(io, exit));
 	buffer_group buffers{io, 32 * 1024, 32};
 	io.launch([](io_service& io, buffer_group& buffers, std::stop_source& exit) -> task<> {
-		// Try create a socket and fallback to sync if unsupported
+	// Try create a socket and fallback to sync if unsupported
+#if ASYNCPP_URING_OP_LAST >= 45
 		int sock = io.has_capability(IORING_OP_SOCKET)					//
 					   ? co_await io.socket(AF_INET, SOCK_STREAM, 0, 0) //
 					   : socket(AF_INET, SOCK_STREAM, 0);
+#else
+		int sock = socket(AF_INET, SOCK_STREAM, 0);
+#endif
 		if (sock < 0) {
 			std::cout << "failed to create socket: " << strerror(-sock) << std::endl;
 			co_return;

include/asyncpp/uring/capability_set.h

@@ -12,7 +12,7 @@ namespace asyncpp::uring {
 
 	public:
 		constexpr static struct {
-		} no_parse_tag;
+		} no_parse_tag{};
 		capability_set(struct io_uring* ring) : m_supported{} { this->parse(ring); }
 		capability_set() : m_supported{} { this->parse(nullptr); }
 		constexpr capability_set(decltype(no_parse_tag)) noexcept : m_supported{} {}
@@ -115,6 +115,8 @@ namespace asyncpp::uring {
 				"GETXATTR",
 				"SOCKET",
 				"URING_CMD",
+				"SEND_ZC",
+				"SENDMSG_ZC",
 			};
 
 			if (index >= (sizeof(names) / sizeof(names[0]))) return "";

include/asyncpp/uring/index_set.h

@@ -65,6 +65,8 @@ namespace asyncpp::uring {
 			~bit_storage() noexcept { clear(); }
 
 			bit_storage(const bit_storage& other) : m_allocator{other.m_allocator} {
+				memset(&m_data, 0, sizeof(m_data));
+				m_data.inplace.size = 0x80;
 				resize_bits(other.bit_size());
 				memcpy(data(), other.data(), std::min(byte_size(), other.byte_size()));
 			}