comparison framework/Align.cpp @ 718:464fed3096f5

Avoid deadlock when process finishes immediately (so alignmentProgramFinished is called from waitForStarted while mutex already held)

                             ModelId referenceId,
                             ModelId otherId,
                             QString program,
                             QString &error)
 {
-    QMutexLocker locker (&m_mutex);
-    
     // Run an external program, passing to it paths to the main
     // model's audio file and the new model's audio file. It returns
     // the path in CSV form through stdout.
 
     auto reference = ModelById::getAs<ReadOnlyWaveFileModel>(referenceId);

     if (refPath == "" || otherPath == "") {
         error = "Failed to find local filepath for wave-file model";
         return false;
     }
 
-    auto alignmentModel =
-        std::make_shared<AlignmentModel>(referenceId, otherId, ModelId());
-    auto alignmentModelId = ModelById::add(alignmentModel);
-    other->setAlignment(alignmentModelId);
-
-    QProcess *process = new QProcess;
-    process->setProcessChannelMode(QProcess::ForwardedErrorChannel);
+    QProcess *process = nullptr;
+    ModelId alignmentModelId = {};
+    
+    {
+        QMutexLocker locker (&m_mutex);
+
+        auto alignmentModel =
+            std::make_shared<AlignmentModel>(referenceId, otherId, ModelId());
+
+        alignmentModelId = ModelById::add(alignmentModel);
+        other->setAlignment(alignmentModelId);
+
+        process = new QProcess;
+        process->setProcessChannelMode(QProcess::ForwardedErrorChannel);
+
+        connect(process,
+                SIGNAL(finished(int, QProcess::ExitStatus)),
+                this,
+                SLOT(alignmentProgramFinished(int, QProcess::ExitStatus)));
+
+        m_pendingProcesses[process] = alignmentModelId;
+    }
 
     QStringList args;
     args << refPath << otherPath;
-    
-    connect(process, SIGNAL(finished(int, QProcess::ExitStatus)),
-            this, SLOT(alignmentProgramFinished(int, QProcess::ExitStatus)));
-
-    m_pendingProcesses[process] = alignmentModelId;
 
     SVCERR << "Align::alignModelViaProgram: Starting program \""
            << program << "\" with args: ";
     for (auto a: args) {
         SVCERR << "\"" << a << "\" ";

 
     process->start(program, args);
 
     bool success = process->waitForStarted();
 
-    if (!success) {
-        SVCERR << "ERROR: Align::alignModelViaProgram: Program did not start"
-               << endl;
-        error = "Alignment program \"" + program + "\" could not be executed";
-        m_pendingProcesses.erase(process);
-        other->setAlignment({});
-        ModelById::release(alignmentModelId);
-        delete process;
-    } else {
-        doc->addNonDerivedModel(alignmentModelId);
+    {
+        QMutexLocker locker(&m_mutex);
+        
+        if (!success) {
+        
+            SVCERR << "ERROR: Align::alignModelViaProgram: "
+                   << "Program did not start" << endl;
+            error = "Alignment program \"" + program + "\" did not start";
+        
+            m_pendingProcesses.erase(process);
+            other->setAlignment({});
+            ModelById::release(alignmentModelId);
+            delete process;
+        
+        } else {
+            doc->addNonDerivedModel(alignmentModelId);
+        }
     }
 
     return success;
 }