diff options
Diffstat (limited to 'src/org/catacombae/rarx/RARFileEntryStream.java')
| -rw-r--r-- | src/org/catacombae/rarx/RARFileEntryStream.java | 550 |
1 files changed, 0 insertions, 550 deletions
diff --git a/src/org/catacombae/rarx/RARFileEntryStream.java b/src/org/catacombae/rarx/RARFileEntryStream.java deleted file mode 100644 index c632900..0000000 --- a/src/org/catacombae/rarx/RARFileEntryStream.java +++ /dev/null @@ -1,550 +0,0 @@ -/*-
- * Copyright (C) 2006 Erik Larsson
- *
- * All rights reserved.
- *
- * This program is free software; you can redistribute it and/or
- * modify it under the terms of the GNU General Public License
- * as published by the Free Software Foundation; either version 2
- * of the License, or (at your option) any later version.
- *
- * This program is distributed in the hope that it will be useful,
- * but WITHOUT ANY WARRANTY; without even the implied warranty of
- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
- * GNU General Public License for more details.
- *
- * You should have received a copy of the GNU General Public License
- * along with this program; if not, write to the Free Software
- * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA
- */
-
-package org.catacombae.rarx;
-
-import org.catacombae.io.*;
-import java.io.*;
-import java.util.LinkedList;
-import java.util.regex.Pattern;
-
-public class RARFileEntryStream implements RandomAccessStream {
- public static class InvalidRARFilenameException extends RuntimeException {
- private static final long serialVersionUID = 0x2F49329E49173487L;
-
- public InvalidRARFilenameException(String message) {
- super(message);
- }
- }
-
- public static class RAREntrySegment {
- public File file;
- public RandomAccessFile raf;
- public long headerPos;
- public long headerLength;
- public long dataPos;
- public long dataLength;
- public RAREntrySegment nextSegment = null;
-
- public RAREntrySegment(File file, RandomAccessFile raf, long headerPos, long headerLength, long dataPos, long dataLength/*, RAREntrySegment nextSegment*/) {
- this.file = file;
- this.raf = raf;
- this.headerPos = headerPos;
- this.headerLength = headerLength;
- this.dataPos = dataPos;
- this.dataLength = dataLength;
- //this.nextSegment = nextSegment;
- }
- }
-
- public class Interval {
- public RAREntrySegment segment;
- public long startOffset;
- public long endOffset;
-
- public Interval(RAREntrySegment segment, long startOffset, long endOffset) {
- this.segment = segment;
- this.startOffset = startOffset;
- this.endOffset = endOffset;
- }
- }
-
- public class IntervalStructure {
- private LinkedList<Interval> intervals = new LinkedList<Interval>();
-
- public void addSegment(RAREntrySegment res, long startOffset, long endOffset) {
- Interval newInterval = new Interval(res, startOffset, endOffset);
- if(intervals.size() > 0) {
- Interval previous = intervals.getLast();
- previous.segment.nextSegment = newInterval.segment;
- }
- intervals.addLast(newInterval);
- }
-
- public RAREntrySegment getSegment(long offset) {
- for(Interval i : intervals)
- if(offset >= i.startOffset && offset < i.endOffset)
- return i.segment;
- return null;
- }
-
- public Interval getInterval(long offset) {
- for(Interval i : intervals)
- if(offset >= i.startOffset && offset < i.endOffset)
- return i;
- return null;
- }
-
- public RAREntrySegment[] getAllSegmentsUnordered() {
- RAREntrySegment[] result = new RAREntrySegment[intervals.size()];
- int j = 0;
- for(Interval i : intervals)
- result[j++] = i.segment;
- return result;
- }
- }
-
- public static boolean debug = false;
- private IntervalStructure intervalStructure;
- private RAREntrySegment currentSegment;
- private boolean closed = false;
- private long seekPointer;
- private long globalPointer = 0;
- private long segmentPointer = 0;
- private final long length;
-
- public RARFileEntryStream(RARFileEntry entry) throws FileNotFoundException, IOException {
- this(entry.getFile(0), entry.getOffset(0));
- }
-
- public RARFileEntryStream(File startFile, long pos) throws FileNotFoundException, IOException {
- //this.startFile = startFile;
- //this.pos = pos;
-
- LinkedList<RAREntrySegment> entrySegments = getSegments(startFile, pos, new LinkedList<RAREntrySegment>(), false);
-// for(RAREntrySegment res : entrySegments)
-// res.raf.seek(0);
- if(entrySegments == null || entrySegments.size() < 1)
- throw new FileNotFoundException();
- this.currentSegment = entrySegments.getFirst();
-
- long currentPos = 0;
- this.intervalStructure = new IntervalStructure();
- for(RAREntrySegment res : entrySegments) {
- if(debug) System.out.println("Adding \"" + res.file + "\" at " + currentPos);
- intervalStructure.addSegment(res, currentPos, currentPos+res.dataLength);
- currentPos += res.dataLength;
- }
- length = currentPos;
- if(debug) System.out.println("Length of entry: " + length + " bytes");
-
- seekPointer = -2;
- updateSeekPosition();
- }
-
- /** @see java.io.RandomAccessFile */
- public synchronized void close() throws IOException {
- if(debug) System.out.println("RARFileEntryStream.close()");
- if(closed) throw new IOException("Stream closed.");
-
- closed = true;
- for(RAREntrySegment res : intervalStructure.getAllSegmentsUnordered())
- res.raf.close();
- }
-
- /** @see java.io.RandomAccessFile */
- public synchronized long getFilePointer() throws IOException {
- return ((seekPointer == -1)?globalPointer:seekPointer);
- }
-
- /** @see java.io.RandomAccessFile */
- public synchronized long length() throws IOException {
- return length;
- }
-
- /** @see java.io.RandomAccessFile */
- public synchronized int read() throws IOException {
- if(closed) throw new IOException("Stream closed.");
- byte[] b = new byte[1];
- read(b, 0, 1);
- return b[0] & 0xFF;
- }
-
- /** @see java.io.RandomAccessFile */
- public synchronized int read(byte[] b) throws IOException {
- if(closed) throw new IOException("Stream closed.");
- return read(b, 0, b.length);
- }
-
- /** @see java.io.RandomAccessFile */
- public synchronized int read(byte[] b, int off, int len) throws IOException {
-// boolean debug = true;
- if(debug) System.out.print("RARFileEntryStream.read(b, " + off + ", " + len + ") = ");
-// System.out.println();
-// System.out.println("(1)currentSegment.raf.getFilePointer()=" + currentSegment.raf.getFilePointer());
-// System.out.println("(1)=seekPointer=" + seekPointer);
- if(closed) throw new IOException("Stream closed.");
- try {
- updateSeekPosition();
- } catch(IOException ioe) {
- if(debug) System.out.println("-1 (Couldn't update seek position)");
- return -1;
- }
-
- long bytesRemainingInSegment = currentSegment.dataLength - segmentPointer;
- while(bytesRemainingInSegment == 0) {
- if(nextSegment())
- bytesRemainingInSegment = currentSegment.dataLength - segmentPointer;
- else {
- if(debug) System.out.println("-1 (Nothing to read)");
- return -1; // Nothing to read!
- }
- }
- int bytesRead = 0;
- mainLoop:
- while(bytesRead < len) {
- int remainingBytes = len-bytesRead;
- int bytesToRead = (remainingBytes < bytesRemainingInSegment)?remainingBytes:(int)bytesRemainingInSegment;
-
-// System.out.println("(2)currentSegment.raf.getFilePointer()=" + currentSegment.raf.getFilePointer());
- int currentBytesRead = currentSegment.raf.read(b, off+bytesRead, bytesToRead);
- if(currentBytesRead == -1)
- throw new IOException("Reached end of file unexpectedly for file \"" + currentSegment.file + "\"! (segmentPointer=" + segmentPointer + " globalPointer=" + globalPointer + " bytesRemainingInSegment=" + bytesRemainingInSegment + " bytesRead=" + bytesRead + " bytesToRead=" + bytesToRead + " currentSegment.raf.getFilePointer()=" + currentSegment.raf.getFilePointer() + " currentSegment.dataLength=" + currentSegment.dataLength + ")");
-
- bytesRead += currentBytesRead;
- segmentPointer += currentBytesRead;
- globalPointer += currentBytesRead;
- //seekPointer += currentBytesRead;
-
- bytesRemainingInSegment = currentSegment.dataLength - segmentPointer;
- while(bytesRemainingInSegment == 0) {
- if(nextSegment())
- bytesRemainingInSegment = currentSegment.dataLength - segmentPointer;
- else
- break mainLoop; // No more bytes to read;
- }
- }
- if(debug) System.out.println(bytesRead);
- return bytesRead;
- }
-
- /** @see java.io.RandomAccessFile */
- public synchronized void seek(long pos) throws IOException {
- if(debug) System.out.println("RARFileEntryStream.seek(" + pos + ")");
- if(closed) throw new IOException("Stream closed.");
- if(pos < 0) throw new IOException("Invalid position.");
- seekPointer = pos;
- }
-
- private synchronized void updateSeekPosition() throws IOException {
- if(debug) System.out.println("updateSeekPosition()");
-// System.out.println("seekPointer=" + seekPointer);
-// System.out.println("globalPointer=" + globalPointer);
-// System.out.println("segmentPointer=" + segmentPointer);
- if(seekPointer == globalPointer)
- seekPointer = -1;
- else if(seekPointer != -1) {
- //if(seekPointer > length) seek(length-1);
- if(seekPointer == -2)
- seekPointer = 0;
-
- long posDiff = seekPointer-globalPointer;
- long newSegmentPointer = segmentPointer + posDiff;
- if(newSegmentPointer >= 0 &&
- newSegmentPointer < currentSegment.dataLength) {
- if(debug) System.out.println(" Pointer is within segment.");
- globalPointer += posDiff;
- segmentPointer += posDiff;
- if(debug) System.out.println(" Seeking to " + (currentSegment.dataPos + segmentPointer) +".");
- currentSegment.raf.seek(currentSegment.dataPos + segmentPointer);
- if(debug) System.out.println(" Done.");
- }
- else {
- if(debug) System.out.println(" Pointer is OUTSIDE segment. We need to get a new one.");
- Interval newInterval = intervalStructure.getInterval(seekPointer);
- if(newInterval == null)
- throw new IOException("No more data to read.");
- RAREntrySegment newSegment = newInterval.segment;
- newSegmentPointer = (seekPointer-newInterval.startOffset);
- if(debug) System.out.println(" Seeking to " + (currentSegment.dataPos + segmentPointer) +".");
- newSegment.raf.seek(newSegment.dataPos + newSegmentPointer);
- if(debug) System.out.println(" Done.");
-
- // If we got here, all is well.
- globalPointer = seekPointer;
- segmentPointer = newSegmentPointer;
- currentSegment = newSegment;
- }
- seekPointer = -1;
- }
- }
-
- public synchronized boolean isClosed() {
- return closed;
- }
-
- public synchronized boolean reopen() {
- if(debug) System.out.println("RARFileEntryStream.reopen()");
- if(closed) {
- try {
- for(RAREntrySegment res : intervalStructure.getAllSegmentsUnordered())
- res.raf = new RandomAccessFile(res.file, "r");
- closed = false;
- seekPointer = -2;
- updateSeekPosition();
- //seek(0);
- return true;
- } catch(Exception e) {}
- }
- return false;
- }
-
- /**
- * Changes forward to the next segment and sets the pointers.
- */
- private boolean nextSegment() throws IOException {
- if(debug) System.out.println("RARFileEntryStream.nextSegment()");
- RAREntrySegment nextSegment = currentSegment.nextSegment;
- if(nextSegment != null) {
- if(debug) System.out.println(" nextSegment != null");
- if(debug) System.out.println(" currentSegment: " + currentSegment);
- if(debug) System.out.println(" file: " + currentSegment.file);
- if(debug) System.out.println(" headerPos: " + currentSegment.headerPos);
- if(debug) System.out.println(" headerLength: " + currentSegment.headerLength);
- if(debug) System.out.println(" dataPos: " + currentSegment.dataPos);
- if(debug) System.out.println(" dataLength: " + currentSegment.dataLength);
- if(debug) System.out.println(" nextSegment: " + nextSegment);
- if(debug) System.out.println(" file: " + nextSegment.file);
- if(debug) System.out.println(" headerPos: " + nextSegment.headerPos);
- if(debug) System.out.println(" headerLength: " + nextSegment.headerLength);
- if(debug) System.out.println(" dataPos: " + nextSegment.dataPos);
- if(debug) System.out.println(" dataLength: " + nextSegment.dataLength);
- globalPointer += currentSegment.dataLength - segmentPointer;
- segmentPointer = 0;
- nextSegment.raf.seek(nextSegment.dataPos);
- currentSegment = nextSegment;
- return true;
- }
- else {
- if(debug) System.out.println(" nextSegment == null");
- return false;
- }
- }
-
- private static LinkedList<RAREntrySegment> getSegments(File file, long position, LinkedList<RAREntrySegment> list, boolean needsIncoming) throws IOException, FileNotFoundException {
- if(debug) System.out.println("Getting new entry segment: " + file);
- RandomAccessFile raf = new RandomAccessFile(file, "r");
- raf.seek(position);
- RARHeader rh = RARFile.readHeader(raf);
- if(rh instanceof NewFileHeader) {
- NewFileHeader nfh = (NewFileHeader)rh;
- if(//nfh.getMethod() == RARHeader.METHOD_UNCOMPRESSED &&
- (needsIncoming?nfh.hasIncomingData():!nfh.hasIncomingData()) &&
- !(nfh instanceof CommentHeader)) {
- RAREntrySegment res = new RAREntrySegment(file, raf, position, nfh.getSize(), position+nfh.getSize(), nfh.getPackSize());
- list.addLast(res);
- if(nfh.hasOutgoingData()) {
- File nextFile = getNextFile(file);
- if(nextFile == null)
- throw new FileNotFoundException();
- long posInNextFile = getMatchingPosInFile(nextFile, nfh);
- if(posInNextFile == -1)
- throw new FileNotFoundException();
- getSegments(nextFile, posInNextFile, list, true);
- }
- }
- }
- return list;
- }
-
- protected static File getNextFile(File rarFile) {
- String filename = rarFile.getName();
- String newFilename;
- if(Pattern.matches(".+\\.[P|p]art\\d+\\.rar", filename)) {
- String numberString = "";
- long partNumber = 0; // I'm not serious... (:
- int charstep = 0;
- while(true) {
- String currentNumber = filename.substring(filename.length()-5-charstep, filename.length()-4-charstep);
- try {
- partNumber += Integer.parseInt(currentNumber)*Util.pow(10, charstep);
- } catch(NumberFormatException nfe) {
- break;
- }
- ++charstep;
- }
- int numberLength = charstep;
- String newPartNumberString = "" + (partNumber + 1);
-
- // Add leading zeroes
- while(newPartNumberString.length() < numberLength)
- newPartNumberString = "0" + newPartNumberString;
-
- newFilename = filename.substring(0, filename.length()-4-numberLength) + newPartNumberString + ".rar";
- }
- else if(Pattern.matches(".+\\.r((ar)|(\\d\\d)){1}", filename)) {
- String lastTwo = filename.substring(filename.length()-2, filename.length());
- String newLastTwo = "";
- if(lastTwo.equals("ar"))
- newLastTwo = "00";
- else {
- try {
- int archiveNumber = Integer.parseInt(lastTwo);
- newLastTwo = "" + (archiveNumber+1);
- if(newLastTwo.length() < 2)
- newLastTwo = "0" + newLastTwo;
- } catch(NumberFormatException nfe) {
- throw new RuntimeException(nfe);
- }
- }
- if(newLastTwo.length() != 2)
- throw new InvalidRARFilenameException("Incremented filename invalid.");
-
- newFilename = filename.substring(0, filename.length()-2) + newLastTwo;
- }
- else if(Pattern.matches(".+\\.\\d\\d\\d", filename)) {
- String lastThree = filename.substring(filename.length()-3, filename.length());
- String newLastThree = "";
- try {
- int archiveNumber = Integer.parseInt(lastThree);
- newLastThree = "" + (archiveNumber+1);
- while(newLastThree.length() < 3)
- newLastThree = "0" + newLastThree;
- } catch(NumberFormatException nfe) {
- throw new RuntimeException(nfe);
- }
- if(newLastThree.length() != 3)
- throw new InvalidRARFilenameException("Incremented filename invalid.");
-
- newFilename = filename.substring(0, filename.length()-3) + newLastThree;
- }
- else
- throw new InvalidRARFilenameException("Filename in argument invalid for a RAR-file.");
-
- File newFile = new File(rarFile.getParent(), newFilename);
- if(newFile.exists())
- return newFile;
- else {
- if(debug) System.out.println("Couldn't find \"" + newFile + "\"");
- return null;
- }
- }
-
- private static long getMatchingPosInFile(File f, NewFileHeader currentHeader) {
- try {
- RandomAccessFile raf = new RandomAccessFile(f, "r");
- RARFile.readMarkHeader(raf);
- RARHeader rh = RARFile.readHeader(raf);
- while(rh != null) {
- if(rh instanceof NewFileHeader) {
- NewFileHeader nextHeader = (NewFileHeader)rh;
- if(nextHeader.getFilenameAsString().equals(currentHeader.getFilenameAsString()) &&
- nextHeader.getUnpSize() == currentHeader.getUnpSize()) {
- long pos = raf.getFilePointer()-nextHeader.getPackSize()-nextHeader.getHeadSize();
- raf.close();
- return pos;
- }
- }
- rh = RARFile.readHeader(raf);
- }
- raf.close();
- } catch(IOException ioe) {
- ioe.printStackTrace();
- }
- return -1;
- }
-
- /** Testcode */
- public static void main(String[] args) throws IOException {
- if(args.length != 3)
- System.out.println("RARFileEntryStream self test needs exactly 3 arguments...");
- String rarFilename = args[0];
- String entryName = args[1];
- String referenceFilename = args[2];
-
- System.out.println("Initiating self test of RARFileEntryStream...");
- System.out.println(" RAR file: " + rarFilename);
- System.out.println(" Entry name: " + entryName);
- System.out.println(" Reference file: " + referenceFilename);
-
- File rarFile = new File(rarFilename);
- File referenceFile = new File(referenceFilename);
-
- long position = RARFile.findEntry(entryName, new RandomAccessFile(rarFile, "r"));
- RARFileEntryStream stream = new RARFileEntryStream(rarFile, position);
- RandomAccessFile ref = new RandomAccessFile(referenceFile, "r");
- byte[] buffer1 = new byte[4096];
- byte[] buffer2 = new byte[4096];
- int bytesRead1;
- int bytesRead2;
- long totalBytesRead1;
- long totalBytesRead2;
-
- System.out.println("1. Deterministic tests...");
- if(stream.length() != ref.length())
- System.out.println("Lengths not equal! stream: " + stream.length() + " reference file: " + ref.length());
-
- // Testing reading from the beginning
- ref.seek(0);
- stream.seek(0);
- if(ref.getFilePointer() != stream.getFilePointer()) throw new RuntimeException("File pointers not equal! ref: " + ref.getFilePointer() + " stream: " + stream.getFilePointer());
- bytesRead1 = ref.read(buffer1);
- bytesRead2 = stream.read(buffer2);
- if(ref.getFilePointer() != stream.getFilePointer()) throw new RuntimeException("File pointers not equal! ref: " + ref.getFilePointer() + " stream: " + stream.getFilePointer());
- if(bytesRead1 != bytesRead2) throw new RuntimeException("Did not read equal amount of bytes. (bytesRead1="+bytesRead1+" bytesRead2="+bytesRead2+")");
- if(!Util.arraysEqual(buffer1, buffer2)) throw new RuntimeException("Arrays not equal!");
-
- // Going to the middle of the file
- ref.seek(ref.length()/2);
- stream.seek(stream.length()/2);
- if(ref.getFilePointer() != stream.getFilePointer()) throw new RuntimeException("File pointers not equal! ref: " + ref.getFilePointer() + " stream: " + stream.getFilePointer());
- bytesRead1 = ref.read(buffer1);
- bytesRead2 = stream.read(buffer2);
- if(ref.getFilePointer() != stream.getFilePointer()) throw new RuntimeException("File pointers not equal! ref: " + ref.getFilePointer() + " stream: " + stream.getFilePointer());
- if(bytesRead1 != bytesRead2) throw new RuntimeException("Did not read equal amount of bytes. (bytesRead1="+bytesRead1+" bytesRead2="+bytesRead2+")");
- if(!Util.arraysEqual(buffer1, buffer2)) throw new RuntimeException("Arrays not equal!");
-
- // Going to the end of the file
- ref.seek(ref.length());
- stream.seek(stream.length());
- if(ref.getFilePointer() != stream.getFilePointer()) throw new RuntimeException("File pointers not equal! ref: " + ref.getFilePointer() + " stream: " + stream.getFilePointer());
- bytesRead1 = ref.read(buffer1);
- bytesRead2 = stream.read(buffer2);
- if(ref.getFilePointer() != stream.getFilePointer()) throw new RuntimeException("File pointers not equal! ref: " + ref.getFilePointer() + " stream: " + stream.getFilePointer());
- if(bytesRead1 != bytesRead2) throw new RuntimeException("Did not read equal amount of bytes. (bytesRead1="+bytesRead1+" bytesRead2="+bytesRead2+")");
- if(!Util.arraysEqual(buffer1, buffer2)) throw new RuntimeException("Arrays not equal!");
-
- // Going beyond the end of the file
- ref.seek(ref.length()*2);
- stream.seek(stream.length()*2);
- if(ref.getFilePointer() != stream.getFilePointer()) throw new RuntimeException("File pointers not equal! ref: " + ref.getFilePointer() + " stream: " + stream.getFilePointer());
- bytesRead1 = ref.read(buffer1);
- bytesRead2 = stream.read(buffer2);
- if(ref.getFilePointer() != stream.getFilePointer()) throw new RuntimeException("File pointers not equal! ref: " + ref.getFilePointer() + " stream: " + stream.getFilePointer());
- if(bytesRead1 != bytesRead2) throw new RuntimeException("Did not read equal amount of bytes. (bytesRead1="+bytesRead1+" bytesRead2="+bytesRead2+")");
- if(!Util.arraysEqual(buffer1, buffer2)) throw new RuntimeException("Arrays not equal!");
-
- // Comparing files byte for byte
- System.out.println("Comparing file data...");
- ref.seek(0);
- stream.seek(0);
- if(ref.getFilePointer() != stream.getFilePointer()) throw new RuntimeException("File pointers not equal! ref: " + ref.getFilePointer() + " stream: " + stream.getFilePointer());
- totalBytesRead1 = 0;
- totalBytesRead2 = 0;
- while(totalBytesRead1 < ref.length() && totalBytesRead2 < stream.length()) {
- System.out.print("\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b");
- System.out.print(" " + totalBytesRead1 + " bytes processed");
- long bytesRemaining1 = ref.length()-totalBytesRead1;
- long bytesRemaining2 = ref.length()-totalBytesRead2;
- bytesRead1 = ref.read(buffer1, 0, (bytesRemaining1 < buffer1.length?(int)bytesRemaining1:buffer1.length));
- bytesRead2 = stream.read(buffer2, 0, (bytesRemaining2 < buffer2.length?(int)bytesRemaining2:buffer2.length));
- if(bytesRead1 != bytesRead2) throw new RuntimeException("Have not read equal amount of bytes. (bytesRead1="+bytesRead1+" bytesRead2="+bytesRead2+")");
- if(bytesRead1 == -1)
- break;
- totalBytesRead1 += bytesRead1;
- totalBytesRead2 += bytesRead2;
- if(ref.getFilePointer() != stream.getFilePointer()) throw new RuntimeException("File pointers not equal! ref: " + ref.getFilePointer() + " stream: " + stream.getFilePointer());
- if(totalBytesRead1 != totalBytesRead2) throw new RuntimeException("Have not read equal amount of bytes. (totalBytesRead1="+totalBytesRead1+" totalBytesRead2="+totalBytesRead2+")");
- if(!Util.arraysEqual(buffer1, buffer2)) throw new RuntimeException("Arrays not equal!");
- }
- System.out.print("\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b\b");
- System.out.print(" " + totalBytesRead1 + " bytes processed");
- }
-}
|