diff --git a/src/backupformat/rsync.js b/src/backupformat/rsync.js index 24ff4f166..0af5d114b 100644 --- a/src/backupformat/rsync.js +++ b/src/backupformat/rsync.js @@ -77,7 +77,7 @@ async function addFile(sourceFile, encryption, uploader, progressCallback) { await uploader.finish(); } -async function processChange(change, backupConfig, remotePath, dataLayout, progressCallback) { +async function processSyncerChange(change, backupConfig, remotePath, dataLayout, progressCallback) { debug('sync: processing task: %j', change); // the empty task.path is special to signify the directory const destPath = change.path && backupConfig.encryptedFilenames ? hush.encryptFilePath(change.path, backupConfig.encryption) : change.path; @@ -112,10 +112,10 @@ async function sync(backupConfig, remotePath, dataLayout, progressCallback) { const changes = await syncer.sync(dataLayout); debug(`sync: processing ${changes.delQueue.length} deletes and ${changes.addQueue.length} additions`); - const [delError] = await safe(async.eachLimit(changes.delQueue, concurrency, async (task) => await processChange(task, backupConfig, remotePath, dataLayout, progressCallback))); + const [delError] = await safe(async.eachLimit(changes.delQueue, concurrency, async (change) => await processSyncerChange(change, backupConfig, remotePath, dataLayout, progressCallback))); debug('sync: done processing deletes. error: %o', delError); - const [addError] = await safe(async.eachLimit(changes.addQueue, concurrency, async (task) => await processChange(task, backupConfig, remotePath, dataLayout, progressCallback))); + const [addError] = await safe(async.eachLimit(changes.addQueue, concurrency, async (change) => await processSyncerChange(change, backupConfig, remotePath, dataLayout, progressCallback))); debug('sync: done processing adds. error: %o', addError); if (addError) throw addError;