[Rust] Add tokio-uring - HTTP/1.1

frameworks/tokio-uring/.dockerignore

@@ -0,0 +1,2 @@
+target
+.git

frameworks/tokio-uring/.gitignore

@@ -0,0 +1 @@
+/target

frameworks/tokio-uring/Cargo.toml

@@ -0,0 +1,14 @@
+[package]
+name = "httparena-tokio-uring"
+version = "0.1.0"
+edition = "2021"
+
+[dependencies]
+tokio-uring = "0.5"
+socket2 = { version = "0.5", features = ["all"] }
+
+[profile.release]
+codegen-units = 1
+lto = "thin"
+opt-level = 3
+panic = "abort"

frameworks/tokio-uring/Dockerfile

@@ -0,0 +1,13 @@
+FROM rust:1.95 AS build
+WORKDIR /app
+COPY Cargo.toml Cargo.lock ./
+RUN mkdir src && echo "fn main() {}" > src/main.rs \
+    && cargo build --release \
+    && rm -rf src target/release/httparena-tokio-uring target/release/deps/httparena_tokio_uring*
+COPY src ./src
+RUN RUSTFLAGS="-C target-cpu=native" cargo build --release
+
+FROM debian:bookworm-slim
+COPY --from=build /app/target/release/httparena-tokio-uring /server
+EXPOSE 8080
+CMD ["/server"]

frameworks/tokio-uring/README.md

@@ -0,0 +1,24 @@
+# tokio-uring
+
+A minimal **HTTP/1.1** server on **tokio-uring** — the io_uring-backed Rust
+runtime with a completion/owned-buffer API — for the H1-isolated profiles
+(`baseline`, `pipelined`, `limited-conn`). No HTTP framework.
+
+## Serving model
+One `tokio_uring::start` per core, each with its own `SO_REUSEPORT` listener
+(`socket2` + `from_std`). Reads/writes use tokio-uring's owned-buffer model: a
+`Vec<u8>` is passed by value into `read`/`write_all` and handed back, reused
+across iterations. Responses are batched per read.
+
+## Hand-rolled HTTP/1.1
+Request line + headers, `Content-Length` **and** `Transfer-Encoding: chunked`
+bodies, keep-alive, request pipelining, and fragmented-read reassembly.
+
+| Endpoint | Response |
+|---|---|
+| `GET/POST /baseline11?a=&b=` | `text/plain` — `a + b` (+ POST body as an integer) |
+| `GET /pipeline` | `text/plain` — `ok` |
+
+io_uring requires `seccomp=unconfined` under Docker (the harness sets this;
+`engine: "io_uring"` makes validate.sh enable it). `PORT` overrides the listen
+port for local testing.

frameworks/tokio-uring/meta.json

@@ -0,0 +1,15 @@
+{
+  "display_name": "tokio-uring",
+  "language": "Rust",
+  "type": "engine",
+  "engine": "io_uring",
+  "description": "Minimal HTTP/1.1 server on tokio-uring — the io_uring-backed Rust runtime with a completion/owned-buffer API. A hand-rolled request parser (Content-Length + chunked bodies, keep-alive, pipelining, fragmented reads), one runtime per core with SO_REUSEPORT. No HTTP framework.",
+  "repo": "https://github.com/tokio-rs/tokio-uring",
+  "enabled": true,
+  "tests": [
+    "baseline",
+    "pipelined",
+    "limited-conn"
+  ],
+  "maintainers": []
+}