Initial commit

Author: Lucas Paixão

.cargo/config.toml

@@ -0,0 +1,9 @@
+[env]
+RUST_TEST_THREADS = { value = "1" }
+
+[build]
+target = "x86_64-unknown-linux-gnu"
+
+#[target.x86_64-unknown-linux-gnu]
+#linker = "rust-lld"
+#rustflags = ["-C", "link-arg=--target=x86_64-linux-gnu"]

.github/workflows/ci.yml

@@ -0,0 +1,86 @@
+name: CI
+
+on:
+  pull_request:
+    branches:
+      - master
+  push:
+    branches:
+      - master
+
+env:
+  RUSTFLAGS: -Dwarnings
+  RUST_BACKTRACE: 1
+
+jobs:
+  # Depends on all actions that are required for a "successful" CI run.
+  # Based on the ci here: https://github.com/tokio-rs/tokio/blob/master/.github/workflows/ci.yml
+  all-systems-go:
+    runs-on: ubuntu-latest
+    needs:
+      - check
+      - clippy
+      - fmt
+      - test
+      - test-docs
+      - docs
+    steps:
+      - run: exit 0
+
+  bench:
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v4
+      - name: Install Rust
+        run: rustup update stable
+      - run: cargo bench --no-run
+
+  check:
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v4
+      - name: Install Rust
+        run: rustup update stable
+      - run: cargo check
+
+  clippy:
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v4
+      - name: Install Rust
+        run: rustup update stable
+      - run: cargo clippy
+
+  test:
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v4
+      - name: Install Rust
+        run: rustup update stable
+      - run: cargo test
+
+  test-docs:
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v4
+      - name: Install Rust
+        run: rustup update stable
+      - run: cargo test --doc
+
+  fmt:
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v4
+      - name: Install Rust
+        run: rustup update stable
+      - run: cargo fmt -- --check
+
+  docs:
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v4
+      - name: Install Rust
+        run: rustup update nightly && rustup default nightly
+      - run: cargo doc --no-deps --all-features
+        env:
+          RUSTDOCFLAGS: -Dwarnings

.gitignore

@@ -0,0 +1,2 @@
+/target
+Cargo.lock

.idea/.gitignore

