KffFile: replaced knownFile.read(..byte[]) with knownFile.readFully(b…

…yte[]) to prevent bailing on incomplete reads.

src/main/java/emissary/kff/KffFile.java

@@ -3,6 +3,7 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+import java.io.EOFException;
 import java.io.FileInputStream;
 import java.io.IOException;
 import java.io.RandomAccessFile;
@@ -139,26 +140,23 @@ public String getPreferredAlgorithm() {
     private boolean binaryFileSearch(@Nonnull byte[] hash, long crc) {
 
         // Initialize indexes for binary search
-        int low = 0;
-        int high = bSearchInitHigh;
+        long low = 0;
+        long high = bSearchInitHigh;
 
         /* Buffer to hold a record */
         byte[] rec = new byte[recordLength];
 
         reentrantLock.lock();
+        long pos = 0L;
         try {
             // Search until the indexes cross
             while (low <= high) {
                 // Calculate the midpoint
-                int mid = (low + high) >> 1;
+                long mid = (low + high) >> 1;
 
                 // Multiply the index by the record length to get the buffer position and read the record
                 knownFile.seek(recordLength * mid);
-                int count = knownFile.read(rec);
-                if (count != recordLength) {
-                    logger.warn("Short read on KffFile at {} read {} expected {}", (recordLength * mid), count, recordLength);
-                    return false;
-                }
+                knownFile.readFully(rec);
 
                 // Compare the record with the target. Adjust the indexes accordingly.
                 int c = compare(rec, hash, crc);
@@ -170,6 +168,9 @@ private boolean binaryFileSearch(@Nonnull byte[] hash, long crc) {
                     return true;
                 }
             }
+        } catch (EOFException e) {
+            // this shouldn't happen if we're synchronizing calls correctly
+            logger.warn("EOFException reading KffFile: {}", e.getLocalizedMessage());
         } catch (IOException e) {
             logger.warn("Exception reading KffFile", e);
         } finally {