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

fix compilation errors

This commit is contained in:
Michael McCandless 2016-02-08 14:07:14 -05:00 committed by Mike McCandless
parent f0f42780a9
commit c14fa123da
1 changed files with 11 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
lucene/replicator/src/test/org/apache/lucene/replicator/nrt/Jobs.java
View File

@ -80,7 +80,12 @@ class Jobs extends Thread implements Closeable {
} else { } else {
node.message("AlreadyClosedException during job.visit job=" + topJob + "; now cancel"); node.message("AlreadyClosedException during job.visit job=" + topJob + "; now cancel");
} }
try {
topJob.cancel("unexpected exception in visit", t); topJob.cancel("unexpected exception in visit", t);
} catch (Throwable t2) {
node.message("ignore exception calling cancel: " + t2);
t2.printStackTrace(System.out);
}
try { try {
topJob.onceDone.run(topJob); topJob.onceDone.run(topJob);
} catch (Throwable t2) { } catch (Throwable t2) {
@ -112,7 +117,11 @@ class Jobs extends Thread implements Closeable {
while (queue.isEmpty() == false) { while (queue.isEmpty() == false) {
SimpleCopyJob job = (SimpleCopyJob) queue.poll(); SimpleCopyJob job = (SimpleCopyJob) queue.poll();
node.message("top: Jobs: now cancel job=" + job); node.message("top: Jobs: now cancel job=" + job);
try {
job.cancel("jobs closing", null); job.cancel("jobs closing", null);
} catch (Throwable t) {
node.message("ignore exception calling cancel: " + t);
}
try { try {
job.onceDone.run(job); job.onceDone.run(job);
} catch (Throwable t) { } catch (Throwable t) {