commit | 2e6b99f40c85d98e066b5577ded34a46607d496c | [log] [tgz] |
---|---|---|
author | vinayakb <vinayakb@123451ca-8445-de46-9d55-352943316053> | Sun Jan 29 04:50:05 2012 +0000 |
committer | vinayakb <vinayakb@123451ca-8445-de46-9d55-352943316053> | Sun Jan 29 04:50:05 2012 +0000 |
tree | 41f444c3877bebeb773eec483418649499ac1d50 | |
parent | fc14588544b864f6fe8a42e20e75eff663510a79 [diff] |
Fixed clearing of channel state on release git-svn-id: https://hyracks.googlecode.com/svn/branches/hyracks_dev_next@1090 123451ca-8445-de46-9d55-352943316053
diff --git a/hyracks-net/src/main/java/edu/uci/ics/hyracks/net/protocols/muxdemux/ChannelSet.java b/hyracks-net/src/main/java/edu/uci/ics/hyracks/net/protocols/muxdemux/ChannelSet.java index 104f98a..c3f93d2 100644 --- a/hyracks-net/src/main/java/edu/uci/ics/hyracks/net/protocols/muxdemux/ChannelSet.java +++ b/hyracks-net/src/main/java/edu/uci/ics/hyracks/net/protocols/muxdemux/ChannelSet.java
@@ -96,6 +96,10 @@ int idx = channel.getChannelId(); ccbArray[idx] = null; allocationBitmap.clear(idx); + pendingChannelWriteBitmap.clear(idx); + pendingChannelCreditsBitmap.clear(idx); + pendingChannelSynBitmap.clear(idx); + pendingEOSAckBitmap.clear(idx); --openChannelCount; }