rusefi
/
Android-DFU-Library
mirror of https://github.com/rusefi/Android-DFU-Library.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Clean up ArchiveInputStream.

This commit is contained in:
Peter Billström 2018-11-05 15:07:59 +01:00
parent d135355156
commit d4c56d906d
1 changed files with 13 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

35
dfu/src/main/java/no/nordicsemi/android/dfu/internal/ArchiveInputStream.java
View File

@ -357,23 +357,18 @@ public class ArchiveInputStream extends InputStream {
@Override
public int read(@NonNull final byte[] buffer, final int offset, final int length) {
int maxSize = currentSource.length - bytesReadFromCurrentSource;
int size = length <= maxSize ? length : maxSize;
final int size = rawRead(buffer, offset, length);
if (length > size && startNextFile() != null) {
return size + rawRead(buffer, offset + size, length - size);
}
return size;
}
private int rawRead(@NonNull final byte[] buffer, final int offset, final int length) {
final int maxSize = currentSource.length - bytesReadFromCurrentSource;
final int size = length <= maxSize ? length : maxSize;
System.arraycopy(currentSource, bytesReadFromCurrentSource, buffer, offset, size);
bytesReadFromCurrentSource += size;
if (length > size) {
if (startNextFile() == null) {
bytesRead += size;
crc32.update(buffer, offset, size);
return size;
}
maxSize = currentSource.length;
final int nextSize = length - size <= maxSize ? length - size : maxSize;
System.arraycopy(currentSource, 0, buffer, offset + size, nextSize);
bytesReadFromCurrentSource += nextSize;
size += nextSize;
}
bytesRead += size;
crc32.update(buffer, offset, size);
return size;
@ -395,7 +390,7 @@ public class ArchiveInputStream extends InputStream {
}
@Override
public void reset() throws IOException {
public void reset() {
currentSource = markedSource;
bytesRead = bytesReadFromCurrentSource = bytesReadFromMarkedSource;
@ -479,12 +474,8 @@ public class ArchiveInputStream extends InputStream {
else if ((type & DfuBaseService.TYPE_APPLICATION) > 0)
currentSource = applicationBytes;
bytesReadFromCurrentSource = 0;
try {
mark(0);
reset();
} catch (final IOException e) {
// not available
}
mark(0);
reset();
return this.type;
}