diff options
Diffstat (limited to 'win/C#/HandBrake.ApplicationServices/Services/QueueProcessor.cs')
| -rw-r--r-- | win/C#/HandBrake.ApplicationServices/Services/QueueProcessor.cs | 439 |
1 files changed, 217 insertions, 222 deletions
diff --git a/win/C#/HandBrake.ApplicationServices/Services/QueueProcessor.cs b/win/C#/HandBrake.ApplicationServices/Services/QueueProcessor.cs index fc56c3ad8..d49d4379a 100644 --- a/win/C#/HandBrake.ApplicationServices/Services/QueueProcessor.cs +++ b/win/C#/HandBrake.ApplicationServices/Services/QueueProcessor.cs @@ -6,14 +6,8 @@ namespace HandBrake.ApplicationServices.Services
{
using System;
- using System.Collections.Generic;
- using System.Collections.ObjectModel;
using System.Diagnostics;
- using System.IO;
- using System.Linq;
- using System.Threading;
using System.Windows.Forms;
- using System.Xml.Serialization;
using HandBrake.ApplicationServices.EventArgs;
using HandBrake.ApplicationServices.Functions;
@@ -23,12 +17,13 @@ namespace HandBrake.ApplicationServices.Services /// <summary>
/// The HandBrake Queue
/// </summary>
- public class QueueProcessor // : IQueueProcessor
+ public class QueueProcessor : IQueueProcessor
{
- /*
- * TODO
- * - Hook this up when the new encode service is in place
- */
+ /*
+ * TODO
+ * - Hookup the logging to write to disk
+ *
+ */
/// <summary>
/// Initializes a new instance of the <see cref="QueueProcessor"/> class.
@@ -43,18 +38,18 @@ namespace HandBrake.ApplicationServices.Services /// </exception>
public QueueProcessor(IQueueManager queueManager, IEncode encodeService)
{
- //this.QueueManager = queueManager;
- //this.EncodeService = encodeService;
-
- //if (this.QueueManager == null)
- //{
- // throw new ArgumentNullException("queueManager");
- //}
-
- //if (this.QueueManager == null)
- //{
- // throw new ArgumentNullException("queueManager");
- //}
+ this.QueueManager = queueManager;
+ this.EncodeService = encodeService;
+
+ if (this.QueueManager == null)
+ {
+ throw new ArgumentNullException("queueManager");
+ }
+
+ if (this.QueueManager == null)
+ {
+ throw new ArgumentNullException("queueManager");
+ }
}
/// <summary>
@@ -66,11 +61,11 @@ namespace HandBrake.ApplicationServices.Services /// </param>
public QueueProcessor(int instanceId)
{
- //this.EncodeService = new Encode();
- // this.QueueManager = new QueueManager(instanceId);
+ this.EncodeService = new Encode();
+ this.QueueManager = new QueueManager(instanceId);
}
- //#region Events
+ #region Events
/// <summary>
/// Queue Progess Status
@@ -83,201 +78,201 @@ namespace HandBrake.ApplicationServices.Services /// </param>
public delegate void QueueProgressStatus(object sender, QueueProgressEventArgs e);
- ///// <summary>
- ///// Fires when the Queue has started
- ///// </summary>
- //public event QueueProgressStatus JobProcessingStarted;
-
- ///// <summary>
- ///// Fires when a pause to the encode queue has been requested.
- ///// </summary>
- //public event EventHandler QueuePaused;
-
- ///// <summary>
- ///// Fires when the entire encode queue has completed.
- ///// </summary>
- //public event EventHandler QueueCompleted;
-
- ///// <summary>
- ///// Invoke the JobProcessingStarted event
- ///// </summary>
- ///// <param name="e">
- ///// The QueueProgressEventArgs.
- ///// </param>
- //private void InvokeJobProcessingStarted(QueueProgressEventArgs e)
- //{
- // QueueProgressStatus handler = this.JobProcessingStarted;
- // if (handler != null)
- // {
- // handler(this, e);
- // }
- //}
-
- ///// <summary>
- ///// Invoke the QueuePaused event
- ///// </summary>
- ///// <param name="e">
- ///// The EventArgs.
- ///// </param>
- //private void InvokeQueuePaused(EventArgs e)
- //{
- // EventHandler handler = this.QueuePaused;
- // if (handler != null)
- // {
- // handler(this, e);
- // }
- //}
-
- ///// <summary>
- ///// Invoke the QueueCompleted event.
- ///// </summary>
- ///// <param name="e">
- ///// The EventArgs.
- ///// </param>
- //private void InvokeQueueCompleted(EventArgs e)
- //{
- // this.IsProcessing = false;
-
- // EventHandler handler = this.QueueCompleted;
- // if (handler != null)
- // {
- // handler(this, e);
- // }
- //}
-
- //#endregion
-
- //#region Properties
-
- ///// <summary>
- ///// Gets a value indicating whether IsProcessing.
- ///// </summary>
- //public bool IsProcessing { get; private set; }
-
- ///// <summary>
- ///// Gets the IEncodeService instance.
- ///// </summary>
- //public IEncode EncodeService { get; private set; }
-
- ///// <summary>
- ///// Gets the IQueueManager instance.
- ///// </summary>
- //public IQueueManager QueueManager { get; private set; }
-
- //#endregion
-
- ///// <summary>
- ///// Starts encoding the first job in the queue and continues encoding until all jobs
- ///// have been encoded.
- ///// </summary>
- //public void Start()
- //{
- // if (IsProcessing)
- // {
- // throw new Exception("Already Processing the Queue");
- // }
-
- // IsProcessing = true;
- // this.EncodeService.EncodeCompleted += this.EncodeServiceEncodeCompleted;
- // this.ProcessNextJob();
- //}
-
- ///// <summary>
- ///// Requests a pause of the encode queue.
- ///// </summary>
- //public void Pause()
- //{
- // this.EncodeService.EncodeCompleted -= this.EncodeServiceEncodeCompleted;
- // this.InvokeQueuePaused(EventArgs.Empty);
- // this.IsProcessing = false;
- //}
-
- ///// <summary>
- ///// After an encode is complete, move onto the next job.
- ///// </summary>
- ///// <param name="sender">
- ///// The sender.
- ///// </param>
- ///// <param name="e">
- ///// The EncodeCompletedEventArgs.
- ///// </param>
- //private void EncodeServiceEncodeCompleted(object sender, EncodeCompletedEventArgs e)
- //{
- // // Growl
- // if (Init.GrowlEncode)
- // GrowlCommunicator.Notify("Encode Completed",
- // "Put down that cocktail...\nyour Handbrake encode is done.");
-
- // // Handling Log Data
- // // TODO - Still need to re-write this using CopyLog()
-
- // // Move onto the next job.
- // this.ProcessNextJob();
- //}
-
- ///// <summary>
- ///// Run through all the jobs on the queue.
- ///// </summary>
- //private void ProcessNextJob()
- //{
- // if (this.EncodeService.IsEncoding)
- // {
- // // We don't want to try start a second encode, so just return out. The event will trigger the next encode automatically.
- // return;
- // }
-
- // QueueTask job = this.QueueManager.GetNextJobForProcessing();
- // if (job != null)
- // {
- // this.EncodeService.Start(job, true);
- // this.InvokeJobProcessingStarted(new QueueProgressEventArgs(job));
- // }
- // else
- // {
- // // No more jobs to process, so unsubscribe the event
- // this.EncodeService.EncodeCompleted -= this.EncodeServiceEncodeCompleted;
-
- // // Fire the event to tell connected services.
- // this.InvokeQueueCompleted(EventArgs.Empty);
-
- // // Run the After encode completeion work
- // Finish();
- // }
- //}
-
- ///// <summary>
- ///// Perform an action after an encode. e.g a shutdown, standby, restart etc.
- ///// </summary>
- //private static void Finish()
- //{
- // // Growl
- // if (Init.GrowlQueue)
- // GrowlCommunicator.Notify("Queue Completed", "Put down that cocktail...\nyour Handbrake queue is done.");
-
- // // Do something whent he encode ends.
- // switch (Init.CompletionOption)
- // {
- // case "Shutdown":
- // Process.Start("Shutdown", "-s -t 60");
- // break;
- // case "Log Off":
- // Win32.ExitWindowsEx(0, 0);
- // break;
- // case "Suspend":
- // Application.SetSuspendState(PowerState.Suspend, true, true);
- // break;
- // case "Hibernate":
- // Application.SetSuspendState(PowerState.Hibernate, true, true);
- // break;
- // case "Lock System":
- // Win32.LockWorkStation();
- // break;
- // case "Quit HandBrake":
- // Application.Exit();
- // break;
- // default:
- // break;
- // }
- //}
+ /// <summary>
+ /// Fires when the Queue has started
+ /// </summary>
+ public event QueueProgressStatus JobProcessingStarted;
+
+ /// <summary>
+ /// Fires when a pause to the encode queue has been requested.
+ /// </summary>
+ public event EventHandler QueuePaused;
+
+ /// <summary>
+ /// Fires when the entire encode queue has completed.
+ /// </summary>
+ public event EventHandler QueueCompleted;
+
+ /// <summary>
+ /// Invoke the JobProcessingStarted event
+ /// </summary>
+ /// <param name="e">
+ /// The QueueProgressEventArgs.
+ /// </param>
+ private void InvokeJobProcessingStarted(QueueProgressEventArgs e)
+ {
+ QueueProgressStatus handler = this.JobProcessingStarted;
+ if (handler != null)
+ {
+ handler(this, e);
+ }
+ }
+
+ /// <summary>
+ /// Invoke the QueuePaused event
+ /// </summary>
+ /// <param name="e">
+ /// The EventArgs.
+ /// </param>
+ private void InvokeQueuePaused(EventArgs e)
+ {
+ EventHandler handler = this.QueuePaused;
+ if (handler != null)
+ {
+ handler(this, e);
+ }
+ }
+
+ /// <summary>
+ /// Invoke the QueueCompleted event.
+ /// </summary>
+ /// <param name="e">
+ /// The EventArgs.
+ /// </param>
+ private void InvokeQueueCompleted(EventArgs e)
+ {
+ this.IsProcessing = false;
+
+ EventHandler handler = this.QueueCompleted;
+ if (handler != null)
+ {
+ handler(this, e);
+ }
+ }
+
+ #endregion
+
+ #region Properties
+
+ /// <summary>
+ /// Gets a value indicating whether IsProcessing.
+ /// </summary>
+ public bool IsProcessing { get; private set; }
+
+ /// <summary>
+ /// Gets the IEncodeService instance.
+ /// </summary>
+ public IEncode EncodeService { get; private set; }
+
+ /// <summary>
+ /// Gets the IQueueManager instance.
+ /// </summary>
+ public IQueueManager QueueManager { get; private set; }
+
+ #endregion
+
+ /// <summary>
+ /// Starts encoding the first job in the queue and continues encoding until all jobs
+ /// have been encoded.
+ /// </summary>
+ public void Start()
+ {
+ if (IsProcessing)
+ {
+ throw new Exception("Already Processing the Queue");
+ }
+
+ IsProcessing = true;
+ this.EncodeService.EncodeCompleted += this.EncodeServiceEncodeCompleted;
+ this.ProcessNextJob();
+ }
+
+ /// <summary>
+ /// Requests a pause of the encode queue.
+ /// </summary>
+ public void Pause()
+ {
+ this.EncodeService.EncodeCompleted -= this.EncodeServiceEncodeCompleted;
+ this.InvokeQueuePaused(EventArgs.Empty);
+ this.IsProcessing = false;
+ }
+
+ /// <summary>
+ /// After an encode is complete, move onto the next job.
+ /// </summary>
+ /// <param name="sender">
+ /// The sender.
+ /// </param>
+ /// <param name="e">
+ /// The EncodeCompletedEventArgs.
+ /// </param>
+ private void EncodeServiceEncodeCompleted(object sender, EncodeCompletedEventArgs e)
+ {
+ // Growl
+ if (Init.GrowlEncode)
+ GrowlCommunicator.Notify("Encode Completed",
+ "Put down that cocktail...\nyour Handbrake encode is done.");
+
+ // Handling Log Data
+ // TODO - Still need to re-write this using CopyLog()
+
+ // Move onto the next job.
+ this.ProcessNextJob();
+ }
+
+ /// <summary>
+ /// Run through all the jobs on the queue.
+ /// </summary>
+ private void ProcessNextJob()
+ {
+ if (this.EncodeService.IsEncoding)
+ {
+ // We don't want to try start a second encode, so just return out. The event will trigger the next encode automatically.
+ return;
+ }
+
+ QueueTask job = this.QueueManager.GetNextJobForProcessing();
+ if (job != null)
+ {
+ this.EncodeService.Start(job, true);
+ this.InvokeJobProcessingStarted(new QueueProgressEventArgs(job));
+ }
+ else
+ {
+ // No more jobs to process, so unsubscribe the event
+ this.EncodeService.EncodeCompleted -= this.EncodeServiceEncodeCompleted;
+
+ // Fire the event to tell connected services.
+ this.InvokeQueueCompleted(EventArgs.Empty);
+
+ // Run the After encode completeion work
+ Finish();
+ }
+ }
+
+ /// <summary>
+ /// Perform an action after an encode. e.g a shutdown, standby, restart etc.
+ /// </summary>
+ private static void Finish()
+ {
+ // Growl
+ if (Init.GrowlQueue)
+ GrowlCommunicator.Notify("Queue Completed", "Put down that cocktail...\nyour Handbrake queue is done.");
+
+ // Do something whent he encode ends.
+ switch (Init.CompletionOption)
+ {
+ case "Shutdown":
+ Process.Start("Shutdown", "-s -t 60");
+ break;
+ case "Log Off":
+ Win32.ExitWindowsEx(0, 0);
+ break;
+ case "Suspend":
+ Application.SetSuspendState(PowerState.Suspend, true, true);
+ break;
+ case "Hibernate":
+ Application.SetSuspendState(PowerState.Hibernate, true, true);
+ break;
+ case "Lock System":
+ Win32.LockWorkStation();
+ break;
+ case "Quit HandBrake":
+ Application.Exit();
+ break;
+ default:
+ break;
+ }
+ }
}
}
\ No newline at end of file |