@@ -0,0 +1,119 @@
+# 0.4.0 (November 5th, 2022)
+
+### Fixed
+
+- Fix panic in Deref/DerefMut for Slice extending into uninitialized part of the buffer ([#52])
+- docs: all-features = true ([#84])
+- fix fs unit tests to avoid parallelism ([#121])
+- Box the socket address to allow moving the Connect future ([#126])
+- rt: Fix data race ([#146])
+
+### Added
+
+- Implement fs::File::readv_at()/writev_at() ([#87])
+- fs: implement FromRawFd for File ([#89])
+- Implement `AsRawFd` for `TcpStream` ([#94])
+- net: add TcpListener.local_addr method ([#107])
+- net: add TcpStream.write_all ([#111])
+- driver: add Builder API as an option to start ([#113])
+- Socket and TcpStream shutdown ([#124])
+- fs: implement fs::File::from_std ([#131])
+- net: implement FromRawFd for TcpStream ([#132])
+- fs: implement OpenOptionsExt for OpenOptions ([#133])
+- Add NoOp support ([#134])
+- Add writev to TcpStream ([#136])
+- sync TcpStream, UnixStream and UdpSocket functionality ([#141])
+- Add benchmarks for no-op submission ([#144])
+- Expose runtime structure ([#148])
+
+### Changed
+
+- driver: batch submit requests and add benchmark ([#78])
+- Depend on io-uring version ^0.5.8 ([#153])
+
+### Internal Improvements
+
+- chore: fix clippy lints ([#99])
+- io: refactor post-op logic in ops into Completable ([#116])
+- Support multi completion events: v2 ([#130])
+- simplify driver operation futures ([#139])
+- rt: refactor runtime to avoid Rc\<RefCell\<...>> ([#142])
+- Remove unused dev-dependencies ([#143])
+- chore: types and fields explicitly named ([#149])
+- Ignore errors from uring while cleaning up ([#154])
+- rt: drop runtime before driver during shutdown ([#155])
+- rt: refactor drop logic ([#157])
+- rt: fix error when calling block_on twice ([#162])
+
+### CI changes
+
+- chore: update actions/checkout action to v3 ([#90])
+- chore: add all-systems-go ci check ([#98])
+- chore: add clippy to ci ([#100])
+- ci: run cargo test --doc ([#135])
+
+
+[#52]: https://github.com/tokio-rs/tokio-uring/pull/52
+[#78]: https://github.com/tokio-rs/tokio-uring/pull/78
+[#84]: https://github.com/tokio-rs/tokio-uring/pull/84
+[#87]: https://github.com/tokio-rs/tokio-uring/pull/87
+[#89]: https://github.com/tokio-rs/tokio-uring/pull/89
+[#90]: https://github.com/tokio-rs/tokio-uring/pull/90
+[#94]: https://github.com/tokio-rs/tokio-uring/pull/94
+[#98]: https://github.com/tokio-rs/tokio-uring/pull/98
+[#99]: https://github.com/tokio-rs/tokio-uring/pull/99
+[#100]: https://github.com/tokio-rs/tokio-uring/pull/100
+[#107]: https://github.com/tokio-rs/tokio-uring/pull/107
+[#111]: https://github.com/tokio-rs/tokio-uring/pull/111
+[#113]: https://github.com/tokio-rs/tokio-uring/pull/113
+[#116]: https://github.com/tokio-rs/tokio-uring/pull/116
+[#121]: https://github.com/tokio-rs/tokio-uring/pull/121
+[#124]: https://github.com/tokio-rs/tokio-uring/pull/124
+[#126]: https://github.com/tokio-rs/tokio-uring/pull/126
+[#130]: https://github.com/tokio-rs/tokio-uring/pull/130
+[#131]: https://github.com/tokio-rs/tokio-uring/pull/131
+[#132]: https://github.com/tokio-rs/tokio-uring/pull/132
+[#133]: https://github.com/tokio-rs/tokio-uring/pull/133
+[#134]: https://github.com/tokio-rs/tokio-uring/pull/134
+[#135]: https://github.com/tokio-rs/tokio-uring/pull/135
+[#136]: https://github.com/tokio-rs/tokio-uring/pull/136
+[#139]: https://github.com/tokio-rs/tokio-uring/pull/139
+[#141]: https://github.com/tokio-rs/tokio-uring/pull/141
+[#142]: https://github.com/tokio-rs/tokio-uring/pull/142
+[#143]: https://github.com/tokio-rs/tokio-uring/pull/143
+[#144]: https://github.com/tokio-rs/tokio-uring/pull/144
+[#146]: https://github.com/tokio-rs/tokio-uring/pull/146
+[#148]: https://github.com/tokio-rs/tokio-uring/pull/148
+[#149]: https://github.com/tokio-rs/tokio-uring/pull/149
+[#153]: https://github.com/tokio-rs/tokio-uring/pull/153
+[#154]: https://github.com/tokio-rs/tokio-uring/pull/154
+[#155]: https://github.com/tokio-rs/tokio-uring/pull/155
+[#157]: https://github.com/tokio-rs/tokio-uring/pull/157
+[#162]: https://github.com/tokio-rs/tokio-uring/pull/162
+
+# 0.3.0 (March 2nd, 2022)
+### Added
+- net: add unix stream & listener ([#74])
+- net: add tcp and udp support ([#40])
+
+[#74]: https://github.com/tokio-rs/tokio-uring/pull/74
+[#40]: https://github.com/tokio-rs/tokio-uring/pull/40
+
+# 0.2.0 (January 9th, 2022)
+
+### Fixed
+- fs: fix error handling related to changes in rustc ([#69])
+- op: fix 'already borrowed' panic ([#39])
+
+### Added
+- fs: add fs::remove_file ([#66])
+- fs: implement Debug for File ([#65])
+- fs: add remove_dir and unlink ([#63])
+- buf: impl IoBuf/IoBufMut for bytes::Bytes/BytesMut ([#43])
+
+[#69]: https://github.com/tokio-rs/tokio-uring/pull/69
+[#66]: https://github.com/tokio-rs/tokio-uring/pull/66
+[#65]: https://github.com/tokio-rs/tokio-uring/pull/65
+[#63]: https://github.com/tokio-rs/tokio-uring/pull/63
+[#39]: https://github.com/tokio-rs/tokio-uring/pull/39
+[#43]: https://github.com/tokio-rs/tokio-uring/pull/43

.idea/codeStyles/codeStyleConfig.xml

@@ -0,0 +1,53 @@
+[package]
+name = "tokio-uring"
+version = "0.5.0"
+authors = ["Tokio Contributors <team@tokio.rs>"]
+edition = "2018"
+readme = "README.md"
+license = "MIT"
+documentation = "https://docs.rs/tokio-uring/0.5.0/tokio-uring"
+repository = "https://github.com/tokio-rs/tokio-uring"
+homepage = "https://tokio.rs"
+description = """
+io-uring support for the Tokio asynchronous runtime.
+"""
+categories = ["asynchronous", "network-programming"]
+keywords = ["async", "fs", "io-uring"]
+
+# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
+
+[dependencies]
+tokio = { version = "1.2", features = ["full"] }
+atomic-wait = "1.1.0"
+atomic = "0.6"
+libc = "0.2.80"
+bytemuck = "1.22.0"
+io-uring = "0.6.0"
+socket2 = { version = "0.4.4", features = ["all"] }
+bytes = { version = "1.0", optional = true }
+futures-util = { version = "0.3.26", default-features = false, features = ["std"] }
+
+[dev-dependencies]
+tempfile = "3.2.0"
+tokio-test = "0.4.2"
+iai = "0.1.1"
+criterion = "0.4.0"
+# we use joinset in our tests
+tokio = "1.21.2"
+nix = "0.26.1"
+
+[package.metadata.docs.rs]
+all-features = true
+
+[profile.bench]
+debug = true
+
+[[bench]]
+name = "lai_no_op"
+path = "benches/lai/no_op.rs"
+harness = false
+
+[[bench]]
+name = "criterion_no_op"
+path = "benches/criterion/no_op.rs"
+harness = false