mio 1.2.2: mio

# This file is automatically @generated by Cargo.
# It is not intended for manual editing.
version = 4

[[package]]
name = "libc"
version = "0.2.190"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "ce5d3ddc6d3fa000eb1536d85e147bfe31aacaba692ed6a876f95cb7c855be78"

[[package]]
name = "log"
version = "0.4.34"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "f9f8bd3e56ce4dfc153cf470fffbfa98c7620958b312ca5c3a4b8d5181fd13c6"

[[package]]
name = "mio"
version = "1.2.2"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "30d65c71f1ce40ab09135ce117d742b9f8a19ff91a41a8b57ed50bc2de59c427"
dependencies = [
 "libc",
 "log",
 "wasi",
 "windows-sys",
]

[[package]]
name = "sample-mio"
version = "1.0.0"
dependencies = [
 "mio",
]

[[package]]
name = "wasi"
version = "0.11.1+wasi-snapshot-preview1"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "ccf3ec651a847eb01de73ccad15eb7d99f80485de043efb2f370cd654f4ea44b"

[[package]]
name = "windows-link"
version = "0.2.1"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "f0805222e57f7521d6a62e36fa9163bc891acd422f971defe97d64e70d0a4fe5"

[[package]]
name = "windows-sys"
version = "0.61.2"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "ae137229bcbd6cdf0f7b80a31df61766145077ddf49416a728b02cb3921ff3fc"
dependencies = [
 "windows-link",
]

[package]
name = "sample-mio"
version = "1.0.0"
edition = "2021"
publish = false

[dependencies]
mio = { version = "=1.2.2", features = ["os-poll", "net"] }

[[bin]]
name = "contract"
path = "test/contract.rs"

Clean-room public code sample — generation instructions

Write a brand-new, minimal, self-contained code sample in this clean-room directory.
Do not copy, paraphrase, or reference any existing project source. Work only from this spec.

A csx.json manifest scaffold already exists. Do not recreate it from memory. Preserve its case.goal, packages and symbols; fill its empty case.contract with exact assertions and correct its environment, commands and verifierAdapter for the files you generate.

Goal: verify mio in pkg:cargo/mio@1.2.2
Kind: HOW

Use EXACTLY these public packages and versions:
  - pkg:cargo/mio@1.2.2
Demonstrate these symbols/APIs:
  - mio

Rules:
  - One focused purpose; the smallest project that proves the goal.
  - Include a contract test (test/contract.*) that runs OFFLINE and exits 0 exactly when the goal behavior works.
  - Pin every dependency with a lockfile so resolution is reproducible.
  - No secrets, credentials, or tokens. No real URLs (only example.com or localhost). No absolute paths.
  - No personal names, emails, company names, or project identifiers of any kind.
  - No binaries and no generated output (node_modules, dist, target, venv, .git, .env).
  - Keep it under 200 files and 256KB packed.

{"case":{"caseId":"case:sha256:1bad54777ff77839f3b6282958186581d2649b154532c57a29b74538fa3c436f","contract":["Poll and Events creation succeeds with empty initial event set","Interest combines READABLE and WRITABLE readiness flags","Waker wakes Poll and delivers readable event with matching token","TcpListener binds to local port and registers, reregisters, and deregisters with Poll registry","UdpSocket detects readable readiness and receives datagram over loopback"],"goal":"verify mio in pkg:cargo/mio@1.2.2","kind":"HOW","packages":["pkg:cargo/mio@1.2.2"],"schemaVersion":1,"symbols":["mio"]},"contractCommand":["cargo","run","--offline"],"environment":{"arch":"x64","distro":"alpine","ecosystem":"cargo","libc":"musl","os":"linux","packageManager":"cargo","schemaVersion":1},"license":"MIT-0","packages":["pkg:cargo/mio@1.2.2"],"schemaVersion":1,"subject":"pkg:cargo/mio@1.2.2","symbols":["mio"],"verifierAdapter":"cargo@1"}

