Searched refs:change (Results 1 - 25 of 123) sorted by relevance

12345

/forgerock/opendj-b2.6/tests/staf-tests/shared/java/ldapjdk/
H A DImprovedLDAPConnection.java39 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 DWriter.java59 // 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 DChange.java39 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 DImprovedLDAPConnection.java38 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 DWriter.java58 // 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 DChange.java38 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 DImprovedLDAPConnection.java39 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 DWriter.java59 // 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 DChange.java39 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 DImprovedLDAPConnection.java39 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 DWriter.java59 // 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 DChange.java39 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 DImprovedLDAPConnection.java38 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 DWriter.java58 // 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 DChange.java38 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 DRemotePendingChanges.java73 * 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 DRemotePendingChanges.java62 * 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 DRemotePendingChanges.java73 * 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 DRemotePendingChanges.java73 * 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 DRemotePendingChanges.java62 * 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 DRemotePendingChanges.java59 * 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 DaddConnectorTest.js50 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 DLdifUtils.java104 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 DLdifUtils.java104 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 DReplicationData.java49 * @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.

Completed in 138 milliseconds

12345