Java 类java.net.BindException 实例源码

@Test
public void testBindError() throws Exception {
  Configuration conf = new Configuration();
  ServerSocket socket = new ServerSocket();
  InetSocketAddress address = new InetSocketAddress("0.0.0.0",0);
  socket.bind(address);
  try {
    int min = socket.getLocalPort();
    conf.set("TestRange", min+"-"+min);


    ServerSocket socket2 = new ServerSocket();
    InetSocketAddress address2 = new InetSocketAddress("0.0.0.0", 0);
    boolean caught = false;
    try {
      Server.bind(socket2, address2, 10, conf, "TestRange");
    } catch (BindException e) {
      caught = true;
    } finally {
      socket2.close();
    }
    assertTrue("Failed to catch the expected bind exception",caught);
  } finally {
    socket.close();
  }
}

/**
    * Build a new instance of InternalWebServer
    * @param nonce 
    *   A string to verify in responses
    * @throws IOException
    *   In case of Exception when starting webserver
    */
public InternalWebServer(UUID nonce) throws IOException {
    this.listenPort = Integer.parseInt(OwaNotifier.getInstance().getProps().getProperty("listenPort", "8080"));
    this.nonce = nonce;
    // Search an available port
    while(this.socket == null) {
        try {
            InetAddress[] IP=InetAddress.getAllByName("localhost");
            if(IP.length < 1) {
                throw new IOException("Unable to find localhost ip");
            }
            this.socket = new ServerSocket(this.listenPort, 10, IP[0]); // Start, listen on port 8080
            logger.info("Use listen " + this.socket.getInetAddress().toString() + ":" + this.listenPort);

        } catch (BindException e){
            this.listenPort = this.listenPort +1;
            OwaNotifier.getInstance().setProps("listenPort", this.listenPort + "");
        }
    }

    // detach thread
    serverThread = new Thread(this);
    serverThread.start();
}

public TestWebServer() throws IOException {

    int port = 9000;
    boolean bound = false;
    do {
      try {
        httpServer.bind(new InetSocketAddress(port), 0);
        bound = true;
      } catch (BindException e) {
        port++;
      }
    } while (!bound && port < 12000);

    httpServer.createContext(ECHO_ENDPOINT, new EchoHandler());

    httpServer.start();
  }

public ServerSocket createServerSocket(int nport, int backlog, InetAddress bindAddr,
    List<GatewayTransportFilter> transportFilters, int socketBufferSize) throws IOException {
  if (transportFilters.isEmpty()) {
    return createServerSocket(nport, backlog, bindAddr, socketBufferSize);
  } else {
    printConfig();
    ServerSocket result = new TransportFilterServerSocket(transportFilters);
    result.setReuseAddress(true);
    // Set the receive buffer size before binding the socket so
    // that large buffers will be allocated on accepted sockets (see
    // java.net.ServerSocket.setReceiverBufferSize javadocs)
    result.setReceiveBufferSize(socketBufferSize);
    try {
      result.bind(new InetSocketAddress(bindAddr, nport), backlog);
    } catch (BindException e) {
      BindException throwMe =
          new BindException(LocalizedStrings.SocketCreator_FAILED_TO_CREATE_SERVER_SOCKET_ON_0_1
              .toLocalizedString(new Object[] {bindAddr, Integer.valueOf(nport)}));
      throwMe.initCause(e);
      throw throwMe;
    }
    return result;
  }
}

/**
 * Tests setting the rpc port to the same as the web port to test that 
 * an exception
 * is thrown when trying to re-use the same port
 */
