Failed. Code = -31, SFTP Protocol Error

Server: test.rebex.net
Port:   22
User:   demo
Password: password

session.Timeout(settings.timeout * 1000);
	if((connected = session.Connect(
		~settings.host,
		~settings.port,
		~settings.user,
		~settings.password
		))) {
		browser.Attach(new SFtp(session));
		filesystem.Mount(*browser);
		basedir = browser->GetDefaultDir();
		basedir = "msp";//add for testing
		DLOG(basedir);
		dir.SetData("msp");//add for testing
		DLOG(dir.GetData().ToString());
		DLOG(GetWorkdir());
		DLOG("Before work dir");
		Workdir(basedir);
		DLOG("After work dir, and before LoadDir");
		LoadDir();
		DLOG("After load dir");
	}
	else SessionError();
}

void SFtpBrowser::LoadDir()
{
	if(browser->InProgress())
		return;
	list.Clear();
	DLOG("Before SFtpFileSystemInfo sfsi(*browser);");
	SFtpFileSystemInfo sfsi(*browser);
	DLOG("After SFtpFileSystemInfo sfsi(*browser);");
	DLOG("Before If");
	DLOG(GetWorkdir());
	if(Upp::Load(list, GetWorkdir(), "*", false, Null, (FileSystemInfo&) sfsi, Null, false)){
		DLOG("Before sort");
		sortbyext ? SortByExt(list) : SortByName(list);
		DLOG("After sort");
		}
	DLOG("After If");
	DLOG("Before Summary()");
	Summary();
	DLOG("After Summary(), and before Sync()");
	Sync();
	DLOG("After Sync()");
}

