Alawn/Chronicle-Map
1
0
Fork 0
mirror of https://github.com/OpenHFT/Chronicle-Map.git synced 2021-09-13 01:26:12 +00:00
Code Releases Activity

HCOLL-384 fix the previous commit

Browse Source
This commit is contained in:
leventov
2015-09-10 16:25:59 +03:00
parent c801e95a64
commit 8d25dd3454
1 changed files with 11 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/net/openhft/chronicle/map/ChannelProvider.java
+11 -3
View File
@@ -326,6 +326,7 @@ public final class ChannelProvider implements Closeable {
chronicleChannels = new Replica[hub.maxNumberOfChannels()];
channelEntryExternalizables = new EntryExternalizable[hub.maxNumberOfChannels()];
chronicleChannelPositionsInList = new int[hub.maxNumberOfChannels()];
Arrays.fill(chronicleChannelPositionsInList, -1);
chronicleChannelList = new ArrayList<>();
chronicleChannelIds = new ArrayList<>();
MessageHandler systemMessageHandler = new MessageHandler() {
@@ -603,9 +604,16 @@ public final class ChannelProvider implements Closeable {
public void close() throws IOException {
channelDataLock.writeLock().lock();
try {
int index = chronicleChannelPositionsInList[chronicleChannel];
chronicleChannelList.remove(index);
chronicleChannelIds.remove(index);
int removedPos = chronicleChannelPositionsInList[chronicleChannel];
chronicleChannelPositionsInList[removedPos] = -1;
chronicleChannelList.remove(removedPos);
chronicleChannelIds.remove(removedPos);
for (int i = 0, len = chronicleChannelIds.size(); i < len; i++) {
int channelId = chronicleChannelIds.get(i);
int pos = chronicleChannelPositionsInList[channelId];
if (pos > removedPos)
chronicleChannelPositionsInList[channelId] = pos - 1;
}
chronicleChannels[chronicleChannel] = null;
channelEntryExternalizables[chronicleChannel] = null;