summaryrefslogtreecommitdiffstats
path: root/src/main/java/org/openslx/imagemaster/serverconnection/ConnectionHandler.java
diff options
context:
space:
mode:
authorSimon Rettberg2014-09-30 18:30:21 +0200
committerSimon Rettberg2014-09-30 18:30:21 +0200
commit78cddae489f12675b5334e8bf96ae1927c71c79a (patch)
tree153313a5d03e0b1a0415bb41480d393d485e97ff /src/main/java/org/openslx/imagemaster/serverconnection/ConnectionHandler.java
parentFix insert query (diff)
downloadmasterserver-78cddae489f12675b5334e8bf96ae1927c71c79a.tar.gz
masterserver-78cddae489f12675b5334e8bf96ae1927c71c79a.tar.xz
masterserver-78cddae489f12675b5334e8bf96ae1927c71c79a.zip
Handle uploads properly if satellite does not supply crc list
Diffstat (limited to 'src/main/java/org/openslx/imagemaster/serverconnection/ConnectionHandler.java')
-rw-r--r--src/main/java/org/openslx/imagemaster/serverconnection/ConnectionHandler.java5
1 files changed, 4 insertions, 1 deletions
diff --git a/src/main/java/org/openslx/imagemaster/serverconnection/ConnectionHandler.java b/src/main/java/org/openslx/imagemaster/serverconnection/ConnectionHandler.java
index e6319c9..12b5701 100644
--- a/src/main/java/org/openslx/imagemaster/serverconnection/ConnectionHandler.java
+++ b/src/main/java/org/openslx/imagemaster/serverconnection/ConnectionHandler.java
@@ -186,8 +186,10 @@ public class ConnectionHandler implements IncomingEvent
}
// get start of range.
int blockNumber = image.getNextMissingBlock();
- if ( blockNumber == -1 )
+ if ( blockNumber == -1 ) {
+ log.debug( "Download complete." );
return null;
+ }
lastBlock.setValue( blockNumber );
log.debug( "Block " + blockNumber + " was transmitted " + image.getTimesTransmitted( blockNumber ) + " time(s)." );
@@ -197,6 +199,7 @@ public class ConnectionHandler implements IncomingEvent
return range;
}
} );
+ image.updateDb();
}
} );
} catch ( RejectedExecutionException e ) {