@Test(expected = BindException.class, timeout = 300000)
public void testThatMatchingRPCandHttpPortsThrowException() 
    throws IOException {

  NameNode nameNode = null;
  try {
    Configuration conf = new HdfsConfiguration();
    File nameDir = new File(MiniDFSCluster.getBaseDirectory(), "name");
    conf.set(DFSConfigKeys.DFS_NAMENODE_NAME_DIR_KEY,
        nameDir.getAbsolutePath());

    Random rand = new Random();
    final int port = 30000 + rand.nextInt(30000);

    // set both of these to the same port. It should fail.
    FileSystem.setDefaultUri(conf, "hdfs://localhost:" + port);
    conf.set(DFSConfigKeys.DFS_NAMENODE_HTTP_ADDRESS_KEY, "127.0.0.1:" + port);
    DFSTestUtil.formatNameNode(conf);
    nameNode = new NameNode(conf);
  } finally {
    if (nameNode != null) {
      nameNode.stop();
    }
  }
}

@Test
public void testBindError() throws Exception {
  Configuration conf = new Configuration();
  ServerSocket socket = new ServerSocket();
  InetSocketAddress address = new InetSocketAddress("0.0.0.0",0);
  socket.bind(address);
  try {
    int min = socket.getLocalPort();
    conf.set("TestRange", min+"-"+min);


    ServerSocket socket2 = new ServerSocket();
    InetSocketAddress address2 = new InetSocketAddress("0.0.0.0", 0);
    boolean caught = false;
    try {
      Server.bind(socket2, address2, 10, conf, "TestRange");
    } catch (BindException e) {
      caught = true;
    } finally {
      socket2.close();
    }
    assertTrue("Failed to catch the expected bind exception",caught);
  } finally {
    socket.close();
  }
}

/**
 * Test a configuration file which should make the bootstrap fail.
 * The test is assumed to have succeeded if the bootstrap fails.
 * @return null if the test succeeds, an error message otherwise.
 **/
private String testConfigurationKo(File conf,int port) {
    String errStr = null;
    for (int i = 0; i < PORT_TEST_LEN; i++) {
        try {
            errStr = testConfiguration(conf,port+testPort++);
            break;
        } catch (BindException e) {
            // port conflict; try another port
        }
    }
    if (errStr == null) {
        return "Configuration " +
            conf + " should have failed!";
    }
    System.out.println("Configuration " +
                       conf + " failed as expected");
    log.debug("runko","Error was: " + errStr);
    return null;
}

/**
 * Test a configuration file. Determines whether the bootstrap
 * should succeed or fail depending on the file name:
 *     *ok.properties: bootstrap should succeed.
 *     *ko.properties: bootstrap or connection should fail.
 * @return null if the test succeeds, an error message otherwise.
 **/
private String testConfigurationFile(String fileName) {
    File file = new File(fileName);
    final String portStr = System.getProperty("rmi.port",null);
    final int port       = portStr != null ?
                            Integer.parseInt(portStr) : basePort;

    if (fileName.endsWith("ok.properties")) {
        String errStr = null;
        for (int i = 0; i < PORT_TEST_LEN; i++) {
            try {
                errStr = testConfiguration(file,port+testPort++);
                return errStr;
            } catch (BindException e) {
                // port conflict; try another port
            }
        }
        return "Can not locate available port";
    }
    if (fileName.endsWith("ko.properties")) {
        return testConfigurationKo(file,port+testPort++);
    }
    return fileName +
        ": test file suffix must be one of [ko|ok].properties";
}

@Test
public final void testAgentRemote() throws Exception {
    while (true) {
        try {
            int[] ports = PortAllocator.allocatePorts(1);
            jcmd.start(
                "jmxremote.port=" + ports[0],
                "jmxremote.authenticate=false",
                "jmxremote.ssl=false"
            );
            String status = jcmd.status();

            assertStatusMatches(REMOTE_AGENT_STATUS, status);
            return;
        } catch (BindException e) {
            System.out.println("Failed to allocate ports. Retrying ...");
        }
    }
}

/**
 * After enabling the remote agent the 'sun.management.JMXConnectorServer.remote.enabled'
 * counter will be exported with value of '0' - corresponding to the actual
 * version of the associated remote connector perf counters.
 * @throws Exception
 */
