github-mirrors/logstash
1
0
Fork 0
mirror of https://github.com/elastic/logstash.git synced 2025-04-24 06:37:19 -04:00
Code Issues Projects Releases Packages Wiki Activity

Add some safety to closing the writer and deleting the lock file

Browse source 
Fixes #7822
This commit is contained in:
Rob Bavey 2017-07-26 15:49:50 -04:00
parent 6d880e292d
commit b3929f19d6
1 changed files with 24 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

32
logstash-core/src/main/java/org/logstash/common/io/DeadLetterQueueWriter.java
View file

@ -165,17 +165,33 @@ public final class DeadLetterQueueWriter implements Closeable {
@Override
public synchronized void close() throws IOException {
if (this.lock != null){
this.lock.release();
if (this.lock.channel() != null && this.lock.channel().isOpen()) {
this.lock.channel().close();
if (currentWriter != null) {
try {
currentWriter.close();
open = false;
}catch (Exception e){
logger.debug("Unable to close dlq writer", e);
}
}
if (currentWriter != null) {
currentWriter.close();
releaseLock();
}
private void releaseLock() {
if (this.lock != null){
try {
this.lock.release();
if (this.lock.channel() != null && this.lock.channel().isOpen()) {
this.lock.channel().close();
}
} catch (Exception e) {
logger.debug("Unable to close lock channel", e);
}
try {
Files.deleteIfExists(queuePath.resolve(LOCK_FILE));
} catch (IOException e){
logger.debug("Unable to delete lock file", e);
}
}
Files.deleteIfExists(queuePath.resolve(LOCK_FILE));
open = false;
}
public boolean isOpen() {