forked from EvilBeaver/OneScript
-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathDebugControllerBase.cs
More file actions
131 lines (108 loc) · 3.87 KB
/
DebugControllerBase.cs
File metadata and controls
131 lines (108 loc) · 3.87 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
/*----------------------------------------------------------
This Source Code Form is subject to the terms of the
Mozilla Public License, v.2.0. If a copy of the MPL
was not distributed with this file, You can obtain one
at http://mozilla.org/MPL/2.0/.
----------------------------------------------------------*/
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading;
using OneScript.DebugProtocol;
using OneScript.DebugServices;
using ScriptEngine.Machine;
namespace oscript.DebugServer
{
[Obsolete]
internal class MachineWaitToken
{
public MachineInstance Machine;
public ManualResetEventSlim ThreadEvent;
}
[Obsolete]
internal abstract class DebugControllerBase : IDebugController
{
private readonly Dictionary<int, MachineWaitToken> _machinesOnThreads = new Dictionary<int, MachineWaitToken>();
public DebugControllerBase()
{
BreakpointManager = new DefaultBreakpointManager();
}
public virtual void Init()
{
}
public virtual void Wait()
{
var token = GetTokenForThread(Thread.CurrentThread.ManagedThreadId);
token.ThreadEvent = new ManualResetEventSlim();
token.ThreadEvent.Wait();
}
public virtual void NotifyProcessExit(int exitCode)
{
var t = _machinesOnThreads[Thread.CurrentThread.ManagedThreadId];
t.Machine.MachineStopped -= Machine_MachineStopped;
_machinesOnThreads.Remove(Thread.CurrentThread.ManagedThreadId);
}
public void DetachFromThread()
{
if (_machinesOnThreads.TryGetValue(Thread.CurrentThread.ManagedThreadId, out var t))
{
t.Machine.MachineStopped -= Machine_MachineStopped;
_machinesOnThreads.Remove(Thread.CurrentThread.ManagedThreadId);
}
}
public IBreakpointManager BreakpointManager { get; set; }
public virtual void AttachToThread()
{
var machine = MachineInstance.Current;
_machinesOnThreads[Thread.CurrentThread.ManagedThreadId] = new MachineWaitToken()
{
Machine = machine
};
machine.MachineStopped += Machine_MachineStopped;
}
private void Machine_MachineStopped(object sender, MachineStoppedEventArgs e)
{
OnMachineStopped((MachineInstance)sender, e.Reason);
}
protected abstract void OnMachineStopped(MachineInstance machine, MachineStopReason reason);
public void Dispose()
{
Dispose(true);
}
public MachineWaitToken GetTokenForThread(int threadId)
{
return _machinesOnThreads[threadId];
}
public MachineWaitToken[] GetAllTokens()
{
return _machinesOnThreads.Values.ToArray();
}
public int[] GetAllThreadIds()
{
return _machinesOnThreads.Keys.ToArray();
}
protected virtual void Dispose(bool disposing)
{
var tokens = GetAllTokens();
foreach (var machineWaitToken in tokens)
{
machineWaitToken.Machine.MachineStopped -= Machine_MachineStopped;
}
_machinesOnThreads.Clear();
}
protected ThreadStopReason ConvertStopReason(MachineStopReason reason)
{
switch(reason)
{
case MachineStopReason.Breakpoint:
return ThreadStopReason.Breakpoint;
case MachineStopReason.Step:
return ThreadStopReason.Step;
case MachineStopReason.Exception:
return ThreadStopReason.Exception;
default:
throw new NotImplementedException();
}
}
}
}