Make hashing classes more robust, report complete blocks without hash info as hashing

1 files changed, 7 insertions, 2 deletions

diff --git a/src/main/java/org/openslx/filetransfer/util/HashChecker.java b/src/main/java/org/openslx/filetransfer/util/HashChecker.java
index 8bf97a4..5b647aa 100644
--- a/src/main/java/org/openslx/filetransfer/util/HashChecker.java
+++ b/src/main/java/org/openslx/filetransfer/util/HashChecker.java
@@ -43,6 +43,7 @@ public class HashChecker
 				return;
 			invalid = true;
 		}
+		LOGGER.debug( "Marking all queued chunks as failed" );
 		for ( ;; ) {
 			HashTask task = queue.poll();
 			if ( task == null )
@@ -132,7 +133,6 @@ public class HashChecker
 						continue;
 				} catch ( InterruptedException e ) {
 					LOGGER.info( "Interrupted while waiting for hash task", e );
-					threadFailed( this );
 					break;
 				}
 				// Calculate digest
@@ -141,10 +141,15 @@ public class HashChecker
 				HashResult result = Arrays.equals( digest, task.chunk.getSha1Sum() ) ? HashResult.VALID : HashResult.INVALID;
 				execCallback( task, result );
 				if ( extraThread && queue.isEmpty() ) {
-					LOGGER.info( "Stopping additional hash checker" );
 					break;
 				}
 			}
+			if ( extraThread ) {
+				LOGGER.info( "Stopped additional hash checker" );
+			} else {
+				LOGGER.info( "Stopped MAIN hash checker" );
+			}
+			threadFailed( this );
 		}
 	}