RemoteTransport Class Reference

#include <remotetrans.h>

Inheritance diagram for RemoteTransport:

Collaboration diagram for RemoteTransport:

Public Member Functions
int	copyDirectory (const char *urlPrefix, const char *dir, const char *dest, const char *suffix)
virtual std::vector< struct DirEntry >	getDirList (const char *dirURL)
long	getTimeoutMillis ()
virtual char	getURL (const char *destPath, const char *sourceURL, SWBuf *destBuf=0)
bool	isPassive ()
bool	isUnverifiedPeerAllowed ()
virtual char	putURL (const char *destURL, const char *sourcePath, SWBuf *sourceBuf=0)
	RemoteTransport (const char *host, StatusReporter *statusReporter=0)
void	setPassive (bool passive)
void	setPasswd (const char *passwd)
void	setTimeoutMillis (long timeoutMillis)
void	setUnverifiedPeerAllowed (bool val)
void	setUser (const char *user)
void	terminate ()
virtual	~RemoteTransport ()

Protected Attributes
SWBuf	host
SWBuf	p
bool	passive
StatusReporter *	statusReporter
bool	term
long	timeoutMillis
SWBuf	u
bool	unverifiedPeerAllowed

Detailed Description

A base class to be used for reimplementation of network services.

Definition at line 56 of file remotetrans.h.

Constructor & Destructor Documentation

RemoteTransport::RemoteTransport	(	const char *	host,
		StatusReporter *	statusReporter = 0
	)

Definition at line 62 of file remotetrans.cpp.

                                                                                 {
    this->statusReporter = statusReporter;
    this->host = host;
    u = "ftp";
    p = "installmgr@user.com";
    term = false;
    passive = true;
    unverifiedPeerAllowed = true;
}

RemoteTransport::~RemoteTransport ( )

virtual

Definition at line 73 of file remotetrans.cpp.

                                  {
}

Member Function Documentation

int RemoteTransport::copyDirectory	(	const char *	urlPrefix,
		const char *	dir,
		const char *	dest,
		const char *	suffix
	)

network copy recursively a remote directly

Returns

error status 0: OK; -1: operation error, -2: connection error; -3: user requested termination

Definition at line 140 of file remotetrans.cpp.

                                                                                                               {
SWLOGD("RemoteTransport::copyDirectory");
    int retVal = 0;

    SWBuf url = SWBuf(urlPrefix) + SWBuf(dir);
    removeTrailingSlash(url);
    url += '/';
    
SWLOGD("NetTransport: getting dir %s\n", url.c_str());
    vector<struct DirEntry> dirList = getDirList(url.c_str());

    if (!dirList.size()) {
        SWLog::getSystemLog()->logWarning("NetTransport: failed to read dir %s\n", url.c_str());
        return -1;
    }

    // append files in sub directories and calculate total download size
    unsigned int i = 0;
    long totalBytes = 0;
    for (;;) {
        if (i == dirList.size())
            break;

        struct DirEntry &e = dirList.at(i);

        if (e.isDirectory) {
            SWBuf name(e.name); // &e will be invalidated after first insertion
            vector<struct DirEntry> sd = getDirList((url + name + '/').c_str());
            for (unsigned int ii = 0; ii < sd.size(); ii++) {
                sd[ii].name = name + '/' + sd[ii].name;
                dirList.push_back(sd[ii]);
            }
            dirList.erase(dirList.begin() + i);
        }
        else {
            totalBytes += e.size;
            i++;
        }
    }

    long completedBytes = 0;
    for (i = 0; i < dirList.size(); i++) {
        struct DirEntry &dirEntry = dirList[i];
        SWBuf buffer = (SWBuf)dest;
        removeTrailingSlash(buffer);
        buffer += "/";
        buffer += dirEntry.name;
        if (!strcmp(&buffer.c_str()[buffer.length()-strlen(suffix)], suffix)) {
            SWBuf buffer2 = "Downloading (";
            buffer2.appendFormatted("%d", i+1);
            buffer2 += " of ";
            buffer2.appendFormatted("%d", dirList.size());
            buffer2 += "): ";
            buffer2 += dirEntry.name;
            if (statusReporter)
                statusReporter->preStatus(totalBytes, completedBytes, buffer2.c_str());
            FileMgr::createParent(buffer.c_str());  // make sure parent directory exists
            SWTRY {
                SWBuf url = (SWBuf)urlPrefix + (SWBuf)dir;
                removeTrailingSlash(url);
                url += "/";
                url += dirEntry.name;
                retVal = getURL(buffer.c_str(), url.c_str());
                if (retVal) {
                    SWLog::getSystemLog()->logWarning("copyDirectory: failed to get file %s\n", url.c_str());
                    return retVal;
                }
                completedBytes += dirEntry.size;
            }
            SWCATCH (...) {}
            if (term) {
                retVal = -3;
                break;
            }
        }
    }
    return retVal;
}

