/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/server/ |
H A D | ReplicationServerTest.java | 800 ChangeNumber cn = new ChangeNumber(time, ts++, brokerIds[0]); 802 DeleteMsg delMsg = new DeleteMsg("o=example" + itest + "," + TEST_ROOT_DN_STRING, cn, "uid"); 813 cn = new ChangeNumber(time, ts++, brokerIds[0]); 814 AddMsg addMsg = new AddMsg(cn, "o=example," + TEST_ROOT_DN_STRING, 824 cn = new ChangeNumber(time, ts++, brokerIds[0]); 825 ModifyMsg modMsg = new ModifyMsg(cn, DN 830 cn = new ChangeNumber(time, ts++, brokerIds[0]); 834 op.setAttachment(SYNCHROCONTEXT, new ModifyDnContext(cn, "uniqueid", 1263 "dn: ds-task-id=" + UUID.randomUUID() + ",cn=Scheduled Tasks,cn [all...] |
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/server/ |
H A D | ReplicationServerTest.java | 800 ChangeNumber cn = new ChangeNumber(time, ts++, brokerIds[0]); 802 DeleteMsg delMsg = new DeleteMsg("o=example" + itest + "," + TEST_ROOT_DN_STRING, cn, "uid"); 813 cn = new ChangeNumber(time, ts++, brokerIds[0]); 814 AddMsg addMsg = new AddMsg(cn, "o=example," + TEST_ROOT_DN_STRING, 824 cn = new ChangeNumber(time, ts++, brokerIds[0]); 825 ModifyMsg modMsg = new ModifyMsg(cn, DN 830 cn = new ChangeNumber(time, ts++, brokerIds[0]); 834 op.setAttachment(SYNCHROCONTEXT, new ModifyDnContext(cn, "uniqueid", 1263 "dn: ds-task-id=" + UUID.randomUUID() + ",cn=Scheduled Tasks,cn [all...] |
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/server/ |
H A D | ReplicationServerTest.java | 800 ChangeNumber cn = new ChangeNumber(time, ts++, brokerIds[0]); 802 DeleteMsg delMsg = new DeleteMsg("o=example" + itest + "," + TEST_ROOT_DN_STRING, cn, "uid"); 813 cn = new ChangeNumber(time, ts++, brokerIds[0]); 814 AddMsg addMsg = new AddMsg(cn, "o=example," + TEST_ROOT_DN_STRING, 824 cn = new ChangeNumber(time, ts++, brokerIds[0]); 825 ModifyMsg modMsg = new ModifyMsg(cn, DN 830 cn = new ChangeNumber(time, ts++, brokerIds[0]); 834 op.setAttachment(SYNCHROCONTEXT, new ModifyDnContext(cn, "uniqueid", 1263 "dn: ds-task-id=" + UUID.randomUUID() + ",cn=Scheduled Tasks,cn [all...] |
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/guitools/controlpanel/datamodel/ |
H A D | ConnectionHandlersMonitoringTableModel.java | 165 String cn = getFirstValueAsString(sr, "cn"); 166 if (cn != null) 172 if (cn.endsWith(" " + address.getHostAddress() + " port " + cch.getPort() + " Statistics"))
|
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/plugin/ |
H A D | AttrHistoricalMultiple.java | 647 ChangeNumber cn) 654 add(value, cn); 661 delete(value, cn); 666 delete(cn); 669 add(value, cn); 674 delete(cn); 646 assign(HistAttrModificationKey histKey, AttributeValue value, ChangeNumber cn) argument
|
H A D | PersistentServerState.java | 251 conn.processSearch(DN.decode("cn=config"), 439 ChangeNumber cn = histVal.getCn(); 441 if ((cn != null) && (cn.getServerId() == serverId)) 445 if (ChangeNumber.compare(dbMaxCn, cn) < 0) 447 dbMaxCn = cn;
|
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/plugin/ |
H A D | AttrHistoricalMultiple.java | 647 ChangeNumber cn) 654 add(value, cn); 661 delete(value, cn); 666 delete(cn); 669 add(value, cn); 674 delete(cn); 646 assign(HistAttrModificationKey histKey, AttributeValue value, ChangeNumber cn) argument
|
H A D | PersistentServerState.java | 251 conn.processSearch(DN.decode("cn=config"), 439 ChangeNumber cn = histVal.getCn(); 441 if ((cn != null) && (cn.getServerId() == serverId)) 445 if (ChangeNumber.compare(dbMaxCn, cn) < 0) 447 dbMaxCn = cn;
|
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/plugin/ |
H A D | AttrHistoricalMultiple.java | 647 ChangeNumber cn) 654 add(value, cn); 661 delete(value, cn); 666 delete(cn); 669 add(value, cn); 674 delete(cn); 646 assign(HistAttrModificationKey histKey, AttributeValue value, ChangeNumber cn) argument
|
H A D | PersistentServerState.java | 251 conn.processSearch(DN.decode("cn=config"), 439 ChangeNumber cn = histVal.getCn(); 441 if ((cn != null) && (cn.getServerId() == serverId)) 445 if (ChangeNumber.compare(dbMaxCn, cn) < 0) 447 dbMaxCn = cn;
|
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/guitools/controlpanel/util/ |
H A D | ConfigFromDirContext.java | 142 monitorDN = DN.valueOf("cn=monitor"); 143 jvmMemoryUsageDN = DN.valueOf("cn=JVM Memory Usage,cn=monitor"); 144 systemInformationDN = DN.valueOf("cn=System Information,cn=monitor"); 145 entryCachesDN = DN.valueOf("cn=Entry Caches,cn=monitor"); 146 workQueueDN = DN.valueOf("cn=Work Queue,cn=monitor"); 147 versionDN = DN.valueOf("cn [all...] |
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/server/ |
H A D | ReplicationServerDomain.java | 229 ChangeNumber cn = update.getChangeNumber(); 230 int id = cn.getServerId(); 340 waitingAcks.put(cn, preparedAssuredInfo.expectedAcksInfo); 344 AssuredTimeoutTask assuredTimeoutTask = new AssuredTimeoutTask(cn); 543 ChangeNumber cn = update.getChangeNumber(); 611 preparedAssuredInfo.expectedAcksInfo = new SafeReadExpectedAcksInfo(cn, 619 sourceHandler.send(new AckMsg(cn)); 643 ChangeNumber cn = update.getChangeNumber(); 673 sourceHandler.send(new AckMsg(cn)); 693 sourceHandler.send(new AckMsg(cn)); 823 private ChangeNumber cn = null; field in class:ReplicationServerDomain.AssuredTimeoutTask 829 AssuredTimeoutTask(ChangeNumber cn) argument 3319 storeReceivedCTHeartbeat(ChangeNumber cn) argument [all...] |
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/server/ |
H A D | ReplicationServerDomain.java | 319 ChangeNumber cn = update.getChangeNumber(); 320 int id = cn.getServerId(); 430 waitingAcks.put(cn, preparedAssuredInfo.expectedAcksInfo); 434 AssuredTimeoutTask assuredTimeoutTask = new AssuredTimeoutTask(cn); 633 ChangeNumber cn = update.getChangeNumber(); 701 preparedAssuredInfo.expectedAcksInfo = new SafeReadExpectedAcksInfo(cn, 709 sourceHandler.send(new AckMsg(cn)); 733 ChangeNumber cn = update.getChangeNumber(); 763 sourceHandler.send(new AckMsg(cn)); 783 sourceHandler.send(new AckMsg(cn)); 913 private ChangeNumber cn = null; field in class:ReplicationServerDomain.AssuredTimeoutTask 919 AssuredTimeoutTask(ChangeNumber cn) argument 3262 storeReceivedCTHeartbeat(ChangeNumber cn) argument [all...] |
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/server/ |
H A D | ReplicationServerDomain.java | 229 ChangeNumber cn = update.getChangeNumber(); 230 int id = cn.getServerId(); 340 waitingAcks.put(cn, preparedAssuredInfo.expectedAcksInfo); 344 AssuredTimeoutTask assuredTimeoutTask = new AssuredTimeoutTask(cn); 543 ChangeNumber cn = update.getChangeNumber(); 611 preparedAssuredInfo.expectedAcksInfo = new SafeReadExpectedAcksInfo(cn, 619 sourceHandler.send(new AckMsg(cn)); 643 ChangeNumber cn = update.getChangeNumber(); 673 sourceHandler.send(new AckMsg(cn)); 693 sourceHandler.send(new AckMsg(cn)); 823 private ChangeNumber cn = null; field in class:ReplicationServerDomain.AssuredTimeoutTask 829 AssuredTimeoutTask(ChangeNumber cn) argument 3319 storeReceivedCTHeartbeat(ChangeNumber cn) argument [all...] |
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/protocol/ |
H A D | ModifyCommonMsg.java | 83 * @param cn The ChangeNumber of the operation for which the 90 public ModifyCommonMsg(ChangeNumber cn, String entryUUID, String dn) argument 92 super(cn, entryUUID, dn);
|
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/protocol/ |
H A D | ModifyCommonMsg.java | 83 * @param cn The ChangeNumber of the operation for which the 90 public ModifyCommonMsg(ChangeNumber cn, String entryUUID, String dn) argument 92 super(cn, entryUUID, dn);
|
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/protocol/ |
H A D | ModifyCommonMsg.java | 83 * @param cn The ChangeNumber of the operation for which the 90 public ModifyCommonMsg(ChangeNumber cn, String entryUUID, String dn) argument 92 super(cn, entryUUID, dn);
|
/forgerock/opendj2/src/server/org/opends/server/plugins/ |
H A D | ChangeNumberControlPlugin.java | 319 CSN cn = ctx.getCSN(); 320 if (cn != null) { 322 new ChangeNumberControl(c.isCritical(), cn);
|
/forgerock/opendj2/src/guitools/org/opends/guitools/controlpanel/datamodel/ |
H A D | ConnectionHandlersMonitoringTableModel.java | 191 String cn = (String)getFirstMonitoringValue(sr, "cn"); 192 if (cn != null) 201 if (cn.endsWith(
|
/forgerock/opendj-b2.6/src/guitools/org/opends/guitools/controlpanel/datamodel/ |
H A D | ConnectionHandlersMonitoringTableModel.java | 192 String cn = (String)getFirstMonitoringValue(sr, "cn"); 193 if (cn != null) 202 if (cn.endsWith(
|
/forgerock/opendj2.6.2/src/guitools/org/opends/guitools/controlpanel/datamodel/ |
H A D | ConnectionHandlersMonitoringTableModel.java | 192 String cn = (String)getFirstMonitoringValue(sr, "cn"); 193 if (cn != null) 202 if (cn.endsWith(
|
/forgerock/opendj2-hg/src/guitools/org/opends/guitools/controlpanel/datamodel/ |
H A D | ConnectionHandlersMonitoringTableModel.java | 191 String cn = (String)getFirstMonitoringValue(sr, "cn"); 192 if (cn != null) 201 if (cn.endsWith(
|
/forgerock/opendj2-jel-hg/src/guitools/org/opends/guitools/controlpanel/datamodel/ |
H A D | ConnectionHandlersMonitoringTableModel.java | 192 String cn = (String)getFirstMonitoringValue(sr, "cn"); 193 if (cn != null) 202 if (cn.endsWith(
|
/forgerock/opendj2-hg/src/server/org/opends/server/plugins/ |
H A D | ChangeNumberControlPlugin.java | 319 CSN cn = ctx.getCSN(); 320 if (cn != null) { 322 new ChangeNumberControl(c.isCritical(), cn);
|
/forgerock/jee-agents-v3.5/jee-agents-weblogic/jee-agents-weblogic-v10/src/main/java/com/sun/identity/agents/weblogic/v10/ |
H A D | AmWLLoginModule.java | 128 String cn = (String) it.next();
129 getPrincipalsVector().add(new WLSGroupImpl(cn));
135 cn);
|