summaryrefslogtreecommitdiff
path: root/src/test/java/protocols/VSAbstractProtocolTest.java
diff options
context:
space:
mode:
authorPaul Buetow <paul@buetow.org>2026-03-27 13:05:59 +0200
committerPaul Buetow <paul@buetow.org>2026-03-27 13:05:59 +0200
commitf55d67d98dddf5861dc4266564863dde4b0b6ed1 (patch)
treeb87ad04a444b9873cb9ec0ede643772f160e6012 /src/test/java/protocols/VSAbstractProtocolTest.java
parent29252fbc7803e4a660332524d5811ff942e2b0bc (diff)
sr: retune Raft replay for faster reelection
Diffstat (limited to 'src/test/java/protocols/VSAbstractProtocolTest.java')
-rw-r--r--src/test/java/protocols/VSAbstractProtocolTest.java13
1 files changed, 12 insertions, 1 deletions
diff --git a/src/test/java/protocols/VSAbstractProtocolTest.java b/src/test/java/protocols/VSAbstractProtocolTest.java
index b93cae4..2a76c1e 100644
--- a/src/test/java/protocols/VSAbstractProtocolTest.java
+++ b/src/test/java/protocols/VSAbstractProtocolTest.java
@@ -267,6 +267,11 @@ class VSAbstractProtocolTest {
void testScheduleAt() {
testProtocol.process = mockProcess;
testProtocol.currentContextIsServer(true);
+ when(mockProcess.getPrefs()).thenReturn(mockPrefs);
+ when(mockPrefs.getString("lang.server")).thenReturn("Server");
+ when(mockPrefs.getString("lang.client")).thenReturn("Client");
+ when(mockPrefs.getString("lang.events.internal.VSProtocolScheduleEvent.short"))
+ .thenReturn("Protocol Schedule");
long scheduleTime = 100L;
testProtocol.scheduleAt(scheduleTime);
@@ -277,6 +282,12 @@ class VSAbstractProtocolTest {
VSTask capturedTask = taskCaptor.getValue();
assertNotNull(capturedTask);
assertEquals(mockProcess, capturedTask.getProcess());
+ assertInstanceOf(VSProtocolScheduleEvent.class, capturedTask.getEvent());
+ assertEquals("events.internal.VSProtocolScheduleEvent",
+ capturedTask.getEvent().getClassname());
+ assertEquals("protocols.VSAbstractProtocolTest$TestProtocol "
+ + "Server Protocol Schedule",
+ capturedTask.getEvent().getShortname());
}
@Test
@@ -360,4 +371,4 @@ class VSAbstractProtocolTest {
verify(mockOutputStream, atLeast(1)).writeObject(Boolean.TRUE); // hasOnServerStart
}
-} \ No newline at end of file
+}