Searched refs:getServerId (Results 1 - 25 of 335) sorted by relevance

1234567891011>>

/forgerock/opendj-b2.6/src/server/org/opends/server/replication/server/
H A DStatusAnalyzer.java81 .getServerId() + ") delay monitor for domain \""
137 Integer.toString(serverHandler.getServerId()) + " has " + nChanges +
139 replicationServerDomain.getReplicationServer().getServerId());
167 replicationServerDomain.getReplicationServer().getServerId());
185 replicationServerDomain.getReplicationServer().getServerId());
198 replicationServerDomain.getReplicationServer().getServerId());
215 + replicationServerDomain.getReplicationServer().getServerId());
238 replicationServerDomain.getReplicationServer().getServerId());
H A DReplicationServerConnectThread.java53 super("Replication server RS(" + server.getServerId()
H A DReplicationServerListenThread.java53 super("Replication server RS(" + server.getServerId()
H A DMonitoringPublisher.java79 .getServerId() + ") monitor publisher for domain \""
118 .getReplicationServer().getServerId();
124 monitorMsg.setDestination(serverHandler.getServerId());
142 .getServerId()
153 .getServerId());
172 replicationServerDomain.getReplicationServer().getServerId());
195 replicationServerDomain.getReplicationServer().getServerId());
H A DServerWriter.java141 handler.getServiceId(), handler.getServerId(),
149 handler.getServiceId(), handler.getServerId(),
169 handler.getServerId(),
187 " server=" + handler.getServerId() +
206 handler.getReplicationServerId(), handler.getServerId(),
212 handler.getReplicationServerId(), handler.getServerId(),
227 handler.getReplicationServerId(), handler.getServerId(),
233 handler.getReplicationServerId(), handler.getServerId(),
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/server/
H A DStatusAnalyzer.java81 .getServerId() + ") delay monitor for domain \""
137 Integer.toString(serverHandler.getServerId()) + " has " + nChanges +
139 replicationServerDomain.getReplicationServer().getServerId());
167 replicationServerDomain.getReplicationServer().getServerId());
185 replicationServerDomain.getReplicationServer().getServerId());
198 replicationServerDomain.getReplicationServer().getServerId());
215 + replicationServerDomain.getReplicationServer().getServerId());
238 replicationServerDomain.getReplicationServer().getServerId());
H A DReplicationServerConnectThread.java53 super("Replication server RS(" + server.getServerId()
H A DReplicationServerListenThread.java53 super("Replication server RS(" + server.getServerId()
H A DMonitoringPublisher.java79 .getServerId() + ") monitor publisher for domain \""
118 .getReplicationServer().getServerId();
124 monitorMsg.setDestination(serverHandler.getServerId());
142 .getServerId()
153 .getServerId());
172 replicationServerDomain.getReplicationServer().getServerId());
195 replicationServerDomain.getReplicationServer().getServerId());
/forgerock/opendj2/src/server/org/opends/server/replication/server/
H A DReplicationServerConnectThread.java52 super("Replication server RS(" + server.getServerId()
H A DReplicationServerListenThread.java52 super("Replication server RS(" + server.getServerId()
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/server/
H A DReplicationServerConnectThread.java53 super("Replication server RS(" + server.getServerId()
H A DReplicationServerListenThread.java53 super("Replication server RS(" + server.getServerId()
H A DMonitoringPublisher.java74 .getServerId() + ") monitor publisher for domain \""
102 replicationServerDomain.getReplicationServer().getServerId();
140 .getServerId()
150 .getServerId());
169 replicationServerDomain.getReplicationServer().getServerId());
H A DStatusAnalyzer.java76 + replicationServerDomain.getReplicationServer().getServerId()
145 + replicationServerDomain.getReplicationServer().getServerId());
153 + replicationServerDomain.getReplicationServer().getServerId()
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/
H A DReplicationServerConnectThread.java52 super("Replication server RS(" + server.getServerId()
H A DReplicationServerListenThread.java52 super("Replication server RS(" + server.getServerId()
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/
H A DReplicationServerConnectThread.java50 super("Replication server RS(" + server.getServerId()
H A DReplicationServerListenThread.java52 super("Replication server RS(" + server.getServerId()
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/common/
H A DServerStateTest.java76 cn1 = new ChangeNumber(cn.getTime()+1,cn.getSeqnum(),cn.getServerId());
77 cn2 = new ChangeNumber(cn1.getTime(),cn1.getSeqnum()+1,cn1.getServerId());
78 cn3 = new ChangeNumber(cn2.getTime(),cn2.getSeqnum(),(cn2.getServerId()+1));
91 assertEquals(cn2.compareTo(serverState.getMaxChangeNumber(cn2.getServerId())),0);
92 assertEquals(cn3.compareTo(serverState.getMaxChangeNumber(cn3.getServerId())),0);
117 cn1 = new ChangeNumber(cn.getTime()+1,cn.getSeqnum(),cn.getServerId());
118 cn3 = new ChangeNumber(cn1.getTime(),cn1.getSeqnum(),(cn1.getServerId()+1));
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/common/
H A DServerStateTest.java76 cn1 = new ChangeNumber(cn.getTime()+1,cn.getSeqnum(),cn.getServerId());
77 cn2 = new ChangeNumber(cn1.getTime(),cn1.getSeqnum()+1,cn1.getServerId());
78 cn3 = new ChangeNumber(cn2.getTime(),cn2.getSeqnum(),(cn2.getServerId()+1));
91 assertEquals(cn2.compareTo(serverState.getMaxChangeNumber(cn2.getServerId())),0);
92 assertEquals(cn3.compareTo(serverState.getMaxChangeNumber(cn3.getServerId())),0);
117 cn1 = new ChangeNumber(cn.getTime()+1,cn.getSeqnum(),cn.getServerId());
118 cn3 = new ChangeNumber(cn1.getTime(),cn1.getSeqnum(),(cn1.getServerId()+1));
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/common/
H A DServerStateTest.java76 cn1 = new ChangeNumber(cn.getTime()+1,cn.getSeqnum(),cn.getServerId());
77 cn2 = new ChangeNumber(cn1.getTime(),cn1.getSeqnum()+1,cn1.getServerId());
78 cn3 = new ChangeNumber(cn2.getTime(),cn2.getSeqnum(),(cn2.getServerId()+1));
91 assertEquals(cn2.compareTo(serverState.getMaxChangeNumber(cn2.getServerId())),0);
92 assertEquals(cn3.compareTo(serverState.getMaxChangeNumber(cn3.getServerId())),0);
117 cn1 = new ChangeNumber(cn.getTime()+1,cn.getSeqnum(),cn.getServerId());
118 cn3 = new ChangeNumber(cn1.getTime(),cn1.getSeqnum(),(cn1.getServerId()+1));
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/common/
H A DMultiDomainServerStateTest.java113 assertSame(csn3, state2.getCSN(dn1, csn3.getServerId()));
114 assertSame(csn2, state2.getCSN(dn2, csn2.getServerId()));
162 assertSame(csn1, state.getCSN(dn1, csn1.getServerId()));
163 assertSame(csn1, state.getCSN(dn2, csn1.getServerId()));
164 assertSame(csn2, state.getCSN(dn2, csn2.getServerId()));
167 assertSame(csn1, state.getCSN(dn1, csn1.getServerId()));
168 assertSame(csn1, state.getCSN(dn2, csn1.getServerId()));
169 assertSame(csn2, state.getCSN(dn2, csn2.getServerId()));
172 assertSame(csn1, state.getCSN(dn1, csn1.getServerId()));
173 assertNull(state.getCSN(dn2, csn1.getServerId()));
[all...]
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/common/
H A DMultiDomainServerStateTest.java113 assertSame(csn3, state2.getCSN(dn1, csn3.getServerId()));
114 assertSame(csn2, state2.getCSN(dn2, csn2.getServerId()));
162 assertSame(csn1, state.getCSN(dn1, csn1.getServerId()));
163 assertSame(csn1, state.getCSN(dn2, csn1.getServerId()));
164 assertSame(csn2, state.getCSN(dn2, csn2.getServerId()));
167 assertSame(csn1, state.getCSN(dn1, csn1.getServerId()));
168 assertSame(csn1, state.getCSN(dn2, csn1.getServerId()));
169 assertSame(csn2, state.getCSN(dn2, csn2.getServerId()));
172 assertSame(csn1, state.getCSN(dn1, csn1.getServerId()));
173 assertNull(state.getCSN(dn2, csn1.getServerId()));
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/common/
H A DMultiDomainServerStateTest.java136 assertSame(csn3, state2.getCSN(dn1, csn3.getServerId()));
137 assertSame(csn2, state2.getCSN(dn2, csn2.getServerId()));
185 assertSame(csn1, state.getCSN(dn1, csn1.getServerId()));
186 assertSame(csn1, state.getCSN(dn2, csn1.getServerId()));
187 assertSame(csn2, state.getCSN(dn2, csn2.getServerId()));
190 assertSame(csn1, state.getCSN(dn1, csn1.getServerId()));
191 assertSame(csn1, state.getCSN(dn2, csn1.getServerId()));
192 assertSame(csn2, state.getCSN(dn2, csn2.getServerId()));
195 assertSame(csn1, state.getCSN(dn1, csn1.getServerId()));
196 assertNull(state.getCSN(dn2, csn1.getServerId()));
[all...]

Completed in 136 milliseconds

1234567891011>>