lxy/redkale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

createUDPClient

Browse Source
This commit is contained in:
redkale
2024-01-22 22:40:11 +08:00
parent 257b406d73
commit 1c19b70ae9
1 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/main/java/org/redkale/net/AsyncIOGroup.java
View File

@@ -315,8 +315,7 @@ public class AsyncIOGroup extends AsyncGroup {
} catch (IOException e) { } catch (IOException e) {
return CompletableFuture.failedFuture(e); return CompletableFuture.failedFuture(e);
} }
int seconds = connectTimeoutSeconds > 0 ? connectTimeoutSeconds : 6; final CompletableFuture future = new CompletableFuture();
final CompletableFuture future = Utility.orTimeout(new CompletableFuture(), () -> address + " connect timeout", seconds, TimeUnit.SECONDS);
conn.connect(address, null, new CompletionHandler<Void, Void>() { conn.connect(address, null, new CompletionHandler<Void, Void>() {
@Override @Override
public void completed(Void result, Void attachment) { public void completed(Void result, Void attachment) {
@@ -338,7 +337,9 @@ public class AsyncIOGroup extends AsyncGroup {
future.completeExceptionally(exc); future.completeExceptionally(exc);
} }
}); });
return future; int seconds = connectTimeoutSeconds > 0 ? connectTimeoutSeconds : 6;
final Supplier<String> timeoutMsg = () -> address + " udp-connect timeout";
return Utility.orTimeout(future, timeoutMsg, seconds, TimeUnit.SECONDS);
} }
} }