diff options
Diffstat (limited to 'Emby.Common.Implementations/IO/SharpCifs/Smb/SmbComReadAndX.cs')
| -rw-r--r-- | Emby.Common.Implementations/IO/SharpCifs/Smb/SmbComReadAndX.cs | 153 |
1 files changed, 80 insertions, 73 deletions
diff --git a/Emby.Common.Implementations/IO/SharpCifs/Smb/SmbComReadAndX.cs b/Emby.Common.Implementations/IO/SharpCifs/Smb/SmbComReadAndX.cs index e75179700..0ba58a3d0 100644 --- a/Emby.Common.Implementations/IO/SharpCifs/Smb/SmbComReadAndX.cs +++ b/Emby.Common.Implementations/IO/SharpCifs/Smb/SmbComReadAndX.cs @@ -16,92 +16,99 @@ // Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA namespace SharpCifs.Smb { - internal class SmbComReadAndX : AndXServerMessageBlock - { - private static readonly int BatchLimit = Config.GetInt("jcifs.smb.client.ReadAndX.Close" - , 1); + internal class SmbComReadAndX : AndXServerMessageBlock + { + private static readonly int BatchLimit + = Config.GetInt("jcifs.smb.client.ReadAndX.Close", 1); - private long _offset; + private long _offset; - private int _fid; + private int _fid; - private int _openTimeout; + private int _openTimeout; - internal int MaxCount; + internal int MaxCount; - internal int MinCount; + internal int MinCount; - internal int Remaining; + internal int Remaining; - public SmbComReadAndX() : base(null) - { - Command = SmbComReadAndx; - _openTimeout = unchecked((int)(0xFFFFFFFF)); - } + public SmbComReadAndX() : base(null) + { + Command = SmbComReadAndx; + _openTimeout = unchecked((int)(0xFFFFFFFF)); + } - internal SmbComReadAndX(int fid, long offset, int maxCount, ServerMessageBlock andx - ) : base(andx) - { - this._fid = fid; - this._offset = offset; - this.MaxCount = MinCount = maxCount; - Command = SmbComReadAndx; - _openTimeout = unchecked((int)(0xFFFFFFFF)); - } + internal SmbComReadAndX(int fid, + long offset, + int maxCount, + ServerMessageBlock andx) : base(andx) + { + this._fid = fid; + this._offset = offset; + this.MaxCount = MinCount = maxCount; + Command = SmbComReadAndx; + _openTimeout = unchecked((int)(0xFFFFFFFF)); + } - internal virtual void SetParam(int fid, long offset, int maxCount) - { - this._fid = fid; - this._offset = offset; - this.MaxCount = MinCount = maxCount; - } + internal virtual void SetParam(int fid, long offset, int maxCount) + { + this._fid = fid; + this._offset = offset; + this.MaxCount = MinCount = maxCount; + } - internal override int GetBatchLimit(byte command) - { - return command == SmbComClose ? BatchLimit : 0; - } + internal override int GetBatchLimit(byte command) + { + return command == SmbComClose ? BatchLimit : 0; + } - internal override int WriteParameterWordsWireFormat(byte[] dst, int dstIndex) - { - int start = dstIndex; - WriteInt2(_fid, dst, dstIndex); - dstIndex += 2; - WriteInt4(_offset, dst, dstIndex); - dstIndex += 4; - WriteInt2(MaxCount, dst, dstIndex); - dstIndex += 2; - WriteInt2(MinCount, dst, dstIndex); - dstIndex += 2; - WriteInt4(_openTimeout, dst, dstIndex); - dstIndex += 4; - WriteInt2(Remaining, dst, dstIndex); - dstIndex += 2; - WriteInt4(_offset >> 32, dst, dstIndex); - dstIndex += 4; - return dstIndex - start; - } + internal override int WriteParameterWordsWireFormat(byte[] dst, int dstIndex) + { + int start = dstIndex; + WriteInt2(_fid, dst, dstIndex); + dstIndex += 2; + WriteInt4(_offset, dst, dstIndex); + dstIndex += 4; + WriteInt2(MaxCount, dst, dstIndex); + dstIndex += 2; + WriteInt2(MinCount, dst, dstIndex); + dstIndex += 2; + WriteInt4(_openTimeout, dst, dstIndex); + dstIndex += 4; + WriteInt2(Remaining, dst, dstIndex); + dstIndex += 2; + WriteInt4(_offset >> 32, dst, dstIndex); + dstIndex += 4; + return dstIndex - start; + } - internal override int WriteBytesWireFormat(byte[] dst, int dstIndex) - { - return 0; - } + internal override int WriteBytesWireFormat(byte[] dst, int dstIndex) + { + return 0; + } - internal override int ReadParameterWordsWireFormat(byte[] buffer, int bufferIndex - ) - { - return 0; - } + internal override int ReadParameterWordsWireFormat(byte[] buffer, int bufferIndex) + { + return 0; + } - internal override int ReadBytesWireFormat(byte[] buffer, int bufferIndex) - { - return 0; - } + internal override int ReadBytesWireFormat(byte[] buffer, int bufferIndex) + { + return 0; + } - public override string ToString() - { - return "SmbComReadAndX[" + base.ToString() + ",fid=" + _fid + ",offset=" - + _offset + ",maxCount=" + MaxCount + ",minCount=" + MinCount + ",openTimeout=" - + _openTimeout + ",remaining=" + Remaining + ",offset=" + _offset + "]"; - } - } + public override string ToString() + { + return "SmbComReadAndX[" + + base.ToString() + + ",fid=" + _fid + + ",offset=" + _offset + + ",maxCount=" + MaxCount + + ",minCount=" + MinCount + + ",openTimeout=" + _openTimeout + + ",remaining=" + Remaining + + ",offset=" + _offset + "]"; + } + } } |