@Test
public void testRemoteEnabled() throws Exception {
    while (true) {
        try {
            int[] ports = PortAllocator.allocatePorts(1);
            jcmd.start(
                "jmxremote.port=" + ports[0],
                "jmxremote.authenticate=false",
                "jmxremote.ssl=false"
            );
            String v = getCounters().getProperty(REMOTE_STATUS_KEY);
            assertNotNull(v);
            assertEquals("0", v);
            return;
        } catch (BindException e) {
            System.out.println("Failed to allocate ports. Retrying ...");
        }
    }
}

/**
 * After disabling the remote agent the value of 'sun.management.JMXConnectorServer.remote.enabled'
 * counter will become '-1'.
 * @throws Exception
 */
@Test
public void testRemoteDisabled() throws Exception {
    while (true) {
        try {
            int[] ports = PortAllocator.allocatePorts(1);
            jcmd.start(
                "jmxremote.port=" + ports[0],
                "jmxremote.authenticate=false",
                "jmxremote.ssl=false"
            );
            jcmd.stop();
            String v = getCounters().getProperty(REMOTE_STATUS_KEY);
            assertNotNull(v);
            assertEquals("-1", v);
            return;
        } catch (BindException e) {
            System.out.println("Failed to allocate ports. Retrying ...");
        }
    }
}

public int bind(final int initialPort, boolean allowPortHunting) {
  int port = initialPort - 1;
  while (true) {
    try {
      allChannels.add(b.bind(++port).sync().channel());
      break;
    } catch (Exception e) {
      // TODO(DRILL-3026):  Revisit:  Exception is not (always) BindException.
      // One case is "java.io.IOException: bind() failed: Address already in
      // use".
      if (e instanceof BindException && allowPortHunting) {
        continue;
      }
      throw UserException.resourceError( e )
            .addContext( "Server", rpcConfig.getName())
            .message( "Could not bind to port %s.", port )
            .build(logger);
    }
  }

  connect = !connect;
  logger.info("[{}]: Server started on port {}.", rpcConfig.getName(), port);
  return port;
}

public RequestListenerThread(Context context) throws IOException, BindException {
    serversocket = new ServerSocket(PORT);
    params = new BasicHttpParams();
    params.setIntParameter(CoreConnectionPNames.SO_TIMEOUT, 5000).setIntParameter(CoreConnectionPNames.SOCKET_BUFFER_SIZE, 8 * 1024)
            .setBooleanParameter(CoreConnectionPNames.STALE_CONNECTION_CHECK, false)
            .setBooleanParameter(CoreConnectionPNames.TCP_NODELAY, true).setParameter(CoreProtocolPNames.ORIGIN_SERVER, "HttpComponents/1.1");

    // Set up the HTTP protocol processor
    BasicHttpProcessor httpProcessor = new BasicHttpProcessor();
    httpProcessor.addInterceptor(new ResponseDate());
    httpProcessor.addInterceptor(new ResponseServer());
    httpProcessor.addInterceptor(new ResponseContent());
    httpProcessor.addInterceptor(new ResponseConnControl());

    // Set up the HTTP service
    this.httpService = new YaaccHttpService(httpProcessor, new DefaultConnectionReuseStrategy(), new DefaultHttpResponseFactory(), context);

}

/**
 * Creates a NIO ServerSocketChannel, and gets the ServerSocket from
 * there. Then binds the obtained socket.
 * This fails on Windows with Oracle JDK1.6.0u33, if the passed InetAddress is a
 * IPv6 address. Works on Oracle JDK 1.7.
 */
private void bindNIOServerSocket(InetAddress inetAddr) throws IOException {
  while (true) {
    int port = HBaseTestingUtility.randomFreePort();
    InetSocketAddress addr = new InetSocketAddress(inetAddr, port);
    ServerSocketChannel channel = null;
    ServerSocket serverSocket = null;
    try {
      channel = ServerSocketChannel.open();
      serverSocket = channel.socket();
      serverSocket.bind(addr); // This does not work
      break;
    } catch (BindException ex) {
      //continue
    } finally {
      if (serverSocket != null) {
        serverSocket.close();
      }
      if (channel != null) {
        channel.close();
      }
    }  
  }
}

/**
 * Checks whether we are effected by the JDK issue on windows, and if so
 * ensures that we are running with preferIPv4Stack=true.
 */
