Skip to content

Instantly share code, notes, and snippets.

@aep

aep/eq.zz

Created July 16, 2020 13:54
Show Gist options

  • Select an option

    Learn more about clone URLs
  • Save aep/6241e20ffb9cd68540e5cf72abd11b9d to your computer and use it in GitHub Desktop.

Select an option

Learn more about clone URLs
Save aep/6241e20ffb9cd68540e5cf72abd11b9d to your computer and use it in GitHub Desktop.
Download ZIP

Revisions

  1. aep created this gist Jul 16, 2020.
    36 changes: 36 additions & 0 deletions eq.zz
    View file
    Original file line number Diff line number Diff line change
    @@ -0,0 +1,36 @@
    struct UdpLogger
    {
    udp::Socket sock;
    string::String+1000 buf;
    udp::ReceiveEvent ev;
    }


    fn my_udp_logger_poll(UdpLogger mut*self, async::Eq mut*eq)
    {
    switch self->ev.state() {
    async::State::Parked => {
    return;
    },
    async::State::Error => {
    ev->error.abort();
    return;
    }
    async::State::Ready => {
    log::info("got %s", self->buf.mem);
    }
    async::State::Invalid => {
    }
    }
    self->ev = self->sock.recv(self->buf.to_mut_slice());
    }


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

    for (;;) {
    my_udp_logger_poll(eq);
    eq.wait();
    }
    }