diff options
Diffstat (limited to 'Emby.Common.Implementations/IO/SharpCifs/Smb/TransactNamedPipeOutputStream.cs')
| -rw-r--r-- | Emby.Common.Implementations/IO/SharpCifs/Smb/TransactNamedPipeOutputStream.cs | 121 |
1 files changed, 62 insertions, 59 deletions
diff --git a/Emby.Common.Implementations/IO/SharpCifs/Smb/TransactNamedPipeOutputStream.cs b/Emby.Common.Implementations/IO/SharpCifs/Smb/TransactNamedPipeOutputStream.cs index d3e8d3e1a..f436d593c 100644 --- a/Emby.Common.Implementations/IO/SharpCifs/Smb/TransactNamedPipeOutputStream.cs +++ b/Emby.Common.Implementations/IO/SharpCifs/Smb/TransactNamedPipeOutputStream.cs @@ -16,71 +16,74 @@ // 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; - /// <exception cref="System.IO.IOException"></exception> - 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; - } + /// <exception cref="System.IO.IOException"></exception> + 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; + } - /// <exception cref="System.IO.IOException"></exception> - public override void Close() - { - _pipe.Close(); - } + /// <exception cref="System.IO.IOException"></exception> + public override void Close() + { + _pipe.Close(); + } - /// <exception cref="System.IO.IOException"></exception> - public override void Write(int b) - { - _tmp[0] = unchecked((byte)b); - Write(_tmp, 0, 1); - } + /// <exception cref="System.IO.IOException"></exception> + public override void Write(int b) + { + _tmp[0] = unchecked((byte)b); + Write(_tmp, 0, 1); + } - /// <exception cref="System.IO.IOException"></exception> - public override void Write(byte[] b) - { - Write(b, 0, b.Length); - } + /// <exception cref="System.IO.IOException"></exception> + public override void Write(byte[] b) + { + Write(b, 0, b.Length); + } - /// <exception cref="System.IO.IOException"></exception> - 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)); - } - } - } - } + /// <exception cref="System.IO.IOException"></exception> + 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)); + } + } + } + } } |