@Test
public void testServerSocket() throws IOException {
  byte[] addr = { 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 1 };
  InetAddress inetAddr = InetAddress.getByAddress(addr);

  try {
    bindServerSocket(inetAddr);
    bindNIOServerSocket(inetAddr);
    //if on *nix or windows JDK7, both will pass
  } catch(java.net.SocketException ex) {
    //On Windows JDK6, we will get expected exception:
    //java.net.SocketException: Address family not supported by protocol family
    //or java.net.SocketException: Protocol family not supported
    Assert.assertFalse(ex.getClass().isInstance(BindException.class));
    Assert.assertTrue(ex.getMessage().toLowerCase().contains("protocol family"));
    LOG.info("Received expected exception:");
    LOG.info(ex);

    //if this is the case, ensure that we are running on preferIPv4=true
    ensurePreferIPv4();
  }
}

/**
 * Assign a HiddenServicePortInstance to a port.
 * 
 * @param instance
 *            instance inclusive port number
 * @throws BindException
 *             if the port is already in use
 */
public synchronized void putHiddenServicePortInstance(
        HiddenServicePortInstance instance) throws BindException
{
    // check that port is still available
    final int port = instance.getPort();
    final HiddenServicePortInstance old = getHiddenServicePortInstance(port);
    if (old != null && old.isOpen())
    {
        // port is already occupied
        throw new BindException("port=" + port
                + " is already in use - instance=" + instance
                + " cannot be bound to");
    }

    // reserve the port
    listenPortsOfThisHiddenService.put(port, instance);
    instance.setHiddenServiceInstance(this);
}

private static void directProxyTest(int proxyPort, boolean samePort) throws IOException, InterruptedException {
    Object proxy = null;
    try {
        proxy = getProxy(proxyPort, true);
    } catch (BindException e) {
        System.out.println("Bind failed");
        throw e;
    } catch (Throwable ee) {
        throw new RuntimeException(ee);
    }
    System.out.println("Proxy port = " + proxyPort);
    if (!samePort)
        proxyPort++;

    HttpClient cl = HttpClient.create()
            .proxy(ProxySelector.of(
                            new InetSocketAddress("127.0.0.1", proxyPort)))
            .build();
    clients.add(cl);

    URI u = URI.create("http://127.0.0.1:" + port + "/files/foo.txt");
    HttpRequest request = cl.request(u)
            .headers("X-Foo", "bar", "X-Bar", "foo")
            .GET();
    HttpResponse response = request.response();
}

@Test
public final void testAgentRemote() throws Exception {
    while (true) {
        try {
            int[] ports = PortAllocator.allocatePorts(1);
            jcmd.start(
                "jmxremote.port=" + ports[0],
                "jmxremote.authenticate=false",
                "jmxremote.ssl=false"
            );
            String status = jcmd.status();

            assertStatusMatches(REMOTE_AGENT_STATUS, status);
            return;
        } catch (BindException e) {
            System.out.println("Failed to allocate ports. Retrying ...");
        }
    }
}

private Application build() throws Exception {
    Application app = null;
    Exception exception = null;

    // if we get a bind exception, then retry a few times (may conflict with parallel test runs)
    for (int i = 0; i < 5; i++) {
        try {
            generateXml();
            app = new Application(path, networking, true);
            break;
        } catch (Error e) { // the container thinks this is really serious, in this case is it not in the cause is a BindException
            // catch bind error and reset container
            if (e.getCause() != null && e.getCause().getCause() != null && e.getCause().getCause() instanceof BindException) {
                exception = (Exception) e.getCause().getCause();
                com.yahoo.container.Container.resetInstance(); // this is needed to be able to recreate the container from config again
            } else {
                throw new Exception(e.getCause());
            }
        }
    }

    if (app == null) {
        throw exception;
    }
    return app;
}

/**
 * After enabling the remote agent the 'sun.management.JMXConnectorServer.remote.enabled'
 * counter will be exported with value of '0' - corresponding to the actual
 * version of the associated remote connector perf counters.
 * @throws Exception
 */
