|
|
@ -234,6 +234,7 @@ class ConcurrentEngineProcessingController extends Actor with ActorLogging { |
|
|
|
*/ |
|
|
|
def checkForResults() = { |
|
|
|
try { |
|
|
|
listener ! SubmitMessage(s"Finished Processing ${processed}/${processed} images") |
|
|
|
processorsFinished = 0 |
|
|
|
toProcess = 0 |
|
|
|
processed = 0 |
|
|
@ -395,6 +396,7 @@ class ConcurrentEngineSimilarityController extends Actor with ActorLogging { |
|
|
|
*/ |
|
|
|
def checkForResults() = { |
|
|
|
try { |
|
|
|
listener ! SubmitMessage(s"Finished Scanning ${processed}/${processed} images") |
|
|
|
processorsFinished = 0 |
|
|
|
toProcess = 0 |
|
|
|
processed = 0 |
|
|
|