[ 
https://issues.apache.org/jira/browse/ZOOKEEPER-2442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15320859#comment-15320859
 ] 

Hudson commented on ZOOKEEPER-2442:
-----------------------------------

FAILURE: Integrated in ZooKeeper-trunk #2953 (See 
[https://builds.apache.org/job/ZooKeeper-trunk/2953/])
ZOOKEEPER-2442: Socket leak in QuorumCnxManager connectOne
(Michael Han via rgs) (rgs: 
[http://svn.apache.org/viewcvs.cgi/?root=Apache-SVN&view=rev&rev=1747408])
* trunk/CHANGES.txt
* trunk/src/java/main/org/apache/zookeeper/server/quorum/QuorumCnxManager.java


> Socket leak in QuorumCnxManager connectOne
> ------------------------------------------
>
>                 Key: ZOOKEEPER-2442
>                 URL: https://issues.apache.org/jira/browse/ZOOKEEPER-2442
>             Project: ZooKeeper
>          Issue Type: Bug
>          Components: quorum, server
>    Affects Versions: 3.5.1
>            Reporter: Michael Han
>            Assignee: Michael Han
>         Attachments: ZOOKEEPER-2442.patch
>
>
> The function connectOne() in QuorumCnxManager.java sometimes fails to release 
> a socket allocated by Socket():
> {code}
>  try {
>                 if (LOG.isDebugEnabled()) {
>                     LOG.debug("Opening channel to server " + sid);
>                 }
>                 Socket sock = new Socket();
>                 setSockOpts(sock);
>                 sock.connect(self.getView().get(sid).electionAddr, cnxTO);
>                 if (LOG.isDebugEnabled()) {
>                     LOG.debug("Connected to server " + sid);
>                 }
>                 initiateConnection(sock, sid);
>             } catch (UnresolvedAddressException e) {
>                 // Sun doesn't include the address that causes this
>                 // exception to be thrown, also UAE cannot be wrapped cleanly
>                 // so we log the exception in order to capture this critical
>                 // detail.
>                 LOG.warn("Cannot open channel to " + sid
>                         + " at election address " + electionAddr, e);
>                 throw e;
>             } catch (IOException e) {
>                 LOG.warn("Cannot open channel to " + sid
>                         + " at election address " + electionAddr,
>                         e);
>             }
> {code}
> Another place in Listener.run() where the client socket is not explicitly 
> closed.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to