@Test
public void testRemoteEnabled() throws Exception {
    while (true) {
        try {
            int[] ports = PortAllocator.allocatePorts(1);
            jcmd.start(
                "jmxremote.port=" + ports[0],
                "jmxremote.authenticate=false",
                "jmxremote.ssl=false"
            );
            String v = getCounters().getProperty(REMOTE_STATUS_KEY);
            assertNotNull(v);
            assertEquals("0", v);
            return;
        } catch (BindException e) {
            System.out.println("Failed to allocate ports. Retrying ...");
        }
    }
}

/**
 * After disabling the remote agent the value of 'sun.management.JMXConnectorServer.remote.enabled'
 * counter will become '-1'.
 * @throws Exception
 */
@Test
public void testRemoteDisabled() throws Exception {
    while (true) {
        try {
            int[] ports = PortAllocator.allocatePorts(1);
            jcmd.start(
                "jmxremote.port=" + ports[0],
                "jmxremote.authenticate=false",
                "jmxremote.ssl=false"
            );
            jcmd.stop();
            String v = getCounters().getProperty(REMOTE_STATUS_KEY);
            assertNotNull(v);
            assertEquals("-1", v);
            return;
        } catch (BindException e) {
            System.out.println("Failed to allocate ports. Retrying ...");
        }
    }
}

private static ServerSocket createServerSocketTry(int port, boolean ssl) {
    try {
        InetAddress bindAddress = getBindAddress();
        if (ssl) {
            return CipherFactory.createServerSocket(port, bindAddress);
        }
        if (bindAddress == null) {
            return new ServerSocket(port);
        }
        return new ServerSocket(port, 0, bindAddress);
    } catch (BindException be) {
        throw DbException.get(ErrorCode.EXCEPTION_OPENING_PORT_2,
                be, "" + port, be.toString());
    } catch (IOException e) {
        throw DbException.convertIOException(e, "port: " + port + " ssl: " + ssl);
    }
}

/**
 * Tests setting the rpc port to the same as the web port to test that 
 * an exception
 * is thrown when trying to re-use the same port
 */
@Test(expected = BindException.class, timeout = 300000)
public void testThatMatchingRPCandHttpPortsThrowException() 
    throws IOException {

  NameNode nameNode = null;
  try {
    Configuration conf = new HdfsConfiguration();
    File nameDir = new File(MiniDFSCluster.getBaseDirectory(), "name");
    conf.set(DFSConfigKeys.DFS_NAMENODE_NAME_DIR_KEY,
        nameDir.getAbsolutePath());

    Random rand = new Random();
    final int port = 30000 + rand.nextInt(30000);

    // set both of these to the same port. It should fail.
    FileSystem.setDefaultUri(conf, "hdfs://localhost:" + port);
    conf.set(DFSConfigKeys.DFS_NAMENODE_HTTP_ADDRESS_KEY, "127.0.0.1:" + port);
    DFSTestUtil.formatNameNode(conf);
    nameNode = new NameNode(conf);
  } finally {
    if (nameNode != null) {
      nameNode.stop();
    }
  }
}

public static StartResult start(int port) {
    try {
        smtpServer = new SMTPServer(new SimpleMessageListenerAdapter(listener), new SMTPAuthHandlerFactory());
        smtpServer.setPort(port);
        smtpServer.start();

        return new StartResult(true, null);
    } catch (Throwable e) {
        log.error("Failed to start SMTP server", e);

        if (e.getCause() instanceof BindException) {
            return new StartResult(false, String.format(Messages.get("%s, port: %s"), e.getCause().getMessage(), port));
        } else if (e.getCause() instanceof IllegalArgumentException && e.getMessage().contains("out of range")) {
            return new StartResult(false, String.format(Messages.get("server.error.outofrange"), port));
        } else {
            return new StartResult(false, e.getLocalizedMessage());
        }
    }
}

