aboutsummaryrefslogtreecommitdiff
path: root/Emby.Common.Implementations/IO/SharpCifs/Smb/SmbComReadAndX.cs
diff options
context:
space:
mode:
Diffstat (limited to 'Emby.Common.Implementations/IO/SharpCifs/Smb/SmbComReadAndX.cs')
-rw-r--r--Emby.Common.Implementations/IO/SharpCifs/Smb/SmbComReadAndX.cs153
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 + "]";
+ }
+ }
}