mstoeck3/autopsy-flatpak
1
0
Fork 0
mirror of https://github.com/overcuriousity/autopsy-flatpak.git synced 2025-07-13 08:26:15 +00:00
Code Issues Packages Projects Releases Wiki Activity

Added thread names to threads used by IngestManager

Browse Source
This commit is contained in:
Richard Cordovano 2015-02-09 14:09:55 -05:00
parent b9a95fd421
commit df770cb94d
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
Core/src/org/sleuthkit/autopsy/ingest/IngestManager.java
View File

@ -18,6 +18,7 @@
*/ */
package org.sleuthkit.autopsy.ingest; package org.sleuthkit.autopsy.ingest;
import com.google.common.util.concurrent.ThreadFactoryBuilder;
import java.awt.EventQueue; import java.awt.EventQueue;
import java.beans.PropertyChangeEvent; import java.beans.PropertyChangeEvent;
import java.beans.PropertyChangeListener; import java.beans.PropertyChangeListener;
@ -226,10 +227,10 @@ public class IngestManager {
this.ingestErrorMessagePosts = new AtomicLong(0L); this.ingestErrorMessagePosts = new AtomicLong(0L);
this.ingestMonitor = new IngestMonitor(); this.ingestMonitor = new IngestMonitor();
this.ingestModuleEventPublisher = new PropertyChangeSupport(IngestManager.class); this.ingestModuleEventPublisher = new PropertyChangeSupport(IngestManager.class);
this.fireIngestEventsThreadPool = Executors.newSingleThreadExecutor(); this.fireIngestEventsThreadPool = Executors.newSingleThreadExecutor(new ThreadFactoryBuilder().setNameFormat("IM-ingest-events-%d").build());
this.ingestJobEventPublisher = new PropertyChangeSupport(IngestManager.class); this.ingestJobEventPublisher = new PropertyChangeSupport(IngestManager.class);
this.dataSourceIngestThreadPool = Executors.newSingleThreadExecutor(); this.dataSourceIngestThreadPool = Executors.newSingleThreadExecutor(new ThreadFactoryBuilder().setNameFormat("IM-data-source-ingest-%d").build());
this.startIngestJobsThreadPool = Executors.newSingleThreadExecutor(); this.startIngestJobsThreadPool = Executors.newSingleThreadExecutor(new ThreadFactoryBuilder().setNameFormat("IM-start-ingest-jobs-%d").build());
this.nextThreadId = new AtomicLong(0L); this.nextThreadId = new AtomicLong(0L);
this.jobsById = new ConcurrentHashMap<>(); this.jobsById = new ConcurrentHashMap<>();
this.ingestJobStarters = new ConcurrentHashMap<>(); this.ingestJobStarters = new ConcurrentHashMap<>();
@ -241,7 +242,7 @@ public class IngestManager {
numberOfFileIngestThreads = DEFAULT_NUMBER_OF_FILE_INGEST_THREADS; numberOfFileIngestThreads = DEFAULT_NUMBER_OF_FILE_INGEST_THREADS;
UserPreferences.setNumberOfFileIngestThreads(numberOfFileIngestThreads); UserPreferences.setNumberOfFileIngestThreads(numberOfFileIngestThreads);
} }
fileIngestThreadPool = Executors.newFixedThreadPool(numberOfFileIngestThreads); fileIngestThreadPool = Executors.newFixedThreadPool(numberOfFileIngestThreads, new ThreadFactoryBuilder().setNameFormat("IM-file-ingest-%d").build());
for (int i = 0; i < numberOfFileIngestThreads; ++i) { for (int i = 0; i < numberOfFileIngestThreads; ++i) {
startFileIngestThread(); startFileIngestThread();
} }