MoonTools.NETPhysFS/SharpPhysFS/PhysFSStream.cs

121 lines
2.3 KiB
C#

using System;
using System.IO;
namespace MoonTools.NETPhysFS
{
public class PhysFSStream : Stream
{
private IntPtr handle;
private readonly bool readOnly;
private readonly PhysFS physFS;
internal PhysFSStream(PhysFS pfs, IntPtr ptr, bool readOnly)
{
handle = ptr;
this.readOnly = readOnly;
physFS = pfs;
}
public override bool CanRead
{
get
{
return true;
}
}
public override bool CanSeek
{
get
{
return true;
}
}
public override bool CanWrite
{
get
{
return !readOnly;
}
}
public override void Flush()
{
PhysFS.LowLevel.Flush(handle, physFS);
}
public override long Length
{
get
{
return PhysFS.LowLevel.FileLength(handle);
}
}
public override long Position
{
get
{
return PhysFS.LowLevel.Tell(handle);
}
set
{
PhysFS.LowLevel.Seek(handle, (ulong)value, physFS);
}
}
public long Read(byte[] buffer, int offset, uint count)
{
return PhysFS.LowLevel.Read(handle, buffer, 1, count, offset);
}
public override int Read(byte[] buffer, int offset, int count)
{
return (int)Read(buffer, offset, (uint)count);
}
public override long Seek(long offset, SeekOrigin origin)
{
long pos;
if (origin == SeekOrigin.Begin)
pos = 0;
else if (origin == SeekOrigin.Current)
pos = PhysFS.LowLevel.Tell(handle);
else
pos = PhysFS.LowLevel.FileLength(handle);
PhysFS.LowLevel.Seek(handle, (ulong)(pos + offset), physFS);
return pos + offset;
}
public long Write(byte[] buffer, uint count)
{
return PhysFS.LowLevel.Write(handle, buffer, 1, count);
}
public override void Write(byte[] buffer, int offset, int count)
{
Write(buffer, (uint)count);
}
public override void SetLength(long value)
{
throw new NotSupportedException();
}
protected override void Dispose(bool disposing)
{
if(disposing)
{
if (handle != IntPtr.Zero)
{
PhysFS.LowLevel.Close(handle, physFS);
handle = IntPtr.Zero;
}
}
base.Dispose(disposing);
}
}
}