@@ -15,20 +15,18 @@ internal class Broker
15
15
{
16
16
private readonly ILogger logger ;
17
17
private readonly Process process ;
18
- private readonly IDiagnoser diagnoser ;
19
18
private readonly AnonymousPipeServerStream inputFromBenchmark , acknowledgments ;
20
- private readonly DiagnoserActionParameters diagnoserActionParameters ;
21
19
private readonly ManualResetEvent finished ;
22
20
23
21
public Broker ( ILogger logger , Process process , IDiagnoser diagnoser ,
24
22
BenchmarkCase benchmarkCase , BenchmarkId benchmarkId , AnonymousPipeServerStream inputFromBenchmark , AnonymousPipeServerStream acknowledgments )
25
23
{
26
24
this . logger = logger ;
27
25
this . process = process ;
28
- this . diagnoser = diagnoser ;
26
+ this . Diagnoser = diagnoser ;
29
27
this . inputFromBenchmark = inputFromBenchmark ;
30
28
this . acknowledgments = acknowledgments ;
31
- diagnoserActionParameters = new DiagnoserActionParameters ( process , benchmarkCase , benchmarkId ) ;
29
+ DiagnoserActionParameters = new DiagnoserActionParameters ( process , benchmarkCase , benchmarkId ) ;
32
30
finished = new ManualResetEvent ( false ) ;
33
31
34
32
Results = new List < string > ( ) ;
@@ -38,6 +36,10 @@ public Broker(ILogger logger, Process process, IDiagnoser diagnoser,
38
36
process . Exited += OnProcessExited ;
39
37
}
40
38
39
+ internal IDiagnoser Diagnoser { get ; }
40
+
41
+ internal DiagnoserActionParameters DiagnoserActionParameters { get ; }
42
+
41
43
internal List < string > Results { get ; }
42
44
43
45
internal List < string > PrefixedOutput { get ; }
@@ -90,7 +92,7 @@ private void ProcessDataBlocking()
90
92
}
91
93
else if ( Engine . Signals . TryGetSignal ( line , out var signal ) )
92
94
{
93
- diagnoser ? . Handle ( signal , diagnoserActionParameters ) ;
95
+ Diagnoser ? . Handle ( signal , DiagnoserActionParameters ) ;
94
96
95
97
writer . WriteLine ( Engine . Signals . Acknowledgment ) ;
96
98
0 commit comments