OSDN Git Service

Updated CA certificates file for cURL.
[x264-launcher/x264-launcher.git] / src / encoder_abstract.cpp
index d0144ad..3ccd4c9 100644 (file)
@@ -1,6 +1,6 @@
 ///////////////////////////////////////////////////////////////////////////////
 // Simple x264 Launcher
-// Copyright (C) 2004-2014 LoRd_MuldeR <MuldeR2@GMX.de>
+// Copyright (C) 2004-2021 LoRd_MuldeR <MuldeR2@GMX.de>
 //
 // This program is free software; you can redistribute it and/or modify
 // it under the terms of the GNU General Public License as published by
 
 #include "encoder_abstract.h"
 
+//Internal
 #include "global.h"
 #include "model_options.h"
 #include "model_preferences.h"
 #include "model_sysinfo.h"
 #include "model_status.h"
 #include "source_abstract.h"
-#include "binaries.h"
 
+//MUtils
+#include <MUtils/Global.h>
+#include <MUtils/Exception.h>
+#include <MUtils/OSSupport.h>
+
+//Qt
 #include <QProcess>
 #include <QDir>
 #include <QTextCodec>
 #include <QLocale>
 
 // ------------------------------------------------------------
-// Helper Macros
-// ------------------------------------------------------------
-
-#define APPEND_AND_CLEAR(LIST, STR) do \
-{ \
-       if(!((STR).isEmpty())) \
-       { \
-               (LIST) << (STR); \
-               (STR).clear(); \
-       } \
-} \
-while(0)
-
-// ------------------------------------------------------------
 // Constructor & Destructor
 // ------------------------------------------------------------
 
@@ -75,7 +67,7 @@ AbstractEncoder::~AbstractEncoder(void)
 // Encoding Functions
 // ------------------------------------------------------------
 
