| | |
| | | assertThat(state.getDomainToServerIds().get(domainDN)).containsOnly(SERVER_ID_1, SERVER_ID_2); |
| | | assertThat(state.getDomainToGenerationId()).containsExactly(MapEntry.entry(domainDN, 1L)); |
| | | |
| | | assertThat(state).isEqualTo(environment.getChangelogState()); |
| | | assertThat(state.isEqualTo(environment.getChangelogState())).isTrue(); |
| | | } |
| | | finally |
| | | { |
| | |
| | | MapEntry.entry(domainDNs.get(1), 2L), |
| | | MapEntry.entry(domainDNs.get(2), 3L)); |
| | | |
| | | assertThat(state).isEqualTo(environment.getChangelogState()); |
| | | assertThat(state.isEqualTo(environment.getChangelogState())).isTrue(); |
| | | } |
| | | finally |
| | | { |
| | |
| | | assertThat(state.getOfflineReplicas().getSnapshot()) |
| | | .containsExactly(MapEntry.entry(domainDN, Arrays.asList(offlineCSN))); |
| | | |
| | | assertThat(state).isEqualTo(environment.getChangelogState()); |
| | | assertThat(state.isEqualTo(environment.getChangelogState())).isTrue(); |
| | | } |
| | | finally |
| | | { |
| | |
| | | final ChangelogState state = environment.readOnDiskChangelogState(); |
| | | assertThat(state.getOfflineReplicas().getSnapshot()) |
| | | .containsExactly(MapEntry.entry(domainDN, Arrays.asList(lastOfflineCSN))); |
| | | assertThat(state).isEqualTo(environment.getChangelogState()); |
| | | assertThat(state.isEqualTo(environment.getChangelogState())).isTrue(); |
| | | } |
| | | finally |
| | | { |
| | |
| | | |
| | | final ChangelogState state = environment.readOnDiskChangelogState(); |
| | | assertThat(state.getOfflineReplicas()).isEmpty(); |
| | | assertThat(state).isEqualTo(environment.getChangelogState()); |
| | | assertThat(state.isEqualTo(environment.getChangelogState())).isTrue(); |
| | | } |
| | | finally |
| | | { |
| | |
| | | assertThat(state.getOfflineReplicas().getSnapshot()) |
| | | .containsExactly(MapEntry.entry(domainDN, Arrays.asList(offlineCSN))); |
| | | |
| | | assertThat(state).isEqualTo(environment.getChangelogState()); |
| | | assertThat(state.isEqualTo(environment.getChangelogState())).isTrue(); |
| | | } |
| | | finally |
| | | { |