Method handleParseFileDatas

src/plugins/git/utils/diffutils.cpp:183–241

}

void GitDiffWorker::handleParseFileDatas(const QList<FileData> &dataList, const QFont &font)
{
    isStop = false;
    const DiffEditorInput input(dataList, font);
    const SideBySideDiffOutput output = diffOutput(input);
    if (isStop) {
        Q_EMIT parseFileDatasFinished(false);
        return;
    }

    const SideBySideShowResult leftResult { QSharedPointer<QTextDocument>(new QTextDocument()),
                                            output.side[LeftSide].diffData, output.side[LeftSide].selections };
    const SideBySideShowResult rightResult { QSharedPointer<QTextDocument>(new QTextDocument()),
                                             output.side[RightSide].diffData, output.side[RightSide].selections };
    const SideBySideShowResults result { leftResult, rightResult };

    auto propagateDocument = [&output, this](DiffSide side, const SideBySideShowResult &result) {
        // No need to store the change history
        result.textDocument->setUndoRedoEnabled(false);

        // We could do just:
        //   result.textDocument->setPlainText(output.diffText);
        // but this would freeze the thread for couple of seconds without progress reporting
        // and without checking for canceled.
        const int diffSize = output.side[side].diffText.size();
        const int packageSize = 10000;
        int currentPos = 0;
        QTextCursor cursor(result.textDocument.data());
        while (currentPos < diffSize) {
            const QString package = output.side[side].diffText.mid(currentPos, packageSize);
            cursor.insertText(package);
            currentPos += package.size();
            if (isStop) {
                Q_EMIT parseFileDatasFinished(false);
                return;
            }
        }

        // If future was canceled, the destructor runs in this thread, so we can't move it
        // to caller's thread. We push it to no thread (make object to have no thread affinity),
        // and later, in the caller's thread, we pull it back to the caller's thread.
        result.textDocument->moveToThread(nullptr);
    };

    propagateDocument(LeftSide, leftResult);
    if (isStop) {
        Q_EMIT parseFileDatasFinished(false);
        return;
    }

    propagateDocument(RightSide, rightResult);
    if (isStop) {
        Q_EMIT parseFileDatasFinished(false);
        return;
    }

    showResults = result;
    Q_EMIT parseFileDatasFinished(true);