-bool AbstractEncoder::runEncodingPass(AbstractSource* pipedSource, const QString outputFile, const unsigned int &frames, const int &pass, const QString &passLogFile)
+bool AbstractEncoder::runEncodingPass(AbstractSource* pipedSource, const QString outputFile, const ClipInfo &clipInfo, const int &pass, const QString &passLogFile)
 {
        QProcess processEncode, processInput;
        
@@ -85,10 +77,10 @@ bool AbstractEncoder::runEncodingPass(AbstractSource* pipedSource, const QString
        }
 
        QStringList cmdLine_Encode;
-       buildCommandLine(cmdLine_Encode, (pipedSource != NULL), frames, m_indexFile, pass, passLogFile);
+       buildCommandLine(cmdLine_Encode, (pipedSource != NULL), clipInfo, m_indexFile, pass, passLogFile);
 
        log("Creating encoder process:");
-       if(!startProcess(processEncode, ENC_BINARY(m_sysinfo, m_options), cmdLine_Encode))
+       if(!startProcess(processEncode, getBinaryPath(), cmdLine_Encode, true, &getExtraPaths(), &getExtraEnv()))
        {
                return false;
        }
@@ -96,13 +88,12 @@ bool AbstractEncoder::runEncodingPass(AbstractSource* pipedSource, const QString
        QList<QRegExp*> patterns;
        runEncodingPass_init(patterns);
        
+       double last_progress = 0.0;
+       double size_estimate = 0.0;
+       
        bool bTimeout = false;
        bool bAborted = false;
 
-       unsigned int last_progress = UINT_MAX;
-       unsigned int last_indexing = UINT_MAX;
-       qint64 size_estimate = 0I64;
-
        //Main processing loop
        while(processEncode.state() != QProcess::NotRunning)
        {
@@ -125,12 +116,12 @@ bool AbstractEncoder::runEncodingPass(AbstractSource* pipedSource, const QString
                                log(tr("Job paused by user at %1, %2.").arg(QDate::currentDate().toString(Qt::ISODate), QTime::currentTime().toString( Qt::ISODate)));
                                bool ok[2] = {false, false};
                                QProcess *proc[2] = { &processEncode, &processInput };
-                               ok[0] = x264_suspendProcess(proc[0], true);
-                               ok[1] = x264_suspendProcess(proc[1], true);
+                               ok[0] = MUtils::OS::suspend_process(proc[0], true);
+                               ok[1] = MUtils::OS::suspend_process(proc[1], true);
                                while(*m_pause) m_semaphorePause->tryAcquire(1, 5000);
                                while(m_semaphorePause->tryAcquire(1, 0));
-                               ok[0] = x264_suspendProcess(proc[0], false);
-                               ok[1] = x264_suspendProcess(proc[1], false);
+                               ok[0] = MUtils::OS::suspend_process(proc[0], false);
+                               ok[1] = MUtils::OS::suspend_process(proc[1], false);
                                if(!(*m_abort)) setStatus(previousStatus);
                                log(tr("Job resumed by user at %1, %2.").arg(QDate::currentDate().toString(Qt::ISODate), QTime::currentTime().toString( Qt::ISODate)));
                                waitCounter = 0;
@@ -173,12 +164,12 @@ bool AbstractEncoder::runEncodingPass(AbstractSource* pipedSource, const QString
                }
 
                //Process all output
-               PROCESS_PENDING_LINES(processEncode, runEncodingPass_parseLine, patterns, pass);
+               PROCESS_PENDING_LINES(processEncode, runEncodingPass_parseLine, patterns, clipInfo, pass, last_progress, size_estimate);
        }
        
        if(!(bTimeout || bAborted))
        {
-               PROCESS_PENDING_LINES(processEncode, runEncodingPass_parseLine, patterns, pass);
+               PROCESS_PENDING_LINES(processEncode, runEncodingPass_parseLine, patterns, clipInfo, pass, last_progress, size_estimate);
        }
 
        processEncode.waitForFinished(5000);
@@ -207,7 +198,7 @@ bool AbstractEncoder::runEncodingPass(AbstractSource* pipedSource, const QString
        while(!patterns.isEmpty())
        {
                QRegExp *pattern = patterns.takeFirst();
-               X264_DELETE(pattern);
+               MUTILS_DELETE(pattern);
        }
 
        if(bTimeout || bAborted || processEncode.exitCode() != EXIT_SUCCESS)
@@ -215,7 +206,7 @@ bool AbstractEncoder::runEncodingPass(AbstractSource* pipedSource, const QString
                if(!(bTimeout || bAborted))
                {
                        const int exitCode = processEncode.exitCode();
-                       if((exitCode < 0) || (exitCode >= 32))
+                       if((exitCode < -1) || (exitCode >= 32))
                        {
                                log(tr("\nFATAL ERROR: The encoder process has *crashed* -> your encode probably is *incomplete* !!!"));
                                log(tr("Note that this indicates a bug in the current encoder, *not* in Simple x264/x265 Launcher."));
@@ -231,7 +222,6 @@ bool AbstractEncoder::runEncodingPass(AbstractSource* pipedSource, const QString
 
        QFileInfo completedFileInfo(m_outputFile);
        const qint64 finalSize = (completedFileInfo.exists() && completedFileInfo.isFile()) ? completedFileInfo.size() : 0;
-       QLocale locale(QLocale::English);
        log(tr("Final file size is %1 bytes.").arg(sizeToString(finalSize)));
 
        switch(pass)
@@ -260,48 +250,19 @@ bool AbstractEncoder::runEncodingPass(AbstractSource* pipedSource, const QString
 // Utilities
 // ------------------------------------------------------------
 
-QStringList AbstractEncoder::splitParams(const QString &params, const QString &sourceFile, const QString &outputFile)
+double AbstractEncoder::estimateSize(const QString &fileName, const double &progress)
 {
-       QStringList list; 
-       bool ignoreWhitespaces = false;
-       QString temp;
-
-       for(int i = 0; i < params.length(); i++)
+       double estimatedSize = 0.0;
+       if(progress >= 0.03)
        {
-               const QChar c = params.at(i);
-
-               if(c == QChar::fromLatin1('"'))
-               {
-                       ignoreWhitespaces = (!ignoreWhitespaces);
-                       continue;
-               }
-               else if((!ignoreWhitespaces) && (c == QChar::fromLatin1(' ')))
+               QFileInfo fileInfo(fileName);
+               if(fileInfo.exists() && fileInfo.isFile())
                {
-                       APPEND_AND_CLEAR(list, temp);
-                       continue;
+                       const qint64 currentSize = QFileInfo(fileName).size();
+                       estimatedSize = static_cast<double>(currentSize) * (1.0 / qBound(0.0, progress, 1.0));
                }
-               
-               temp.append(c);
        }
-       
-       APPEND_AND_CLEAR(list, temp);
-
-       list.replaceInStrings("$(INPUT)",  QDir::toNativeSeparators(sourceFile), Qt::CaseInsensitive);
-       list.replaceInStrings("$(OUTPUT)", QDir::toNativeSeparators(outputFile), Qt::CaseInsensitive);
-
-       return list;
-}
-
-qint64 AbstractEncoder::estimateSize(const QString &fileName, const int &progress)
-{
-       QFileInfo fileInfo(fileName);
-       if((progress >= 3) && fileInfo.exists() && fileInfo.isFile())
-       {
-               qint64 currentSize = QFileInfo(fileName).size();
-               qint64 estimatedSize = (currentSize * 100I64) / static_cast<qint64>(progress);
-               return estimatedSize;
-       }
-       return 0I64;
+       return estimatedSize;
 }
 
 QString AbstractEncoder::sizeToString(qint64 size)
@@ -332,7 +293,47 @@ QString AbstractEncoder::sizeToString(qint64 size)
 // Encoder Info
 // ------------------------------------------------------------
 
-const AbstractEncoderInfo& AbstractEncoder::getEncoderInfo(void)
+template <class T>
+static T getElementAt(const QList<T> &list, const quint32 &index)
+{
+       if (index >= quint32(list.count()))
+       {
+               MUTILS_THROW("Index is out of bounds!");
+       }
+       return list[index];
+}
+
+QStringList AbstractEncoderInfo::getDependencies(const SysinfoModel *sysinfo, const quint32 &encArch, const quint32 &encVariant) const
+{
+       return QStringList();
+}
+
+QString AbstractEncoderInfo::getFullName(const quint32 &encArch, const quint32 &encVariant) const
+{
+       return QString("%1, %2, %3").arg(getName(), archToString(encArch), variantToString(encVariant));
+}
+
+QString AbstractEncoderInfo::archToString(const quint32 &index) const
+{
+       return getElementAt(getArchitectures(), index).first;
+}
+
+AbstractEncoderInfo::ArchBit AbstractEncoderInfo::archToType(const quint32 &index) const
+{
+       return getElementAt(getArchitectures(), index).second;
+}
+
+QString AbstractEncoderInfo::variantToString(const quint32 &index) const
+{
+       return getElementAt(getVariants(), index);
+}
+
+QString AbstractEncoderInfo::rcModeToString(const quint32 &index) const
+{
+       return getElementAt(getRCModes(), index).first;
+}
+
+AbstractEncoderInfo::RCType AbstractEncoderInfo::rcModeToType(const quint32 &index) const
 {
-       THROW("[getEncoderInfo] This function must be overwritten in sub-classes!");
+       return getElementAt(getRCModes(), index).second;
 }