eq.zz.cpp

struct UdpEcho
{
    udp::Socket         sock;
    udp::Receive+1000   recv;
    udp::Receive+1000   send;
}

fn poll(UdpEcho mut*self, async::Eq mut*eq)
{
    switch self->send.state() {
        async::State::Parked => {
            return;
        },
        async::State::Error  => {
            ev->error.abort();
            return;
        }
        default => {
        }
    }

    switch self->recv.state() {
        async::State::Parked => {
            return;
        },
        async::State::Error  => {
            ev->error.abort();
            return;
        }
        async::State::Ready => {
            log::info("got %s", self->buf.mem);
            slice::copy(&self->recv.mem, &self->send.packet);
            self->sock.async_send(&self->send, eq);
        }
        async::State::Invalid | async::State::Canceled => {
        }
    }
    self->sock.async_recv(&self->recv, eq);
}


fn main() {
    new eq = async::eventqueue();

    for (;;) {
        myecho.poll(&eq);
        eq.park();
    }
}