Files
HandyControl/Net35/HandyControl_Net35/Shell/Standard/ManagedIStream.cs
T
2019-01-21 00:43:10 +08:00

144 lines
5.2 KiB
C#

namespace Standard
{
using System;
using System.Diagnostics.CodeAnalysis;
using System.IO;
using System.Runtime.InteropServices;
using System.Runtime.InteropServices.ComTypes;
internal sealed class ManagedIStream : IStream, IDisposable
{
private Stream _source;
private const int LOCK_EXCLUSIVE = 2;
private const int STGM_READWRITE = 2;
private const int STGTY_STREAM = 2;
public ManagedIStream(Stream source)
{
Standard.Verify.IsNotNull<Stream>(source, "source");
this._source = source;
}
private void _Validate()
{
if (this._source == null)
{
throw new ObjectDisposedException("this");
}
}
[SuppressMessage("Microsoft.Globalization", "CA1303:Do not pass literals as localized parameters", MessageId="Standard.HRESULT.ThrowIfFailed(System.String)"), Obsolete("The method is not implemented", true)]
public void Clone(out IStream ppstm)
{
ppstm = null;
Standard.HRESULT.STG_E_INVALIDFUNCTION.ThrowIfFailed("The method is not implemented.");
}
public void Commit(int grfCommitFlags)
{
this._Validate();
this._source.Flush();
}
[SuppressMessage("Microsoft.Security", "CA2122:DoNotIndirectlyExposeMethodsWithLinkDemands"), SuppressMessage("Microsoft.Design", "CA1062:Validate arguments of public methods", MessageId="0")]
public void CopyTo(IStream pstm, long cb, IntPtr pcbRead, IntPtr pcbWritten)
{
Standard.Verify.IsNotNull<IStream>(pstm, "pstm");
this._Validate();
byte[] buffer = new byte[0x1000];
long val = 0L;
while (val < cb)
{
int num2 = this._source.Read(buffer, 0, buffer.Length);
if (num2 == 0)
{
break;
}
pstm.Write(buffer, num2, IntPtr.Zero);
val += num2;
}
if (IntPtr.Zero != pcbRead)
{
Marshal.WriteInt64(pcbRead, val);
}
if (IntPtr.Zero != pcbWritten)
{
Marshal.WriteInt64(pcbWritten, val);
}
}
public void Dispose()
{
this._source = null;
}
[SuppressMessage("Microsoft.Globalization", "CA1303:Do not pass literals as localized parameters", MessageId="Standard.HRESULT.ThrowIfFailed(System.String)"), Obsolete("The method is not implemented", true)]
public void LockRegion(long libOffset, long cb, int dwLockType)
{
Standard.HRESULT.STG_E_INVALIDFUNCTION.ThrowIfFailed("The method is not implemented.");
}
[SuppressMessage("Microsoft.Security", "CA2122:DoNotIndirectlyExposeMethodsWithLinkDemands")]
public void Read(byte[] pv, int cb, IntPtr pcbRead)
{
this._Validate();
int val = this._source.Read(pv, 0, cb);
if (IntPtr.Zero != pcbRead)
{
Marshal.WriteInt32(pcbRead, val);
}
}
[SuppressMessage("Microsoft.Globalization", "CA1303:Do not pass literals as localized parameters", MessageId="Standard.HRESULT.ThrowIfFailed(System.String)"), Obsolete("The method is not implemented", true)]
public void Revert()
{
Standard.HRESULT.STG_E_INVALIDFUNCTION.ThrowIfFailed("The method is not implemented.");
}
[SuppressMessage("Microsoft.Security", "CA2122:DoNotIndirectlyExposeMethodsWithLinkDemands")]
public void Seek(long dlibMove, int dwOrigin, IntPtr plibNewPosition)
{
this._Validate();
long val = this._source.Seek(dlibMove, (SeekOrigin) dwOrigin);
if (IntPtr.Zero != plibNewPosition)
{
Marshal.WriteInt64(plibNewPosition, val);
}
}
public void SetSize(long libNewSize)
{
this._Validate();
this._source.SetLength(libNewSize);
}
public void Stat(out System.Runtime.InteropServices.ComTypes.STATSTG pstatstg, int grfStatFlag)
{
pstatstg = new System.Runtime.InteropServices.ComTypes.STATSTG();
this._Validate();
pstatstg.type = 2;
pstatstg.cbSize = this._source.Length;
pstatstg.grfMode = 2;
pstatstg.grfLocksSupported = 2;
}
[Obsolete("The method is not implemented", true), SuppressMessage("Microsoft.Globalization", "CA1303:Do not pass literals as localized parameters", MessageId="Standard.HRESULT.ThrowIfFailed(System.String)")]
public void UnlockRegion(long libOffset, long cb, int dwLockType)
{
Standard.HRESULT.STG_E_INVALIDFUNCTION.ThrowIfFailed("The method is not implemented.");
}
[SuppressMessage("Microsoft.Security", "CA2122:DoNotIndirectlyExposeMethodsWithLinkDemands")]
public void Write(byte[] pv, int cb, IntPtr pcbWritten)
{
this._Validate();
this._source.Write(pv, 0, cb);
if (IntPtr.Zero != pcbWritten)
{
Marshal.WriteInt32(pcbWritten, cb);
}
}
}
}