if(Upp::Load(list, GetWorkdir(), "*", false, Null, (FileSystemInfo&) sfsi, Null, false)){

void SFtpBrowser::LoadDir()
{
	if(browser->InProgress())
		return;
	list.Clear();
	DLOG("Before SFtpFileSystemInfo sfsi(*browser);");
	SFtpFileSystemInfo sfsi(*browser);
	DLOG("After SFtpFileSystemInfo sfsi(*browser);");
	DLOG("Start list folder");
	DLOG(GetWorkdir());
	SFtp::DirList ls;
		// Get a remote dir listing.
	if(!browser->ListDir(GetWorkdir(), ls)) {
		DLOG(browser->GetErrorDesc());
		return;
	}
	// Filter the dir list.
	auto files =  FilterRange(ls, [](const SFtp::DirEntry& e) { return e.IsFile() && e.GetSize() <= 65536; });
		// Download the files, using worker threads in parallel.
	CoFor(min(files.GetCount(), 1000), [&](int i){
		DLOG(files[i]);
	});
	DLOG("Before If");		
	if(Upp::Load(list, GetWorkdir(), "*", false, Null, (FileSystemInfo&) sfsi, Null, false)){
	DLOG("Before sort");
		sortbyext ? SortByExt(list) : SortByName(list);
		DLOG("After sort");
		}
		
	DLOG("After If");
	DLOG("Before Summary()");
	Summary();
	DLOG("After Summary(), and before Sync()");
	Sync();
	DLOG("After Sync()");
}

String  GetWorkdir() const          { 
    String workDir = dir.GetData().ToString(); 
    if(workDir == "/") return Null;
        else return workDir;
    }

DLOG(GetWorkdir());
	SFtp::DirList ls;
		// Get a remote dir listing.
	if(!browser->ListDir(GetWorkdir(), ls)) {
		DLOG(browser->GetErrorDesc());
		return;
	}
	// Filter the dir list.
	//auto files =  FilterRange(ls, [](const SFtp::DirEntry& e) { return e.IsFile() && e.GetSize() <= 65536; });	
	auto files =  FilterRange(ls, [](const SFtp::DirEntry& e) { return true; });
		// Download the files, using worker threads in parallel.
	CoFor(min(files.GetCount(), 1000), [&](int i){
		DLOG(files[i]);	});

	DLOG("Start for sfsi.Find");	
		Array<FileSystemInfo::FileInfo> root = sfsi.Find("*");
		for(int i = 0; i < root.GetCount(); i++){
			DLOG(root[i].filename);
			//DLOG(root[i].root_style);
			//DLOG(root[i].root_desc);
		}
	DLOG("End for sfsi.Find");

	Array<FileSystemInfo::FileInfo> ffi =
			filesystem.Find(AppendFileName(dir, filesystem.IsWin32() ? "*.*" : "*"));

void SFtpBrowser::LoadDir()
{
	if(browser->InProgress())
		return;
	list.Clear();
	SFtp::DirList ls;
	if(browser->ListDir(GetWorkdir(), ls)) {
		for(const SFtp::DirEntry& e : ls) {
			String s = e.GetName();
			if(s == "." || s == "..") continue;
			FileList::File f; // Can be easily costumized...
			f.name = s;
			f.time = e.GetLastModified();
			f.font = StdFont();
			f.ink  = SColorText;
			f.icon = e.IsFile() ? CtrlImg::File() : CtrlImg::Dir();
			f.isdir = e.IsDirectory();
			f.length = e.GetSize();
			f.extink = SLtBlue;
                        f.hidden = false;//Scott: add this sentence, or else summary function would not count it.
			list.Add(f);
		}
		sortbyext ? SortByExt(list) : SortByName(list);
			
	}
	Summary();
	Sync();
}

void SFtpBrowser::Transfer(int opcode, const String src, const String& dest)
{
	SFtp worker(session);
	Progress pi(this, src);

	worker.WhenProgress = [&pi](int64 done, int64 total)
	{
		pi.SetText(
			Format(
				t_("%1:s of %2:s is transferred"),
				FormatFileSize(done),
				FormatFileSize(total)
			)
		);
		return pi.SetCanceled(int(done), int(total));
	};
	pi.Create();
	switch(opcode) {
		case GET: {
			pi.Title(t_("Downloading ") << GetFileName(src));
			FileOut fout(dest);
			if(fout && !worker.LoadFile(fout, src))
				ErrorOK(DeQtf(worker.GetErrorDesc()));
			break;
		}
		case PUT: {
			pi.Title(t_("Uploading ") << GetFileName(src)); // Not for use, only for testing
			String s = LoadFile(src);
			if(auto h = worker.OpenWrite(dest); h) {
				int n = worker.Put(h, ~s, s.GetLength());
				RLOG(String() << "Uploaded: " << n << ", filesize: " << s.GetLength());
				RDUMP(worker.IsError());
				if(worker.IsError())
					ErrorOK(DeQtf(worker.GetErrorDesc()));
				worker.Close(h);
			}
			else
				RLOG("Couldn't open file: " << src << ", error: " << worker.GetErrorDesc());
			break;
		}
	}
	LoadDir();
}

case PUT: {
			pi.Title(t_("Uploading ") << GetFileName(src)); // Not for use, only for testing
			String s = LoadFile(src);
			if(auto h = worker.OpenWrite(dest); h) {
				int n = worker.Put(h, ~s, s.GetLength());
				RLOG(String() << "Uploaded: " << n << ", filesize: " << s.GetLength());
				RDUMP(worker.IsError());
				if(worker.IsError())
					ErrorOK(DeQtf(worker.GetErrorDesc()));
				worker.Close(h);
			}
			else
				RLOG("Couldn't open file: " << src << ", error: " << worker.GetErrorDesc());
			break;
		}

case PUT: {
			pi.Title(t_("Uploading ") << GetFileName(src));
			FileIn fin(src);
			if(fin && !worker.SaveFile(dest, fin))
				ErrorOK(DeQtf(worker.GetErrorDesc()));
			break;
		}

		case PUT: {
			pi.Title(t_("Uploading ") << GetFileName(src));
			FileIn fin(src);
			/*
			if(fin && !worker.SaveFile(dest, fin))
				ErrorOK(DeQtf(worker.GetErrorDesc()));
			break;
			*/

			SFtpFileOut fout(worker, dest);
			int64 size = fin.GetSize(), count = 0;
			int64 chunkSize = 1024 * 64;
			Buffer<byte> chunk(chunkSize, 0);
			Gate<int64, int64>      WhenProgress;
			WhenProgress(0, size);
			
				while(!fin.IsEof()) {
					RLOG(Format("size %d, count %d, chunkSize %d, min %d",  size, count, chunkSize, (int)min<int64>(size - count, chunkSize)  ));
					int n = fin.Get(chunk, (int) min<int64>(size - count, chunkSize));
					RLOG(Format("n %d",n));
					if(n > 0) {
						fout.Put(chunk, n);
						if(fout.IsError()) {
							RLOG("Stream write error. " + fin.GetErrorText() + " out stream: "+fout.GetErrorText());
							ErrorOK(DeQtf(worker.GetErrorDesc())+"Stream write error. " + fin.GetErrorText() + " out stream: "+fout.GetErrorText());
							break;
						}
						count += n;
						if(WhenProgress(count, size)) {
							break;
						}
					}
					if(fin.IsError()) {
						RLOG("Stream read error. " + fin.GetErrorText());
						ErrorOK(DeQtf(worker.GetErrorDesc())+"Stream read error. " + fin.GetErrorText());
						break;
					}
				}
				
				
			}

void SFtpBrowser::Transfer(int opcode, const String src, const String& dest)
{
	SFtp worker(session);
	Progress pi(this, src);

	worker.WhenProgress = [&pi](int64 done, int64 total) {
		pi.SetText(Format(t_("%1:s of %2:s is transferred"), FormatFileSize(done),
		                  FormatFileSize(total)));
		return pi.SetCanceled(int(done), int(total));
	};
	pi.Create();
	switch(opcode) {
	case GET: {
		pi.Title(t_("Downloading ") << GetFileName(src));
		FileOut fout(dest);
		if(fout && !worker.LoadFile(fout, src))
			ErrorOK(DeQtf(worker.GetErrorDesc()));
		break;
	}
	case PUT: {
		pi.Title(t_("Uploading ") << GetFileName(src)); // Not for use, only for testing
		String s = LoadFile(src);

		if(auto h = worker.OpenWrite(dest); h) {

			/*			int n = worker.Put(h, ~s, s.GetLength());
			            RLOG(String() << "Uploaded: " << n << ", filesize: " << s.GetLength());
			            RDUMP(worker.IsError());
			            if(worker.IsError())
			                ErrorOK(DeQtf(worker.GetErrorDesc()));
			            worker.Close(h);*/

			int64 size = s.GetLength(), count = 0;
			if(settings.log)
				RLOG(Format("File size %d", size));
			int chunkSize = 1024 * 64, thisTimeSize = 0;
			worker.WhenProgress(0, size);
			while(!(count >= size)) {
				thisTimeSize = (int)min<int64>(size - count, chunkSize);
				if(settings.log)
					RLOG(Format("======= size %d, count %d, chunkSize %d, min %d", size, count,
					            chunkSize, thisTimeSize));
				int x = worker.Put(h, (~s) + count, thisTimeSize);
				count += x;
				if(settings.log)
					RLOG(String() << "This time should be uploaded: " << thisTimeSize
					              << ", Real uploaded: " << x << ", Current Accumulated Count:"
					              << count << ", total filesize: " << size);
				// RDUMP(worker.IsError());
				if(worker.WhenProgress(count, size)) {
					break;
				}

				if(worker.IsError()) {
					ErrorOK("Upload failed : " + DeQtf(worker.GetErrorDesc()));
					break;
				}
			}

			worker.Close(h);
			break;
		}
		else if(settings.log)
			RLOG("Couldn't open file: " << src << ", error: " << worker.GetErrorDesc());

		break;
	}
	}
	LoadDir();
}

bool SFtpStream::Open(SFtp& sftp_, const char *filename, dword mode, int acm)
{
	if(IsOpen())
		Close();
	sftp = &sftp_;
	int iomode = mode & ~SHAREMASK;
	handle = sftp->Open(filename,
						iomode == READ
							? SFtp::READ
							: iomode == CREATE
								? SFtp::READ|SFtp::WRITE|SFtp::CREATE|SFtp::TRUNCATE // <- remove SFtp::TRUNCATE
								: SFtp::READ|SFtp::WRITE,
						acm
						);
				
	if(handle) {
		SFtpAttrs attrs;
		if(!sftp->GetAttrs(handle, attrs)) {
			sftp->Close(handle);
			handle = nullptr;
			return false;
		}
		OpenInit(mode, attrs.filesize);
	}
	return handle;
}