Public-Mirror/GARbro-mirror
1
0
Fork 0
mirror of https://github.com/crskycode/GARbro.git synced 2024-12-24 03:44:13 +08:00
Code Issues Projects Releases Wiki Activity

(ConcatStream): moved to CommonStreams.

Browse Source
This commit is contained in:
morkt 2016-10-09 01:27:58 +04:00
parent ffd0648b27
commit a2c9e3f79b
2 changed files with 90 additions and 90 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

90
ArcFormats/CommonStreams.cs
View File

@ -438,6 +438,96 @@ namespace GameRes.Formats
#endregion
}
/// <summary>
/// Concatenation of the two input Streams.
/// </summary>
public class ConcatStream : InputProxyStream
{
Stream m_second;
long m_position;
Stream m_active;
public ConcatStream (Stream first, Stream second) : base (first)
{
m_second = second;
m_position = 0;
m_active = first;
}
internal Stream First { get { return BaseStream; } }
internal Stream Second { get { return m_second; } }
public override bool CanSeek { get { return First.CanSeek && Second.CanSeek; } }
public override long Length { get { return First.Length + Second.Length; } }
public override long Position
{
get { return m_position; }
set { m_position = value; }
}
public override int Read (byte[] buffer, int offset, int count)
{
if (First.CanSeek)
{
if (m_position >= First.Length)
{
m_active = Second;
m_active.Position = m_position - First.Length;
}
else
{
m_active = First;
m_active.Position = m_position;
}
}
int total_read = 0;
while (count > 0)
{
int read = m_active.Read (buffer, offset, count);
if (0 == read)
break;
total_read += read;
m_position += read;
offset += read;
count -= read;
}
if (count > 0 && m_active != Second)
{
m_active = Second;
if (m_active.CanSeek)
m_active.Position = 0;
int read = m_active.Read (buffer, offset, count);
m_position += read;
total_read += read;
}
return total_read;
}
public override long Seek (long offset, SeekOrigin origin)
{
if (SeekOrigin.Begin == origin)
Position = offset;
else if (SeekOrigin.Current == origin)
Position = m_position + offset;
else
Position = Length + offset;
return m_position;
}
bool _disposed = false;
protected override void Dispose (bool disposing)
{
if (!_disposed)
{
if (disposing)
m_second.Dispose();
_disposed = true;
base.Dispose (disposing);
}
}
}
public class XoredStream : ProxyStream
{
private byte m_key;

90
ArcFormats/TamaSoft/ArcEPK.cs
View File

@ -167,94 +167,4 @@ namespace GameRes.Formats.Tama
return new ConcatStream (begin, end);
}
}
/// <summary>
/// Concatenation of the two input Streams.
/// </summary>
public class ConcatStream : InputProxyStream
{
Stream m_second;
long m_position;
Stream m_active;
public ConcatStream (Stream first, Stream second) : base (first)
{
m_second = second;
m_position = 0;
m_active = first;
}
internal Stream First { get { return BaseStream; } }
internal Stream Second { get { return m_second; } }
public override bool CanSeek { get { return First.CanSeek && Second.CanSeek; } }
public override long Length { get { return First.Length + Second.Length; } }
public override long Position
{
get { return m_position; }
set { m_position = value; }
}
public override int Read (byte[] buffer, int offset, int count)
{
if (First.CanSeek)
{
if (m_position >= First.Length)
{
m_active = Second;
m_active.Position = m_position - First.Length;
}
else
{
m_active = First;
m_active.Position = m_position;
}
}
int total_read = 0;
while (count > 0)
{
int read = m_active.Read (buffer, offset, count);
if (0 == read)
break;
total_read += read;
m_position += read;
offset += read;
count -= read;
}
if (count > 0 && m_active != Second)
{
m_active = Second;
if (m_active.CanSeek)
m_active.Position = 0;
int read = m_active.Read (buffer, offset, count);
m_position += read;
total_read += read;
}
return total_read;
}
public override long Seek (long offset, SeekOrigin origin)
{
if (SeekOrigin.Begin == origin)
Position = offset;
else if (SeekOrigin.Current == origin)
Position = m_position + offset;
else
Position = Length + offset;
return m_position;
}
bool _disposed = false;
protected override void Dispose (bool disposing)
{
if (!_disposed)
{
if (disposing)
m_second.Dispose();
_disposed = true;
base.Dispose (disposing);
}
}
}
}