gsadmin/ssh.net
1
0
Fork 0
mirror of https://github.com/sshnet/SSH.NET.git synced 2026-09-10 17:25:51 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix SFTP Write method

Browse Source
This commit is contained in:
olegkap_cp
2010-11-08 13:54:59 +00:00
parent 66cc98d2e0
commit ba8f01a661
1 changed files with 7 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Renci.SshClient/Renci.SshClient/Channels/ChannelSessionSftp.cs
+7 -6
View File
@@ -54,7 +54,7 @@ namespace Renci.SshClient.Channels
SubsystemName = "sftp",
});
this.Session.WaitHandle(this._channelRequestSuccessWaitHandle);
this.WaitHandle(this._channelRequestSuccessWaitHandle);
this.SendMessage(new InitMessage
{
@@ -92,9 +92,10 @@ namespace Renci.SshClient.Channels
var buffer = new byte[1024];
ulong offset = 0;
while (source.Read(buffer, 0, buffer.Length) > 0)
var bytesRead = 0;
while ((bytesRead = source.Read(buffer, 0, buffer.Length)) > 0)
{
this.RemoteWrite(handle, offset, buffer.GetSshString());
this.RemoteWrite(handle, offset, buffer.Take(bytesRead).GetSshString());
offset += (ulong)buffer.Length;
}
}
@@ -269,7 +270,7 @@ namespace Renci.SshClient.Channels
private SftpMessage ReceiveMessage()
{
this.Session.WaitHandle(this._responseMessageReceivedWaitHandle);
this.WaitHandle(this._responseMessageReceivedWaitHandle);
var statusMessage = this._responseMessage as StatusMessage;
@@ -470,8 +471,8 @@ namespace Renci.SshClient.Channels
var status = this.ReceiveMessage<StatusMessage>();
var attempts = 0;
// If close is fails wait a litle a try to close it again, in case server flushed data into the file during close
while (status.StatusCode != StatusCodes.Ok && attempts++ < this.Session.ConnectionInfo.RetryAttempts)
// If close fails wait a litle a try to close it again, in case server flushed data into the file during close
while (status.StatusCode != StatusCodes.Ok && attempts++ < this.ConnectionInfo.RetryAttempts)
{
Thread.Sleep(50);
status = this.ReceiveMessage<StatusMessage>();