Leader(QuorumPeer self,LeaderZooKeeperServer zk) throws IOException {
    this.self = self;
    try {
        if (self.getQuorumListenOnAllIPs()) {
            ss = new ServerSocket(self.getQuorumAddress().getPort());
        } else {
            ss = new ServerSocket();
        }
        ss.setReuseAddress(true);
        if (!self.getQuorumListenOnAllIPs()) {
            ss.bind(self.getQuorumAddress());
        }
    } catch (BindException e) {
        if (self.getQuorumListenOnAllIPs()) {
            LOG.error("Couldn't bind to port " + self.getQuorumAddress().getPort(), e);
        } else {
            LOG.error("Couldn't bind to " + self.getQuorumAddress(), e);
        }
        throw e;
    }
    this.zk=zk;
}

Leader(QuorumPeer self,LeaderZooKeeperServer zk) throws IOException {
    this.self = self;
    try {
        if (self.getQuorumListenOnAllIPs()) {
            ss = new ServerSocket(self.getQuorumAddress().getPort());
        } else {
            ss = new ServerSocket();
        }
        ss.setReuseAddress(true);
        if (!self.getQuorumListenOnAllIPs()) {
            ss.bind(self.getQuorumAddress());
        }
    } catch (BindException e) {
        if (self.getQuorumListenOnAllIPs()) {
            LOG.error("Couldn't bind to port " + self.getQuorumAddress().getPort(), e);
        } else {
            LOG.error("Couldn't bind to " + self.getQuorumAddress(), e);
        }
        throw e;
    }
    this.zk = zk;
}

/**
 * 智能选择port.
 * 
 * @param port
 * @return
 * @throws BindException
 */
protected int getAutoPort(int port) throws BindException {
    if (System.getProperty("os.name").startsWith("Mac")) {
        if (port == 80) {
            port = 8080;
        }
        return port;
    }
    try {
        checkOpened(port);
    }
    catch (BindException e) {
        if (port == 80) {
            checkOpened(8080);
            port = 8080;
        }
        else {
            throw e;
        }
    }
    return port;
}

@Test
public void errorEmittedIfServerSocketBusy() throws IOException {
    reset();
    TestSubscriber<Object> ts = TestSubscriber.create();
    ServerSocket socket = null;
    int port = 12345;
    try {
        socket = new ServerSocket(port);
        IO.serverSocket(port).readTimeoutMs(10000).bufferSize(5).create().subscribe(ts);
        ts.assertNoValues();
        ts.assertNotComplete();
        ts.assertTerminated();
        ts.assertError(new Predicate<Throwable>() {
            @Override
            public boolean test(Throwable e) throws Exception {
                return e instanceof BindException;
            }
        });
    } finally {
        socket.close();
    }
}

/** keeping a few tests with mcast-port */
private static Connection getConnectionWithRandomMcastPort()
    throws SQLException {
  Properties props = new Properties();
  RETRY: while (true) {
    final int mcastPort = AvailablePort
        .getRandomAvailablePort(AvailablePort.JGROUPS);
    props.setProperty("mcast-port", String.valueOf(mcastPort));
    try {
      return getConnection(props);
    } catch (SQLException ex) {
      if ("XJ040".equals(ex.getSQLState())) {
        // check if a BindException then retry
        Throwable t = ex;
        while ((t = t.getCause()) != null) {
          if (t instanceof BindException) {
            continue RETRY;
          }
        }
      }
      throw ex;
    }
  }
}

/**
 * Returns true if a cause of the given (non-null) exception is a
 * BindException with message containing {@link #ADDRESS_ALREADY_IN_USE}.
 * or a SocketException with message containing {@link #UNRECOGNIZED_SOCKET}.
 */
public static boolean addressAlreadyInUse(Throwable t) {
  if (t == null) {
    throw new IllegalArgumentException("Exception cannot be null");
  }
  Throwable root = t;
  while (root != null) {
    if (root instanceof BindException &&
        root.getMessage() != null &&
        root.getMessage().contains(ADDRESS_ALREADY_IN_USE)) {
      Log.getLogWriter().warning("Got BindException: " + ADDRESS_ALREADY_IN_USE);
      return true;
    }
    if (root instanceof SocketException &&
        root.getMessage() != null &&
        root.getMessage().contains(UNRECOGNIZED_SOCKET)) {
      Log.getLogWriter().warning("Got SocketException: " + UNRECOGNIZED_SOCKET);
      return true;
    }
    root = root.getCause();
  }
  return false;
}

