Lunacy cleanup.

This commit is contained in:
esaunders 2018-05-16 17:43:23 -04:00
parent 180b74bc2d
commit 41cfd733f9
4 changed files with 8 additions and 8 deletions

View File

@ -1213,11 +1213,11 @@ public final class DataSourceIngestJob {
return this.dataSourceLevelIngestModule; return this.dataSourceLevelIngestModule;
} }
boolean fileIngestIsRunning() { boolean getFileIngestIsRunning() {
return this.fileIngestRunning; return this.fileIngestRunning;
} }
Date fileIngestStartTime() { Date getFileIngestStartTime() {
return this.fileIngestStartTime; return this.fileIngestStartTime;
} }

View File

@ -355,10 +355,10 @@ public final class IngestJob {
dataSourceModule = new DataSourceIngestModuleHandle(dataSourceJobs.get(snapshot.getJobId()), module); dataSourceModule = new DataSourceIngestModuleHandle(dataSourceJobs.get(snapshot.getJobId()), module);
} }
} }
if (snapshot.fileIngestIsRunning()) { if (snapshot.getFileIngestIsRunning()) {
fileIngestRunning = true; fileIngestRunning = true;
} }
Date childFileIngestStartTime = snapshot.fileIngestStartTime(); Date childFileIngestStartTime = snapshot.getFileIngestStartTime();
if (null != childFileIngestStartTime && (null == fileIngestStartTime || childFileIngestStartTime.before(fileIngestStartTime))) { if (null != childFileIngestStartTime && (null == fileIngestStartTime || childFileIngestStartTime.before(fileIngestStartTime))) {
fileIngestStartTime = childFileIngestStartTime; fileIngestStartTime = childFileIngestStartTime;
} }

View File

@ -31,19 +31,19 @@ public interface IngestProgressSnapshotProvider {
* *
* @return A list of IngestThreadActivitySnapshot * @return A list of IngestThreadActivitySnapshot
*/ */
public List<IngestManager.IngestThreadActivitySnapshot> getIngestThreadActivitySnapshots(); List<IngestManager.IngestThreadActivitySnapshot> getIngestThreadActivitySnapshots();
/** /**
* Get a snapshot of the state of ingest jobs. * Get a snapshot of the state of ingest jobs.
* *
* @return A list of ingest job snapshots. * @return A list of ingest job snapshots.
*/ */
public List<DataSourceIngestJob.Snapshot> getIngestJobSnapshots(); List<DataSourceIngestJob.Snapshot> getIngestJobSnapshots();
/** /**
* Gets the cumulative run times for the ingest module. * Gets the cumulative run times for the ingest module.
* *
* @return Map of module name to run time (in milliseconds) * @return Map of module name to run time (in milliseconds)
*/ */
public Map<String, Long> getModuleRunTimes(); Map<String, Long> getModuleRunTimes();
} }

View File

@ -156,7 +156,7 @@ final class AutoIngestAdminActions {
if (tc != null) { if (tc != null) {
AutoIngestDashboard dashboard = tc.getAutoIngestDashboard(); AutoIngestDashboard dashboard = tc.getAutoIngestDashboard();
if (dashboard != null) { if (dashboard != null) {
IngestProgressSnapshotDialog ingestProgressSnapshotDialog = new IngestProgressSnapshotDialog(dashboard.getTopLevelAncestor(), true, job); new IngestProgressSnapshotDialog(dashboard.getTopLevelAncestor(), true, job);
} }
} }
} }