@@ -32,7 +32,7 @@ public static void IdCannotBeReused()
32
32
database . Register ( DummyAgent ) ;
33
33
Assert . That ( ( ) => database . AddAgent ( DummyAgentId , DummyProcess ) , Throws . ArgumentException . With . Property ( "ParamName" ) . EqualTo ( "agentId" ) ) ;
34
34
35
- database . MarkProcessTerminated ( DummyProcess ) ;
35
+ database . MarkTerminated ( DummyAgentId ) ;
36
36
Assert . That ( ( ) => database . AddAgent ( DummyAgentId , DummyProcess ) , Throws . ArgumentException . With . Property ( "ParamName" ) . EqualTo ( "agentId" ) ) ;
37
37
}
38
38
@@ -60,7 +60,7 @@ public static void AgentMustNotRegisterAfterTerminating()
60
60
var database = new AgentStore ( ) ;
61
61
62
62
database . AddAgent ( DummyAgentId , DummyProcess ) ;
63
- database . MarkProcessTerminated ( DummyProcess ) ;
63
+ database . MarkTerminated ( DummyAgentId ) ;
64
64
Assert . That ( ( ) => database . Register ( DummyAgent ) , Throws . ArgumentException . With . Property ( "ParamName" ) . EqualTo ( "agent" ) ) ;
65
65
}
66
66
@@ -69,7 +69,7 @@ public static void AgentMustBeStartedBeforeTerminating()
69
69
{
70
70
var database = new AgentStore ( ) ;
71
71
72
- Assert . That ( ( ) => database . MarkProcessTerminated ( DummyProcess ) ,
72
+ Assert . That ( ( ) => database . MarkTerminated ( DummyAgentId ) ,
73
73
Throws . Exception . TypeOf < NUnitEngineException > ( ) . With . Message . EqualTo ( "Process terminated without registering an agent." ) ) ;
74
74
}
75
75
@@ -108,7 +108,7 @@ public static void AgentIsNotReadyWhenTerminated()
108
108
109
109
database . AddAgent ( DummyAgentId , DummyProcess ) ;
110
110
database . Register ( DummyAgent ) ;
111
- database . MarkProcessTerminated ( DummyProcess ) ;
111
+ database . MarkTerminated ( DummyAgentId ) ;
112
112
Assert . That ( database . IsReady ( DummyAgentId , out _ ) , Is . False ) ;
113
113
}
114
114
@@ -117,7 +117,7 @@ public static void AgentIsNotRunningWhenNotStarted()
117
117
{
118
118
var database = new AgentStore ( ) ;
119
119
120
- Assert . That ( database . IsAgentProcessActive ( DummyAgentId , out _ ) , Is . False ) ;
120
+ Assert . That ( database . IsAgentActive ( DummyAgentId , out _ ) , Is . False ) ;
121
121
}
122
122
123
123
[ Test ]
@@ -126,7 +126,7 @@ public static void AgentIsRunningWhenStarted()
126
126
var database = new AgentStore ( ) ;
127
127
128
128
database . AddAgent ( DummyAgentId , DummyProcess ) ;
129
- Assert . That ( database . IsAgentProcessActive ( DummyAgentId , out var process ) , Is . True ) ;
129
+ Assert . That ( database . IsAgentActive ( DummyAgentId , out var process ) , Is . True ) ;
130
130
Assert . That ( process , Is . SameAs ( DummyProcess ) ) ;
131
131
}
132
132
@@ -137,7 +137,7 @@ public static void AgentIsRunningWhenRegistered()
137
137
138
138
database . AddAgent ( DummyAgentId , DummyProcess ) ;
139
139
database . Register ( DummyAgent ) ;
140
- Assert . That ( database . IsAgentProcessActive ( DummyAgentId , out var process ) , Is . True ) ;
140
+ Assert . That ( database . IsAgentActive ( DummyAgentId , out var process ) , Is . True ) ;
141
141
Assert . That ( process , Is . SameAs ( DummyProcess ) ) ;
142
142
}
143
143
@@ -148,8 +148,8 @@ public static void AgentIsNotRunningWhenTerminated()
148
148
149
149
database . AddAgent ( DummyAgentId , DummyProcess ) ;
150
150
database . Register ( DummyAgent ) ;
151
- database . MarkProcessTerminated ( DummyProcess ) ;
152
- Assert . That ( database . IsAgentProcessActive ( DummyAgentId , out _ ) , Is . False ) ;
151
+ database . MarkTerminated ( DummyAgentId ) ;
152
+ Assert . That ( database . IsAgentActive ( DummyAgentId , out _ ) , Is . False ) ;
153
153
}
154
154
155
155
[ Test ]
@@ -163,21 +163,20 @@ public static void ConcurrentOperationsDoNotCorruptState()
163
163
{
164
164
var id = Guid . NewGuid ( ) ;
165
165
166
- Assert . That ( database . IsAgentProcessActive ( id , out _ ) , Is . False ) ;
166
+ Assert . That ( database . IsAgentActive ( id , out _ ) , Is . False ) ;
167
167
Assert . That ( database . IsReady ( id , out _ ) , Is . False ) ;
168
168
169
169
database . AddAgent ( id , DummyProcess ) ;
170
- Assert . That ( database . IsAgentProcessActive ( id , out _ ) , Is . True ) ;
170
+ Assert . That ( database . IsAgentActive ( id , out _ ) , Is . True ) ;
171
171
Assert . That ( database . IsReady ( id , out _ ) , Is . False ) ;
172
172
173
173
// Pretend that the agent process started and registered
174
174
database . Register ( new DummyTestAgent ( id ) ) ;
175
- Assert . That ( database . IsAgentProcessActive ( id , out _ ) , Is . True ) ;
175
+ Assert . That ( database . IsAgentActive ( id , out _ ) , Is . True ) ;
176
176
Assert . That ( database . IsReady ( id , out _ ) , Is . True ) ;
177
177
178
- //database.MarkProcessTerminated(DummyProcess);
179
- database . MarkAgentTerminated ( id ) ;
180
- Assert . That ( database . IsAgentProcessActive ( id , out _ ) , Is . False ) ;
178
+ database . MarkTerminated ( id ) ;
179
+ Assert . That ( database . IsAgentActive ( id , out _ ) , Is . False ) ;
181
180
Assert . That ( database . IsReady ( id , out _ ) , Is . False ) ;
182
181
}
183
182
} , threadCount : Environment . ProcessorCount ) ;
@@ -221,10 +220,13 @@ private sealed class DummyTestAgent : ITestAgent
221
220
public DummyTestAgent ( Guid id )
222
221
{
223
222
Id = id ;
223
+ AgentType = TestAgentType . LocalProcess ;
224
224
}
225
225
226
226
public Guid Id { get ; }
227
227
228
+ public TestAgentType AgentType { get ; }
229
+
228
230
public ITestEngineRunner CreateRunner ( TestPackage package )
229
231
{
230
232
throw new NotImplementedException ( ) ;
0 commit comments