commit | 13429a059f99b47d7fba7f6a684ddc8af6debd2b | [log] [tgz] |
---|---|---|
author | buyingyi <buyingyi@123451ca-8445-de46-9d55-352943316053> | Tue Feb 12 21:28:57 2013 +0000 |
committer | buyingyi <buyingyi@123451ca-8445-de46-9d55-352943316053> | Tue Feb 12 21:28:57 2013 +0000 |
tree | 4eac2f55a7246decacae7a904a0f9954ace462d3 | |
parent | 5472b8c929635c663d72c4a95e496f5da9fc80da [diff] |
revert a wrong checkin of the channelset fix git-svn-id: https://hyracks.googlecode.com/svn/branches/fullstack_asterix_stabilization@2904 123451ca-8445-de46-9d55-352943316053
diff --git a/hyracks/hyracks-net/src/main/java/edu/uci/ics/hyracks/net/protocols/muxdemux/ChannelSet.java b/hyracks/hyracks-net/src/main/java/edu/uci/ics/hyracks/net/protocols/muxdemux/ChannelSet.java index 5cae7b2..eb5f716 100644 --- a/hyracks/hyracks-net/src/main/java/edu/uci/ics/hyracks/net/protocols/muxdemux/ChannelSet.java +++ b/hyracks/hyracks-net/src/main/java/edu/uci/ics/hyracks/net/protocols/muxdemux/ChannelSet.java
@@ -58,7 +58,7 @@ ChannelControlBlock allocateChannel() throws NetException { synchronized (mConn) { - cleanupClosedChannels(); + //cleanupClosedChannels(); int idx = allocationBitmap.nextClearBit(0); if (idx < 0 || idx >= ccbArray.length) { cleanupClosedChannels(); @@ -232,4 +232,4 @@ ccbArray = Arrays.copyOf(ccbArray, ccbArray.length * 2); } } -} \ No newline at end of file +}