opends/src/server/org/opends/server/replication/protocol/AddMsg.java
@@ -364,6 +364,24 @@ } /** * Get the attributes of this add msg. * @throws LDAPException In case of LDAP decoding exception * @throws ASN1Exception In case of ASN1 decoding exception * @return the list of attributes */ public List<Attribute> getAttributes() throws LDAPException, ASN1Exception { List<Attribute> attrs = new ArrayList<Attribute>(); ASN1Reader reader = ASN1.getReader(encodedAttributes); while (reader.hasNextElement()) attrs.add(LDAPAttribute.decode(reader).toAttribute()); return attrs; } /** * Set the parent unique id of this add msg. * * @param uid the parent unique id. @@ -394,6 +412,7 @@ /** * {@inheritDoc} */ @Override public byte[] getBytes_V1() throws UnsupportedEncodingException { int length = encodedAttributes.length; opends/src/server/org/opends/server/replication/protocol/ModifyCommonMsg.java
@@ -26,9 +26,12 @@ */ package org.opends.server.replication.protocol; import java.util.ArrayList; import java.util.List; import org.opends.server.protocols.asn1.ASN1; import org.opends.server.protocols.asn1.ASN1Exception; import org.opends.server.protocols.asn1.ASN1Reader; import org.opends.server.protocols.asn1.ASN1Writer; import org.opends.server.protocols.ldap.LDAPAttribute; import org.opends.server.protocols.ldap.LDAPModification; @@ -38,6 +41,7 @@ import org.opends.server.types.AttributeType; import org.opends.server.types.AttributeUsage; import org.opends.server.types.ByteStringBuilder; import org.opends.server.types.LDAPException; import org.opends.server.types.Modification; /** @@ -97,6 +101,24 @@ } /** * Get the Modifications associated to the UpdateMsg to the provided value. * @throws LDAPException In case of LDAP decoding exception * @throws ASN1Exception In case of ASN1 decoding exception * @return the list of modifications */ public List<Modification> getMods() throws ASN1Exception, LDAPException { List<Modification> mods = new ArrayList<Modification>(); ASN1Reader reader = ASN1.getReader(encodedMods); while (reader.hasNextElement()) mods.add((LDAPModification.decode(reader)).toModification()); return mods; } /** * Encode an ArrayList of Modification into a byte[] suitable * for storage in a database or send on the network. * opends/src/server/org/opends/server/replication/protocol/ModifyDNMsg.java
@@ -401,6 +401,15 @@ } /** * Get the delete old rdn option. * @return true if delete old rdn option */ public boolean getDeleteOldRdn() { return deleteOldRdn; } /** * Get the new RDN of this operation. * * @return The new RDN of this operation. @@ -525,6 +534,7 @@ /** * {@inheritDoc} */ @Override public byte[] getBytes_V1() throws UnsupportedEncodingException { if (bytes == null)