dorkbox/Network
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Added back timeout

Browse Source
This commit is contained in:
nathan 2017-11-08 11:38:12 +01:00
parent 5a746d9344
commit ecce442137
1 changed files with 14 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
src/dorkbox/network/dns/resolver/DnsQueryContext.java
View File

@ -18,6 +18,7 @@ package dorkbox.network.dns.resolver;
import static io.netty.util.internal.ObjectUtil.checkNotNull;
import java.net.InetSocketAddress;
import java.util.concurrent.TimeUnit;
import dorkbox.network.dns.DnsQuestion;
import dorkbox.network.dns.DnsResponse;
@ -135,20 +136,19 @@ class DnsQueryContext {
// Schedule a query timeout task if necessary.
final long queryTimeoutMillis = parent.queryTimeoutMillis();
if (queryTimeoutMillis > 0) {
// TODO UNCOMMENT!
// timeoutFuture = parent.ch.eventLoop()
// .schedule(new Runnable() {
// @Override
// public
// void run() {
// if (promise.isDone()) {
// // Received a response before the query times out.
// return;
// }
//
// setFailure("query timed out after " + queryTimeoutMillis + " milliseconds", null);
// }
// }, queryTimeoutMillis, TimeUnit.MILLISECONDS);
timeoutFuture = parent.ch.eventLoop()
.schedule(new Runnable() {
@Override
public
void run() {
if (promise.isDone()) {
// Received a response before the query times out.
return;
}
setFailure("query timed out after " + queryTimeoutMillis + " milliseconds", null);
}
}, queryTimeoutMillis, TimeUnit.MILLISECONDS);
}
}