linux support using liburing

.clang-format

@@ -37,7 +37,7 @@ BraceWrapping: {
   BeforeCatch: true,
   BeforeElse: true,
   IndentBraces: false,
-  #SplitEmptyFunctionBody: false
+  SplitEmptyFunction: false
 }
 BreakBeforeInheritanceComma: true
 BreakBeforeTernaryOperators: true

CMakeLists.txt

@@ -0,0 +1,243 @@
+cmake_minimum_required(VERSION 3.11)
+
+set(CMAKE_CXX_STANDARD 20)
+set(CMAKE_CXX_STANDARD_REQUIRED TRUE)
+
+include(CheckIncludeFileCXX)
+macro(check_include_file_cxx _header _var)
+  _check_include_file_cxx(${_header} ${_var})
+  if(NOT ${_var})
+    set(${_var} 0)
+  endif()
+endmacro()
+
+list(APPEND CMAKE_MODULE_PATH "${CMAKE_CURRENT_SOURCE_DIR}/cmake")
+
+project(cppcoro)
+
+set(${PROJECT_NAME}_PUBLIC_HEADERS
+  include/cppcoro/async_auto_reset_event.hpp
+  include/cppcoro/async_generator.hpp
+  include/cppcoro/async_latch.hpp
+  include/cppcoro/async_manual_reset_event.hpp
+  include/cppcoro/async_mutex.hpp
+  include/cppcoro/async_scope.hpp
+  include/cppcoro/awaitable_traits.hpp
+  include/cppcoro/broken_promise.hpp
+  include/cppcoro/cancellation_registration.hpp
+  include/cppcoro/cancellation_source.hpp
+  include/cppcoro/cancellation_token.hpp
+  include/cppcoro/config.hpp
+
+  include/cppcoro/detail/any.hpp
+  include/cppcoro/detail/get_awaiter.hpp
+  include/cppcoro/detail/is_awaiter.hpp
+  include/cppcoro/detail/lightweight_manual_reset_event.hpp
+  include/cppcoro/detail/manual_lifetime.hpp
+  include/cppcoro/detail/remove_rvalue_reference.hpp
+  include/cppcoro/detail/sync_wait_task.hpp
+  include/cppcoro/detail/unwrap_reference.hpp
+  include/cppcoro/detail/void_value.hpp
+  include/cppcoro/detail/when_all_counter.hpp
+  include/cppcoro/detail/when_all_ready_awaitable.hpp
+  include/cppcoro/detail/when_all_task.hpp
+
+  include/cppcoro/file.hpp
+  include/cppcoro/file_buffering_mode.hpp
+  include/cppcoro/file_open_mode.hpp
+  include/cppcoro/file_read_operation.hpp
+  include/cppcoro/file_share_mode.hpp
+  include/cppcoro/file_write_operation.hpp
+  include/cppcoro/fmap.hpp
+  include/cppcoro/generator.hpp
+  include/cppcoro/inline_scheduler.hpp
+  include/cppcoro/is_awaitable.hpp
+  include/cppcoro/multi_producer_sequencer.hpp
+  include/cppcoro/on_scope_exit.hpp
+  include/cppcoro/operation_cancelled.hpp
+  include/cppcoro/readable_file.hpp
+  include/cppcoro/read_only_file.hpp
+  include/cppcoro/read_write_file.hpp
+  include/cppcoro/recursive_generator.hpp
+  include/cppcoro/resume_on.hpp
+  include/cppcoro/round_robin_scheduler.hpp
+  include/cppcoro/schedule_on.hpp
+  include/cppcoro/sequence_barrier.hpp
+  include/cppcoro/sequence_range.hpp
+  include/cppcoro/sequence_traits.hpp
+  include/cppcoro/shared_task.hpp
+  include/cppcoro/single_consumer_async_auto_reset_event.hpp
+  include/cppcoro/single_consumer_event.hpp
+  include/cppcoro/single_producer_sequencer.hpp
+  include/cppcoro/static_thread_pool.hpp
+  include/cppcoro/sync_wait.hpp
+  include/cppcoro/task.hpp
+  include/cppcoro/when_all.hpp
+  include/cppcoro/when_all_ready.hpp
+  include/cppcoro/writable_file.hpp
+  include/cppcoro/write_only_file.hpp
+
+  include/cppcoro/net/ipv4_address.hpp
+  include/cppcoro/net/ipv4_endpoint.hpp
+  include/cppcoro/net/ipv6_address.hpp
+  include/cppcoro/net/ipv6_endpoint.hpp
+  include/cppcoro/net/ip_address.hpp
+  include/cppcoro/net/ip_endpoint.hpp
+  include/cppcoro/io_service.hpp
+
+  include/cppcoro/file.hpp
+  include/cppcoro/read_only_file.hpp
+  include/cppcoro/file_read_operation.hpp
+  include/cppcoro/readable_file.hpp
+
+  include/cppcoro/net/socket.hpp
+  include/cppcoro/net/socket_accept_operation.hpp
+  include/cppcoro/net/socket_connect_operation.hpp
+  include/cppcoro/net/socket_disconnect_operation.hpp
+  include/cppcoro/net/socket_recv_from_operation.hpp
+  include/cppcoro/net/socket_recv_operation.hpp
+  include/cppcoro/net/socket_send_operation.hpp
+  include/cppcoro/net/socket_send_to_operation.hpp
+  )
+
+set(${PROJECT_NAME}_SOURCES
+  lib/async_auto_reset_event.cpp
+  lib/async_manual_reset_event.cpp
+  lib/async_mutex.cpp
+  lib/auto_reset_event.cpp
+  lib/cancellation_registration.cpp
+  lib/cancellation_source.cpp
+  lib/cancellation_state.cpp
+  lib/cancellation_token.cpp
+  lib/lightweight_manual_reset_event.cpp
+  lib/spin_mutex.cpp
+  lib/spin_wait.cpp
+  lib/static_thread_pool.cpp
+  lib/ipv4_address.cpp
+  lib/ipv4_endpoint.cpp
+  lib/ipv6_address.cpp
+  lib/ipv6_endpoint.cpp
+  lib/ip_address.cpp
+  lib/ip_endpoint.cpp
+  lib/io_service.cpp
+
+  lib/file.cpp
+  lib/read_only_file.cpp
+  lib/file_read_operation.cpp
+  lib/readable_file.cpp
+  lib/file_write_operation.cpp
+  lib/writable_file.cpp
+  lib/write_only_file.cpp
+  lib/read_write_file.cpp
+
+  lib/socket.cpp
+  lib/socket_accept_operation.cpp
+  lib/socket_connect_operation.cpp
+  lib/socket_disconnect_operation.cpp
+  lib/socket_helpers.cpp
+  lib/socket_recv_from_operation.cpp
+  lib/socket_recv_operation.cpp
+  lib/socket_send_operation.cpp
+  lib/socket_send_to_operation.cpp
+  )
+
+
+if(WIN32)
+  list(APPEND ${PROJECT_NAME}_SOURCES
+    lib/win32.cpp
+    )
+
+  list(APPEND ${PROJECT_NAME}_PUBLIC_HEADERS
+    include/cppcoro/detail/win32.hpp
+    include/cppcoro/detail/win32_overlapped_operation.hpp
+    )
+else()
+  list(APPEND ${PROJECT_NAME}_SOURCES
+    lib/linux.cpp
+    )
+  list(APPEND ${PROJECT_NAME}_PUBLIC_HEADERS
+    include/cppcoro/detail/linux.hpp
+    include/cppcoro/detail/linux_uring_operation.hpp
+    )
+endif()
+
+add_library(${PROJECT_NAME} ${${PROJECT_NAME}_SOURCES} ${${PROJECT_NAME}_PUBLIC_HEADERS})
+target_include_directories(${PROJECT_NAME} PUBLIC $<BUILD_INTERFACE:${CMAKE_CURRENT_SOURCE_DIR}/include>)
+
+if(WIN32)
+  set(CMAKE_REQUIRED_FLAGS /std:c++latest /await)
+  target_link_libraries(${PROJECT_NAME} PUBLIC ws2_32 Synchronization)
+elseif(CMAKE_CXX_COMPILER_ID MATCHES GNU)
+  set(CMAKE_REQUIRED_FLAGS -fcoroutines)
+elseif(CMAKE_CXX_COMPILER_ID MATCHES Clang)
+  set(CMAKE_REQUIRED_FLAGS -stdlib=libc++ -fcoroutines-ts)
+endif()
+target_compile_options(${PROJECT_NAME} PUBLIC ${CMAKE_REQUIRED_FLAGS})
+
+if(UNIX)
+  find_package(Threads REQUIRED)
+  include(geturing)
+  target_link_libraries(${PROJECT_NAME} PUBLIC Threads::Threads liburing::liburing)
+endif()
+
+check_include_file_cxx(coroutine HAS_STD_COROUTINE_HEADER)
+check_include_file_cxx(experimental/coroutine HAS_STD_EXPERIMENTAL_COROUTINES_HEADER)
+
+check_include_file_cxx(filesystem HAS_STD_FILESYSTEM_HEADER)
+check_include_file_cxx(experimental/filesystem HAS_STD_EXPERIMENTAL_FILESYSTEM_HEADER)
+
+message(STATUS "HAS_STD_COROUTINE_HEADER: ${HAS_STD_COROUTINE_HEADER}")
+message(STATUS "HAS_STD_EXPERIMENTAL_COROUTINES_HEADER: ${HAS_STD_EXPERIMENTAL_COROUTINES_HEADER}")
+message(STATUS "HAS_STD_FILESYSTEM_HEADER: ${HAS_STD_FILESYSTEM_HEADER}")
+message(STATUS "HAS_STD_EXPERIMENTAL_FILESYSTEM_HEADER: ${HAS_STD_EXPERIMENTAL_FILESYSTEM_HEADER}")
+
+target_compile_options(${PROJECT_NAME} PUBLIC
+  -DCPPCORO_HAS_STD_COROUTINE_HEADER=${HAS_STD_COROUTINE_HEADER}
+  )
+target_compile_options(${PROJECT_NAME} PUBLIC
+  -DCPPCORO_HAS_STD_EXPERIMENTAL_COROUTINES_HEADER=${HAS_STD_EXPERIMENTAL_COROUTINES_HEADER}
+  )
+
+target_compile_options(${PROJECT_NAME} PUBLIC
+  -DCPPCORO_HAS_STD_FILESYSTEM_HEADER=${HAS_STD_FILESYSTEM_HEADER}
+  )
+
+target_compile_options(${PROJECT_NAME} PUBLIC
+  -DCPPCORO_HAS_STD_EXPERIMENTAL_FILESYSTEM_HEADER=${HAS_STD_EXPERIMENTAL_FILESYSTEM_HEADER}
+  )
+
+add_library(cppcoro::cppcoro ALIAS ${PROJECT_NAME})
+
+enable_testing()
+if(ENABLE_TESTING)
+  add_subdirectory(test)
+endif()
+
+install(TARGETS ${PROJECT_NAME}
+  EXPORT ${PROJECT_NAME}-targets
+  ARCHIVE DESTINATION lib
+  )
+install(DIRECTORY include/ DESTINATION include)
+
+configure_file(cmake/cppcoroConfig.cmake.in
+  "${CMAKE_CURRENT_BINARY_DIR}/cppcoroConfig.cmake"
+  @ONLY
+  )
+
+export(EXPORT ${PROJECT_NAME}-targets
+  FILE "${CMAKE_CURRENT_BINARY_DIR}/cppcoroTargets.cmake"
+  NAMESPACE cppcoro::
+  )
+
+set(CONFIG_PACKAGE_LOCATION lib/cmake/${PROJECT_NAME})
+install(EXPORT ${PROJECT_NAME}-targets
+  FILE cppcoroTargets.cmake
+  NAMESPACE cppcoro::
+  DESTINATION ${CONFIG_PACKAGE_LOCATION}
+  )
+install(
+  FILES
+  "${CMAKE_CURRENT_SOURCE_DIR}/cmake/Findliburing.cmake"
+  "${CMAKE_CURRENT_BINARY_DIR}/cppcoroConfig.cmake"
+  DESTINATION ${CONFIG_PACKAGE_LOCATION}
+)

