| /forgerock/openam-v13/openam-core-rest/src/main/java/org/forgerock/openam/core/rest/session/query/ |
| H A D | SessionQueryFactory.java | 31 * @param serverId Non null server id.
34 public SessionQueryType getSessionQueryType(String serverId) { argument
35 return new RemoteSessionQuery(serverId);
|
| /forgerock/openam/openam-core-rest/src/main/java/org/forgerock/openam/core/rest/session/query/ |
| H A D | SessionQueryFactory.java | 31 * @param serverId Non null server id.
34 public SessionQueryType getSessionQueryType(String serverId) { argument
35 return new RemoteSessionQuery(serverId);
|
| /forgerock/opendj-b2.6/src/server/org/opends/server/replication/common/ |
| H A D | ChangeNumberGenerator.java | 42 private int serverId; field in class:ChangeNumberGenerator
52 this.serverId = serverID2;
74 this.serverId = id;
105 return new ChangeNumber(myTime, mySeqnum, serverId);
145 if ((serverId == changeServerId) && (seqnum < changeSeqNum))
|
| /forgerock/opendj-b2.6/src/server/org/opends/server/replication/service/ |
| H A D | CTHeartbeatPublisherThread.java | 64 private final int serverId; field in class:CTHeartbeatPublisherThread
78 * @param serverId2 The serverId of the sender domain.
86 this.serverId = serverId2;
108 new ChangeNumber(TimeThread.getTime(),0, serverId));
|
| /forgerock/opendj2/src/server/org/opends/server/replication/common/ |
| H A D | CSNGenerator.java | 47 private final int serverId; field in class:CSNGenerator
52 * @param serverId
57 public CSNGenerator(int serverId, long timestamp) argument
60 this.serverId = serverId;
67 * @param serverId serverId to use when creating {@link CSN}s.
72 public CSNGenerator(int serverId, ServerState state) argument
81 if (csn.getServerId() == serverId)
86 this.serverId
[all...] |
| /forgerock/opendj2/src/server/org/opends/server/replication/service/ |
| H A D | CTHeartbeatPublisherThread.java | 64 private final int serverId; field in class:CTHeartbeatPublisherThread
78 * @param serverId The serverId of the sender domain.
81 long heartbeatInterval, int serverId)
86 this.serverId = serverId;
109 final CSN csn = new CSN(now, 0, serverId);
80 CTHeartbeatPublisherThread(String threadName, Session session, long heartbeatInterval, int serverId) argument
|
| /forgerock/opendj2.6.2/src/server/org/opends/server/replication/common/ |
| H A D | ChangeNumberGenerator.java | 42 private int serverId; field in class:ChangeNumberGenerator
52 this.serverId = serverID2;
74 this.serverId = id;
105 return new ChangeNumber(myTime, mySeqnum, serverId);
145 if ((serverId == changeServerId) && (seqnum < changeSeqNum))
|
| /forgerock/opendj2.6.2/src/server/org/opends/server/replication/service/ |
| H A D | CTHeartbeatPublisherThread.java | 64 private final int serverId; field in class:CTHeartbeatPublisherThread
78 * @param serverId2 The serverId of the sender domain.
86 this.serverId = serverId2;
108 new ChangeNumber(TimeThread.getTime(),0, serverId));
|
| /forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/common/ |
| H A D | ChangeNumberGenerator.java | 42 private int serverId; field in class:ChangeNumberGenerator
52 this.serverId = serverID2;
74 this.serverId = id;
105 return new ChangeNumber(myTime, mySeqnum, serverId);
145 if ((serverId == changeServerId) && (seqnum < changeSeqNum))
|
| /forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/service/ |
| H A D | CTHeartbeatPublisherThread.java | 64 private final int serverId; field in class:CTHeartbeatPublisherThread
78 * @param serverId2 The serverId of the sender domain.
86 this.serverId = serverId2;
108 new ChangeNumber(TimeThread.getTime(),0, serverId));
|
| /forgerock/opendj2-hg/src/server/org/opends/server/replication/common/ |
| H A D | CSNGenerator.java | 47 private final int serverId; field in class:CSNGenerator
52 * @param serverId
57 public CSNGenerator(int serverId, long timestamp) argument
60 this.serverId = serverId;
67 * @param serverId serverId to use when creating {@link CSN}s.
72 public CSNGenerator(int serverId, ServerState state) argument
81 if (csn.getServerId() == serverId)
86 this.serverId
[all...] |
| /forgerock/opendj2-hg/src/server/org/opends/server/replication/service/ |
| H A D | CTHeartbeatPublisherThread.java | 64 private final int serverId; field in class:CTHeartbeatPublisherThread
78 * @param serverId The serverId of the sender domain.
81 long heartbeatInterval, int serverId)
86 this.serverId = serverId;
109 final CSN csn = new CSN(now, 0, serverId);
80 CTHeartbeatPublisherThread(String threadName, Session session, long heartbeatInterval, int serverId) argument
|
| /forgerock/openam-v13/openam-core/src/main/java/com/iplanet/dpro/session/service/cluster/ |
| H A D | ClusterMonitor.java | 42 * @param serverId server id
45 boolean checkServerUp(String serverId); argument
|
| /forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/common/ |
| H A D | CSNGenerator.java | 47 private final int serverId; field in class:CSNGenerator
52 * @param serverId
57 public CSNGenerator(int serverId, long timestamp) argument
60 this.serverId = serverId;
67 * @param serverId serverId to use when creating {@link CSN}s.
72 public CSNGenerator(int serverId, ServerState state) argument
81 if (csn.getServerId() == serverId)
86 this.serverId
[all...] |
| /forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/service/ |
| H A D | CTHeartbeatPublisherThread.java | 58 private final int serverId; field in class:CTHeartbeatPublisherThread
72 * @param serverId The serverId of the sender domain.
75 long heartbeatInterval, int serverId)
80 this.serverId = serverId;
100 final CSN csn = new CSN(now, 0, serverId);
74 CTHeartbeatPublisherThread(String threadName, Session session, long heartbeatInterval, int serverId) argument
|
| /forgerock/openam/openam-core/src/main/java/com/iplanet/dpro/session/service/cluster/ |
| H A D | ClusterMonitor.java | 42 * @param serverId server id
45 boolean checkServerUp(String serverId); argument
|
| /forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
| H A D | HistoricalCsnOrderingTest.java | 79 final int serverId = 123; field in class:HistoricalCsnOrderingTest
135 final int serverId = 123;
140 LDAPReplicationDomain rd1 = createReplicationDomain(serverId);
210 new ChangeNumber(startTime, 0, serverId),
255 LDAPReplicationDomain rd1 = createReplicationDomain(serverId);
319 new ChangeNumber(startTime, 0, serverId),
|
| /forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
| H A D | HistoricalCsnOrderingTest.java | 64 private final int serverId = 123; field in class:HistoricalCsnOrderingTest
115 final int serverId = 123;
120 LDAPReplicationDomain rd1 = createReplicationDomain(serverId);
184 CSN csn = new CSN(startTime, 0, serverId);
223 LDAPReplicationDomain rd1 = createReplicationDomain(serverId);
285 CSN csn = new CSN(startTime, 0, serverId);
|
| /forgerock/opendj2/src/server/org/opends/server/replication/server/changelog/je/ |
| H A D | DomainDBCursor.java | 95 * @param serverId
96 * the serverId of the replica
100 public void addReplicaDB(int serverId, CSN startCSN) argument
103 newReplicas.putIfAbsent(serverId, startCSN != null ? startCSN : NULL_CSN);
113 final int serverId = pair.getKey();
117 domainDB.getCursorFrom(baseDN, serverId, startCSN, matchingStrategy, positionStrategy);
|
| /forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
| H A D | HistoricalCsnOrderingTest.java | 80 final int serverId = 123; field in class:HistoricalCsnOrderingTest
129 final int serverId = 123;
134 LDAPReplicationDomain rd1 = createReplicationDomain(serverId);
202 ChangeNumber cn = new ChangeNumber(startTime, 0, serverId);
243 LDAPReplicationDomain rd1 = createReplicationDomain(serverId);
305 ChangeNumber cn = new ChangeNumber(startTime, 0, serverId);
|
| /forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
| H A D | HistoricalCsnOrderingTest.java | 64 private final int serverId = 123; field in class:HistoricalCsnOrderingTest
115 final int serverId = 123;
120 LDAPReplicationDomain rd1 = createReplicationDomain(serverId);
184 CSN csn = new CSN(startTime, 0, serverId);
223 LDAPReplicationDomain rd1 = createReplicationDomain(serverId);
285 CSN csn = new CSN(startTime, 0, serverId);
|
| /forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
| H A D | HistoricalCsnOrderingTest.java | 79 final int serverId = 123; field in class:HistoricalCsnOrderingTest
135 final int serverId = 123;
140 LDAPReplicationDomain rd1 = createReplicationDomain(serverId);
210 new ChangeNumber(startTime, 0, serverId),
255 LDAPReplicationDomain rd1 = createReplicationDomain(serverId);
319 new ChangeNumber(startTime, 0, serverId),
|
| /forgerock/opendj2-hg/src/server/org/opends/server/replication/server/changelog/je/ |
| H A D | DomainDBCursor.java | 95 * @param serverId
96 * the serverId of the replica
100 public void addReplicaDB(int serverId, CSN startCSN) argument
103 newReplicas.putIfAbsent(serverId, startCSN != null ? startCSN : NULL_CSN);
113 final int serverId = pair.getKey();
117 domainDB.getCursorFrom(baseDN, serverId, startCSN, matchingStrategy, positionStrategy);
|
| /forgerock/openam-v13/openam-core-rest/src/main/java/org/forgerock/openam/core/rest/session/query/impl/ |
| H A D | RemoteSessionQuery.java | 51 private String serverId; field in class:RemoteSessionQuery
60 * @param serverId Non null Server Id as defined against the result of calling
63 public RemoteSessionQuery(String serverId) { argument
64 this.serverId = serverId;
77 URL svcurl = sessionServiceUrlService.getSessionServiceURL(serverId);
94 debug.warning("Failed to fetch sessions from " + serverId, e);
|
| /forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/changelog/api/ |
| H A D | ReplicaId.java | 29 /** Replica identifier comprised of the domain baseDN and its serverId within this domain. */
33 private final int serverId; field in class:ReplicaId
40 * @param serverId
41 * serverId within the domain
43 private ReplicaId(DN baseDN, int serverId) argument
46 this.serverId = serverId;
54 * @param serverId
55 * serverId within the domain
58 public static ReplicaId of(DN baseDN, int serverId) argument
[all...] |