/**
 * Tests setting the rpc port to the same as the web port to test that 
 * an exception
 * is thrown when trying to re-use the same port
 */
@Test(expected = BindException.class, timeout = 300000)
public void testThatMatchingRPCandHttpPortsThrowException() 
    throws IOException {

  NameNode nameNode = null;
  try {
    Configuration conf = new HdfsConfiguration();
    File nameDir = new File(MiniDFSCluster.getBaseDirectory(), "name");
    conf.set(DFSConfigKeys.DFS_NAMENODE_NAME_DIR_KEY,
        nameDir.getAbsolutePath());

    Random rand = new Random();
    final int port = 30000 + rand.nextInt(30000);

    // set both of these to the same port. It should fail.
    FileSystem.setDefaultUri(conf, "hdfs://localhost:" + port);
    conf.set(DFSConfigKeys.DFS_NAMENODE_HTTP_ADDRESS_KEY, "127.0.0.1:" + port);
    DFSTestUtil.formatNameNode(conf);
    nameNode = new NameNode(conf);
  } finally {
    if (nameNode != null) {
      nameNode.stop();
    }
  }
}

@Test
public void testBindError() throws Exception {
  Configuration conf = new Configuration();
  ServerSocket socket = new ServerSocket();
  InetSocketAddress address = new InetSocketAddress("0.0.0.0",0);
  socket.bind(address);
  try {
    int min = socket.getLocalPort();
    conf.set("TestRange", min+"-"+min);


    ServerSocket socket2 = new ServerSocket();
    InetSocketAddress address2 = new InetSocketAddress("0.0.0.0", 0);
    boolean caught = false;
    try {
      Server.bind(socket2, address2, 10, conf, "TestRange");
    } catch (BindException e) {
      caught = true;
    } finally {
      socket2.close();
    }
    assertTrue("Failed to catch the expected bind exception",caught);
  } finally {
    socket.close();
  }
}

Leader(QuorumPeer self,LeaderZooKeeperServer zk) throws IOException {
    this.self = self;
    try {
        if (self.getQuorumListenOnAllIPs()) {
            ss = new ServerSocket(self.getQuorumAddress().getPort());
        } else {
            ss = new ServerSocket();
        }
        ss.setReuseAddress(true);
        if (!self.getQuorumListenOnAllIPs()) {
            ss.bind(self.getQuorumAddress());
        }
    } catch (BindException e) {
        if (self.getQuorumListenOnAllIPs()) {
            LOG.error("Couldn't bind to port " + self.getQuorumAddress().getPort(), e);
        } else {
            LOG.error("Couldn't bind to " + self.getQuorumAddress(), e);
        }
        throw e;
    }
    this.zk=zk;
}

/**
 * Test a configuration file which should make the bootstrap fail.
 * The test is assumed to have succeeded if the bootstrap fails.
 * @return null if the test succeeds, an error message otherwise.
 **/
private String testConfigurationKo(File conf,int port) {
    String errStr = null;
    for (int i = 0; i < PORT_TEST_LEN; i++) {
        try {
            errStr = testConfiguration(conf,port+testPort++);
            break;
        } catch (BindException e) {
            // port conflict; try another port
        }
    }
    if (errStr == null) {
        return "Configuration " +
            conf + " should have failed!";
    }
    System.out.println("Configuration " +
                       conf + " failed as expected");
    log.debug("runko","Error was: " + errStr);
    return null;
}

/**
 * Test a configuration file. Determines whether the bootstrap
 * should succeed or fail depending on the file name:
 *     *ok.properties: bootstrap should succeed.
 *     *ko.properties: bootstrap or connection should fail.
 * @return null if the test succeeds, an error message otherwise.
 **/