vector< struct DirEntry > RemoteTransport::getDirList ( const char *  dirURL )

virtual

Reimplemented in CURLHTTPTransport.

Definition at line 92 of file remotetrans.cpp.

                                                                      {

SWLOGD("RemoteTransport::getDirList(%s)", dirURL);
    vector<struct DirEntry> dirList;
    
    SWBuf dirBuf;
    if (!getURL("", dirURL, &dirBuf)) {
        char *start = dirBuf.getRawData();
        char *end = start;
        while (start < (dirBuf.getRawData()+dirBuf.size())) {
            struct ftpparse item;
            bool looking = true;
            for (end = start; *end; end++) {
                if (looking) {
                    if ((*end == 10) || (*end == 13)) {
                        *end = 0;
                        looking = false;
                    }
                }
                else if ((*end != 10) && (*end != 13))
                    break;
            }
SWLOGD("getDirList: parsing item %s(%d)\n", start, end-start);
            int status = ftpparse(&item, start, (int)(end - start));
            // in ftpparse.h, there is a warning that name is not necessarily null terminated
            SWBuf name;
            name.append(item.name, item.namelen);
SWLOGD("getDirList: got item %s\n", name.c_str());
            if (status && name != "." && name != "..") {
                struct DirEntry i;
                i.name = name;
                i.size = item.size;
                i.isDirectory = (item.flagtrycwd == 1);
                dirList.push_back(i);
            }
            start = end;
        }
    }
    else {
        SWLog::getSystemLog()->logWarning("getDirList: failed to get dir %s\n", dirURL);
    }
    return dirList;
}

long RemoteTransport::getTimeoutMillis ( )

inline

Definition at line 94 of file remotetrans.h.

{ return timeoutMillis; }

char RemoteTransport::getURL ( const char *  destPath, const char *  sourceURL, SWBuf *  destBuf = 0  )

virtual

Reimplemented in CURLHTTPTransport, FTPLibFTPTransport, CURLFTPTransport, and RTransportGDrive.

Definition at line 78 of file remotetrans.cpp.

                                                                                        {
    SWLog::getSystemLog()->logWarning("RemoteTransport::getURL called but unsupported");
    char retVal = -1;
    return retVal;
}

bool RemoteTransport::isPassive ( )

inline

Definition at line 95 of file remotetrans.h.

{ return passive; }

bool RemoteTransport::isUnverifiedPeerAllowed ( )

inline

Definition at line 99 of file remotetrans.h.

{ return unverifiedPeerAllowed; }

char RemoteTransport::putURL ( const char *  destURL, const char *  sourcePath, SWBuf *  sourceBuf = 0  )

virtual

Reimplemented in RTransportGDrive.

Definition at line 85 of file remotetrans.cpp.

                                                                                          {
    SWLog::getSystemLog()->logWarning("RemoteTransport::putURL called but unsupported");
    char retVal = -1;
    return retVal;
}

void RemoteTransport::setPassive ( bool  passive )

inline

Definition at line 92 of file remotetrans.h.

{ this->passive = passive; }

void RemoteTransport::setPasswd ( const char *  passwd )

inline

Definition at line 97 of file remotetrans.h.

{ p = passwd; }

void RemoteTransport::setTimeoutMillis ( long  timeoutMillis )

inline

Definition at line 93 of file remotetrans.h.

{ this->timeoutMillis = timeoutMillis; }

void RemoteTransport::setUnverifiedPeerAllowed ( bool  val )

inline

Definition at line 98 of file remotetrans.h.

{ this->unverifiedPeerAllowed = val; }

void RemoteTransport::setUser ( const char *  user )

inline

Definition at line 96 of file remotetrans.h.

{ u = user; }

void RemoteTransport::terminate ( )

inline

Definition at line 100 of file remotetrans.h.

{ term = true; }

Member Data Documentation

SWBuf RemoteTransport::host

protected

Definition at line 64 of file remotetrans.h.

SWBuf RemoteTransport::p

protected

Definition at line 66 of file remotetrans.h.

bool RemoteTransport::passive

protected

Definition at line 60 of file remotetrans.h.

StatusReporter* RemoteTransport::statusReporter

protected

Definition at line 59 of file remotetrans.h.

bool RemoteTransport::term

protected

Definition at line 62 of file remotetrans.h.

long RemoteTransport::timeoutMillis

protected

Definition at line 61 of file remotetrans.h.

SWBuf RemoteTransport::u

protected

Definition at line 65 of file remotetrans.h.

bool RemoteTransport::unverifiedPeerAllowed

protected

Definition at line 63 of file remotetrans.h.

---

The documentation for this class was generated from the following files:

• include/remotetrans.h
• src/mgr/remotetrans.cpp