README.md

@@ -714,15 +714,15 @@ namespace cppcoro
   {
   public:
     bool await_ready() const noexcept;
-    bool await_suspend(std::experimental::coroutine_handle<> awaiter) noexcept;
+    bool await_suspend(stdcoro::coroutine_handle<> awaiter) noexcept;
     void await_resume() const noexcept;
   };
 
   class async_mutex_scoped_lock_operation
   {
   public:
     bool await_ready() const noexcept;
-    bool await_suspend(std::experimental::coroutine_handle<> awaiter) noexcept;
+    bool await_suspend(stdcoro::coroutine_handle<> awaiter) noexcept;
     [[nodiscard]] async_mutex_lock await_resume() const noexcept;
   };
 
@@ -836,7 +836,7 @@ namespace cppcoro
     async_manual_reset_event_operation(async_manual_reset_event& event) noexcept;
 
     bool await_ready() const noexcept;
-    bool await_suspend(std::experimental::coroutine_handle<> awaiter) noexcept;
+    bool await_suspend(stdcoro::coroutine_handle<> awaiter) noexcept;
     void await_resume() const noexcept;
   };
 }
@@ -904,7 +904,7 @@ namespace cppcoro
     async_auto_reset_event_operation(const async_auto_reset_event_operation& other) noexcept;
 
     bool await_ready() const noexcept;
