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

123456

/forgerock/opendj2/src/server/org/opends/server/replication/server/
H A DChangelogState.java41 * <li>its generationId</li>
59 * Sets the generationId for the supplied replication domain.
63 * @param generationId
66 public void setDomainGenerationId(DN baseDN, long generationId) argument
68 domainToGenerationId.put(baseDN, generationId);
127 * Returns the Map of domainBaseDN => generationId.
129 * @return a Map of domainBaseDN => generationId
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/protocol/
H A DStartMsg.java45 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/opendj2.6.2/src/server/org/opends/server/replication/server/
H A DReplicationDbEnv.java180 " 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-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DDummyReplicationDomain.java43 public DummyReplicationDomain(long generationId) argument
45 super(new DomainFakeCfg(null, -1, new TreeSet<String>()), generationId);
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/server/changelog/je/
H A DReplicationDbEnvTest.java115 public void encodeDecodeChangelogState(DN baseDN, long generationId, argument
122 put(wholeState, toGenIdEntry(baseDN, generationId));
136 entry(baseDN, generationId));
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/service/
H A DFakeReplicationDomain.java70 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
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/protocol/
H A DStartMsg.java45 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/opendj2-jel-hg/src/server/org/opends/server/replication/server/
H A DReplicationDbEnv.java180 " 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-hg/src/server/org/opends/server/replication/protocol/
H A DReplServerStartMsg.java75 * @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 DStartMsg.java42 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-hg/src/server/org/opends/server/replication/server/
H A DChangelogState.java41 * <li>its generationId</li>
59 * Sets the generationId for the supplied replication domain.
63 * @param generationId
66 public void setDomainGenerationId(DN baseDN, long generationId) argument
68 domainToGenerationId.put(baseDN, generationId);
127 * Returns the Map of domainBaseDN => generationId.
129 * @return a Map of domainBaseDN => generationId
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/protocol/
H A DReplServerStartMsg.java75 * @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 DStartMsg.java42 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/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/
H A DChangelogState.java41 * <li>its generationId</li>
57 * Sets the generationId for the supplied replication domain.
61 * @param generationId
64 public void setDomainGenerationId(DN baseDN, long generationId) argument
66 domainToGenerationId.put(baseDN, generationId);
125 * Returns the Map of domainBaseDN => generationId.
127 * @return a Map of domainBaseDN => generationId
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/plugin/
H A DDummyReplicationDomain.java57 public DummyReplicationDomain(long generationId) argument
59 super(new DomainFakeCfg(null, -1, new TreeSet<String>()), generationId);
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/service/
H A DFakeReplicationDomain.java70 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
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/common/
H A DDSInfo.java51 private long generationId = -1; field in class:DSInfo
81 * @param generationId
102 public DSInfo(int dsId, String dsUrl, int rsId, long generationId, argument
111 this.generationId = generationId;
156 return generationId;
258 (generationId == dsInfo.getGenerationId()) &&
289 hash = 73 * hash + (int) (this.generationId ^ (this.generationId >>> 32));
319 sb.append(generationId);
[all...]
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/protocol/
H A DReplServerStartDSMsg.java78 * @param generationId The generationId for this server.
90 long generationId,
97 super((short) -1 /* version set when sending */, generationId);
364 "\ngenerationId: " + generationId +
87 ReplServerStartDSMsg(int serverId, String serverURL, String baseDn, int windowSize, ServerState serverState, long generationId, boolean sslEncryption, byte groupId, int degradedStatusThreshold, int weight, int connectedDSNumber) argument
H A DReplServerStartMsg.java76 * @param generationId The generationId for this server.
85 long generationId,
90 super((short) -1 /* version set when sending */, generationId);
413 "\ngenerationId: " + generationId +
82 ReplServerStartMsg(int serverId, String serverURL, String baseDn, int windowSize, ServerState serverState, long generationId, boolean sslEncryption, byte groupId, int degradedStatusThreshold) argument
H A DServerStartECLMsg.java76 * @param generationId The generationId for this server.
86 long generationId,
90 super((short) -1 /* version set when sending */, generationId);
355 "\ngenerationId: " + generationId +
81 ServerStartECLMsg(String serverURL, int maxReceiveDelay, int maxReceiveQueue, int maxSendDelay, int maxSendQueue, int windowSize, long heartbeatInterval, ServerState serverState, long generationId, boolean sslEncryption, byte groupId) argument
H A DServerStartMsg.java76 * @param generationId The generationId for this server.
83 long generationId, boolean sslEncryption,
86 super((short) -1 /* version set when sending */, generationId);
394 "\ngenerationId: " + generationId +
81 ServerStartMsg(int serverId2, String serverURL, String baseDn, int windowSize, long heartbeatInterval, ServerState serverState, long generationId, boolean sslEncryption, byte groupId) argument
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/server/
H A DLightweightServerHandler.java79 private long generationId = -1; field in class:LightweightServerHandler
109 * @param generationId The generation id of this remote DS.
123 long generationId, byte groupId, ServerStatus status,
133 this.generationId = generationId;
159 return new DSInfo(serverId, serverUrl, replicationServerId, generationId,
121 LightweightServerHandler(ReplicationServerHandler replServerHandler, int replicationServerId, int serverId, String serverUrl, long generationId, byte groupId, ServerStatus status, List<String> refUrls, boolean assuredFlag, AssuredMode assuredMode, byte safeDataLevel, Set<String> eclInclude, Set<String> eclIncludeForDeletes, short protocolVersion) argument
/forgerock/opendj2/src/server/org/opends/server/replication/common/
H A DDSInfo.java49 private final long generationId; field in class:DSInfo
77 * @param generationId
98 public DSInfo(int dsId, String dsUrl, int rsId, long generationId, argument
107 this.generationId = generationId;
154 return generationId;
250 return new DSInfo(dsId, dsUrl, rsId, generationId, status, assuredFlag,
274 && generationId == dsInfo.getGenerationId()
301 hash = 73 * hash + (int) (this.generationId ^ (this.generationId >>> 3
[all...]
/forgerock/opendj2/src/server/org/opends/server/replication/protocol/
H A DReplServerStartDSMsg.java77 * @param generationId The generationId for this server.
89 long generationId,
96 super((short) -1 /* version set when sending */, generationId);
243 "\ngenerationId: " + generationId +
86 ReplServerStartDSMsg(int serverId, String serverURL, DN baseDN, int windowSize, ServerState serverState, long generationId, boolean sslEncryption, byte groupId, int degradedStatusThreshold, int weight, int connectedDSNumber) argument
H A DServerStartMsg.java76 * @param generationId The generationId for this server.
83 long generationId, boolean sslEncryption,
86 super((short) -1 /* version set when sending */, generationId);
262 "\ngenerationId: " + generationId +
81 ServerStartMsg(int serverId2, String serverURL, DN baseDN, int windowSize, long heartbeatInterval, ServerState serverState, long generationId, boolean sslEncryption, byte groupId) argument

Completed in 100 milliseconds

123456