| commit | e9e01c74a70831040298475ff71c654547c82715 | [log] [tgz] |
|---|---|---|
| author | buyingyi <buyingyi@123451ca-8445-de46-9d55-352943316053> | Tue Feb 12 11:17:07 2013 +0000 |
| committer | buyingyi <buyingyi@123451ca-8445-de46-9d55-352943316053> | Tue Feb 12 11:17:07 2013 +0000 |
| tree | d57a028f82e4ab35ef1e2d55e1b17e7e2ba00050 | |
| parent | ee7b3c5b2b8afc68db74a44a664e1a9d2fe43502 [diff] |
distable activity cluster planning in job builder git-svn-id: https://hyracks.googlecode.com/svn/branches/fullstack_asterix_stabilization@2902 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 dabc8a4..5cae7b2 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,6 +58,7 @@ ChannelControlBlock allocateChannel() throws NetException { synchronized (mConn) { + cleanupClosedChannels(); int idx = allocationBitmap.nextClearBit(0); if (idx < 0 || idx >= ccbArray.length) { cleanupClosedChannels();