org.sleuthkit.autopsy.ingest.IngestTasksScheduler.IngestTaskTrackingQueue Class Reference

Inherits org.sleuthkit.autopsy.ingest.BlockingIngestTaskQueue.

Public Member Functions
IngestTask	getNextTask () throws InterruptedException

Private Attributes
final List< IngestTask >	queuedTasks = new LinkedList<>()
final BlockingDeque< IngestTask >	taskQueue = new LinkedBlockingDeque<>()
final List< IngestTask >	tasksInProgress = new LinkedList<>()

Detailed Description

A blocking ingest task queue for the ingest manager's ingest threads that keeps tracks of the tasks that are queued and in progress.

Definition at line 687 of file IngestTasksScheduler.java.

Member Function Documentation

IngestTask org.sleuthkit.autopsy.ingest.IngestTasksScheduler.IngestTaskTrackingQueue.getNextTask

(

)

throws InterruptedException

Gets the next ingest task in the queue, blocking if the queue is empty.

Returns

The next ingest task in the queue.

Exceptions

InterruptedException

If the thread getting the task is interrupted while blocked on a queue empty condition.

Definition at line 754 of file IngestTasksScheduler.java.

References org.sleuthkit.autopsy.ingest.IngestTasksScheduler.IngestTaskTrackingQueue.queuedTasks, and org.sleuthkit.autopsy.ingest.IngestTasksScheduler.IngestTaskTrackingQueue.tasksInProgress.

Member Data Documentation

final List<IngestTask> org.sleuthkit.autopsy.ingest.IngestTasksScheduler.IngestTaskTrackingQueue.queuedTasks = new LinkedList<>()

private

Definition at line 691 of file IngestTasksScheduler.java.

Referenced by org.sleuthkit.autopsy.ingest.IngestTasksScheduler.IngestTaskTrackingQueue.getNextTask().

final BlockingDeque<IngestTask> org.sleuthkit.autopsy.ingest.IngestTasksScheduler.IngestTaskTrackingQueue.taskQueue = new LinkedBlockingDeque<>()

private

Definition at line 689 of file IngestTasksScheduler.java.

final List<IngestTask> org.sleuthkit.autopsy.ingest.IngestTasksScheduler.IngestTaskTrackingQueue.tasksInProgress = new LinkedList<>()

private

Definition at line 693 of file IngestTasksScheduler.java.

Referenced by org.sleuthkit.autopsy.ingest.IngestTasksScheduler.IngestTaskTrackingQueue.getNextTask().

---

The documentation for this class was generated from the following file:

• /home/carriersleuth/repos/autopsy/Core/src/org/sleuthkit/autopsy/ingest/IngestTasksScheduler.java