エンコードに失敗したときの動作を改善

mangabuta · May 4, 2019 · fd0abf4 · fd0abf4
1 parent 75360f7
commit fd0abf4
Showing 1 changed file with 19 additions and 1 deletion.
diff --git a/AmatsukazeServer/Server/TranscodeWorker.cs b/AmatsukazeServer/Server/TranscodeWorker.cs
@@ -1125,7 +1125,20 @@ await Task.WhenAll(
                     if (item.IsTest)
                     {
                         // 出力ファイルを削除
-                        File.Delete(dstpath + ext);
+                        for(int retry = 0; ; ++retry)
+                        {
+                            // 終了直後は消せないことがあるので、リトライする
+                            try
+                            {
+                                File.Delete(dstpath + ext);
+                                break;
+                            }
+                            catch(IOException)
+                            {
+                                if (retry > 10) throw;
+                                await Task.Delay(3000);
+                            }
+                        }
                     }
 
                     if (item.State == QueueState.Canceled)
@@ -1412,6 +1425,11 @@ public async Task<bool> RunItem(QueueItem workerItem, bool forceStart)
             catch (Exception e)
             {
                 await server.FatalError(Id, "エンコード中にエラー", e);
+                if(item != null)
+                {
+                    item.State = QueueState.Failed;
+                    await server.NotifyQueueItemUpdate(item);
+                }
                 return false;
             }
             finally