Apache
/
druid
mirror of https://github.com/apache/druid.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

AsyncQueryForwardingServletTest#testDeleteBroadcast sometimes fails by port conflict

This commit is contained in:
navis.ryu 2016-01-29 19:28:58 +09:00
parent edd7ce58aa
commit c03918f89a
1 changed files with 10 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
server/src/test/java/io/druid/server/AsyncQueryForwardingServletTest.java
View File

@ -29,6 +29,7 @@ import com.google.inject.Key;
import com.google.inject.Module; import com.google.inject.Module;
import com.google.inject.servlet.GuiceFilter; import com.google.inject.servlet.GuiceFilter;
import com.metamx.common.lifecycle.Lifecycle; import com.metamx.common.lifecycle.Lifecycle;
import io.druid.common.utils.SocketUtil;
import io.druid.guice.GuiceInjectors; import io.druid.guice.GuiceInjectors;
import io.druid.guice.Jerseys; import io.druid.guice.Jerseys;
import io.druid.guice.JsonConfigProvider; import io.druid.guice.JsonConfigProvider;
@ -69,6 +70,9 @@ import java.util.concurrent.CountDownLatch;
public class AsyncQueryForwardingServletTest extends BaseJettyTest public class AsyncQueryForwardingServletTest extends BaseJettyTest
{ {
private static int port1;
private static int port2;
@Before @Before
public void setup() throws Exception public void setup() throws Exception
{ {
@ -76,6 +80,8 @@ public class AsyncQueryForwardingServletTest extends BaseJettyTest
Injector injector = setupInjector(); Injector injector = setupInjector();
final DruidNode node = injector.getInstance(Key.get(DruidNode.class, Self.class)); final DruidNode node = injector.getInstance(Key.get(DruidNode.class, Self.class));
port = node.getPort(); port = node.getPort();
port1 = SocketUtil.findOpenPort(port + 1);
port2 = SocketUtil.findOpenPort(port1 + 1);
lifecycle = injector.getInstance(Lifecycle.class); lifecycle = injector.getInstance(Lifecycle.class);
lifecycle.start(); lifecycle.start();
@ -133,8 +139,8 @@ public class AsyncQueryForwardingServletTest extends BaseJettyTest
public void testDeleteBroadcast() throws Exception public void testDeleteBroadcast() throws Exception
{ {
CountDownLatch latch = new CountDownLatch(2); CountDownLatch latch = new CountDownLatch(2);
makeTestDeleteServer(port + 1, latch).start(); makeTestDeleteServer(port1, latch).start();
makeTestDeleteServer(port + 2, latch).start(); makeTestDeleteServer(port2, latch).start();
final URL url = new URL("http://localhost:" + port + "/druid/v2/abc123"); final URL url = new URL("http://localhost:" + port + "/druid/v2/abc123");
final HttpURLConnection post = (HttpURLConnection) url.openConnection(); final HttpURLConnection post = (HttpURLConnection) url.openConnection();
@ -199,8 +205,8 @@ public class AsyncQueryForwardingServletTest extends BaseJettyTest
{ {
return ImmutableList.of( return ImmutableList.of(
"localhost:" + node.getPort(), "localhost:" + node.getPort(),
"localhost:" + (node.getPort() + 1), "localhost:" + port1,
"localhost:" + (node.getPort() + 2) "localhost:" + port2
); );
} }
}; };