|
|
@ -603,6 +603,7 @@ public class HeapReader {
|
|
|
|
public void close(boolean writeIDX) {
|
|
|
|
public void close(boolean writeIDX) {
|
|
|
|
if (this.index == null) return;
|
|
|
|
if (this.index == null) return;
|
|
|
|
synchronized (this.index) {
|
|
|
|
synchronized (this.index) {
|
|
|
|
|
|
|
|
try {
|
|
|
|
if (this.file != null)
|
|
|
|
if (this.file != null)
|
|
|
|
try {
|
|
|
|
try {
|
|
|
|
this.file.close();
|
|
|
|
this.file.close();
|
|
|
@ -654,6 +655,7 @@ public class HeapReader {
|
|
|
|
if (this.index != null) this.index.close();
|
|
|
|
if (this.index != null) this.index.close();
|
|
|
|
this.index = null;
|
|
|
|
this.index = null;
|
|
|
|
this.closeDate = new Date();
|
|
|
|
this.closeDate = new Date();
|
|
|
|
|
|
|
|
} catch (Throwable e) {ConcurrentLog.logException(e);}
|
|
|
|
log.info("close HeapFile " + this.heapFile.getName() + "; trace: " + ConcurrentLog.stackTrace());
|
|
|
|
log.info("close HeapFile " + this.heapFile.getName() + "; trace: " + ConcurrentLog.stackTrace());
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|