/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/ |
H A D | DataServerHandler.java | 92 * @param newGenId The new generation id to take into account 95 public void changeStatusForResetGenId(long newGenId) throws IOException argument 97 StatusMachineEvent event = getStatusMachineEvent(newGenId); 108 getBaseDN(), serverId, generationId, newGenId); 115 private StatusMachineEvent getStatusMachineEvent(long newGenId) argument 117 if (newGenId == -1) 123 if (newGenId != generationId) 136 + " has already generation id " + newGenId 151 + " and remote one match and DS is in bad gen id: " + newGenId);
|
H A D | ReplicationServerDomain.java | 1785 final long newGenId = genIdMsg.getGenerationId(); 1786 if (newGenId != this.generationId) 1788 changeGenerationId(newGenId); 1808 rsHandler.setGenerationId(newGenId); 1825 dsHandler.changeStatusForResetGenId(newGenId); 1840 logger.info(NOTE_RESET_GENERATION_ID, baseDN, newGenId);
|
/forgerock/opendj2/src/server/org/opends/server/replication/server/ |
H A D | DataServerHandler.java | 89 * @param newGenId The new generation id to take into account 92 public void changeStatusForResetGenId(long newGenId) throws IOException argument 94 StatusMachineEvent event = getStatusMachineEvent(newGenId); 110 Long.toString(newGenId)); 118 private StatusMachineEvent getStatusMachineEvent(long newGenId) argument 120 if (newGenId == -1) 126 if (newGenId != generationId) 139 + " has already generation id " + newGenId 155 + newGenId);
|
H A D | ReplicationServerDomain.java | 1834 final long newGenId = genIdMsg.getGenerationId(); 1835 if (newGenId != this.generationId) 1837 changeGenerationId(newGenId); 1857 rsHandler.setGenerationId(newGenId); 1875 dsHandler.changeStatusForResetGenId(newGenId); 1893 newGenId));
|
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/ |
H A D | DataServerHandler.java | 89 * @param newGenId The new generation id to take into account 92 public void changeStatusForResetGenId(long newGenId) throws IOException argument 94 StatusMachineEvent event = getStatusMachineEvent(newGenId); 110 Long.toString(newGenId)); 118 private StatusMachineEvent getStatusMachineEvent(long newGenId) argument 120 if (newGenId == -1) 126 if (newGenId != generationId) 139 + " has already generation id " + newGenId 155 + newGenId);
|
H A D | ReplicationServerDomain.java | 1834 final long newGenId = genIdMsg.getGenerationId(); 1835 if (newGenId != this.generationId) 1837 changeGenerationId(newGenId); 1857 rsHandler.setGenerationId(newGenId); 1875 dsHandler.changeStatusForResetGenId(newGenId); 1893 newGenId));
|
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/server/ |
H A D | DataServerHandler.java | 107 * @param newGenId The new generation id to take into account 110 public void changeStatusForResetGenId(long newGenId) argument 115 if (newGenId == -1) 122 if (newGenId == generationId) 139 newGenId); 175 " has already generation id " + newGenId + 199 Long.toString(newGenId));
|
H A D | ReplicationServerDomain.java | 2109 long newGenId = genIdMsg.getGenerationId(); 2111 if (newGenId != this.generationId) 2113 changeGenerationId(newGenId, false); 2134 rsHandler.setGenerationId(newGenId); 2152 dsHandler.changeStatusForResetGenId(newGenId); 2169 Message message = NOTE_RESET_GENERATION_ID.get(baseDn, newGenId);
|
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/server/ |
H A D | DataServerHandler.java | 106 * @param newGenId The new generation id to take into account 109 public void changeStatusForResetGenId(long newGenId) argument 114 if (newGenId == -1) 121 if (newGenId == generationId) 138 newGenId); 174 " has already generation id " + newGenId + 198 Long.toString(newGenId));
|
H A D | ReplicationServerDomain.java | 2113 long newGenId = genIdMsg.getGenerationId(); 2115 if (newGenId != this.generationId) 2117 changeGenerationId(newGenId, false); 2138 rsHandler.setGenerationId(newGenId); 2156 dsHandler.changeStatusForResetGenId(newGenId); 2172 Message message = NOTE_RESET_GENERATION_ID.get(baseDn, newGenId);
|
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/server/ |
H A D | DataServerHandler.java | 107 * @param newGenId The new generation id to take into account 110 public void changeStatusForResetGenId(long newGenId) argument 115 if (newGenId == -1) 122 if (newGenId == generationId) 139 newGenId); 175 " has already generation id " + newGenId + 199 Long.toString(newGenId));
|
H A D | ReplicationServerDomain.java | 2109 long newGenId = genIdMsg.getGenerationId(); 2111 if (newGenId != this.generationId) 2113 changeGenerationId(newGenId, false); 2134 rsHandler.setGenerationId(newGenId); 2152 dsHandler.changeStatusForResetGenId(newGenId); 2169 Message message = NOTE_RESET_GENERATION_ID.get(baseDn, newGenId);
|
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
H A D | StateMachineTest.java | 868 private void resetGenId(ReplicationBroker rb, long newGenId) argument 870 ResetGenerationIdMsg resetMsg = new ResetGenerationIdMsg(newGenId);
|
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
H A D | StateMachineTest.java | 722 private void resetGenId(ReplicationBroker rb, long newGenId) argument 724 ResetGenerationIdMsg resetMsg = new ResetGenerationIdMsg(newGenId);
|
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
H A D | StateMachineTest.java | 868 private void resetGenId(ReplicationBroker rb, long newGenId) argument 870 ResetGenerationIdMsg resetMsg = new ResetGenerationIdMsg(newGenId);
|
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
H A D | StateMachineTest.java | 722 private void resetGenId(ReplicationBroker rb, long newGenId) argument 724 ResetGenerationIdMsg resetMsg = new ResetGenerationIdMsg(newGenId);
|
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
H A D | StateMachineTest.java | 868 private void resetGenId(ReplicationBroker rb, long newGenId) argument 870 ResetGenerationIdMsg resetMsg = new ResetGenerationIdMsg(newGenId);
|
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/plugin/ |
H A D | StateMachineTest.java | 679 private void resetGenId(ReplicationBroker rb, long newGenId) argument 681 ResetGenerationIdMsg resetMsg = new ResetGenerationIdMsg(newGenId);
|