Searched defs:generationId (Results 126 - 131 of 131) sorted by relevance

123456

/forgerock/opendj2-hg/src/server/org/opends/server/replication/service/
H A DReplicationBroker.java540 * @return the generationId
1462 * @param generationId The generation id we are using
1471 byte groupId, long generationId)
1505 filterServersWithSameGenerationId(evals, localServerId, generationId);
1596 * then the 'empty'(generationId==-1) replication servers are also included
1600 * @param generationId The generation id that must match
1604 RSEvaluations evals, long localServerId, long generationId)
1614 if (rsInfo.getGenerationId() == generationId)
1623 generationId, localServerId));
1628 rsId, rsInfo.getGenerationId(), localServerId, generationId));
1468 computeBestReplicationServer( boolean firstConnection, int rsServerId, ServerState myState, Map<Integer, ReplicationServerInfo> rsInfos, int localServerId, byte groupId, long generationId) argument
1603 filterServersWithSameGenerationId( RSEvaluations evals, long localServerId, long generationId) argument
[all...]
H A DReplicationDomain.java375 * The generationId for this replication domain. It is made of a hash of the
378 protected volatile long generationId; field in class:ReplicationDomain
397 * @param generationId
400 public ReplicationDomain(ReplicationDomainCfg config, long generationId) argument
402 this(config, generationId, new ServerState());
411 * @param generationId
416 public ReplicationDomain(ReplicationDomainCfg config, long generationId, argument
421 this.generationId = generationId;
1790 { // and with the expected generationId
3466 setGenerationID(long generationId) argument
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/plugin/
H A DLDAPReplicationDomain.java505 generationId = loadGenerationId();
2076 saveGenerationId(generationId);
3123 * and generationId.
3133 generationId = loadGenerationId();
3141 * The generationId will be retrieved or computed if necessary.
3166 * Compute the data generationId associated with the current data present
3168 * @return The computed generationId.
3176 logger.trace("Computed generationId: generationId=" + genId);
3186 * @param generationId Th
3190 runSaveGenerationId(DN entryDN, long generationId) argument
3211 saveGenerationId(long generationId) argument
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/service/
H A DReplicationBroker.java531 * @return the generationId
1438 * @param generationId The generation id we are using
1447 byte groupId, long generationId)
1481 filterServersWithSameGenerationId(evals, localServerId, generationId);
1572 * then the 'empty'(generationId==-1) replication servers are also included
1576 * @param generationId The generation id that must match
1580 RSEvaluations evals, long localServerId, long generationId)
1590 if (rsInfo.getGenerationId() == generationId)
1601 generationId, localServerId));
1606 rsId, rsInfo.getGenerationId(), localServerId, generationId));
1444 computeBestReplicationServer( boolean firstConnection, int rsServerId, ServerState myState, Map<Integer, ReplicationServerInfo> rsInfos, int localServerId, byte groupId, long generationId) argument
1579 filterServersWithSameGenerationId( RSEvaluations evals, long localServerId, long generationId) argument
[all...]
H A DReplicationDomain.java354 * The generationId for this replication domain. It is made of a hash of the
357 protected volatile long generationId; field in class:ReplicationDomain
376 * @param generationId
379 public ReplicationDomain(ReplicationDomainCfg config, long generationId) argument
381 this(config, generationId, new ServerState());
390 * @param generationId
395 public ReplicationDomain(ReplicationDomainCfg config, long generationId, argument
400 this.generationId = generationId;
1763 { // and with the expected generationId
3425 setGenerationID(long generationId) argument
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/server/
H A DAssuredReplicationServerTest.java242 int groupId, int rsId, long generationId, AssuredMode assuredMode,
245 return createFakeReplicationDomain(serverId, groupId, rsId, generationId,
262 * @param generationId
285 int serverId, int groupId, int rsId, long generationId,
292 return createFakeReplicationDomain(config, rsId, generationId, scenario,
297 ReplicationDomainCfg config, int rsId, long generationId, int scenario,
301 new FakeReplicationDomain(config, generationId, scenario, serverState);
350 int groupId, long generationId, boolean assured,
354 return createFakeReplicationServer(serverId, groupId, RS1_ID, generationId,
362 int groupId, int rsId, long generationId, boolea
241 createFakeReplicationDomain(int serverId, int groupId, int rsId, long generationId, AssuredMode assuredMode, int safeDataLevel, long assuredTimeout, int scenario) argument
284 createFakeReplicationDomain( int serverId, int groupId, int rsId, long generationId, AssuredMode assuredMode, int safeDataLevel, long assuredTimeout, int scenario, ServerState serverState, boolean startListen) argument
296 createFakeReplicationDomain( ReplicationDomainCfg config, int rsId, long generationId, int scenario, ServerState serverState, boolean startListen) argument
349 createFakeReplicationServer(int serverId, int groupId, long generationId, boolean assured, AssuredMode assuredMode, int safeDataLevel, int scenario) argument
361 createFakeReplicationServer(int serverId, int groupId, int rsId, long generationId, boolean assured, AssuredMode assuredMode, int safeDataLevel, ServerState serverState, int scenario) argument
473 FakeReplicationDomain(ReplicationDomainCfg config, long generationId, int scenario, ServerState serverState) argument
727 private long generationId = -1L; field in class:AssuredReplicationServerTest.FakeReplicationServer
757 FakeReplicationServer(int port, int serverId, boolean assured, AssuredMode assuredMode, int safeDataLevel, int groupId, DN baseDN, long generationId) argument
1844 assertRSExpectations(List<Integer> expectedServers, int groupId, long generationId, int expectedScenario, int rsId) argument
[all...]

Completed in 75 milliseconds

123456