blob: d0ed6f3ec3f619d21cb214f7092ec3a17aec62a9 (
plain)
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
|
package testing.protocols;
import testing.*;
import org.junit.jupiter.api.*;
import static org.junit.jupiter.api.Assertions.*;
/**
* JUnit test for Broadcast protocol.
*/
@DisplayName("Broadcast Protocol Tests")
public class BroadcastProtocolTest {
private HeadlessSimulationRunner runner;
@BeforeEach
public void setup() {
runner = new HeadlessSimulationRunner();
}
@AfterEach
public void teardown() {
runner.shutdown();
}
@Test
@DisplayName("Test Broadcast protocol activation")
public void testProtocolActivation() throws Exception {
SimulationResult result = runner.runSimulation(
"saved-simulations/broadcast.dat",
1000
);
ProtocolVerifier verifier = new ProtocolVerifier()
.expectLog("Broadcast.*activated")
.expectNoLog("ERROR")
.expectNoLog("Exception");
VerificationResult verification = verifier.verify(result.getAllLogs());
assertTrue(verification.passed(), verification.getFailureMessage());
}
@Test
@DisplayName("Test broadcast message delivery to all nodes")
public void testBroadcastDelivery() throws Exception {
SimulationResult result = runner.runSimulation(
"saved-simulations/broadcast.dat",
3000
);
// In broadcast, one message should be received by multiple nodes
ProtocolVerifier verifier = new ProtocolVerifier()
.expectLog("Message sent")
.expectLog("Message received")
.expectLog("Broadcast|broadcast|BROADCAST");
VerificationResult verification = verifier.verify(result.getAllLogs());
assertTrue(verification.passed(), verification.getFailureMessage());
// Verify broadcast property: more receives than sends
int sent = result.countLogs("Message sent");
int received = result.countLogs("Message received");
if (sent > 0 && result.getMetrics().getNumProcesses() > 2) {
assertTrue(received > sent,
"Broadcast should deliver to multiple receivers");
}
}
@Test
@DisplayName("Test all processes receive broadcast")
public void testAllProcessesReceive() throws Exception {
SimulationResult result = runner.runSimulation(
"saved-simulations/broadcast.dat",
4000
);
// Count how many different processes received messages
var processLogs = result.getProcessLogs();
int processesWithReceivedMessages = 0;
for (var entry : processLogs.entrySet()) {
boolean hasReceived = entry.getValue().stream()
.anyMatch(log -> log.getMessage().contains("received"));
if (hasReceived) {
processesWithReceivedMessages++;
}
}
// In broadcast, multiple processes should receive messages
assertTrue(processesWithReceivedMessages >= 1,
"At least one process should receive messages");
}
}
|
