mirror of
https://github.com/ultimatepp/ultimatepp.git
synced 2026-05-15 22:02:49 -06:00
5f2d0f4938
* reset * reference/SshBasics: MT example with CoFor added. * reference/SshBasics: Cosmetics.
36 lines
968 B
C++
36 lines
968 B
C++
#include "SshBasics.h"
|
|
|
|
// SFtpAsyncGet2: Demonstrates multiple file downloads, using a parallelization loop.
|
|
|
|
|
|
void SFtpAsyncGet2(SshSession& session)
|
|
{
|
|
const int MAXDOWNLOADS = 4;
|
|
const char *path = "/pub/example/";
|
|
|
|
SFtp::DirList ls;
|
|
{
|
|
// Get a remote dir listing.
|
|
SFtp browser(session);
|
|
if(!browser.ListDir(path, ls)) {
|
|
RLOG(browser.GetErrorDesc());
|
|
return;
|
|
}
|
|
}
|
|
|
|
// Filter the dir list.
|
|
auto files = FilterRange(ls, [](const SFtp::DirEntry& e) { return e.IsFile() && e.GetSize() <= 65536; });
|
|
|
|
// Loop over.
|
|
CoFor(min(files.GetCount(), MAXDOWNLOADS), [&files, &path, &session](int i){
|
|
const SFtp::DirEntry& e = files[i];
|
|
String fpath = AppendFileName(path, e.GetName());
|
|
RLOG("Downloading " << fpath);
|
|
SFtp sftp(session);
|
|
String file = sftp.LoadFile(fpath);
|
|
if(sftp.IsError())
|
|
RLOG(Format("Worker #%d: %s", sftp.GetId(), sftp.GetErrorDesc()));
|
|
else
|
|
RLOG("File " << e.GetName() << " is successfully downloaded.");
|
|
});
|
|
}
|