{
  "schemaVersion": 1,
  "goal": "verify mio in pkg:cargo/mio@1.2.2",
  "kind": "HOW",
  "packages": [
    "pkg:cargo/mio@1.2.2"
  ],
  "symbols": [
    "mio"
  ]
}

//! Clean-room verification sample for mio.

pub use mio::*;

use std::time::Duration;
use mio::net::{TcpListener, UdpSocket};
use mio::{Events, Interest, Poll, Token, Waker};

fn main() {
    // 1. Poll and Events creation and capacity verification
    let mut poll = Poll::new().expect("Poll::new should succeed");
    let mut events = Events::with_capacity(32);
    assert!(events.is_empty(), "Events should initially be empty");

    // 2. Interest bitflags combinations
    let rw_interest = Interest::READABLE.add(Interest::WRITABLE);
    assert!(rw_interest.is_readable(), "Should include readable interest");
    assert!(rw_interest.is_writable(), "Should include writable interest");

    // 3. Waker waking poll instance with custom token
    const WAKER_TOKEN: Token = Token(10);
    let waker = Waker::new(poll.registry(), WAKER_TOKEN).expect("Waker::new should succeed");
    waker.wake().expect("Waker::wake should succeed");

    poll.poll(&mut events, Some(Duration::from_millis(500)))
        .expect("poll should succeed after waker");
    let mut waker_seen = false;
    for event in events.iter() {
        if event.token() == WAKER_TOKEN && event.is_readable() {
            waker_seen = true;
        }
    }
    assert!(waker_seen, "Waker event with token 10 should be received");

    // 4. TcpListener registration, reregistration, and deregistration
    const LISTENER_TOKEN_A: Token = Token(20);
    const LISTENER_TOKEN_B: Token = Token(21);
    let mut listener = TcpListener::bind("127.0.0.1:0".parse().unwrap())
        .expect("TcpListener::bind should succeed");
    let local_addr = listener.local_addr().expect("local_addr should succeed");
    assert!(local_addr.port() > 0, "Port should be non-zero");

    poll.registry()
        .register(&mut listener, LISTENER_TOKEN_A, Interest::READABLE)
        .expect("register listener should succeed");

    poll.registry()
        .reregister(&mut listener, LISTENER_TOKEN_B, Interest::READABLE)
        .expect("reregister listener should succeed");

    poll.registry()
        .deregister(&mut listener)
        .expect("deregister listener should succeed");

    // 5. UdpSocket readiness notification and datagram transfer over loopback
    const UDP_SERVER_TOKEN: Token = Token(30);
    let mut server_sock = UdpSocket::bind("127.0.0.1:0".parse().unwrap())
        .expect("UdpSocket server bind should succeed");
    let server_addr = server_sock.local_addr().expect("server local_addr should succeed");

    let client_sock = UdpSocket::bind("127.0.0.1:0".parse().unwrap())
        .expect("UdpSocket client bind should succeed");
    let client_addr = client_sock.local_addr().expect("client local_addr should succeed");

    poll.registry()
        .register(&mut server_sock, UDP_SERVER_TOKEN, Interest::READABLE)
        .expect("register udp server should succeed");

    client_sock
        .send_to(b"ping-mio", server_addr)
        .expect("send_to should succeed");

    events.clear();
    poll.poll(&mut events, Some(Duration::from_millis(500)))
        .expect("poll should succeed waiting for udp datagram");

    let mut udp_seen = false;
    for event in events.iter() {
        if event.token() == UDP_SERVER_TOKEN && event.is_readable() {
            udp_seen = true;
        }
    }
    assert!(udp_seen, "UDP server socket should be readable");

    let mut buf = [0u8; 32];
    let (bytes_read, peer_addr) = server_sock
        .recv_from(&mut buf)
        .expect("recv_from should succeed");
    assert_eq!(&buf[..bytes_read], b"ping-mio");
    assert_eq!(peer_addr, client_addr);

    poll.registry()
        .deregister(&mut server_sock)
        .expect("deregister udp socket should succeed");

    println!("All mio contract assertions passed successfully.");
}