-    bool await_suspend(std::experimental::coroutine_handle<> awaiter) noexcept;
+    bool await_suspend(stdcoro::coroutine_handle<> awaiter) noexcept;
     void await_resume() const noexcept;
 
   };
@@ -1389,7 +1389,7 @@ namespace cppcoro
       schedule_operation(static_thread_pool* tp) noexcept;
 
       bool await_ready() noexcept;
-      bool await_suspend(std::experimental::coroutine_handle<> h) noexcept;
+      bool await_suspend(stdcoro::coroutine_handle<> h) noexcept;
       bool await_resume() noexcept;
 
     private:
@@ -1546,7 +1546,7 @@ namespace cppcoro
     schedule_operation& operator=(const schedule_operation&) noexcept;
 
     bool await_ready() const noexcept;
-    void await_suspend(std::experimental::coroutine_handle<> awaiter) noexcept;
+    void await_suspend(stdcoro::coroutine_handle<> awaiter) noexcept;
     void await_resume() noexcept;
   };
 
@@ -1560,7 +1560,7 @@ namespace cppcoro
     timed_schedule_operation& operator=(timed_schedule_operation&&) = delete;
 
     bool await_ready() const noexcept;
-    void await_suspend(std::experimental::coroutine_handle<> awaiter);
+    void await_suspend(stdcoro::coroutine_handle<> awaiter);
     void await_resume();
   };
 
