using Renci.SshNet.Sftp.Responses; using System; namespace Renci.SshNet.Sftp.Requests { internal sealed class SftpReadRequest : SftpRequest { private readonly Action<SftpDataResponse> _dataAction; public override SftpMessageTypes SftpMessageType => SftpMessageTypes.Read; public byte[] Handle { get; set; } public ulong Offset { get; set; } public uint Length { get; set; } protected override int BufferCapacity => base.BufferCapacity + 4 + Handle.Length + 8 + 4; public SftpReadRequest(uint protocolVersion, uint requestId, byte[] handle, ulong offset, uint length, Action<SftpDataResponse> dataAction, Action<SftpStatusResponse> statusAction) : base(protocolVersion, requestId, statusAction) { Handle = handle; Offset = offset; Length = length; _dataAction = dataAction; } protected override void LoadData() { base.LoadData(); Handle = ReadBinary(); Offset = ReadUInt64(); Length = ReadUInt32(); } protected override void SaveData() { base.SaveData(); WriteBinaryString(Handle); Write(Offset); Write(Length); } public override void Complete(SftpResponse response) { SftpDataResponse sftpDataResponse = response as SftpDataResponse; if (sftpDataResponse != null) _dataAction(sftpDataResponse); else base.Complete(response); } } }