/*
* CDDL HEADER START
*
* The contents of this file are subject to the terms of the
* Common Development and Distribution License, Version 1.0 only
* (the "License"). You may not use this file except in compliance
* with the License.
*
* You can obtain a copy of the license at
* trunk/opends/resource/legal-notices/OpenDS.LICENSE
* or https://OpenDS.dev.java.net/OpenDS.LICENSE.
* See the License for the specific language governing permissions
* and limitations under the License.
*
* When distributing Covered Code, include this CDDL HEADER in each
* file and include the License file at
* trunk/opends/resource/legal-notices/OpenDS.LICENSE. If applicable,
* add the following below this CDDL HEADER, with the fields enclosed
* by brackets "[]" replaced with your own identifying information:
* Portions Copyright [yyyy] [name of copyright owner]
*
* CDDL HEADER END
*
*
* Copyright 2009 Sun Microsystems, Inc.
*/
package org.opends.sdk;
import java.util.*;
import com.sun.opends.sdk.util.Validator;
/**
* An implementation of the {@code Attribute} interface with predictable
* iteration order.
*
* Internally, attribute values are stored in a linked list and it's
* this list which defines the iteration ordering, which is the order in
* which elements were inserted into the set (insertion-order). This
* ordering is particularly useful in LDAP where clients generally
* appreciate having things returned in the same order they were
* presented.
*
* All operations are supported by this implementation.
*/
public final class LinkedAttribute extends AbstractAttribute
{
private static abstract class Impl
{
abstract boolean add(LinkedAttribute attribute, ByteString value);
boolean addAll(LinkedAttribute attribute,
Collection extends ByteString> values,
Collection super ByteString> duplicateValues)
throws NullPointerException
{
// TODO: could optimize if values is a BasicAttribute.
ensureCapacity(attribute, values.size());
boolean modified = false;
for (ByteString value : values)
{
if (add(attribute, value))
{
modified = true;
}
else if (duplicateValues != null)
{
duplicateValues.add(value);
}
}
resize(attribute);
return modified;
}
abstract void clear(LinkedAttribute attribute);
abstract boolean contains(LinkedAttribute attribute,
ByteString value);
boolean containsAll(LinkedAttribute attribute, Collection> values)
{
// TODO: could optimize if objects is a BasicAttribute.
for (Object value : values)
{
if (!contains(attribute, ByteString.valueOf(value)))
{
return false;
}
}
return true;
}
abstract void ensureCapacity(LinkedAttribute attribute, int size);
abstract ByteString firstValue(LinkedAttribute attribute)
throws NoSuchElementException;
abstract Iterator iterator(LinkedAttribute attribute);
abstract boolean remove(LinkedAttribute attribute, ByteString value);
boolean removeAll(LinkedAttribute attribute,
Collection values, Collection super T> missingValues)
{
// TODO: could optimize if objects is a BasicAttribute.
boolean modified = false;
for (T value : values)
{
if (remove(attribute, ByteString.valueOf(value)))
{
modified = true;
}
else if (missingValues != null)
{
missingValues.add(value);
}
}
return modified;
}
abstract void resize(LinkedAttribute attribute);
abstract boolean retainAll(LinkedAttribute attribute,
Collection values, Collection super T> missingValues);
abstract int size(LinkedAttribute attribute);
}
private static final class MultiValueImpl extends Impl
{
boolean add(LinkedAttribute attribute, ByteString value)
{
ByteString normalizedValue = normalizeValue(attribute, value);
if (attribute.multipleValues.put(normalizedValue, value) == null)
{
return true;
}
else
{
return false;
}
}
void clear(LinkedAttribute attribute)
{
attribute.multipleValues = null;
attribute.pimpl = ZERO_VALUE_IMPL;
}
boolean contains(LinkedAttribute attribute, ByteString value)
{
return attribute.multipleValues.containsKey(normalizeValue(
attribute, value));
}
void ensureCapacity(LinkedAttribute attribute, int size)
{
// Nothing to do.
}
ByteString firstValue(LinkedAttribute attribute)
throws NoSuchElementException
{
return attribute.multipleValues.values().iterator().next();
}
Iterator iterator(final LinkedAttribute attribute)
{
return new Iterator()
{
private Impl expectedImpl = MULTI_VALUE_IMPL;
private Iterator iterator = attribute.multipleValues
.values().iterator();
public boolean hasNext()
{
return iterator.hasNext();
}
public ByteString next()
{
if (attribute.pimpl != expectedImpl)
{
throw new ConcurrentModificationException();
}
else
{
return iterator.next();
}
}
public void remove()
{
if (attribute.pimpl != expectedImpl)
{
throw new ConcurrentModificationException();
}
else
{
iterator.remove();
// Resize if we have removed the second to last value.
if (attribute.multipleValues != null
&& attribute.multipleValues.size() == 1)
{
resize(attribute);
iterator = attribute.pimpl.iterator(attribute);
}
// Always update since we may change to single or zero value
// impl.
expectedImpl = attribute.pimpl;
}
}
};
}
boolean remove(LinkedAttribute attribute, ByteString value)
{
ByteString normalizedValue = normalizeValue(attribute, value);
if (attribute.multipleValues.remove(normalizedValue) != null)
{
resize(attribute);
return true;
}
else
{
return false;
}
}
void resize(LinkedAttribute attribute)
{
// May need to resize if initial size estimate was wrong (e.g. all
// values in added collection were the same).
switch (attribute.multipleValues.size())
{
case 0:
attribute.multipleValues = null;
attribute.pimpl = ZERO_VALUE_IMPL;
break;
case 1:
Map.Entry e = attribute.multipleValues
.entrySet().iterator().next();
attribute.singleValue = e.getValue();
attribute.normalizedSingleValue = e.getKey();
attribute.multipleValues = null;
attribute.pimpl = SINGLE_VALUE_IMPL;
break;
default:
// Nothing to do.
break;
}
}
boolean retainAll(LinkedAttribute attribute,
Collection values, Collection super T> missingValues)
{
// TODO: could optimize if objects is a BasicAttribute.
if (values.isEmpty())
{
clear(attribute);
return true;
}
Map valuesToRetain = new HashMap(
values.size());
for (T value : values)
{
valuesToRetain.put(normalizeValue(attribute, ByteString
.valueOf(value)), value);
}
boolean modified = false;
Iterator iterator = attribute.multipleValues.keySet()
.iterator();
while (iterator.hasNext())
{
ByteString normalizedValue = iterator.next();
if (valuesToRetain.remove(normalizedValue) == null)
{
modified = true;
iterator.remove();
}
}
if (missingValues != null)
{
missingValues.addAll(valuesToRetain.values());
}
resize(attribute);
return modified;
}
int size(LinkedAttribute attribute)
{
return attribute.multipleValues.size();
}
}
private static final class SingleValueImpl extends Impl
{
boolean add(LinkedAttribute attribute, ByteString value)
{
ByteString normalizedValue = normalizeValue(attribute, value);
if (attribute.normalizedSingleValue().equals(normalizedValue))
{
return false;
}
attribute.multipleValues = new LinkedHashMap(
2);
attribute.multipleValues.put(attribute.normalizedSingleValue,
attribute.singleValue);
attribute.multipleValues.put(normalizedValue, value);
attribute.singleValue = null;
attribute.normalizedSingleValue = null;
attribute.pimpl = MULTI_VALUE_IMPL;
return true;
}
void clear(LinkedAttribute attribute)
{
attribute.singleValue = null;
attribute.normalizedSingleValue = null;
attribute.pimpl = ZERO_VALUE_IMPL;
}
boolean contains(LinkedAttribute attribute, ByteString value)
{
ByteString normalizedValue = normalizeValue(attribute, value);
return attribute.normalizedSingleValue().equals(normalizedValue);
}
void ensureCapacity(LinkedAttribute attribute, int size)
{
if (size == 0)
{
return;
}
attribute.multipleValues = new LinkedHashMap(
1 + size);
attribute.multipleValues.put(attribute.normalizedSingleValue,
attribute.singleValue);
attribute.singleValue = null;
attribute.normalizedSingleValue = null;
attribute.pimpl = MULTI_VALUE_IMPL;
}
ByteString firstValue(LinkedAttribute attribute)
throws NoSuchElementException
{
if (attribute.singleValue != null)
{
return attribute.singleValue;
}
else
{
throw new NoSuchElementException();
}
}
Iterator iterator(final LinkedAttribute attribute)
{
return new Iterator()
{
private Impl expectedImpl = SINGLE_VALUE_IMPL;
private boolean hasNext = true;
public boolean hasNext()
{
return hasNext;
}
public ByteString next()
{
if (attribute.pimpl != expectedImpl)
{
throw new ConcurrentModificationException();
}
else if (hasNext)
{
hasNext = false;
return attribute.singleValue;
}
else
{
throw new NoSuchElementException();
}
}
public void remove()
{
if (attribute.pimpl != expectedImpl)
{
throw new ConcurrentModificationException();
}
else if (hasNext || attribute.singleValue == null)
{
throw new IllegalStateException();
}
else
{
clear(attribute);
expectedImpl = attribute.pimpl;
}
}
};
}
boolean remove(LinkedAttribute attribute, ByteString value)
{
if (contains(attribute, value))
{
clear(attribute);
return true;
}
else
{
return false;
}
}
void resize(LinkedAttribute attribute)
{
// Nothing to do.
}
boolean retainAll(LinkedAttribute attribute,
Collection values, Collection super T> missingValues)
{
// TODO: could optimize if objects is a BasicAttribute.
if (values.isEmpty())
{
clear(attribute);
return true;
}
ByteString normalizedSingleValue = attribute
.normalizedSingleValue();
boolean retained = false;
for (T value : values)
{
ByteString normalizedValue = normalizeValue(attribute,
ByteString.valueOf(value));
if (normalizedSingleValue.equals(normalizedValue))
{
if (missingValues == null)
{
// We can stop now.
return false;
}
retained = true;
}
else if (missingValues != null)
{
missingValues.add(value);
}
}
if (!retained)
{
clear(attribute);
return true;
}
else
{
return false;
}
}
int size(LinkedAttribute attribute)
{
return 1;
}
}
private static final class ZeroValueImpl extends Impl
{
boolean add(LinkedAttribute attribute, ByteString value)
{
attribute.singleValue = value;
attribute.pimpl = SINGLE_VALUE_IMPL;
return true;
}
void clear(LinkedAttribute attribute)
{
// Nothing to do.
}
boolean contains(LinkedAttribute attribute, ByteString value)
{
return false;
}
boolean containsAll(LinkedAttribute attribute, Collection> values)
{
return values.isEmpty();
}
void ensureCapacity(LinkedAttribute attribute, int size)
{
if (size < 2)
{
return;
}
attribute.multipleValues = new LinkedHashMap(
size);
attribute.pimpl = MULTI_VALUE_IMPL;
}
ByteString firstValue(LinkedAttribute attribute)
throws NoSuchElementException
{
throw new NoSuchElementException();
}
Iterator iterator(final LinkedAttribute attribute)
{
return new Iterator()
{
public boolean hasNext()
{
return false;
}
public ByteString next()
{
if (attribute.pimpl != ZERO_VALUE_IMPL)
{
throw new ConcurrentModificationException();
}
else
{
throw new NoSuchElementException();
}
}
public void remove()
{
if (attribute.pimpl != ZERO_VALUE_IMPL)
{
throw new ConcurrentModificationException();
}
else
{
throw new IllegalStateException();
}
}
};
}
boolean remove(LinkedAttribute attribute, ByteString value)
{
return false;
}
void resize(LinkedAttribute attribute)
{
// Nothing to do.
}
boolean retainAll(LinkedAttribute attribute,
Collection values, Collection super T> missingValues)
{
if (missingValues != null)
{
missingValues.addAll(values);
}
return false;
}
int size(LinkedAttribute attribute)
{
return 0;
}
}
private static final MultiValueImpl MULTI_VALUE_IMPL = new MultiValueImpl();
private static final SingleValueImpl SINGLE_VALUE_IMPL = new SingleValueImpl();
private static final ZeroValueImpl ZERO_VALUE_IMPL = new ZeroValueImpl();
private final AttributeDescription attributeDescription;
private Map multipleValues = null;
private ByteString normalizedSingleValue = null;
private Impl pimpl = ZERO_VALUE_IMPL;
private ByteString singleValue = null;
/**
* Creates a new attribute having the same attribute description and
* attribute values as {@code attribute}.
*
* @param attribute
* The attribute to be copied.
* @throws NullPointerException
* If {@code attribute} was {@code null}.
*/
public LinkedAttribute(Attribute attribute)
throws NullPointerException
{
this.attributeDescription = attribute.getAttributeDescription();
if (attribute instanceof LinkedAttribute)
{
LinkedAttribute other = (LinkedAttribute) attribute;
this.pimpl = other.pimpl;
this.singleValue = other.singleValue;
this.normalizedSingleValue = other.normalizedSingleValue;
if (other.multipleValues != null)
{
this.multipleValues = new LinkedHashMap(
other.multipleValues);
}
}
else
{
addAll(attribute);
}
}
/**
* Creates a new attribute having the specified attribute description
* and no attribute values.
*
* @param attributeDescription
* The attribute description.
* @throws NullPointerException
* If {@code attributeDescription} was {@code null}.
*/
public LinkedAttribute(AttributeDescription attributeDescription)
throws NullPointerException
{
Validator.ensureNotNull(attributeDescription);
this.attributeDescription = attributeDescription;
}
/**
* Creates a new attribute having the specified attribute description
* and no attribute values. The attribute description will be decoded
* using the default schema.
*
* @param attributeDescription
* The attribute description.
* @throws LocalizedIllegalArgumentException
* If {@code attributeDescription} could not be decoded
* using the default schema.
* @throws NullPointerException
* If {@code attributeDescription} was {@code null}.
*/
public LinkedAttribute(String attributeDescription)
throws LocalizedIllegalArgumentException, NullPointerException
{
this(AttributeDescription.valueOf(attributeDescription));
}
/**
* Creates a new attribute having the specified attribute description
* and single attribute value.
*
* @param attributeDescription
* The attribute description.
* @param value
* The single attribute value.
* @throws NullPointerException
* If {@code attributeDescription} or {@code value} was
* {@code null}.
*/
public LinkedAttribute(AttributeDescription attributeDescription,
ByteString value) throws NullPointerException
{
this(attributeDescription);
add(value);
}
/**
* Creates a new attribute having the specified attribute description
* and attribute values.
*
* @param attributeDescription
* The attribute description.
* @param values
* The attribute values.
* @throws NullPointerException
* If {@code attributeDescription} or {@code values} was
* {@code null}.
*/
public LinkedAttribute(AttributeDescription attributeDescription,
ByteString... values) throws NullPointerException
{
this(attributeDescription);
addAll(Arrays.asList(values));
}
/**
* Creates a new attribute having the specified attribute description
* and attribute values.
*
* @param attributeDescription
* The attribute description.
* @param values
* The attribute values.
* @throws NullPointerException
* If {@code attributeDescription} or {@code values} was
* {@code null}.
*/
public LinkedAttribute(AttributeDescription attributeDescription,
Collection values) throws NullPointerException
{
this(attributeDescription);
addAll(values);
}
/**
* Creates a new attribute having the specified attribute description
* and single attribute value. The attribute description will be
* decoded using the default schema.
*
* If {@code value} is not an instance of {@code ByteString} then it
* will be converted using the {@link ByteString#valueOf(Object)}
* method.
*
* @param attributeDescription
* The attribute description.
* @param value
* The single attribute value.
* @throws LocalizedIllegalArgumentException
* If {@code attributeDescription} could not be decoded
* using the default schema.
* @throws NullPointerException
* If {@code attributeDescription} or {@code value} was
* {@code null}.
*/
public LinkedAttribute(String attributeDescription, Object value)
throws LocalizedIllegalArgumentException, NullPointerException
{
this(attributeDescription);
add(ByteString.valueOf(value));
}
/**
* Creates a new attribute having the specified attribute description
* and attribute values. The attribute description will be decoded
* using the default schema.
*
* Any attribute values which are not instances of {@code ByteString}
* will be converted using the {@link ByteString#valueOf(Object)}
* method.
*
* @param attributeDescription
* The attribute description.
* @param values
* The attribute values.
* @throws LocalizedIllegalArgumentException
* If {@code attributeDescription} could not be decoded
* using the default schema.
* @throws NullPointerException
* If {@code attributeDescription} or {@code values} was
* {@code null}.
*/
public LinkedAttribute(String attributeDescription, Object... values)
throws LocalizedIllegalArgumentException, NullPointerException
{
this(attributeDescription);
for (Object value : values)
{
add(ByteString.valueOf(value));
}
}
/**
* {@inheritDoc}
*/
public boolean add(ByteString value) throws NullPointerException
{
Validator.ensureNotNull(value);
return pimpl.add(this, value);
}
/**
* {@inheritDoc}
*/
public boolean addAll(Collection extends ByteString> values,
Collection super ByteString> duplicateValues)
throws NullPointerException
{
Validator.ensureNotNull(values);
return pimpl.addAll(this, values, duplicateValues);
}
/**
* {@inheritDoc}
*/
public void clear()
{
pimpl.clear(this);
}
/**
* {@inheritDoc}
*/
public boolean containsAll(Collection> values)
throws NullPointerException
{
Validator.ensureNotNull(values);
return pimpl.containsAll(this, values);
}
/**
* {@inheritDoc}
*/
public ByteString firstValue() throws NoSuchElementException
{
return pimpl.firstValue(this);
}
/**
* {@inheritDoc}
*/
public AttributeDescription getAttributeDescription()
{
return attributeDescription;
}
/**
* {@inheritDoc}
*/
public Iterator iterator()
{
return pimpl.iterator(this);
}
/**
* {@inheritDoc}
*/
public boolean removeAll(Collection values,
Collection super T> missingValues) throws NullPointerException
{
Validator.ensureNotNull(values);
return pimpl.removeAll(this, values, missingValues);
}
/**
* {@inheritDoc}
*/
public boolean retainAll(Collection values,
Collection super T> missingValues) throws NullPointerException
{
Validator.ensureNotNull(values);
return pimpl.retainAll(this, values, missingValues);
}
/**
* {@inheritDoc}
*/
public int size()
{
return pimpl.size(this);
}
/**
* {@inheritDoc}
*/
public boolean contains(Object value) throws NullPointerException
{
Validator.ensureNotNull(value);
return pimpl.contains(this, ByteString.valueOf(value));
}
/**
* {@inheritDoc}
*/
public boolean remove(Object value) throws NullPointerException
{
Validator.ensureNotNull(value);
return pimpl.remove(this, ByteString.valueOf(value));
}
// Lazily computes the normalized single value.
private ByteString normalizedSingleValue()
{
if (normalizedSingleValue == null)
{
normalizedSingleValue = normalizeValue(this, singleValue);
}
return normalizedSingleValue;
}
}