@@ -1596,7 +1596,7 @@ Example:
 #include <algorithm>
 #include <iostream>
 
-namespace fs = std::experimental::filesystem;
+namespace fs = stdcoro::filesystem;
 
 cppcoro::task<std::uint64_t> count_lines(cppcoro::io_service& ioService, fs::path path)
 {
@@ -1740,7 +1740,7 @@ namespace cppcoro
     file_read_operation(file_read_operation&& other) noexcept;
 
     bool await_ready() const noexcept;
-    bool await_suspend(std::experimental::coroutine_handle<> awaiter);
+    bool await_suspend(stdcoro::coroutine_handle<> awaiter);
     std::size_t await_resume();
 
   };
@@ -1752,7 +1752,7 @@ namespace cppcoro
     file_write_operation(file_write_operation&& other) noexcept;
 
     bool await_ready() const noexcept;
-    bool await_suspend(std::experimental::coroutine_handle<> awaiter);
+    bool await_suspend(stdcoro::coroutine_handle<> awaiter);
     std::size_t await_resume();
 
   };
@@ -1774,7 +1774,7 @@ namespace cppcoro
     [[nodiscard]]
     static read_only_file open(
       io_service& ioService,
-      const std::experimental::filesystem::path& path,
+      const stdcoro::filesystem::path& path,
       file_share_mode shareMode = file_share_mode::read,
       file_buffering_mode bufferingMode = file_buffering_mode::default_);
 
@@ -1787,7 +1787,7 @@ namespace cppcoro
     [[nodiscard]]
     static write_only_file open(
       io_service& ioService,
-      const std::experimental::filesystem::path& path,
+      const stdcoro::filesystem::path& path,
       file_open_mode openMode = file_open_mode::create_or_open,
       file_share_mode shareMode = file_share_mode::none,
       file_buffering_mode bufferingMode = file_buffering_mode::default_);
@@ -1801,7 +1801,7 @@ namespace cppcoro
     [[nodiscard]]
     static read_write_file open(
       io_service& ioService,
-      const std::experimental::filesystem::path& path,
+      const stdcoro::filesystem::path& path,
       file_open_mode openMode = file_open_mode::create_or_open,
       file_share_mode shareMode = file_share_mode::none,
       file_buffering_mode bufferingMode = file_buffering_mode::default_);
@@ -2794,7 +2794,7 @@ coroutine.
 
 A type that satisfies `Awaiter<T>` must have, for an instance of the type, `awaiter`:
 - `awaiter.await_ready()` -> `bool`
-- `awaiter.await_suspend(std::experimental::coroutine_handle<void>{})` -> `void` or `bool` or `std::experimental::coroutine_handle<P>` for some `P`.
+- `awaiter.await_suspend(stdcoro::coroutine_handle<void>{})` -> `void` or `bool` or `stdcoro::coroutine_handle<P>` for some `P`.
 - `awaiter.await_resume()` -> `T`
 
 Any type that implements the `Awaiter<T>` concept also implements the `Awaitable<T>` concept.
@@ -3125,7 +3125,7 @@ ninja install-clang \
 
 ### Building libc++
 
-The cppcoro project requires libc++ as it contains the `<experimental/coroutine>`
+The cppcoro project requires libc++ as it contains the `<cppcoro/stdcoro.hpp>`
 header required to use C++ coroutines under Clang.
 
 Checkout `libc++` + `llvm`: