mirror of
https://github.com/aaru-dps/Aaru.git
synced 2025-12-16 19:24:25 +00:00
Use cached stream. Gives a 600% speed boost on analyze.
This commit is contained in:
@@ -46,6 +46,7 @@ namespace DiscImageChef.Filters
|
|||||||
DateTime creationTime;
|
DateTime creationTime;
|
||||||
bool opened;
|
bool opened;
|
||||||
long decompressedSize;
|
long decompressedSize;
|
||||||
|
Stream innerStream;
|
||||||
|
|
||||||
public BZip2()
|
public BZip2()
|
||||||
{
|
{
|
||||||
@@ -69,9 +70,7 @@ namespace DiscImageChef.Filters
|
|||||||
|
|
||||||
public override Stream GetDataForkStream()
|
public override Stream GetDataForkStream()
|
||||||
{
|
{
|
||||||
// Otherwise base stream is not at correct position
|
return innerStream;
|
||||||
dataStream.Seek(0, SeekOrigin.Begin);
|
|
||||||
return new ForcedSeekStream<BZip2Stream>(decompressedSize, dataStream, CompressionMode.Decompress, true, false);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
public override string GetPath()
|
public override string GetPath()
|
||||||
@@ -157,31 +156,14 @@ namespace DiscImageChef.Filters
|
|||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
|
|
||||||
// BZIP2 does not store the uncompressed size so we must read the whole file. Whole. Whatever time it takes. Or we couldn't seek on it...
|
|
||||||
long GuessSize(Stream stream)
|
|
||||||
{
|
|
||||||
stream.Seek(0, SeekOrigin.Begin);
|
|
||||||
BZip2Stream bzStream = new BZip2Stream(stream, CompressionMode.Decompress, true);
|
|
||||||
long size = 0;
|
|
||||||
int read = 0;
|
|
||||||
byte[] buffer = new byte[1048576];
|
|
||||||
do
|
|
||||||
{
|
|
||||||
read = bzStream.Read(buffer, 0, buffer.Length);
|
|
||||||
size += read;
|
|
||||||
}
|
|
||||||
while(read > 0);
|
|
||||||
stream.Seek(0, SeekOrigin.Begin);
|
|
||||||
return size;
|
|
||||||
}
|
|
||||||
|
|
||||||
public override void Open(byte[] buffer)
|
public override void Open(byte[] buffer)
|
||||||
{
|
{
|
||||||
dataStream = new MemoryStream(buffer);
|
dataStream = new MemoryStream(buffer);
|
||||||
basePath = null;
|
basePath = null;
|
||||||
decompressedSize = GuessSize(dataStream);
|
|
||||||
creationTime = DateTime.UtcNow;
|
creationTime = DateTime.UtcNow;
|
||||||
lastWriteTime = creationTime;
|
lastWriteTime = creationTime;
|
||||||
|
innerStream = new ForcedSeekStream<BZip2Stream>(dataStream, CompressionMode.Decompress, false, false);
|
||||||
|
decompressedSize = innerStream.Length;
|
||||||
opened = true;
|
opened = true;
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -189,9 +171,10 @@ namespace DiscImageChef.Filters
|
|||||||
{
|
{
|
||||||
dataStream = stream;
|
dataStream = stream;
|
||||||
basePath = null;
|
basePath = null;
|
||||||
decompressedSize = GuessSize(dataStream);
|
|
||||||
creationTime = DateTime.UtcNow;
|
creationTime = DateTime.UtcNow;
|
||||||
lastWriteTime = creationTime;
|
lastWriteTime = creationTime;
|
||||||
|
innerStream = new ForcedSeekStream<BZip2Stream>(dataStream, CompressionMode.Decompress, false, false);
|
||||||
|
decompressedSize = innerStream.Length;
|
||||||
opened = true;
|
opened = true;
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -201,13 +184,15 @@ namespace DiscImageChef.Filters
|
|||||||
basePath = Path.GetFullPath(path);
|
basePath = Path.GetFullPath(path);
|
||||||
|
|
||||||
DateTime start = DateTime.UtcNow;
|
DateTime start = DateTime.UtcNow;
|
||||||
decompressedSize = GuessSize(dataStream);
|
//decompressedSize = GuessSize(dataStream);
|
||||||
DateTime end = DateTime.UtcNow;
|
DateTime end = DateTime.UtcNow;
|
||||||
DicConsole.DebugWriteLine("BZip2 filter", "Took {0} seconds to guess size is {1}", (end - start).TotalSeconds, decompressedSize);
|
DicConsole.DebugWriteLine("BZip2 filter", "Took {0} seconds to guess size is {1}", (end - start).TotalSeconds, decompressedSize);
|
||||||
|
|
||||||
FileInfo fi = new FileInfo(path);
|
FileInfo fi = new FileInfo(path);
|
||||||
creationTime = fi.CreationTimeUtc;
|
creationTime = fi.CreationTimeUtc;
|
||||||
lastWriteTime = fi.LastWriteTimeUtc;
|
lastWriteTime = fi.LastWriteTimeUtc;
|
||||||
|
innerStream = new ForcedSeekStream<BZip2Stream>(dataStream, CompressionMode.Decompress, false, false);
|
||||||
|
decompressedSize = innerStream.Length;
|
||||||
opened = true;
|
opened = true;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -44,6 +44,7 @@ namespace DiscImageChef.Filters
|
|||||||
DateTime creationTime;
|
DateTime creationTime;
|
||||||
bool opened;
|
bool opened;
|
||||||
uint decompressedSize;
|
uint decompressedSize;
|
||||||
|
Stream zStream;
|
||||||
|
|
||||||
public GZip()
|
public GZip()
|
||||||
{
|
{
|
||||||
@@ -67,9 +68,7 @@ namespace DiscImageChef.Filters
|
|||||||
|
|
||||||
public override Stream GetDataForkStream()
|
public override Stream GetDataForkStream()
|
||||||
{
|
{
|
||||||
// Otherwise base stream is not at correct position and deflate throws errors
|
return zStream;
|
||||||
dataStream.Seek(0, SeekOrigin.Begin);
|
|
||||||
return new ForcedSeekStream<GZipStream>(decompressedSize, dataStream, CompressionMode.Decompress);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
public override string GetPath()
|
public override string GetPath()
|
||||||
@@ -142,6 +141,7 @@ namespace DiscImageChef.Filters
|
|||||||
decompressedSize = isize;
|
decompressedSize = isize;
|
||||||
creationTime = DateHandlers.UNIXUnsignedToDateTime(mtime);
|
creationTime = DateHandlers.UNIXUnsignedToDateTime(mtime);
|
||||||
lastWriteTime = creationTime;
|
lastWriteTime = creationTime;
|
||||||
|
zStream = new ForcedSeekStream<GZipStream>(decompressedSize, dataStream, CompressionMode.Decompress);
|
||||||
opened = true;
|
opened = true;
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -167,6 +167,7 @@ namespace DiscImageChef.Filters
|
|||||||
decompressedSize = isize;
|
decompressedSize = isize;
|
||||||
creationTime = DateHandlers.UNIXUnsignedToDateTime(mtime);
|
creationTime = DateHandlers.UNIXUnsignedToDateTime(mtime);
|
||||||
lastWriteTime = creationTime;
|
lastWriteTime = creationTime;
|
||||||
|
zStream = new ForcedSeekStream<GZipStream>(decompressedSize, dataStream, CompressionMode.Decompress);
|
||||||
opened = true;
|
opened = true;
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -193,6 +194,7 @@ namespace DiscImageChef.Filters
|
|||||||
FileInfo fi = new FileInfo(path);
|
FileInfo fi = new FileInfo(path);
|
||||||
creationTime = fi.CreationTimeUtc;
|
creationTime = fi.CreationTimeUtc;
|
||||||
lastWriteTime = DateHandlers.UNIXUnsignedToDateTime(mtime);
|
lastWriteTime = DateHandlers.UNIXUnsignedToDateTime(mtime);
|
||||||
|
zStream = new ForcedSeekStream<GZipStream>(decompressedSize, dataStream, CompressionMode.Decompress);
|
||||||
opened = true;
|
opened = true;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user