aboutsummaryrefslogtreecommitdiff
path: root/Ryujinx.Common/Logging/Targets/AsyncLogTargetWrapper.cs
diff options
context:
space:
mode:
authorTSR Berry <20988865+TSRBerry@users.noreply.github.com>2023-04-08 01:22:00 +0200
committerMary <thog@protonmail.com>2023-04-27 23:51:14 +0200
commitcee712105850ac3385cd0091a923438167433f9f (patch)
tree4a5274b21d8b7f938c0d0ce18736d3f2993b11b1 /Ryujinx.Common/Logging/Targets/AsyncLogTargetWrapper.cs
parentcd124bda587ef09668a971fa1cac1c3f0cfc9f21 (diff)
Move solution and projects to src
Diffstat (limited to 'Ryujinx.Common/Logging/Targets/AsyncLogTargetWrapper.cs')
-rw-r--r--Ryujinx.Common/Logging/Targets/AsyncLogTargetWrapper.cs79
1 files changed, 0 insertions, 79 deletions
diff --git a/Ryujinx.Common/Logging/Targets/AsyncLogTargetWrapper.cs b/Ryujinx.Common/Logging/Targets/AsyncLogTargetWrapper.cs
deleted file mode 100644
index 43c62d31..00000000
--- a/Ryujinx.Common/Logging/Targets/AsyncLogTargetWrapper.cs
+++ /dev/null
@@ -1,79 +0,0 @@
-using System;
-using System.Collections.Concurrent;
-using System.Threading;
-
-namespace Ryujinx.Common.Logging
-{
- public enum AsyncLogTargetOverflowAction
- {
- /// <summary>
- /// Block until there's more room in the queue
- /// </summary>
- Block = 0,
-
- /// <summary>
- /// Discard the overflowing item
- /// </summary>
- Discard = 1
- }
-
- public class AsyncLogTargetWrapper : ILogTarget
- {
- private ILogTarget _target;
-
- private Thread _messageThread;
-
- private BlockingCollection<LogEventArgs> _messageQueue;
-
- private readonly int _overflowTimeout;
-
- string ILogTarget.Name { get => _target.Name; }
-
- public AsyncLogTargetWrapper(ILogTarget target)
- : this(target, -1, AsyncLogTargetOverflowAction.Block)
- { }
-
- public AsyncLogTargetWrapper(ILogTarget target, int queueLimit, AsyncLogTargetOverflowAction overflowAction)
- {
- _target = target;
- _messageQueue = new BlockingCollection<LogEventArgs>(queueLimit);
- _overflowTimeout = overflowAction == AsyncLogTargetOverflowAction.Block ? -1 : 0;
-
- _messageThread = new Thread(() => {
- while (!_messageQueue.IsCompleted)
- {
- try
- {
- _target.Log(this, _messageQueue.Take());
- }
- catch (InvalidOperationException)
- {
- // IOE means that Take() was called on a completed collection.
- // Some other thread can call CompleteAdding after we pass the
- // IsCompleted check but before we call Take.
- // We can simply catch the exception since the loop will break
- // on the next iteration.
- }
- }
- });
-
- _messageThread.Name = "Logger.MessageThread";
- _messageThread.IsBackground = true;
- _messageThread.Start();
- }
-
- public void Log(object sender, LogEventArgs e)
- {
- if (!_messageQueue.IsAddingCompleted)
- {
- _messageQueue.TryAdd(e, _overflowTimeout);
- }
- }
-
- public void Dispose()
- {
- _messageQueue.CompleteAdding();
- _messageThread.Join();
- }
- }
-} \ No newline at end of file