diff options
Diffstat (limited to 'plugins/org.eclipse.net4j.http.common/src/org/eclipse/net4j/http/internal/common/HTTPChannel.java')
-rw-r--r-- | plugins/org.eclipse.net4j.http.common/src/org/eclipse/net4j/http/internal/common/HTTPChannel.java | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/plugins/org.eclipse.net4j.http.common/src/org/eclipse/net4j/http/internal/common/HTTPChannel.java b/plugins/org.eclipse.net4j.http.common/src/org/eclipse/net4j/http/internal/common/HTTPChannel.java index 1ade346795..93530788ce 100644 --- a/plugins/org.eclipse.net4j.http.common/src/org/eclipse/net4j/http/internal/common/HTTPChannel.java +++ b/plugins/org.eclipse.net4j.http.common/src/org/eclipse/net4j/http/internal/common/HTTPChannel.java @@ -17,6 +17,7 @@ import org.eclipse.internal.net4j.channel.Channel; import java.util.Map; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.CountDownLatch; +import java.util.concurrent.TimeUnit; /** * @author Eike Stepper @@ -72,11 +73,11 @@ public class HTTPChannel extends Channel openAck.countDown(); } - public void waitForOpenAck() + public void waitForOpenAck(long timeout) { try { - openAck.await(); + openAck.await(timeout, TimeUnit.MILLISECONDS); } catch (InterruptedException ignore) { |