/forgerock/opendj-b2.6/src/server/org/opends/server/replication/server/ |
H A D | StatusAnalyzer.java | 81 .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 D | ReplicationServerConnectThread.java | 53 super("Replication server RS(" + server.getServerId()
|
H A D | ReplicationServerListenThread.java | 53 super("Replication server RS(" + server.getServerId()
|
H A D | MonitoringPublisher.java | 79 .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 D | ServerWriter.java | 141 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 D | StatusAnalyzer.java | 81 .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 D | ReplicationServerConnectThread.java | 53 super("Replication server RS(" + server.getServerId()
|
H A D | ReplicationServerListenThread.java | 53 super("Replication server RS(" + server.getServerId()
|
H A D | MonitoringPublisher.java | 79 .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 D | ReplicationServerConnectThread.java | 52 super("Replication server RS(" + server.getServerId()
|
H A D | ReplicationServerListenThread.java | 52 super("Replication server RS(" + server.getServerId()
|
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/server/ |
H A D | ReplicationServerConnectThread.java | 53 super("Replication server RS(" + server.getServerId()
|
H A D | ReplicationServerListenThread.java | 53 super("Replication server RS(" + server.getServerId()
|
H A D | MonitoringPublisher.java | 74 .getServerId() + ") monitor publisher for domain \"" 102 replicationServerDomain.getReplicationServer().getServerId(); 140 .getServerId() 150 .getServerId()); 169 replicationServerDomain.getReplicationServer().getServerId());
|
H A D | StatusAnalyzer.java | 76 + replicationServerDomain.getReplicationServer().getServerId() 145 + replicationServerDomain.getReplicationServer().getServerId()); 153 + replicationServerDomain.getReplicationServer().getServerId()
|
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/ |
H A D | ReplicationServerConnectThread.java | 52 super("Replication server RS(" + server.getServerId()
|
H A D | ReplicationServerListenThread.java | 52 super("Replication server RS(" + server.getServerId()
|
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/ |
H A D | ReplicationServerConnectThread.java | 50 super("Replication server RS(" + server.getServerId()
|
H A D | ReplicationServerListenThread.java | 52 super("Replication server RS(" + server.getServerId()
|
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/common/ |
H A D | ServerStateTest.java | 76 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 D | ServerStateTest.java | 76 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 D | ServerStateTest.java | 76 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 D | MultiDomainServerStateTest.java | 113 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 D | MultiDomainServerStateTest.java | 113 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 D | MultiDomainServerStateTest.java | 136 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...] |