Ticket #7731: delay_unlink.patch

programs/mythtranscode/main.cpp

@@ -816 +816 @@
     return unlink(filename.toLocal8Bit().constData());
 }
 
+void WaitToDelete(ProgramInfo *pginfo)
+{
+    VERBOSE(VB_GENERAL,
+            "Transcode: delete old file: "
+            "waiting while program is in use.");
+    unsigned inUse = 1;
+    MSqlQuery query(MSqlQuery::InitCon());
+    while (inUse)
+    {
+        query.prepare("SELECT count(*) FROM inuseprograms "
+                      "WHERE chanid = :CHANID "
+                      "AND starttime = :STARTTIME "
+                      "AND recusage != 'jobqueue' ;");
+        query.bindValue(":CHANID", pginfo->chanid);
+        query.bindValue(":STARTTIME", pginfo->recstartts);
+        if (!query.exec() || !query.next())
+        {
+            VERBOSE(VB_GENERAL,
+                    "Transcode: delete old file: in-use query failed;");
+            VERBOSE(VB_GENERAL,
+                    "    proceeding with delete of old file.");
+            return;
+        }
+        inUse = query.value(0).toUInt();
+        if (inUse)
+        {
+            unsigned secondsToWait = 10;
+            VERBOSE(VB_GENERAL,
+                    QString("Transcode: program in use, "
+                            "rechecking in %1 seconds.").arg(secondsToWait));
+            sleep(secondsToWait);
+        }
+    }
+    VERBOSE(VB_GENERAL, "Transcode: program is no longer in use.");
+}
+
 void CompleteJob(int jobID, ProgramInfo *pginfo, bool useCutlist, int &resultCode)
 {
     int status = JobQueue::GetJobStatus(jobID);
@@ -871 +907 @@
 
         if (!gContext->GetNumSetting("SaveTranscoding", 0))
         {
+            WaitToDelete(pginfo);
             int err;
             bool followLinks = gContext->GetNumSetting("DeletesFollowLinks", 0);