Support a receive timeout for UDP connections

[s-ludwig]

Add either an overload of receive that takes a timeout parameter, or add a separate waitForData method analogous to the one in TCPConnection.

[zek]

Is this done?

[s-ludwig]

Seems like this slipped the 0.7.19 milestone. It's marked now for 0.7.20. I'm still very busy with other issues, so I can't work on it right now yet, though.

[zek]

I see.
Is there any temporary solution to solve this problem?
I am sending udp packet and trying to receive but sometimes it just goes infinite loop it's waiting data

[s-ludwig]

A relatively crude workaround would go similar to this:

ubyte[] readTimeout(UDPConnection udp, ubyte[] buffer, Duration timeout)
{
    ubyte[] ret;
    Exception ex;
    auto read_task = runTask({
        try ret = udp.read(buffer);
        catch (Exception e) ex = e;
    }
    auto timer = setTimer(timeout, { read_task.interrupt(); });
    read_task.join();
    timer.stop();
    if (ex) throw ex;
    return ret;
}

(I didn't test actually this, so it may still contain some mistakes)

[zek]

It works well 👍

[zek]

I tried the same code for
connectTCP(ip, port);
but it doesn't work.

[s-ludwig]

What happens for connectTCP? The code looks like it should work there, too.

[zek]

I tried but doesnt work. it tries to connect to peer but it just stuck. Need to a connection timeout

[s-ludwig]

This works for me:

import vibe.d;

TCPConnection connectTCPTimeout(Duration timeout, string host, ushort port)
{
    TCPConnection conn;
    Exception ex;
    auto connect_task = runTask({
        try conn = connectTCP(host, port);
        catch (Exception e) { ex = e; }
    });
    auto tm = setTimer(10.seconds, { connect_task.interrupt(); });
    connect_task.join();
    tm.stop();
    if (ex) throw ex;
    return conn;
}

shared static this()
{
    runTask({
        // must run in a task so that join() works
        connectTCPTimeout(10.seconds, "1.1.1.1", 23);
    });
}

[Downchuck]

Was this tested in Windows? My thread is handing on a simple timeout on Win 8.1, vibe 0.7.22:
Duration packetTimeout = dur!"msecs"(100);
auto pack = udp_listener.recv(packetTimeout);