Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix for https://issues.apache.org/activemq/browse/AMQ-1872 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@680465 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Robert Davies 2008-07-28 19:51:06 +00:00
parent 7614fe25b7
commit dc03bad9f4
1 changed files with 3 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/hash/HashIndex.java
View File

@ -81,7 +81,6 @@ public class HashIndex implements Index, HashIndexMBean {
* @param directory
* @param name
* @param indexManager
* @param numberOfBins
* @throws IOException
*/
public HashIndex(File directory, String name, IndexManager indexManager) throws IOException {
@ -242,6 +241,7 @@ public class HashIndex implements Index, HashIndexMBean {
capacity <<= 1;
}
this.bins = new HashBin[capacity];
this.numberOfBins=capacity;
threshold = calculateThreashold();
keysPerPage = pageSize / keySize;
dataIn = new DataByteArrayInputStream();
@ -426,10 +426,8 @@ public class HashIndex implements Index, HashIndexMBean {
void addToBin(HashPage page) throws IOException {
int index = page.getBinId();
if (index >= numberOfBins) {
HashBin[] newBins = new HashBin[index+1];
System.arraycopy(this.bins, 0, newBins, 0, this.bins.length);
this.bins=newBins;
if (index >= this.bins.length) {
resize(index+1);
}
HashBin bin = getBin(index);
bin.addHashPageInfo(page.getId(), page.getPersistedSize());
@ -545,7 +543,6 @@ public class HashIndex implements Index, HashIndexMBean {
newCapacity=capacity;
if (newCapacity != numberOfBins) {
LOG.info("Resize hash bins " + this.name + " from " + numberOfBins + " to " + newCapacity);
String backFileName = name + "-REISZE";
HashIndex backIndex = new HashIndex(directory,backFileName,indexManager);
backIndex.setKeyMarshaller(keyMarshaller);