| | |
| | | * CDDL HEADER END |
| | | * |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | * Portions Copyright 2006-2008 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.protocols.jmx; |
| | | import java.io.IOException; |
| | | import org.opends.messages.Message; |
| | | |
| | | |
| | |
| | | |
| | | import java.net.InetSocketAddress; |
| | | import java.net.ServerSocket; |
| | | import java.net.Socket; |
| | | import java.util.ArrayList; |
| | | import java.util.Collection; |
| | | import java.util.LinkedHashMap; |
| | |
| | | ServerSocket s = null; |
| | | try |
| | | { |
| | | // HACK: |
| | | // With dual stacks we can have a situation when INADDR_ANY/PORT |
| | | // is bound in TCP4 space but available in TCP6 space and since |
| | | // JavaServerSocket implemantation will always use TCP46 on dual |
| | | // stacks the bind below will always succeed in such cases thus |
| | | // shadowing anything that is already bound to INADDR_ANY/PORT. |
| | | // While technically correct, with IPv4 and IPv6 being separate |
| | | // address spaces, it presents a problem to end users because a |
| | | // common case scenario is to have a single service serving both |
| | | // address spaces ie listening to the same port in both spaces |
| | | // on wildcard addresses 0 and ::. ServerSocket implemantation |
| | | // does not provide any means of working with each address space |
| | | // separately such as doing TCP4 or TCP6 only binds thus we have |
| | | // to do a dummy connect to INADDR_ANY/PORT to check if it is |
| | | // bound to something already. This is only needed for wildcard |
| | | // addresses as specific IPv4 or IPv6 addresses will always be |
| | | // handled in their respective address space. |
| | | Socket clientSocket = new Socket(); |
| | | try { |
| | | // This might fail on some stacks but this is the best we |
| | | // can do. No need for explicit timeout since it is local |
| | | // address and we have to know for sure unless it fails. |
| | | clientSocket.connect(new InetSocketAddress( |
| | | config.getListenPort())); |
| | | } catch (IOException e) { |
| | | // Expected, ignore. |
| | | } |
| | | if (clientSocket.isConnected()) { |
| | | clientSocket.close(); |
| | | throw new IOException( |
| | | ERR_CONNHANDLER_ADDRESS_INUSE.get().toString()); |
| | | } |
| | | |
| | | s = new ServerSocket(); |
| | | s.setReuseAddress(true); |
| | | s.bind(new InetSocketAddress(config.getListenPort())); |