/forgerock/opendj-b2.6/src/server/org/opends/server/replication/protocol/ |
H A D | ResetGenerationIdMsg.java | 42 private long generationId; field in class:ResetGenerationIdMsg 46 * @param generationId The new reference value of the generationID. 48 public ResetGenerationIdMsg(long generationId) argument 50 this.generationId = generationId; 71 /* read the generationId */ 73 generationId = Long.valueOf(new String(in, pos, length, 96 // Put the generationId 97 oStream.write(String.valueOf(generationId).getBytes("UTF-8")); 116 return this.generationId; [all...] |
H A D | StartMsg.java | 45 protected long generationId; field in class:StartMsg 67 * @param generationId The generationId for this server. 70 public StartMsg(short protocolVersion, long generationId) argument 73 this.generationId = generationId; 96 String.valueOf(generationId).getBytes("UTF-8"); 112 /* put the generationId */ 142 String.valueOf(generationId).getBytes("UTF-8"); 160 /* put the generationId */ [all...] |
/forgerock/opendj-b2.6/src/server/org/opends/server/tasks/ |
H A D | SetGenerationIdTask.java | 64 private Long generationId = null; field in class:SetGenerationIdTask 106 generationId = new Long(TaskUtils.getSingleValueString(attrList)); 150 domain.resetGenerationId(generationId);
|
/forgerock/opendj2/src/server/org/opends/server/replication/protocol/ |
H A D | ResetGenerationIdMsg.java | 37 private final long generationId; field in class:ResetGenerationIdMsg 41 * @param generationId The new reference value of the generationID. 43 public ResetGenerationIdMsg(long generationId) argument 45 this.generationId = generationId; 64 generationId = scanner.nextLongUTF8(); 73 builder.appendLongUTF8(generationId); 84 return this.generationId; 92 "\ngenerationId: " + generationId;
|
H A D | ReplServerStartMsg.java | 75 * @param generationId The generationId for this server. 84 long generationId, 89 super((short) -1 /* version set when sending */, generationId); 251 "\ngenerationId: " + generationId + 81 ReplServerStartMsg(int serverId, String serverURL, DN baseDN, int windowSize, ServerState serverState, long generationId, boolean sslEncryption, byte groupId, int degradedStatusThreshold) argument
|
H A D | StartMsg.java | 42 protected long generationId; field in class:StartMsg 59 * @param generationId The generationId for this server. 62 StartMsg(short protocolVersion, long generationId) argument 65 this.generationId = generationId; 83 builder.appendLongUTF8(generationId); 103 builder.appendLongUTF8(generationId); 144 generationId = scanner.nextLongUTF8(); 155 generationId [all...] |
/forgerock/opendj2/src/server/org/opends/server/tasks/ |
H A D | SetGenerationIdTask.java | 58 private Long generationId = null; field in class:SetGenerationIdTask 90 generationId = Long.parseLong(TaskUtils.getSingleValueString(attrList)); 137 domain.resetGenerationId(generationId);
|
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/protocol/ |
H A D | ResetGenerationIdMsg.java | 42 private long generationId; field in class:ResetGenerationIdMsg 46 * @param generationId The new reference value of the generationID. 48 public ResetGenerationIdMsg(long generationId) argument 50 this.generationId = generationId; 71 /* read the generationId */ 73 generationId = Long.valueOf(new String(in, pos, length, 96 // Put the generationId 97 oStream.write(String.valueOf(generationId).getBytes("UTF-8")); 116 return this.generationId; [all...] |
/forgerock/opendj2.6.2/src/server/org/opends/server/tasks/ |
H A D | SetGenerationIdTask.java | 64 private Long generationId = null; field in class:SetGenerationIdTask 106 generationId = new Long(TaskUtils.getSingleValueString(attrList)); 150 domain.resetGenerationId(generationId);
|
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/protocol/ |
H A D | ResetGenerationIdMsg.java | 42 private long generationId; field in class:ResetGenerationIdMsg 46 * @param generationId The new reference value of the generationID. 48 public ResetGenerationIdMsg(long generationId) argument 50 this.generationId = generationId; 71 /* read the generationId */ 73 generationId = Long.valueOf(new String(in, pos, length, 96 // Put the generationId 97 oStream.write(String.valueOf(generationId).getBytes("UTF-8")); 116 return this.generationId; [all...] |
/forgerock/opendj2-jel-hg/src/server/org/opends/server/tasks/ |
H A D | SetGenerationIdTask.java | 64 private Long generationId = null; field in class:SetGenerationIdTask 106 generationId = new Long(TaskUtils.getSingleValueString(attrList)); 150 domain.resetGenerationId(generationId);
|
/forgerock/opendj2-hg/src/server/org/opends/server/replication/protocol/ |
H A D | ResetGenerationIdMsg.java | 37 private final long generationId; field in class:ResetGenerationIdMsg 41 * @param generationId The new reference value of the generationID. 43 public ResetGenerationIdMsg(long generationId) argument 45 this.generationId = generationId; 64 generationId = scanner.nextLongUTF8(); 73 builder.appendLongUTF8(generationId); 84 return this.generationId; 92 "\ngenerationId: " + generationId;
|
/forgerock/opendj2-hg/src/server/org/opends/server/tasks/ |
H A D | SetGenerationIdTask.java | 58 private Long generationId = null; field in class:SetGenerationIdTask 90 generationId = Long.parseLong(TaskUtils.getSingleValueString(attrList)); 137 domain.resetGenerationId(generationId);
|
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/protocol/ |
H A D | ResetGenerationIdMsg.java | 37 private final long generationId; field in class:ResetGenerationIdMsg 41 * @param generationId The new reference value of the generationID. 43 public ResetGenerationIdMsg(long generationId) argument 45 this.generationId = generationId; 64 generationId = scanner.nextLongUTF8(); 73 builder.appendLongUTF8(generationId); 84 return this.generationId; 92 "\ngenerationId: " + generationId;
|
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/tasks/ |
H A D | SetGenerationIdTask.java | 59 private Long generationId; field in class:SetGenerationIdTask 86 generationId = Long.parseLong(TaskUtils.getSingleValueString(attrList)); 127 domain.resetGenerationId(generationId);
|
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/common/ |
H A D | RSInfo.java | 41 private long generationId = -1; field in class:RSInfo 57 * @param generationId The generation id the RS is using 62 long generationId, byte groupId, int weight) 66 this.generationId = generationId; 86 return generationId; 124 (generationId == rsInfo.getGenerationId()) && 145 hash = 17 * hash + (int) (this.generationId ^ (this.generationId >>> 32)); 174 sb.append(generationId); 61 RSInfo(int id, String serverUrl, long generationId, byte groupId, int weight) argument [all...] |
/forgerock/opendj2/src/server/org/opends/server/replication/common/ |
H A D | RSInfo.java | 41 private final long generationId; field in class:RSInfo 60 * @param generationId The generation id the RS is using 65 long generationId, byte groupId, int weight) 69 this.generationId = generationId; 89 return generationId; 129 && generationId == rsInfo.getGenerationId() 143 hash = 17 * hash + (int) (this.generationId ^ (this.generationId >>> 32)); 167 + " ; Generation id: " + generationId 64 RSInfo(int rsServerId, String rsServerURL, long generationId, byte groupId, int weight) argument [all...] |
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/common/ |
H A D | RSInfo.java | 41 private long generationId = -1; field in class:RSInfo 57 * @param generationId The generation id the RS is using 62 long generationId, byte groupId, int weight) 66 this.generationId = generationId; 86 return generationId; 124 (generationId == rsInfo.getGenerationId()) && 145 hash = 17 * hash + (int) (this.generationId ^ (this.generationId >>> 32)); 174 sb.append(generationId); 61 RSInfo(int id, String serverUrl, long generationId, byte groupId, int weight) argument [all...] |
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/common/ |
H A D | RSInfo.java | 41 private long generationId = -1; field in class:RSInfo 57 * @param generationId The generation id the RS is using 62 long generationId, byte groupId, int weight) 66 this.generationId = generationId; 86 return generationId; 124 (generationId == rsInfo.getGenerationId()) && 145 hash = 17 * hash + (int) (this.generationId ^ (this.generationId >>> 32)); 174 sb.append(generationId); 61 RSInfo(int id, String serverUrl, long generationId, byte groupId, int weight) argument [all...] |
/forgerock/opendj2-hg/src/server/org/opends/server/replication/common/ |
H A D | RSInfo.java | 41 private final long generationId; field in class:RSInfo 60 * @param generationId The generation id the RS is using 65 long generationId, byte groupId, int weight) 69 this.generationId = generationId; 89 return generationId; 129 && generationId == rsInfo.getGenerationId() 143 hash = 17 * hash + (int) (this.generationId ^ (this.generationId >>> 32)); 167 + " ; Generation id: " + generationId 64 RSInfo(int rsServerId, String rsServerURL, long generationId, byte groupId, int weight) argument [all...] |
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/common/ |
H A D | RSInfo.java | 41 private final long generationId; field in class:RSInfo 60 * @param generationId The generation id the RS is using 65 long generationId, byte groupId, int weight) 69 this.generationId = generationId; 89 return generationId; 129 && generationId == rsInfo.getGenerationId() 143 hash = 17 * hash + (int) (this.generationId ^ (this.generationId >>> 32)); 167 + " ; Generation id: " + generationId 64 RSInfo(int rsServerId, String rsServerURL, long generationId, byte groupId, int weight) argument [all...] |
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/server/ |
H A D | ReplicationDbEnv.java | 180 " Read tag baseDn generationId=" + stringData); 185 long generationId; 188 // <generationId> 189 generationId = new Long(str[1]); 207 + " generationId=" + generationId); 210 initGenerationID(generationId); 303 * @param generationId The generationId associated to this domain. 307 public Database getOrAddDb(int serverId, String baseDn, Long generationId) argument [all...] |
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
H A D | DummyReplicationDomain.java | 43 public DummyReplicationDomain(long generationId) argument 45 super(new DomainFakeCfg(null, -1, new TreeSet<String>()), generationId);
|
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/server/changelog/je/ |
H A D | ReplicationDbEnvTest.java | 115 public void encodeDecodeChangelogState(DN baseDN, long generationId, argument 122 put(wholeState, toGenIdEntry(baseDN, generationId)); 136 entry(baseDN, generationId));
|
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/service/ |
H A D | FakeReplicationDomain.java | 70 long generationId) throws ConfigException 72 super(newConfig(baseDN, serverID, replicationServers, window, heartbeatInterval), generationId); 89 long generationId) throws ConfigException 91 this(baseDN, serverID, replicationServers, 100, heartbeatInterval, generationId); 68 FakeReplicationDomain(DN baseDN, int serverID, SortedSet<String> replicationServers, int window, long heartbeatInterval, long generationId) argument 87 FakeReplicationDomain(DN baseDN, int serverID, SortedSet<String> replicationServers, long heartbeatInterval, long generationId) argument
|