Replace comments about relevancy of chunk to propagat v1 with variable name change
authorClaudio Cambra <claudio.cambra@nextcloud.com>
Thu, 31 Aug 2023 11:35:09 +0000 (19:35 +0800)
committerMatthieu Gallien <matthieu_gallien@yahoo.fr>
Thu, 31 Aug 2023 13:25:00 +0000 (15:25 +0200)
Signed-off-by: Claudio Cambra <claudio.cambra@nextcloud.com>
src/common/syncjournaldb.cpp
src/common/syncjournaldb.h
src/libsync/bulkpropagatorjob.cpp
src/libsync/propagateuploadv1.cpp
test/testsyncjournaldb.cpp

index 03719c6d2bf8a2e49d93d1f000e473b144d9a282..c277f04602359d68d87139fed36deb16b7a3bf00 100644 (file)
@@ -1648,7 +1648,7 @@ SyncJournalDb::UploadInfo SyncJournalDb::getUploadInfo(const QString &file)
 
         if (query->next().hasData) {
             bool ok = true;
-            res._chunk = query->intValue(0);
+            res._chunkUploadV1 = query->intValue(0);
             res._transferid = query->int64Value(1);
             res._errorCount = query->intValue(2);
             res._size = query->int64Value(3);
@@ -1678,7 +1678,7 @@ void SyncJournalDb::setUploadInfo(const QString &file, const SyncJournalDb::Uplo
         }
 
         query->bindValue(1, file);
-        query->bindValue(2, i._chunk);
+        query->bindValue(2, i._chunkUploadV1);
         query->bindValue(3, i._transferid);
         query->bindValue(4, i._errorCount);
         query->bindValue(5, i._size);
@@ -2714,13 +2714,8 @@ bool operator==(const SyncJournalDb::DownloadInfo &lhs,
 bool operator==(const SyncJournalDb::UploadInfo &lhs,
     const SyncJournalDb::UploadInfo &rhs)
 {
-    return lhs._errorCount == rhs._errorCount
-        && lhs._chunk == rhs._chunk
-        && lhs._modtime == rhs._modtime
-        && lhs._valid == rhs._valid
-        && lhs._size == rhs._size
-        && lhs._transferid == rhs._transferid
-        && lhs._contentChecksum == rhs._contentChecksum;
+    return lhs._errorCount == rhs._errorCount && lhs._chunkUploadV1 == rhs._chunkUploadV1 && lhs._modtime == rhs._modtime && lhs._valid == rhs._valid
+        && lhs._size == rhs._size && lhs._transferid == rhs._transferid && lhs._contentChecksum == rhs._contentChecksum;
 }
 
 QDebug& operator<<(QDebug &stream, const SyncJournalFileRecord::EncryptionStatus status)
index 1d7892a626cd6eb05d5d28425d2a3419bd5de6f8..01cc1e39012bee9c812d0bdb4ead3da36e7f795d 100644 (file)
@@ -115,7 +115,7 @@ public:
     };
     struct UploadInfo
     {
-        int _chunk = 0; // Relevant to PropagateUploadV1 only
+        int _chunkUploadV1 = 0;
         uint _transferid = 0;
         qint64 _size = 0;
         qint64 _modtime = 0;
index f1b83873117887e199b8861836de2a11a3d6bf8e..08dbadcbca7388f246eededff5537192e24b3410 100644 (file)
@@ -140,7 +140,7 @@ void BulkPropagatorJob::doStartUpload(SyncFileItemPtr item,
     // in reconcile (issue #5106)
     SyncJournalDb::UploadInfo pi;
     pi._valid = true;
-    pi._chunk = 0; // Relevant to PropagateUploadV1 only
+    pi._chunkUploadV1 = 0;
     pi._transferid = 0; // We set a null transfer id because it is not chunked.
     pi._modtime = item->_modtime;
     pi._errorCount = 0;
index f5ccb805311f3c08f0b115216a90b93c1f31c1c9..c51fdd3bee7a3f81ae791d80cf7f4423dc7160fa 100644 (file)
@@ -53,7 +53,7 @@ void PropagateUploadFileV1::doStartUpload()
     }
     if (progressInfo._valid && progressInfo.isChunked() && progressInfo._modtime == _item->_modtime && progressInfo._size == _item->_size
         && (progressInfo._contentChecksum == _item->_checksumHeader || progressInfo._contentChecksum.isEmpty() || _item->_checksumHeader.isEmpty())) {
-        _startChunk = progressInfo._chunk;
+        _startChunk = progressInfo._chunkUploadV1;
         _transferId = progressInfo._transferid;
         qCInfo(lcPropagateUploadV1) << _item->_file << ": Resuming from chunk " << _startChunk;
     } else if (_chunkCount <= 1 && !_item->_checksumHeader.isEmpty()) {
@@ -62,7 +62,7 @@ void PropagateUploadFileV1::doStartUpload()
         // in reconcile (issue #5106)
         SyncJournalDb::UploadInfo pi;
         pi._valid = true;
-        pi._chunk = 0;
+        pi._chunkUploadV1 = 0;
         pi._transferid = 0; // We set a null transfer id because it is not chunked.
         Q_ASSERT(_item->_modtime > 0);
         if (_item->_modtime <= 0) {
@@ -297,7 +297,7 @@ void PropagateUploadFileV1::slotPutFinished()
                 currentChunk = qMin(currentChunk, putJob->_chunk - 1);
             }
         }
-        pi._chunk = (currentChunk + _startChunk + 1) % _chunkCount; // next chunk to start with
+        pi._chunkUploadV1 = (currentChunk + _startChunk + 1) % _chunkCount; // next chunk to start with
         pi._transferid = _transferId;
         Q_ASSERT(_item->_modtime > 0);
         if (_item->_modtime <= 0) {
index 405ab269d38317a520516751c1601f4c0ba9d247..79cb88a138136ca4dc8640d38dbad667ec79b62f 100644 (file)
@@ -153,7 +153,7 @@ private slots:
         QVERIFY(!record._valid);
 
         record._errorCount = 5;
-        record._chunk = 12;
+        record._chunkUploadV1 = 12;
         record._transferid = 812974891;
         record._size = 12894789147;
         record._modtime = dropMsecs(QDateTime::currentDateTime());