/forgerock/opendj-b2.6/tests/staf-tests/shared/java/ldapjdk/ |
H A D | ImprovedLDAPConnection.java | 39 public void apply (Change change) { argument 41 for (String mychange: change.changes) { 75 LDAPEntry addEntry = new LDAPEntry ( change.dn, attrSet ); 81 EclReadAndPlay.println("ERROR", "Cannot add entry \"" + change.dn + "\" (csn=" 82 + change.csn + ")" ); 89 // LDAPAttribute myAttr = new LDAPAttribute ("nsuniqueid", change.nsUniqueId); 90 // LDAPAttribute myAttr = new LDAPAttribute ("entryuuid", change.nsUniqueId); 93 // this.modify( change.dn, mod ); 97 // + change.dn + "\" (csn=" + change [all...] |
H A D | Writer.java | 59 // Read change from the queue 60 Change change = q.take(); 61 //EclReadAndPlay.println ("DEBUG", "Change read from the queue -----> : " + change.toString() ); 63 CSN RUVcsn=EclReadAndPlay.RUV.get(change.replicaIdentifier); 66 if ( change.csn == null ) 69 if (change.csn.compareTo(RUVcsn) < 0) { 71 EclReadAndPlay.println("DEBUG", "Operation " + change.changeNumberValue + " csn " 72 + change.csn + " has already been replayed"); 78 // Write change on stand-alone server 79 applicationConnection.apply(change); [all...] |
H A D | Change.java | 39 String change = ""; field in class:Change 125 change = attr.getStringValueArray()[0]; 126 if ( change.trim().endsWith("-") ) { 127 change = change.substring(0, change.length()-3) + "\r\n"; 129 String changeHasReplFixupOp=change.replaceFirst("targetDn", "dn") + "\r\n"; 137 change = attr.getStringValueArray()[0]; 138 if ( change.trim().endsWith("-") ) { 139 change [all...] |
/forgerock/opendj2/tests/staf-tests/shared/java/ldapjdk/ |
H A D | ImprovedLDAPConnection.java | 38 public void apply (Change change) { argument 40 for (String mychange: change.changes) { 74 LDAPEntry addEntry = new LDAPEntry ( change.dn, attrSet ); 80 EclReadAndPlay.println("ERROR", "Cannot add entry \"" + change.dn + "\" (csn=" 81 + change.csn + ")" ); 88 // LDAPAttribute myAttr = new LDAPAttribute ("nsuniqueid", change.nsUniqueId); 89 // LDAPAttribute myAttr = new LDAPAttribute ("entryuuid", change.nsUniqueId); 92 // this.modify( change.dn, mod ); 96 // + change.dn + "\" (csn=" + change [all...] |
H A D | Writer.java | 58 // Read change from the queue 59 Change change = q.take(); 60 //EclReadAndPlay.println ("DEBUG", "Change read from the queue -----> : " + change.toString() ); 62 CSN RUVcsn=EclReadAndPlay.RUV.get(change.replicaIdentifier); 65 if ( change.csn == null ) 68 if (change.csn.compareTo(RUVcsn) < 0) { 70 EclReadAndPlay.println("DEBUG", "Operation " + change.changeNumberValue + " csn " 71 + change.csn + " has already been replayed"); 77 // Write change on stand-alone server 78 applicationConnection.apply(change); [all...] |
H A D | Change.java | 38 String change = ""; field in class:Change 124 change = attr.getStringValueArray()[0]; 125 if ( change.trim().endsWith("-") ) { 126 change = change.substring(0, change.length()-3) + "\r\n"; 128 String changeHasReplFixupOp=change.replaceFirst("targetDn", "dn") + "\r\n"; 136 change = attr.getStringValueArray()[0]; 137 if ( change.trim().endsWith("-") ) { 138 change [all...] |
/forgerock/opendj2.6.2/tests/staf-tests/shared/java/ldapjdk/ |
H A D | ImprovedLDAPConnection.java | 39 public void apply (Change change) { argument 41 for (String mychange: change.changes) { 75 LDAPEntry addEntry = new LDAPEntry ( change.dn, attrSet ); 81 EclReadAndPlay.println("ERROR", "Cannot add entry \"" + change.dn + "\" (csn=" 82 + change.csn + ")" ); 89 // LDAPAttribute myAttr = new LDAPAttribute ("nsuniqueid", change.nsUniqueId); 90 // LDAPAttribute myAttr = new LDAPAttribute ("entryuuid", change.nsUniqueId); 93 // this.modify( change.dn, mod ); 97 // + change.dn + "\" (csn=" + change [all...] |
H A D | Writer.java | 59 // Read change from the queue 60 Change change = q.take(); 61 //EclReadAndPlay.println ("DEBUG", "Change read from the queue -----> : " + change.toString() ); 63 CSN RUVcsn=EclReadAndPlay.RUV.get(change.replicaIdentifier); 66 if ( change.csn == null ) 69 if (change.csn.compareTo(RUVcsn) < 0) { 71 EclReadAndPlay.println("DEBUG", "Operation " + change.changeNumberValue + " csn " 72 + change.csn + " has already been replayed"); 78 // Write change on stand-alone server 79 applicationConnection.apply(change); [all...] |
H A D | Change.java | 39 String change = ""; field in class:Change 125 change = attr.getStringValueArray()[0]; 126 if ( change.trim().endsWith("-") ) { 127 change = change.substring(0, change.length()-3) + "\r\n"; 129 String changeHasReplFixupOp=change.replaceFirst("targetDn", "dn") + "\r\n"; 137 change = attr.getStringValueArray()[0]; 138 if ( change.trim().endsWith("-") ) { 139 change [all...] |
/forgerock/opendj2-jel-hg/tests/staf-tests/shared/java/ldapjdk/ |
H A D | ImprovedLDAPConnection.java | 39 public void apply (Change change) { argument 41 for (String mychange: change.changes) { 75 LDAPEntry addEntry = new LDAPEntry ( change.dn, attrSet ); 81 EclReadAndPlay.println("ERROR", "Cannot add entry \"" + change.dn + "\" (csn=" 82 + change.csn + ")" ); 89 // LDAPAttribute myAttr = new LDAPAttribute ("nsuniqueid", change.nsUniqueId); 90 // LDAPAttribute myAttr = new LDAPAttribute ("entryuuid", change.nsUniqueId); 93 // this.modify( change.dn, mod ); 97 // + change.dn + "\" (csn=" + change [all...] |
H A D | Writer.java | 59 // Read change from the queue 60 Change change = q.take(); 61 //EclReadAndPlay.println ("DEBUG", "Change read from the queue -----> : " + change.toString() ); 63 CSN RUVcsn=EclReadAndPlay.RUV.get(change.replicaIdentifier); 66 if ( change.csn == null ) 69 if (change.csn.compareTo(RUVcsn) < 0) { 71 EclReadAndPlay.println("DEBUG", "Operation " + change.changeNumberValue + " csn " 72 + change.csn + " has already been replayed"); 78 // Write change on stand-alone server 79 applicationConnection.apply(change); [all...] |
H A D | Change.java | 39 String change = ""; field in class:Change 125 change = attr.getStringValueArray()[0]; 126 if ( change.trim().endsWith("-") ) { 127 change = change.substring(0, change.length()-3) + "\r\n"; 129 String changeHasReplFixupOp=change.replaceFirst("targetDn", "dn") + "\r\n"; 137 change = attr.getStringValueArray()[0]; 138 if ( change.trim().endsWith("-") ) { 139 change [all...] |
/forgerock/opendj2-hg/tests/staf-tests/shared/java/ldapjdk/ |
H A D | ImprovedLDAPConnection.java | 38 public void apply (Change change) { argument 40 for (String mychange: change.changes) { 74 LDAPEntry addEntry = new LDAPEntry ( change.dn, attrSet ); 80 EclReadAndPlay.println("ERROR", "Cannot add entry \"" + change.dn + "\" (csn=" 81 + change.csn + ")" ); 88 // LDAPAttribute myAttr = new LDAPAttribute ("nsuniqueid", change.nsUniqueId); 89 // LDAPAttribute myAttr = new LDAPAttribute ("entryuuid", change.nsUniqueId); 92 // this.modify( change.dn, mod ); 96 // + change.dn + "\" (csn=" + change [all...] |
H A D | Writer.java | 58 // Read change from the queue 59 Change change = q.take(); 60 //EclReadAndPlay.println ("DEBUG", "Change read from the queue -----> : " + change.toString() ); 62 CSN RUVcsn=EclReadAndPlay.RUV.get(change.replicaIdentifier); 65 if ( change.csn == null ) 68 if (change.csn.compareTo(RUVcsn) < 0) { 70 EclReadAndPlay.println("DEBUG", "Operation " + change.changeNumberValue + " csn " 71 + change.csn + " has already been replayed"); 77 // Write change on stand-alone server 78 applicationConnection.apply(change); [all...] |
H A D | Change.java | 38 String change = ""; field in class:Change 124 change = attr.getStringValueArray()[0]; 125 if ( change.trim().endsWith("-") ) { 126 change = change.substring(0, change.length()-3) + "\r\n"; 128 String changeHasReplFixupOp=change.replaceFirst("targetDn", "dn") + "\r\n"; 136 change = attr.getStringValueArray()[0]; 137 if ( change.trim().endsWith("-") ) { 138 change [all...] |
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/plugin/ |
H A D | RemotePendingChanges.java | 73 * another change to be completed. 164 for (PendingChange change : dependentChanges) 166 if (change.dependenciesIsCovered(state)) 168 dependentChanges.remove(change); 169 return change.getMsg(); 210 PendingChange change = pendingChanges.get(changeNumber); 211 if (change == null) 230 addDependency(change, pendingChange); 242 addDependency(change, pendingChange); 255 addDependency(change, pendingChang [all...] |
/forgerock/opendj2/src/server/org/opends/server/replication/plugin/ |
H A D | RemotePendingChanges.java | 62 * another change to be completed. 158 for (PendingChange change : dependentChanges) 160 if (change.dependenciesIsCovered(state)) 162 dependentChanges.remove(change); 163 return change.getLDAPUpdateMsg(); 204 final PendingChange change = pendingChanges.get(csn); 205 if (change == null) 226 addDependency(change, pendingChange); 238 addDependency(change, pendingChange); 251 addDependency(change, pendingChang [all...] |
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/plugin/ |
H A D | RemotePendingChanges.java | 73 * another change to be completed. 166 for (PendingChange change : dependentChanges) 168 if (change.dependenciesIsCovered(state)) 170 dependentChanges.remove(change); 171 return change.getMsg(); 212 PendingChange change = pendingChanges.get(changeNumber); 213 if (change == null) 232 addDependency(change, pendingChange); 244 addDependency(change, pendingChange); 257 addDependency(change, pendingChang [all...] |
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/plugin/ |
H A D | RemotePendingChanges.java | 73 * another change to be completed. 164 for (PendingChange change : dependentChanges) 166 if (change.dependenciesIsCovered(state)) 168 dependentChanges.remove(change); 169 return change.getMsg(); 210 PendingChange change = pendingChanges.get(changeNumber); 211 if (change == null) 230 addDependency(change, pendingChange); 242 addDependency(change, pendingChange); 255 addDependency(change, pendingChang [all...] |
/forgerock/opendj2-hg/src/server/org/opends/server/replication/plugin/ |
H A D | RemotePendingChanges.java | 62 * another change to be completed. 158 for (PendingChange change : dependentChanges) 160 if (change.dependenciesIsCovered(state)) 162 dependentChanges.remove(change); 163 return change.getLDAPUpdateMsg(); 204 final PendingChange change = pendingChanges.get(csn); 205 if (change == null) 226 addDependency(change, pendingChange); 238 addDependency(change, pendingChange); 251 addDependency(change, pendingChang [all...] |
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/plugin/ |
H A D | RemotePendingChanges.java | 59 * another change to be completed. 152 for (PendingChange change : dependentChanges) 154 if (change.dependenciesIsCovered(state)) 156 dependentChanges.remove(change); 157 return change.getLDAPUpdateMsg(); 198 final PendingChange change = pendingChanges.get(csn); 199 if (change == null) 220 addDependency(change, pendingChange); 232 addDependency(change, pendingChange); 245 addDependency(change, pendingChang [all...] |
/forgerock/openidm-v4/openidm-ui/openidm-ui-admin/src/test/qunit/connector/ |
H A D | addConnectorTest.js | 50 addConnector.$el.find("#connectorName").change(); 52 addConnector.$el.find("#csvFilePath").change(); 54 addConnector.$el.find("#csvUniqueAttribute").change(); 56 addConnector.$el.find("#csvNameAttribute").change(); 61 addConnector.$el.find("#connectorType").change(); 68 QUnit.ok(addConnector.$el.find("#submitConnector").is(':disabled'), "Connector submit button disabled after type change");
|
/forgerock/openam-v13/openam-ldap-utils/src/main/java/org/forgerock/openam/ldap/ |
H A D | LdifUtils.java | 104 public Void visitChangeRecord(Void aVoid, AddRequest change) { 106 change.addControl(TransactionIdControl.newControl( 108 ld.add(change); 111 for (Attribute attr : change.getAllAttributes()) { 112 ModifyRequest modifyRequest = LDAPRequests.newModifyRequest(change.getName()); 122 DEBUG.warning("LDAPUtils.createSchemaFromLDIF - Could not add to schema: {}", change, e); 129 public Void visitChangeRecord(Void aVoid, ModifyRequest change) { 131 change.addControl(TransactionIdControl.newControl( 133 ld.modify(change); 135 DEBUG.warning("LDAPUtils.createSchemaFromLDIF - Could not modify schema: {}", change, [all...] |
/forgerock/openam/openam-ldap-utils/src/main/java/org/forgerock/openam/ldap/ |
H A D | LdifUtils.java | 104 public Void visitChangeRecord(Void aVoid, AddRequest change) { 106 change.addControl(TransactionIdControl.newControl( 108 ld.add(change); 111 for (Attribute attr : change.getAllAttributes()) { 112 ModifyRequest modifyRequest = LDAPRequests.newModifyRequest(change.getName()); 122 DEBUG.warning("LDAPUtils.createSchemaFromLDIF - Could not add to schema: {}", change, e); 129 public Void visitChangeRecord(Void aVoid, ModifyRequest change) { 131 change.addControl(TransactionIdControl.newControl( 133 ld.modify(change); 135 DEBUG.warning("LDAPUtils.createSchemaFromLDIF - Could not modify schema: {}", change, [all...] |
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/server/ |
H A D | ReplicationData.java | 49 * @param change the UpdateMsg used to create the ReplicationData. 51 public ReplicationData(UpdateMsg change) argument 57 this.setData(change.getBytes()); 71 * @return The generated change.
|