| DirScanningQueueWriter |
Executes a dir scanner and collects the scanned files into a queue on the
node, where the data is located
|
| FileEntryQueue |
A queue that contains files
When reading entries, the queue returns a file or waits until a file is
added.
Also implements signaling the end of the queue with shutdown operations.
|
| FileEntryQueue.FileEntry |
An entry in a queue
|
| FileEntryQueue.Statistic |
Some statistical data about the queue
|
| MultithreadedFileCopyHelper |
Provides copying of files from the node (controller or agent) to the
controller using multiple threads.
|
| QueueReadingDirScanner |
Reads files from a queue and makes them accessible as dir scanner locally (on
the controller or on the agent)
|
| QueueShutdownAndRemover |
Removes a queue from the cache on the node, where the data is located
|