// ************************************************************************** // * This file is part of the FreeFileSync project. It is distributed under * // * GNU General Public License: http://www.gnu.org/licenses/gpl.html * // * Copyright (C) 2008-2010 ZenJu (zhnmju123 AT gmx.de) * // ************************************************************************** // #include "synchronization.h" #include #include #include #include #include "shared/stringConv.h" #include "shared/util.h" #include "shared/systemConstants.h" #include "library/statusHandler.h" #include "shared/fileHandling.h" #include "shared/recycler.h" #include #include #include "shared/globalFunctions.h" #include #include #include "library/dbFile.h" #ifdef FFS_WIN #include "shared/longPathPrefix.h" #include #endif using namespace FreeFileSync; void SyncStatistics::init() { createLeft = 0; createRight = 0; overwriteLeft = 0; overwriteRight = 0; deleteLeft = 0; deleteRight = 0; conflict = 0; rowsTotal = 0; } SyncStatistics::SyncStatistics(const HierarchyObject& hierObj) { init(); getNumbersRecursively(hierObj); } SyncStatistics::SyncStatistics(const FolderComparison& folderCmp) { init(); std::for_each(folderCmp.begin(), folderCmp.end(), boost::bind(&SyncStatistics::getNumbersRecursively, this, _1)); } int SyncStatistics::getCreate(bool inclLeft, bool inclRight) const { return (inclLeft ? createLeft : 0) + (inclRight ? createRight : 0); } int SyncStatistics::getOverwrite(bool inclLeft, bool inclRight) const { return (inclLeft ? overwriteLeft : 0) + (inclRight ? overwriteRight : 0); } int SyncStatistics::getDelete(bool inclLeft, bool inclRight) const { return (inclLeft ? deleteLeft : 0) + (inclRight ? deleteRight : 0); } int SyncStatistics::getConflict() const { return conflict; } const SyncStatistics::ConflictTexts& SyncStatistics::getFirstConflicts() const //get first few sync conflicts { return firstConflicts; } wxULongLong SyncStatistics::getDataToProcess() const { return dataToProcess; } size_t SyncStatistics::getRowCount() const { return rowsTotal; } inline void SyncStatistics::getNumbersRecursively(const HierarchyObject& hierObj) { //process directories std::for_each(hierObj.useSubDirs().begin(), hierObj.useSubDirs().end(), boost::bind(&SyncStatistics::getDirNumbers, this, _1)); //process files std::for_each(hierObj.useSubFiles().begin(), hierObj.useSubFiles().end(), boost::bind(&SyncStatistics::getFileNumbers, this, _1)); rowsTotal += hierObj.useSubDirs().size(); rowsTotal += hierObj.useSubFiles().size(); } inline void SyncStatistics::getFileNumbers(const FileMapping& fileObj) { switch (fileObj.getSyncOperation()) //evaluate comparison result and sync direction { case SO_CREATE_NEW_LEFT: ++createLeft; dataToProcess += fileObj.getFileSize(); break; case SO_CREATE_NEW_RIGHT: ++createRight; dataToProcess += fileObj.getFileSize(); break; case SO_DELETE_LEFT: ++deleteLeft; break; case SO_DELETE_RIGHT: ++deleteRight; break; case SO_OVERWRITE_LEFT: ++overwriteLeft; dataToProcess += fileObj.getFileSize(); break; case SO_OVERWRITE_RIGHT: ++overwriteRight; dataToProcess += fileObj.getFileSize(); break; case SO_DO_NOTHING: case SO_EQUAL: break; case SO_UNRESOLVED_CONFLICT: ++conflict; if (firstConflicts.size() < 3) //save the first 3 conflict texts firstConflicts.push_back(std::make_pair(fileObj.getObjRelativeName(), fileObj.getSyncOpConflict())); break; } } inline void SyncStatistics::getDirNumbers(const DirMapping& dirObj) { switch (dirObj.getSyncOperation()) //evaluate comparison result and sync direction { case SO_CREATE_NEW_LEFT: ++createLeft; break; case SO_CREATE_NEW_RIGHT: ++createRight; break; case SO_DELETE_LEFT: ++deleteLeft; break; case SO_DELETE_RIGHT: ++deleteRight; break; case SO_OVERWRITE_LEFT: case SO_OVERWRITE_RIGHT: case SO_UNRESOLVED_CONFLICT: assert(false); break; case SO_DO_NOTHING: case SO_EQUAL: break; } //recurse into sub-dirs getNumbersRecursively(dirObj); } std::vector FreeFileSync::extractSyncCfg(const MainConfiguration& mainCfg) { //merge first and additional pairs std::vector allPairs; allPairs.push_back(mainCfg.firstPair); allPairs.insert(allPairs.end(), mainCfg.additionalPairs.begin(), //add additional pairs mainCfg.additionalPairs.end()); std::vector output; //process all pairs for (std::vector::const_iterator i = allPairs.begin(); i != allPairs.end(); ++i) output.push_back( i->altSyncConfig.get() ? FolderPairSyncCfg(i->altSyncConfig->syncConfiguration.automatic, i->altSyncConfig->handleDeletion, wxToZ(i->altSyncConfig->customDeletionDirectory)) : FolderPairSyncCfg(mainCfg.syncConfiguration.automatic, mainCfg.handleDeletion, wxToZ(mainCfg.customDeletionDirectory))); return output; } //------------------------------------------------------------------------------------------------------------ template class DiskSpaceNeeded { public: DiskSpaceNeeded(const BaseDirMapping& baseObj) { processRecursively(baseObj); } std::pair getSpaceTotal() const { return std::make_pair(spaceNeededLeft, spaceNeededRight); } private: void processRecursively(const HierarchyObject& hierObj) { //don't process directories //process files for (HierarchyObject::SubFileMapping::const_iterator i = hierObj.useSubFiles().begin(); i != hierObj.useSubFiles().end(); ++i) switch (i->getSyncOperation()) //evaluate comparison result and sync direction { case SO_CREATE_NEW_LEFT: spaceNeededLeft += globalFunctions::convertToSigned(i->getFileSize()); break; case SO_CREATE_NEW_RIGHT: spaceNeededRight += globalFunctions::convertToSigned(i->getFileSize()); break; case SO_DELETE_LEFT: if (!recyclerUsed) spaceNeededLeft -= globalFunctions::convertToSigned(i->getFileSize()); break; case SO_DELETE_RIGHT: if (!recyclerUsed) spaceNeededRight -= globalFunctions::convertToSigned(i->getFileSize()); break; case SO_OVERWRITE_LEFT: if (!recyclerUsed) spaceNeededLeft -= globalFunctions::convertToSigned(i->getFileSize()); spaceNeededLeft += globalFunctions::convertToSigned(i->getFileSize()); break; case SO_OVERWRITE_RIGHT: if (!recyclerUsed) spaceNeededRight -= globalFunctions::convertToSigned(i->getFileSize()); spaceNeededRight += globalFunctions::convertToSigned(i->getFileSize()); break; case SO_DO_NOTHING: case SO_EQUAL: case SO_UNRESOLVED_CONFLICT: break; } //recurse into sub-dirs std::for_each(hierObj.useSubDirs().begin(), hierObj.useSubDirs().end(), boost::bind(&DiskSpaceNeeded::processRecursively, this, _1)); } wxLongLong spaceNeededLeft; wxLongLong spaceNeededRight; }; std::pair freeDiskSpaceNeeded(const BaseDirMapping& baseDirObj, const DeletionPolicy handleDeletion) { switch (handleDeletion) { case FreeFileSync::DELETE_PERMANENTLY: return DiskSpaceNeeded(baseDirObj).getSpaceTotal(); case FreeFileSync::MOVE_TO_RECYCLE_BIN: return DiskSpaceNeeded(baseDirObj).getSpaceTotal(); case FreeFileSync::MOVE_TO_CUSTOM_DIRECTORY: //warning: this is not necessarily correct! it needs to be checked if user-def recycle bin dir and sync-dir are on same drive return DiskSpaceNeeded(baseDirObj).getSpaceTotal(); } assert(false); return std::make_pair(2000000000, 2000000000); //dummy } //------------------------------------------------------------------------------------------------------------ bool synchronizationNeeded(const SyncStatistics& statisticsTotal) { return statisticsTotal.getCreate() + statisticsTotal.getOverwrite() + statisticsTotal.getDelete() + //conflicts (unless excluded) justify a sync! Also note: if this method returns false, no warning about unresolved conflicts were shown! statisticsTotal.getConflict() != 0; } bool FreeFileSync::synchronizationNeeded(const FolderComparison& folderCmp) { const SyncStatistics statisticsTotal(folderCmp); return ::synchronizationNeeded(statisticsTotal); } //test if user accidentally tries to sync the wrong folders bool significantDifferenceDetected(const SyncStatistics& folderPairStat) { //initial file copying shall not be detected as major difference if ( folderPairStat.getCreate(true, false) == 0 && folderPairStat.getOverwrite() == 0 && folderPairStat.getDelete() == 0 && folderPairStat.getConflict() == 0) return false; if ( folderPairStat.getCreate(false, true) == 0 && folderPairStat.getOverwrite() == 0 && folderPairStat.getDelete() == 0 && folderPairStat.getConflict() == 0) return false; const int changedRows = folderPairStat.getCreate() + folderPairStat.getOverwrite() + folderPairStat.getDelete() + folderPairStat.getConflict(); return changedRows >= 10 && changedRows > 0.5 * folderPairStat.getRowCount(); } //################################################################################################################# FolderPairSyncCfg::FolderPairSyncCfg(bool automaticMode, const DeletionPolicy handleDel, const Zstring& custDelDir) : inAutomaticMode(automaticMode), handleDeletion(handleDel), custDelFolder(FreeFileSync::getFormattedDirectoryName(custDelDir)) {} //----------------------------------------------------------------------------------------------------------- template inline void tryReportingError(StatusHandler& handler, Function cmd) { while (true) { try { cmd(); break; } catch (FileError& error) { //User abort when copying files or moving files/directories into custom deletion directory: //windows build: abort if requested, don't show error message if cancelled by user! //linux build: this refresh is not necessary, because user abort triggers an AbortThisProcess() exception without a FileError() handler.requestUiRefresh(true); //may throw! ErrorHandler::Response rv = handler.reportError(error.show()); //may throw! if ( rv == ErrorHandler::IGNORE_ERROR) break; else if (rv == ErrorHandler::RETRY) ; //continue with loop else throw std::logic_error("Programming Error: Unknown return value!"); } } } /* add some postfix to alternate deletion directory: deletionDirectory\2010-06-30 12-59-12\ */ Zstring getSessionDeletionDir(const Zstring& deletionDirectory, const Zstring& prefix = Zstring()) { Zstring formattedDirectory = deletionDirectory; if (formattedDirectory.empty()) return Zstring(); //no valid directory for deletion specified (checked later) if (!formattedDirectory.EndsWith(globalFunctions::FILE_NAME_SEPARATOR)) formattedDirectory += globalFunctions::FILE_NAME_SEPARATOR; wxString timeNow = wxDateTime::Now().FormatISOTime(); timeNow.Replace(wxT(":"), wxT("-")); const wxString sessionName = wxDateTime::Now().FormatISODate() + wxChar(' ') + timeNow; formattedDirectory += prefix + wxToZ(sessionName); //ensure that session directory does not yet exist (must be unique) if (FreeFileSync::dirExists(formattedDirectory)) { //if it's not unique, add a postfix number int postfix = 1; while (FreeFileSync::dirExists(formattedDirectory + DefaultStr("_") + numberToZstring(postfix))) ++postfix; formattedDirectory += Zstring(DefaultStr("_")) + numberToZstring(postfix); } formattedDirectory += globalFunctions::FILE_NAME_SEPARATOR; return formattedDirectory; } SyncProcess::SyncProcess(bool copyFileSymLinks, bool traverseDirSymLinks, xmlAccess::OptionalDialogs& warnings, bool verifyCopiedFiles, bool copyLockedFiles, StatusHandler& handler) : m_copyFileSymLinks(copyFileSymLinks), m_traverseDirSymLinks(traverseDirSymLinks), m_verifyCopiedFiles(verifyCopiedFiles), copyLockedFiles_(copyLockedFiles), m_warnings(warnings), statusUpdater(handler) {} //-------------------------------------------------------------------------------------------------------------- class DeletionHandling { public: DeletionHandling(const DeletionPolicy handleDel, const Zstring& custDelFolder, const Zstring& baseDirLeft, const Zstring& baseDirRight, StatusHandler& statusUpdater); ~DeletionHandling(); //always (try to) clean up, even if synchronization is aborted! //clean-up temporary directory (recycler bin optimization) void tryCleanup() const; //throw FileError() -> call this in non-exceptional coding, i.e. after Sync somewhere! template void removeFile(const FileMapping& fileObj) const; //throw FileError() template void removeFolder(const DirMapping& dirObj) const; //throw FileError() const Zstring& getTxtRemovingFile() const; //status text templates const Zstring& getTxtRemovingDir() const; //status text templates private: template const Zstring& getSessionDir() const; void tryCleanupLeft() const; //throw FileError() void tryCleanupRight() const; //throw FileError() const DeletionPolicy deletionType; StatusHandler& statusUpdater_; Zstring sessionDelDirLeft; //target deletion folder for current folder pair (with timestamp, ends with path separator) Zstring sessionDelDirRight; // //preloaded status texts: Zstring txtRemovingFile; Zstring txtRemovingDirectory; }; DeletionHandling::DeletionHandling(const DeletionPolicy handleDel, const Zstring& custDelFolder, const Zstring& baseDirLeft, const Zstring& baseDirRight, StatusHandler& statusUpdater) : deletionType(handleDel), statusUpdater_(statusUpdater) { switch (handleDel) { case DELETE_PERMANENTLY: txtRemovingFile = wxToZ(_("Deleting file %x")).Replace(DefaultStr("%x"), DefaultStr("\n\"%x\""), false); txtRemovingDirectory = wxToZ(_("Deleting folder %x")).Replace( DefaultStr("%x"), DefaultStr("\n\"%x\""), false); break; case MOVE_TO_RECYCLE_BIN: sessionDelDirLeft = getSessionDeletionDir(baseDirLeft, DefaultStr("FFS ")); sessionDelDirRight = getSessionDeletionDir(baseDirRight, DefaultStr("FFS ")); txtRemovingFile = txtRemovingDirectory = wxToZ(_("Moving %x to Recycle Bin")).Replace(DefaultStr("%x"), DefaultStr("\"%x\""), false); break; case MOVE_TO_CUSTOM_DIRECTORY: sessionDelDirLeft = sessionDelDirRight = getSessionDeletionDir(custDelFolder); txtRemovingFile = wxToZ(_("Moving file %x to user-defined directory %y")). Replace(DefaultStr("%x"), DefaultStr("\"%x\"\n"), false).Replace(DefaultStr("%y"), Zstring(DefaultStr("\"")) + custDelFolder + DefaultStr("\""), false); txtRemovingDirectory = wxToZ(_("Moving folder %x to user-defined directory %y")).Replace(DefaultStr("%x"), DefaultStr("\"%x\"\n"), false).Replace(DefaultStr("%y"), Zstring(DefaultStr("\"")) + custDelFolder + DefaultStr("\""), false); break; } } DeletionHandling::~DeletionHandling() { try //always (try to) clean up, even if synchronization is aborted! { tryCleanupLeft(); } catch (...) {} try //always clean up BOTH sides separately! { tryCleanupRight(); } catch (...) {} } void DeletionHandling::tryCleanup() const //throw(AbortThisProcess) { tryReportingError(statusUpdater_, boost::bind(&DeletionHandling::tryCleanupLeft, this)); tryReportingError(statusUpdater_, boost::bind(&DeletionHandling::tryCleanupRight, this)); } void DeletionHandling::tryCleanupLeft() const //throw FileError() { if (deletionType == MOVE_TO_RECYCLE_BIN) //clean-up temporary directory (recycle bin) FreeFileSync::moveToRecycleBin(sessionDelDirLeft.BeforeLast(globalFunctions::FILE_NAME_SEPARATOR)); //throw (FileError) } void DeletionHandling::tryCleanupRight() const //throw FileError() { if (deletionType == MOVE_TO_RECYCLE_BIN) //clean-up temporary directory (recycle bin) FreeFileSync::moveToRecycleBin(sessionDelDirRight.BeforeLast(globalFunctions::FILE_NAME_SEPARATOR)); //throw (FileError) } inline const Zstring& DeletionHandling::getTxtRemovingFile() const { return txtRemovingFile; } inline const Zstring& DeletionHandling::getTxtRemovingDir() const { return txtRemovingDirectory; } template <> inline const Zstring& DeletionHandling::getSessionDir() const { return sessionDelDirLeft; } template <> inline const Zstring& DeletionHandling::getSessionDir() const { return sessionDelDirRight; } class MoveFileCallbackImpl : public MoveFileCallback //callback functionality { public: MoveFileCallbackImpl(StatusHandler& handler) : statusHandler_(handler) {} virtual Response requestUiRefresh() //DON'T throw exceptions here, at least in Windows build! { #ifdef FFS_WIN statusHandler_.requestUiRefresh(false); //don't allow throwing exception within this call: windows copying callback can't handle this if (statusHandler_.abortIsRequested()) return MoveFileCallback::CANCEL; #elif defined FFS_LINUX statusHandler_.requestUiRefresh(); //exceptions may be thrown here! #endif return MoveFileCallback::CONTINUE; } private: StatusHandler& statusHandler_; }; template void DeletionHandling::removeFile(const FileMapping& fileObj) const { switch (deletionType) { case FreeFileSync::DELETE_PERMANENTLY: FreeFileSync::removeFile(fileObj.getFullName()); break; case FreeFileSync::MOVE_TO_RECYCLE_BIN: if (FreeFileSync::fileExists(fileObj.getFullName())) { const Zstring targetFile = getSessionDir() + fileObj.getRelativeName(); //altDeletionDir ends with path separator const Zstring targetDir = targetFile.BeforeLast(globalFunctions::FILE_NAME_SEPARATOR); if (!FreeFileSync::dirExists(targetDir)) { if (!targetDir.empty()) //kind of pathological ? //lazy creation of alternate deletion directory (including super-directories of targetFile) FreeFileSync::createDirectory(targetDir, Zstring(), false); } try //rename file: no copying!!! { //performance optimization!! Instead of moving each object into recycle bin separately, we rename them ony by one into a //temporary directory and delete this directory only ONCE! FreeFileSync::renameFile(fileObj.getFullName(), targetFile); //throw (FileError); } catch (...) { //if anything went wrong, move to recycle bin the standard way (single file processing: slow) FreeFileSync::moveToRecycleBin(fileObj.getFullName()); //throw (FileError) } } break; case FreeFileSync::MOVE_TO_CUSTOM_DIRECTORY: if (FreeFileSync::fileExists(fileObj.getFullName())) { const Zstring targetFile = getSessionDir() + fileObj.getRelativeName(); //altDeletionDir ends with path separator const Zstring targetDir = targetFile.BeforeLast(globalFunctions::FILE_NAME_SEPARATOR); if (!FreeFileSync::dirExists(targetDir)) { if (!targetDir.empty()) //kind of pathological ? //lazy creation of alternate deletion directory (including super-directories of targetFile) FreeFileSync::createDirectory(targetDir, Zstring(), false); /*symbolic link handling: if "not traversing symlinks": fullName == c:\syncdir\some\dirs\leaf => setting irrelevant if "traversing symlinks": fullName == c:\syncdir\some\dirs\leaf => setting NEEDS to be false: We want to move leaf, therefore symlinks in "some\dirs" must not interfere */ } MoveFileCallbackImpl callBack(statusUpdater_); //if file needs to be copied we need callback functionality to update screen and offer abort FreeFileSync::moveFile(fileObj.getFullName(), targetFile, &callBack); } break; } } template void DeletionHandling::removeFolder(const DirMapping& dirObj) const { switch (deletionType) { case FreeFileSync::DELETE_PERMANENTLY: FreeFileSync::removeDirectory(dirObj.getFullName()); break; case FreeFileSync::MOVE_TO_RECYCLE_BIN: if (FreeFileSync::dirExists(dirObj.getFullName())) { const Zstring targetDir = getSessionDir() + dirObj.getRelativeName(); const Zstring targetSuperDir = targetDir.BeforeLast(globalFunctions::FILE_NAME_SEPARATOR); if (!FreeFileSync::dirExists(targetSuperDir)) { if (!targetSuperDir.empty()) //kind of pathological ? //lazy creation of alternate deletion directory (including super-directories of targetFile) FreeFileSync::createDirectory(targetSuperDir, Zstring(), false); } try //rename directory: no copying!!! { //performance optimization!! Instead of moving each object into recycle bin separately, we rename them ony by one into a //temporary directory and delete this directory only ONCE! FreeFileSync::renameFile(dirObj.getFullName(), targetDir); //throw (FileError); } catch (...) { //if anything went wrong, move to recycle bin the standard way (single file processing: slow) FreeFileSync::moveToRecycleBin(dirObj.getFullName()); //throw (FileError) } } break; case FreeFileSync::MOVE_TO_CUSTOM_DIRECTORY: if (FreeFileSync::dirExists(dirObj.getFullName())) { const Zstring targetDir = getSessionDir() + dirObj.getRelativeName(); const Zstring targetSuperDir = targetDir.BeforeLast(globalFunctions::FILE_NAME_SEPARATOR); if (!FreeFileSync::dirExists(targetSuperDir)) { if (!targetSuperDir.empty()) //kind of pathological ? //lazy creation of alternate deletion directory (including super-directories of targetFile) FreeFileSync::createDirectory(targetSuperDir, Zstring(), false); /*symbolic link handling: if "not traversing symlinks": fullName == c:\syncdir\some\dirs\leaf => setting irrelevant if "traversing symlinks": fullName == c:\syncdir\some\dirs\leaf => setting NEEDS to be false: We want to move leaf, therefore symlinks in "some\dirs" must not interfere */ } MoveFileCallbackImpl callBack(statusUpdater_); //if files need to be copied, we need callback functionality to update screen and offer abort FreeFileSync::moveDirectory(dirObj.getFullName(), targetDir, true, &callBack); } break; } } //---------------------------------------------------------------------------------------- //test if current sync-line will result in deletion of files or //big file is overwritten by smaller one -> used to avoid disc space bottlenecks (at least if permanent deletion is active) inline bool diskSpaceIsReduced(const FileMapping& fileObj) { switch (fileObj.getSyncOperation()) //evaluate comparison result and sync direction { case SO_DELETE_LEFT: case SO_DELETE_RIGHT: return true; case SO_OVERWRITE_LEFT: return fileObj.getFileSize() > fileObj.getFileSize(); case SO_OVERWRITE_RIGHT: return fileObj.getFileSize() < fileObj.getFileSize(); case SO_CREATE_NEW_LEFT: case SO_CREATE_NEW_RIGHT: case SO_DO_NOTHING: case SO_EQUAL: case SO_UNRESOLVED_CONFLICT: return false; } return false; //dummy } inline bool diskSpaceIsReduced(const DirMapping& dirObj) { switch (dirObj.getSyncOperation()) //evaluate comparison result and sync direction { case SO_DELETE_LEFT: case SO_DELETE_RIGHT: return true; case SO_OVERWRITE_LEFT: case SO_OVERWRITE_RIGHT: case SO_UNRESOLVED_CONFLICT: assert(false); case SO_CREATE_NEW_LEFT: case SO_CREATE_NEW_RIGHT: case SO_DO_NOTHING: case SO_EQUAL: return false; } return false; //dummy } //---------------------------------------------------------------------------------------- class RemoveInvalid { public: RemoveInvalid(BaseDirMapping& baseDir) : baseDir_(baseDir) {} ~RemoveInvalid() { FileSystemObject::removeEmpty(baseDir_); } private: BaseDirMapping& baseDir_; }; class FreeFileSync::SynchronizeFolderPair { public: SynchronizeFolderPair(const SyncProcess& syncProc, #ifdef FFS_WIN ShadowCopy* shadowCopyHandler, #endif const DeletionHandling& delHandling) : statusUpdater_(syncProc.statusUpdater), #ifdef FFS_WIN shadowCopyHandler_(shadowCopyHandler), #endif delHandling_(delHandling), copyFileSymLinks_(syncProc.m_copyFileSymLinks), traverseDirSymLinks_(syncProc.m_traverseDirSymLinks), verifyCopiedFiles_(syncProc.m_verifyCopiedFiles), txtCopyingFile(wxToZ(_("Copying file %x to %y")).Replace(DefaultStr("%x"), DefaultStr("\"%x\""), false).Replace(DefaultStr("%y"), DefaultStr("\n\"%y\""), false)), txtOverwritingFile(wxToZ(_("Copying file %x to %y overwriting target")).Replace(DefaultStr("%x"), DefaultStr("\"%x\""), false).Replace(DefaultStr("%y"), DefaultStr("\n\"%y\""), false)), txtCreatingFolder(wxToZ(_("Creating folder %x")).Replace(DefaultStr("%x"), DefaultStr("\n\"%x\""), false)), txtVerifying(wxToZ(_("Verifying file %x")).Replace(DefaultStr("%x"), DefaultStr("\n\"%x\""), false)) {} template //"true" if files deletion shall happen only void startSync(BaseDirMapping& baseMap) { execute(baseMap); } private: template //"true" if files deletion shall happen only void execute(HierarchyObject& hierObj); void synchronizeFile(FileMapping& fileObj) const; void synchronizeFolder(DirMapping& dirObj) const; void copyFileUpdating(const Zstring& source, const Zstring& target, const wxULongLong& sourceFileSize) const; void verifyFileCopy(const Zstring& source, const Zstring& target) const; StatusHandler& statusUpdater_; #ifdef FFS_WIN ShadowCopy* shadowCopyHandler_; //optional! #endif const DeletionHandling& delHandling_; const bool copyFileSymLinks_; const bool traverseDirSymLinks_; const bool verifyCopiedFiles_; //preload status texts const Zstring txtCopyingFile; const Zstring txtOverwritingFile; const Zstring txtCreatingFolder; const Zstring txtVerifying; }; template //"true" if files deletion shall happen only void SynchronizeFolderPair::execute(HierarchyObject& hierObj) { //synchronize files: for (HierarchyObject::SubFileMapping::iterator i = hierObj.useSubFiles().begin(); i != hierObj.useSubFiles().end(); ++i) { if ( ( reduceDiskSpace && diskSpaceIsReduced(*i)) || (!reduceDiskSpace && !diskSpaceIsReduced(*i))) tryReportingError(statusUpdater_, boost::bind(&SynchronizeFolderPair::synchronizeFile, this, boost::ref(*i))); } //synchronize folders: for (HierarchyObject::SubDirMapping::iterator i = hierObj.useSubDirs().begin(); i != hierObj.useSubDirs().end(); ++i) { const SyncOperation syncOp = i->getSyncOperation(); if ( ( reduceDiskSpace && diskSpaceIsReduced(*i)) || //ensure folder creation happens in second pass, to enable time adaption below (!reduceDiskSpace && !diskSpaceIsReduced(*i))) // tryReportingError(statusUpdater_, boost::bind(&SynchronizeFolderPair::synchronizeFolder, this, boost::ref(*i))); //recursive synchronization: execute(*i); //adapt folder modification dates: apply AFTER all subobjects have been synced to preserve folder modification date! switch (syncOp) { case SO_CREATE_NEW_LEFT: copyFileTimes(i->getFullName(), i->getFullName()); //throw() break; case SO_CREATE_NEW_RIGHT: copyFileTimes(i->getFullName(), i->getFullName()); //throw() break; case SO_OVERWRITE_RIGHT: case SO_OVERWRITE_LEFT: case SO_UNRESOLVED_CONFLICT: assert(false); case SO_DELETE_LEFT: case SO_DELETE_RIGHT: case SO_DO_NOTHING: case SO_EQUAL: break; } } } void SynchronizeFolderPair::synchronizeFile(FileMapping& fileObj) const { Zstring statusText; Zstring target; switch (fileObj.getSyncOperation()) //evaluate comparison result and sync direction { case SO_CREATE_NEW_LEFT: target = fileObj.getBaseDirPf() + fileObj.getRelativeName(); statusText = txtCopyingFile; statusText.Replace(DefaultStr("%x"), fileObj.getShortName(), false); statusText.Replace(DefaultStr("%y"), target.BeforeLast(globalFunctions::FILE_NAME_SEPARATOR), false); statusUpdater_.updateStatusText(statusText); statusUpdater_.requestUiRefresh(); //trigger display refresh copyFileUpdating(fileObj.getFullName(), target, fileObj.getFileSize()); break; case SO_CREATE_NEW_RIGHT: target = fileObj.getBaseDirPf() + fileObj.getRelativeName(); statusText = txtCopyingFile; statusText.Replace(DefaultStr("%x"), fileObj.getShortName(), false); statusText.Replace(DefaultStr("%y"), target.BeforeLast(globalFunctions::FILE_NAME_SEPARATOR), false); statusUpdater_.updateStatusText(statusText); statusUpdater_.requestUiRefresh(); //trigger display refresh copyFileUpdating(fileObj.getFullName(), target, fileObj.getFileSize()); break; case SO_DELETE_LEFT: statusText = delHandling_.getTxtRemovingFile(); statusText.Replace(DefaultStr("%x"), fileObj.getFullName(), false); statusUpdater_.updateStatusText(statusText); statusUpdater_.requestUiRefresh(); //trigger display refresh delHandling_.removeFile(fileObj); //throw FileError() break; case SO_DELETE_RIGHT: statusText = delHandling_.getTxtRemovingFile(); statusText.Replace(DefaultStr("%x"), fileObj.getFullName(), false); statusUpdater_.updateStatusText(statusText); statusUpdater_.requestUiRefresh(); //trigger display refresh delHandling_.removeFile(fileObj); //throw FileError() break; case SO_OVERWRITE_RIGHT: target = fileObj.getBaseDirPf() + fileObj.getRelativeName(); statusText = txtOverwritingFile; statusText.Replace(DefaultStr("%x"), fileObj.getShortName(), false); statusText.Replace(DefaultStr("%y"), fileObj.getFullName().BeforeLast(globalFunctions::FILE_NAME_SEPARATOR), false); statusUpdater_.updateStatusText(statusText); statusUpdater_.requestUiRefresh(); //trigger display refresh delHandling_.removeFile(fileObj); //throw FileError() fileObj.removeObject(); //remove file from FileMapping, to keep in sync (if subsequent copying fails!!) copyFileUpdating(fileObj.getFullName(), target, fileObj.getFileSize()); break; case SO_OVERWRITE_LEFT: target = fileObj.getBaseDirPf() + fileObj.getRelativeName(); statusText = txtOverwritingFile; statusText.Replace(DefaultStr("%x"), fileObj.getShortName(), false); statusText.Replace(DefaultStr("%y"), fileObj.getFullName().BeforeLast(globalFunctions::FILE_NAME_SEPARATOR), false); statusUpdater_.updateStatusText(statusText); statusUpdater_.requestUiRefresh(); //trigger display refresh delHandling_.removeFile(fileObj); //throw FileError() fileObj.removeObject(); //remove file from FileMapping, to keep in sync (if subsequent copying fails!!) copyFileUpdating(fileObj.getFullName(), target, fileObj.getFileSize()); break; case SO_DO_NOTHING: case SO_EQUAL: case SO_UNRESOLVED_CONFLICT: return; //no update on processed data! } //update FileMapping fileObj.synchronizeSides(); //progress indicator update //indicator is updated only if file is sync'ed correctly (and if some sync was done)! statusUpdater_.updateProcessedData(1, 0); //processed data is communicated in subfunctions! } //class DetectRenamedFiles //{ //public: // static void execute(BaseDirMapping& baseMap, StatusHandler& statusUpdater) // { // DetectRenamedFiles(baseMap, statusUpdater); // } // //private: // DetectRenamedFiles(BaseDirMapping& baseMap, StatusHandler& statusUpdater); // // template // void renameFile(FileMapping& fileObjCreate, FileMapping& fileObjDelete) const; // // const Zstring txtRenamingFile; // StatusHandler& statusUpdater_; //}; //DetectRenamedFiles::DetectRenamedFiles(BaseDirMapping& baseMap, StatusHandler& statusUpdater) : // txtRenamingFile(wxToZ(_("Renaming file %x to %y")).Replace(DefaultStr("%x"), DefaultStr("\"%x\""), false).Replace(DefaultStr("%y"), DefaultStr("\n\"%y\""), false)), // statusUpdater_(statusUpdater) //{ // typedef std::vector > RenameList; // RenameList renameOnLeft; // RenameList renameOnRight; // FreeFileSync::getRenameCandidates(baseMap, renameOnLeft, renameOnRight); //throw()! // // for (RenameList::const_iterator i = renameOnLeft.begin(); i != renameOnLeft.end(); ++i) // tryReportingError(statusUpdater_, boost::bind(&DetectRenamedFiles::renameFile, this, boost::ref(*i->first), boost::ref(*i->second))); // // for (RenameList::const_iterator i = renameOnRight.begin(); i != renameOnRight.end(); ++i) // tryReportingError(statusUpdater_, boost::bind(&DetectRenamedFiles::renameFile, this, boost::ref(*i->first), boost::ref(*i->second))); //} //template //void DetectRenamedFiles::renameFile(FileMapping& fileObjCreate, FileMapping& fileObjDelete) const //{ // const SelectedSide sourceSide = renameOnSide == LEFT_SIDE ? RIGHT_SIDE : LEFT_SIDE; // // Zstring statusText = txtRenamingFile; // statusText.Replace(DefaultStr("%x"), fileObjDelete.getFullName(), false); // statusText.Replace(DefaultStr("%y"), fileObjCreate.getRelativeName(), false); // statusUpdater_.updateStatusText(statusText); // statusUpdater_.requestUiRefresh(); //trigger display refresh // // FreeFileSync::renameFile(fileObjDelete.getFullName(), // fileObjDelete.getBaseDirPf() + fileObjCreate.getRelativeName()); //throw (FileError); // // //update FileMapping // fileObjCreate.synchronizeSides(); // fileObjDelete.synchronizeSides(); // //#ifndef _MSC_VER //#warning set FileID! //#warning Test: zweimaliger rename sollte dann klappen // //#warning allgemein: FileID nach jedem kopieren neu bestimmen? //#endif // //progress indicator update // //indicator is updated only if file is sync'ed correctly (and if some sync was done)! // statusUpdater_.updateProcessedData(2, globalFunctions::convertToSigned(fileObjCreate.getFileSize())); //} void SynchronizeFolderPair::synchronizeFolder(DirMapping& dirObj) const { Zstring statusText; Zstring target; //synchronize folders: switch (dirObj.getSyncOperation()) //evaluate comparison result and sync direction { case SO_CREATE_NEW_LEFT: target = dirObj.getBaseDirPf() + dirObj.getRelativeName(); statusText = txtCreatingFolder; statusText.Replace(DefaultStr("%x"), target, false); statusUpdater_.updateStatusText(statusText); statusUpdater_.requestUiRefresh(); //trigger display refresh //some check to catch the error that directory on source has been deleted externally after "compare"... if (!FreeFileSync::dirExists(dirObj.getFullName())) throw FileError(wxString(_("Source directory does not exist anymore:")) + wxT("\n\"") + zToWx(dirObj.getFullName()) + wxT("\"")); createDirectory(target, dirObj.getFullName(), !traverseDirSymLinks_); //traverse symlinks <=> !copy symlinks break; case SO_CREATE_NEW_RIGHT: target = dirObj.getBaseDirPf() + dirObj.getRelativeName(); statusText = txtCreatingFolder; statusText.Replace(DefaultStr("%x"), target, false); statusUpdater_.updateStatusText(statusText); statusUpdater_.requestUiRefresh(); //trigger display refresh //some check to catch the error that directory on source has been deleted externally after "compare"... if (!FreeFileSync::dirExists(dirObj.getFullName())) throw FileError(wxString(_("Source directory does not exist anymore:")) + wxT("\n\"") + zToWx(dirObj.getFullName()) + wxT("\"")); createDirectory(target, dirObj.getFullName(), !traverseDirSymLinks_); //traverse symlinks <=> !copy symlinks break; case SO_DELETE_LEFT: //status information statusText = delHandling_.getTxtRemovingDir(); statusText.Replace(DefaultStr("%x"), dirObj.getFullName(), false); statusUpdater_.updateStatusText(statusText); statusUpdater_.requestUiRefresh(); //trigger display refresh delHandling_.removeFolder(dirObj); //throw FileError() { //progress indicator update: DON'T forget to notify about implicitly deleted objects! const SyncStatistics subObjects(dirObj); //...then remove everything dirObj.useSubFiles().clear(); dirObj.useSubDirs().clear(); statusUpdater_.updateProcessedData(subObjects.getCreate() + subObjects.getOverwrite() + subObjects.getDelete(), subObjects.getDataToProcess().ToDouble()); } break; case SO_DELETE_RIGHT: //status information statusText = delHandling_.getTxtRemovingDir(); statusText.Replace(DefaultStr("%x"), dirObj.getFullName(), false); statusUpdater_.updateStatusText(statusText); statusUpdater_.requestUiRefresh(); //trigger display refresh delHandling_.removeFolder(dirObj); //throw FileError() { //progress indicator update: DON'T forget to notify about implicitly deleted objects! const SyncStatistics subObjects(dirObj); //...then remove everything dirObj.useSubFiles().clear(); dirObj.useSubDirs().clear(); statusUpdater_.updateProcessedData(subObjects.getCreate() + subObjects.getOverwrite() + subObjects.getDelete(), subObjects.getDataToProcess().ToDouble()); } break; case SO_OVERWRITE_RIGHT: case SO_OVERWRITE_LEFT: case SO_UNRESOLVED_CONFLICT: assert(false); case SO_DO_NOTHING: case SO_EQUAL: return; //no update on processed data! } //update DirMapping dirObj.synchronizeSides(); //progress indicator update //indicator is updated only if directory is sync'ed correctly (and if some work was done)! statusUpdater_.updateProcessedData(1, 0); //each call represents one processed file } //avoid data loss when source directory doesn't (temporarily?) exist anymore AND user chose to ignore errors (else we wouldn't arrive here) bool dataLossPossible(const Zstring& dirName, const SyncStatistics& folderPairStat) { return folderPairStat.getCreate() + folderPairStat.getOverwrite() + folderPairStat.getConflict() == 0 && folderPairStat.getDelete() > 0 && //deletions only... (respect filtered items!) !dirName.empty() && !FreeFileSync::dirExists(dirName); } namespace { void makeSameLength(wxString& first, wxString& second) { const size_t maxPref = std::max(first.length(), second.length()); first.Pad(maxPref - first.length(), wxT(' '), true); second.Pad(maxPref - second.length(), wxT(' '), true); } } void SyncProcess::startSynchronizationProcess(const std::vector& syncConfig, FolderComparison& folderCmp) { #ifndef __WXDEBUG__ wxLogNull noWxLogs; //prevent wxWidgets logging #endif //PERF_START; //inform about the total amount of data that will be processed from now on const SyncStatistics statisticsTotal(folderCmp); //keep at beginning so that all gui elements are initialized properly statusUpdater.initNewProcess(statisticsTotal.getCreate() + statisticsTotal.getOverwrite() + statisticsTotal.getDelete(), globalFunctions::convertToSigned(statisticsTotal.getDataToProcess()), StatusHandler::PROCESS_SYNCHRONIZING); //-------------------some basic checks:------------------------------------------ if (syncConfig.size() != folderCmp.size()) throw std::logic_error("Programming Error: Contract violation!"); for (FolderComparison::const_iterator j = folderCmp.begin(); j != folderCmp.end(); ++j) { const SyncStatistics statisticsFolderPair(*j); const FolderPairSyncCfg& folderPairCfg = syncConfig[j - folderCmp.begin()]; if (statisticsFolderPair.getOverwrite() + statisticsFolderPair.getDelete() > 0) { //test existence of Recycle Bin if (folderPairCfg.handleDeletion == FreeFileSync::MOVE_TO_RECYCLE_BIN && !FreeFileSync::recycleBinExists()) { statusUpdater.reportFatalError(_("Recycle Bin not yet supported for this system!")); return; //should be obsolete! } if (folderPairCfg.handleDeletion == FreeFileSync::MOVE_TO_CUSTOM_DIRECTORY) { //check if user-defined directory for deletion was specified if (folderPairCfg.custDelFolder.empty()) { statusUpdater.reportFatalError(_("User-defined directory for deletion was not specified!")); return; //should be obsolete! } } } //avoid data loss when source directory doesn't (temporarily?) exist anymore AND user chose to ignore errors(else we wouldn't arrive here) if (dataLossPossible(j->getBaseDir(), statisticsFolderPair)) { statusUpdater.reportFatalError(wxString(_("Source directory does not exist anymore:")) + wxT("\n\"") + zToWx(j->getBaseDir()) + wxT("\"")); return; //should be obsolete! } if (dataLossPossible(j->getBaseDir(), statisticsFolderPair)) { statusUpdater.reportFatalError(wxString(_("Source directory does not exist anymore:")) + wxT("\n\"") + zToWx(j->getBaseDir()) + wxT("\"") ); return; //should be obsolete! } //check if more than 50% of total number of files/dirs are to be created/overwritten/deleted if (significantDifferenceDetected(statisticsFolderPair)) { statusUpdater.reportWarning(wxString(_("Significant difference detected:")) + wxT("\n") + zToWx(j->getBaseDir()) + wxT(" <-> ") + wxT("\n") + zToWx(j->getBaseDir()) + wxT("\n\n") + _("More than 50% of the total number of files will be copied or deleted!"), m_warnings.warningSignificantDifference); } //check for sufficient free diskspace in left directory const std::pair spaceNeeded = freeDiskSpaceNeeded(*j, folderPairCfg.handleDeletion); wxLongLong freeDiskSpaceLeft; if (wxGetDiskSpace(zToWx(j->getBaseDir()), NULL, &freeDiskSpaceLeft)) { if (0 < freeDiskSpaceLeft && //zero disk space is either an error or not: in both cases this warning message is obsolete (WebDav seems to report 0) freeDiskSpaceLeft < spaceNeeded.first) statusUpdater.reportWarning(wxString(_("Not enough free disk space available in:")) + wxT("\n") + wxT("\"") + zToWx(j->getBaseDir()) + wxT("\"\n\n") + _("Total required free disk space:") + wxT(" ") + formatFilesizeToShortString(spaceNeeded.first) + wxT("\n") + _("Free disk space available:") + wxT(" ") + formatFilesizeToShortString(freeDiskSpaceLeft), m_warnings.warningNotEnoughDiskSpace); } //check for sufficient free diskspace in right directory wxLongLong freeDiskSpaceRight; if (wxGetDiskSpace(zToWx(j->getBaseDir()), NULL, &freeDiskSpaceRight)) { if (0 < freeDiskSpaceRight && //zero disk space is either an error or not: in both cases this warning message is obsolete (WebDav seems to report 0) freeDiskSpaceRight < spaceNeeded.second) statusUpdater.reportWarning(wxString(_("Not enough free disk space available in:")) + wxT("\n") + wxT("\"") + zToWx(j->getBaseDir()) + wxT("\"\n\n") + _("Total required free disk space:") + wxT(" ") + formatFilesizeToShortString(spaceNeeded.second) + wxT("\n") + _("Free disk space available:") + wxT(" ") + formatFilesizeToShortString(freeDiskSpaceRight), m_warnings.warningNotEnoughDiskSpace); } } //check if unresolved conflicts exist if (statisticsTotal.getConflict() > 0) { //show the first few conflicts in warning message also: wxString warningMessage = wxString(_("Unresolved conflicts existing!")) + wxT(" (") + numberToWxString(statisticsTotal.getConflict(), true) + wxT(")\n\n"); const SyncStatistics::ConflictTexts& firstConflicts = statisticsTotal.getFirstConflicts(); //get first few sync conflicts for (SyncStatistics::ConflictTexts::const_iterator i = firstConflicts.begin(); i != firstConflicts.end(); ++i) { wxString conflictDescription = i->second; conflictDescription.Replace(wxT("\n"), wxT(" ")); //remove line-breaks warningMessage += wxString(wxT("\"")) + zToWx(i->first) + wxT("\": ") + conflictDescription + wxT("\n"); } if (statisticsTotal.getConflict() > static_cast(firstConflicts.size())) warningMessage += wxT("[...]\n"); else warningMessage += wxT("\n"); warningMessage += _("You can ignore conflicts and continue synchronization."); statusUpdater.reportWarning(warningMessage, m_warnings.warningUnresolvedConflicts); } //-------------------end of basic checks------------------------------------------ #ifdef FFS_WIN //shadow copy buffer: per sync-instance, not folder pair boost::scoped_ptr shadowCopyHandler(copyLockedFiles_ ? new ShadowCopy : NULL); #endif try { //loop through all directory pairs assert(syncConfig.size() == folderCmp.size()); for (FolderComparison::iterator j = folderCmp.begin(); j != folderCmp.end(); ++j) { const FolderPairSyncCfg& folderPairCfg = syncConfig[j - folderCmp.begin()]; //exclude some pathological case (leftdir, rightdir are empty) if (j->getBaseDir() == j->getBaseDir()) continue; //------------------------------------------------------------------------------------------ //info about folder pair to be processed (useful for logfile) wxString left = wxString(_("Left")) + wxT(": "); wxString right = wxString(_("Right")) + wxT(": "); makeSameLength(left, right); const wxString statusTxt = wxString(_("Processing folder pair:")) + wxT(" \n") + wxT("\t") + left + wxT("\"") + zToWx(j->getBaseDir()) + wxT("\"")+ wxT(" \n") + wxT("\t") + right + wxT("\"") + zToWx(j->getBaseDir()) + wxT("\""); statusUpdater.updateStatusText(wxToZ(statusTxt)); //------------------------------------------------------------------------------------------ //generate name of alternate deletion directory (unique for session AND folder pair) const DeletionHandling currentDelHandling(folderPairCfg.handleDeletion, folderPairCfg.custDelFolder, j->getBaseDir(), j->getBaseDir(), statusUpdater); //------------------------------------------------------------------------------------------ //execute synchronization recursively //enforce removal of invalid entries (where both sides are empty) RemoveInvalid dummy(*j); //detect renamed files: currently in automatic mode only // if (folderPairCfg.inAutomaticMode) // DetectRenamedFiles::execute(*j, statusUpdater); SynchronizeFolderPair syncFP( *this, #ifdef FFS_WIN shadowCopyHandler.get(), #endif currentDelHandling); //loop through all files twice; reason: first delete files (or overwrite big ones with smaller ones), then copy rest syncFP.startSync(*j); syncFP.startSync(*j); //(try to gracefully) cleanup temporary folders (Recycle bin optimization) -> will be done in DeletionHandling anyway... currentDelHandling.tryCleanup(); //------------------------------------------------------------------------------------------ //update synchronization database (automatic sync only) if (folderPairCfg.inAutomaticMode) { statusUpdater.updateStatusText(wxToZ(_("Generating database..."))); statusUpdater.forceUiRefresh(); tryReportingError(statusUpdater, boost::bind(FreeFileSync::saveToDisk, boost::cref(*j))); //these call may throw in error-callback! } } } catch (const std::exception& e) { statusUpdater.reportFatalError(wxString::FromAscii(e.what())); return; //should be obsolete! } } //########################################################################################### //callback functionality for smooth progress indicators class WhileCopying : public FreeFileSync::CopyFileCallback //callback functionality { public: WhileCopying(wxLongLong& bytesTransferredLast, StatusHandler& statusHandler) : m_bytesTransferredLast(bytesTransferredLast), m_statusHandler(statusHandler) {} virtual Response updateCopyStatus(const wxULongLong& totalBytesTransferred) { //convert to signed const wxLongLong totalBytes = globalFunctions::convertToSigned(totalBytesTransferred); //inform about the (differential) processed amount of data m_statusHandler.updateProcessedData(0, totalBytes - m_bytesTransferredLast); m_bytesTransferredLast = totalBytes; #ifdef FFS_WIN m_statusHandler.requestUiRefresh(false); //don't allow throwing exception within this call: windows copying callback can't handle this if (m_statusHandler.abortIsRequested()) return CopyFileCallback::CANCEL; #elif defined FFS_LINUX m_statusHandler.requestUiRefresh(); //exceptions may be thrown here! #endif return CopyFileCallback::CONTINUE; } private: wxLongLong& m_bytesTransferredLast; StatusHandler& m_statusHandler; }; //copy file while executing statusUpdater->requestUiRefresh() calls void SynchronizeFolderPair::copyFileUpdating(const Zstring& source, const Zstring& target, const wxULongLong& totalBytesToCpy) const { //create folders first (see http://sourceforge.net/tracker/index.php?func=detail&aid=2628943&group_id=234430&atid=1093080) const Zstring targetDir = target.BeforeLast(globalFunctions::FILE_NAME_SEPARATOR); if (!FreeFileSync::dirExists(targetDir)) { if (!targetDir.empty()) //kind of pathological, but empty target might happen { const Zstring templateDir = source.BeforeLast(globalFunctions::FILE_NAME_SEPARATOR); FreeFileSync::createDirectory(targetDir, templateDir, false); //symbolic link setting: If traversing into links => don't create //if not traversing into links => copy dir symlink of leaf-dir, not relevant here => actually: setting doesn't matter } } //start of (possibly) long-running copy process: ensure status updates are performed regularly wxLongLong totalBytesTransferred; WhileCopying callback(totalBytesTransferred, statusUpdater_); try { #ifdef FFS_WIN FreeFileSync::copyFile(source, target, copyFileSymLinks_, shadowCopyHandler_, &callback); #elif defined FFS_LINUX FreeFileSync::copyFile(source, target, copyFileSymLinks_, &callback); #endif if (verifyCopiedFiles_) //verify if data was copied correctly verifyFileCopy(source, target); } catch (...) { //error situation: undo communication of processed amount of data statusUpdater_.updateProcessedData(0, totalBytesTransferred * -1 ); throw; } //inform about the (remaining) processed amount of data statusUpdater_.updateProcessedData(0, globalFunctions::convertToSigned(totalBytesToCpy) - totalBytesTransferred); } //--------------------- data verification ------------------------- //callback functionality for status updates while verifying class VerifyCallback { public: virtual ~VerifyCallback() {} virtual void updateStatus() = 0; }; void verifyFiles(const Zstring& source, const Zstring& target, VerifyCallback* callback) // throw (FileError) { const unsigned int BUFFER_SIZE = 512 * 1024; //512 kb seems to be the perfect buffer size static boost::scoped_array memory1(new unsigned char[BUFFER_SIZE]); static boost::scoped_array memory2(new unsigned char[BUFFER_SIZE]); #ifdef FFS_WIN wxFile file1(FreeFileSync::applyLongPathPrefix(source).c_str(), wxFile::read); //don't use buffered file input for verification! #elif defined FFS_LINUX wxFile file1(::open(source.c_str(), O_RDONLY)); //utilize UTF-8 filename #endif if (!file1.IsOpened()) throw FileError(wxString(_("Error opening file:")) + wxT(" \"") + zToWx(source) + wxT("\"")); #ifdef FFS_WIN wxFile file2(FreeFileSync::applyLongPathPrefix(target).c_str(), wxFile::read); //don't use buffered file input for verification! #elif defined FFS_LINUX wxFile file2(::open(target.c_str(), O_RDONLY)); //utilize UTF-8 filename #endif if (!file2.IsOpened()) //NO cleanup necessary for (wxFile) file1 throw FileError(wxString(_("Error opening file:")) + wxT(" \"") + zToWx(target) + wxT("\"")); do { const size_t length1 = file1.Read(memory1.get(), BUFFER_SIZE); if (file1.Error()) throw FileError(wxString(_("Error reading file:")) + wxT(" \"") + zToWx(source) + wxT("\"")); const size_t length2 = file2.Read(memory2.get(), BUFFER_SIZE); if (file2.Error()) throw FileError(wxString(_("Error reading file:")) + wxT(" \"") + zToWx(target) + wxT("\"")); if (length1 != length2 || ::memcmp(memory1.get(), memory2.get(), length1) != 0) { const wxString errorMsg = wxString(_("Data verification error: Source and target file have different content!")) + wxT("\n"); throw FileError(errorMsg + wxT("\"") + zToWx(source) + wxT("\" -> \n\"") + zToWx(target) + wxT("\"")); } //send progress updates callback->updateStatus(); } while (!file1.Eof()); if (!file2.Eof()) { const wxString errorMsg = wxString(_("Data verification error: Source and target file have different content!")) + wxT("\n"); throw FileError(errorMsg + wxT("\"") + zToWx(source) + wxT("\" -> \n\"") + zToWx(target) + wxT("\"")); } } class VerifyStatusUpdater : public VerifyCallback { public: VerifyStatusUpdater(StatusHandler& statusHandler) : statusHandler_(statusHandler) {} virtual void updateStatus() { statusHandler_.requestUiRefresh(); //trigger display refresh } private: StatusHandler& statusHandler_; }; void SynchronizeFolderPair::verifyFileCopy(const Zstring& source, const Zstring& target) const { Zstring statusText = txtVerifying; statusText.Replace(DefaultStr("%x"), target, false); statusUpdater_.updateStatusText(statusText); statusUpdater_.requestUiRefresh(); //trigger display refresh VerifyStatusUpdater callback(statusUpdater_); try { verifyFiles(source, target, &callback); } catch (FileError& error) { switch (statusUpdater_.reportError(error.show())) { case ErrorHandler::IGNORE_ERROR: break; case ErrorHandler::RETRY: verifyFileCopy(source, target); break; } } }