From 0d10dfe4718dc6875a20fc7c0c3d0b8b982cf3d8 Mon Sep 17 00:00:00 2001 From: Luke Pulverenti Date: Fri, 7 Jul 2017 23:12:21 -0400 Subject: update sharpcifs --- .../SharpCifs/Smb/TransactNamedPipeOutputStream.cs | 121 ++++++++++----------- 1 file changed, 59 insertions(+), 62 deletions(-) (limited to 'Emby.Common.Implementations/IO/SharpCifs/Smb/TransactNamedPipeOutputStream.cs') diff --git a/Emby.Common.Implementations/IO/SharpCifs/Smb/TransactNamedPipeOutputStream.cs b/Emby.Common.Implementations/IO/SharpCifs/Smb/TransactNamedPipeOutputStream.cs index f436d593c8..d3e8d3e1ad 100644 --- a/Emby.Common.Implementations/IO/SharpCifs/Smb/TransactNamedPipeOutputStream.cs +++ b/Emby.Common.Implementations/IO/SharpCifs/Smb/TransactNamedPipeOutputStream.cs @@ -16,74 +16,71 @@ // Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA namespace SharpCifs.Smb { - internal class TransactNamedPipeOutputStream : SmbFileOutputStream - { - private string _path; + internal class TransactNamedPipeOutputStream : SmbFileOutputStream + { + private string _path; - private SmbNamedPipe _pipe; + private SmbNamedPipe _pipe; - private byte[] _tmp = new byte[1]; + private byte[] _tmp = new byte[1]; - private bool _dcePipe; + private bool _dcePipe; - /// - internal TransactNamedPipeOutputStream(SmbNamedPipe pipe) - : base(pipe, false, (pipe.PipeType & unchecked((int)(0xFFFF00FF))) | SmbFile.OExcl) - { - this._pipe = pipe; - _dcePipe = (pipe.PipeType & SmbNamedPipe.PipeTypeDceTransact) - == SmbNamedPipe.PipeTypeDceTransact; - _path = pipe.Unc; - } + /// + internal TransactNamedPipeOutputStream(SmbNamedPipe pipe) : base(pipe, false, (pipe + .PipeType & unchecked((int)(0xFFFF00FF))) | SmbFile.OExcl) + { + this._pipe = pipe; + _dcePipe = (pipe.PipeType & SmbNamedPipe.PipeTypeDceTransact) == SmbNamedPipe + .PipeTypeDceTransact; + _path = pipe.Unc; + } - /// - public override void Close() - { - _pipe.Close(); - } + /// + public override void Close() + { + _pipe.Close(); + } - /// - public override void Write(int b) - { - _tmp[0] = unchecked((byte)b); - Write(_tmp, 0, 1); - } + /// + public override void Write(int b) + { + _tmp[0] = unchecked((byte)b); + Write(_tmp, 0, 1); + } - /// - public override void Write(byte[] b) - { - Write(b, 0, b.Length); - } + /// + public override void Write(byte[] b) + { + Write(b, 0, b.Length); + } - /// - public override void Write(byte[] b, int off, int len) - { - if (len < 0) - { - len = 0; - } - if ((_pipe.PipeType & SmbNamedPipe.PipeTypeCall) == SmbNamedPipe.PipeTypeCall) - { - _pipe.Send(new TransWaitNamedPipe(_path), - new TransWaitNamedPipeResponse()); - _pipe.Send(new TransCallNamedPipe(_path, b, off, len), - new TransCallNamedPipeResponse(_pipe)); - } - else - { - if ((_pipe.PipeType & SmbNamedPipe.PipeTypeTransact) - == SmbNamedPipe.PipeTypeTransact) - { - EnsureOpen(); - TransTransactNamedPipe req - = new TransTransactNamedPipe(_pipe.Fid, b, off, len); - if (_dcePipe) - { - req.MaxDataCount = 1024; - } - _pipe.Send(req, new TransTransactNamedPipeResponse(_pipe)); - } - } - } - } + /// + public override void Write(byte[] b, int off, int len) + { + if (len < 0) + { + len = 0; + } + if ((_pipe.PipeType & SmbNamedPipe.PipeTypeCall) == SmbNamedPipe.PipeTypeCall) + { + _pipe.Send(new TransWaitNamedPipe(_path), new TransWaitNamedPipeResponse()); + _pipe.Send(new TransCallNamedPipe(_path, b, off, len), new TransCallNamedPipeResponse + (_pipe)); + } + else + { + if ((_pipe.PipeType & SmbNamedPipe.PipeTypeTransact) == SmbNamedPipe.PipeTypeTransact) + { + EnsureOpen(); + TransTransactNamedPipe req = new TransTransactNamedPipe(_pipe.Fid, b, off, len); + if (_dcePipe) + { + req.MaxDataCount = 1024; + } + _pipe.Send(req, new TransTransactNamedPipeResponse(_pipe)); + } + } + } + } } -- cgit v1.2.3