private String testConfigurationFile(String fileName) {
    File file = new File(fileName);
    final String portStr = System.getProperty("rmi.port",null);
    final int port       = portStr != null ?
                            Integer.parseInt(portStr) : basePort;

    if (fileName.endsWith("ok.properties")) {
        String errStr = null;
        for (int i = 0; i < PORT_TEST_LEN; i++) {
            try {
                errStr = testConfiguration(file,port+testPort++);
                return errStr;
            } catch (BindException e) {
                // port conflict; try another port
            }
        }
        return "Can not locate available port";
    }
    if (fileName.endsWith("ko.properties")) {
        return testConfigurationKo(file,port+testPort++);
    }
    return fileName +
        ": test file suffix must be one of [ko|ok].properties";
}

/**
 * Test a configuration file which should make the bootstrap fail.
 * The test is assumed to have succeeded if the bootstrap fails.
 * @return null if the test succeeds, an error message otherwise.
 **/
private String testConfigurationKo(File conf,int port) {
    String errStr = null;
    for (int i = 0; i < PORT_TEST_LEN; i++) {
        try {
            errStr = testConfiguration(conf,port+testPort++);
            break;
        } catch (BindException e) {
            // port conflict; try another port
        }
    }
    if (errStr == null) {
        return "Configuration " +
            conf + " should have failed!";
    }
    System.out.println("Configuration " +
                       conf + " failed as expected");
    log.debug("runko","Error was: " + errStr);
    return null;
}

/**
 * Test a configuration file. Determines whether the bootstrap
 * should succeed or fail depending on the file name:
 *     *ok.properties: bootstrap should succeed.
 *     *ko.properties: bootstrap or connection should fail.
 * @return null if the test succeeds, an error message otherwise.
 **/
private String testConfigurationFile(String fileName) {
    File file = new File(fileName);
    final String portStr = System.getProperty("rmi.port",null);
    final int port       = portStr != null ?
                            Integer.parseInt(portStr) : basePort;

    if (fileName.endsWith("ok.properties")) {
        String errStr = null;
        for (int i = 0; i < PORT_TEST_LEN; i++) {
            try {
                errStr = testConfiguration(file,port+testPort++);
                return errStr;
            } catch (BindException e) {
                // port conflict; try another port
            }
        }
        return "Can not locate available port";
    }
    if (fileName.endsWith("ko.properties")) {
        return testConfigurationKo(file,port+testPort++);
    }
    return fileName +
        ": test file suffix must be one of [ko|ok].properties";
}

@Override
public void start(StartContext context) throws StartException {
    int port = Integer.getInteger(SwarmProperties.ARQUILLIAN_DAEMON_PORT, 12345);

    try {
        this.server = Server.create("localhost", port);
        this.server.start();
    } catch (Exception e) {
        // this shouldn't be possible per Java control flow rules, but there is a "sneaky throw" somewhere
        //noinspection ConstantConditions
        if (e instanceof BindException) {
            log.log(Level.SEVERE, "Couldn't bind Arquillian Daemon on localhost:" + port
                    + "; you can change the port using system property '"
                    + SwarmProperties.ARQUILLIAN_DAEMON_PORT + "'", e);
        }

        throw new StartException(e);
    }
}

private static PatchLogServer server(int port, String base) {
    // --- Reset state.
    FileOps.ensureDir(base);
    FileOps.clearAll("DeltaServer/ABC");
    FileOps.delete("DeltaServer/ABC");
    FileOps.clearAll(base);
    PatchLogServer dps = PatchLogServer.server(port, base);
    try { 
        dps.start();
        return dps; 
    } catch(BindException ex) {
        Delta.DELTA_LOG.error("Address in use: port="+port);
        System.exit(0);
        return null;
    }
}

@Override
public void onError(WebSocket conn, Exception ex) {
    UCore.log("WS error:");
    ex.printStackTrace();
    if(ex instanceof BindException){
        Net.closeServer();
        Vars.ui.showError("$text.server.addressinuse");
    }
}