opendj-sdk/opendj-config/src/main/java/org/forgerock/opendj/config/dsconfig/SetPropSubCommandHandler.java
@@ -22,15 +22,15 @@ * * * Copyright 2007-2010 Sun Microsystems, Inc. * Portions Copyright 2011-2014 ForgeRock AS * Portions Copyright 2011-2015 ForgeRock AS * Portions Copyright 2012 profiq, s.r.o. */ package org.forgerock.opendj.config.dsconfig; import static com.forgerock.opendj.dsconfig.DsconfigMessages.*; import static com.forgerock.opendj.cli.CliMessages.*; import static org.forgerock.opendj.config.dsconfig.ArgumentExceptionFactory.displayMissingMandatoryPropertyException; import static org.forgerock.opendj.config.dsconfig.ArgumentExceptionFactory.displayOperationRejectedException; import static com.forgerock.opendj.dsconfig.DsconfigMessages.*; import static org.forgerock.opendj.config.dsconfig.ArgumentExceptionFactory.*; import java.util.HashMap; import java.util.List; @@ -65,6 +65,7 @@ import org.forgerock.opendj.config.conditions.ContainsCondition; import org.forgerock.opendj.ldap.AuthorizationException; import org.forgerock.opendj.ldap.LdapException; import org.forgerock.util.Pair; import com.forgerock.opendj.cli.Argument; import com.forgerock.opendj.cli.ArgumentException; @@ -76,7 +77,6 @@ import com.forgerock.opendj.cli.StringArgument; import com.forgerock.opendj.cli.SubCommand; import com.forgerock.opendj.cli.SubCommandArgumentParser; import com.forgerock.opendj.util.Pair; /** * A sub-command handler which is used to modify the properties of a managed object. opendj-sdk/opendj-config/src/main/java/org/forgerock/opendj/config/server/ServerManagedObject.java
@@ -22,8 +22,8 @@ * * * Copyright 2006-2009 Sun Microsystems, Inc. * Portions Copyright 2015 ForgeRock AS. */ package org.forgerock.opendj.config.server; import static com.forgerock.opendj.ldap.AdminMessages.*; @@ -52,12 +52,10 @@ import org.forgerock.opendj.config.server.spi.ConfigDeleteListener; import org.forgerock.opendj.config.server.spi.ConfigurationRepository; import org.forgerock.opendj.ldap.DN; import org.forgerock.util.Pair; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import com.forgerock.opendj.util.Pair; /** * A server-side managed object. * @@ -520,9 +518,8 @@ public DN getDN() { if (configDN != null) { return configDN; } else { return DN.rootDN(); } return DN.rootDN(); } /** @@ -562,11 +559,10 @@ */ public <T> T getPropertyValue(PropertyDefinition<T> d) { Set<T> values = getPropertyValues(d); if (values.isEmpty()) { return null; } else { if (!values.isEmpty()) { return values.iterator().next(); } return null; } /** @@ -585,6 +581,7 @@ * If the property definition is not associated with this * managed object's definition. */ @Override @SuppressWarnings("unchecked") public <T> SortedSet<T> getPropertyValues(PropertyDefinition<T> d) { if (!properties.containsKey(d)) { opendj-sdk/opendj-core/src/main/java/com/forgerock/opendj/util/Pair.java
File was deleted opendj-sdk/opendj-core/src/main/java/org/forgerock/opendj/ldif/TemplateFile.java
@@ -22,7 +22,7 @@ * * * Copyright 2006-2009 Sun Microsystems, Inc. * Portions Copyright 2013 ForgeRock AS * Portions Copyright 2013-2015 ForgeRock AS */ package org.forgerock.opendj.ldif; @@ -79,11 +79,10 @@ import org.forgerock.opendj.ldif.TemplateTag.TagResult; import org.forgerock.opendj.ldif.TemplateTag.UnderscoreDNTag; import org.forgerock.opendj.ldif.TemplateTag.UnderscoreParentDNTag; import org.forgerock.util.Pair; import org.forgerock.util.Reject; import org.forgerock.util.Utils; import com.forgerock.opendj.util.Pair; /** * A template file allow to generate entries from a collection of constant * definitions, branches, and templates. opendj-sdk/opendj-core/src/test/java/com/forgerock/opendj/util/PairTestCase.java
File was deleted opendj-sdk/opendj-server-legacy/src/main/java/org/opends/server/backends/pluggable/DN2URI.java
@@ -43,6 +43,7 @@ import org.forgerock.opendj.ldap.ConditionResult; import org.forgerock.opendj.ldap.ResultCode; import org.forgerock.opendj.ldap.SearchScope; import org.forgerock.util.Pair; import org.opends.server.backends.pluggable.spi.Cursor; import org.opends.server.backends.pluggable.spi.ReadableStorage; import org.opends.server.backends.pluggable.spi.Storage; @@ -61,8 +62,6 @@ import org.opends.server.types.SearchResultReference; import org.opends.server.util.StaticUtils; import com.forgerock.opendj.util.Pair; /** * This class represents the referral database which contains URIs from referral * entries. opendj-sdk/opendj-server-legacy/src/main/java/org/opends/server/replication/common/MultiDomainServerState.java
@@ -22,10 +22,12 @@ * * * Copyright 2006-2009 Sun Microsystems, Inc. * Portions Copyright 2011-2014 ForgeRock AS * Portions Copyright 2011-2015 ForgeRock AS */ package org.opends.server.replication.common; import static org.opends.messages.ReplicationMessages.*; import java.util.Collections; import java.util.HashMap; import java.util.Iterator; @@ -37,13 +39,10 @@ import java.util.concurrent.ConcurrentSkipListMap; import org.forgerock.i18n.LocalizableMessage; import org.forgerock.opendj.ldap.ResultCode; import org.forgerock.util.Pair; import org.opends.server.types.DN; import org.opends.server.types.DirectoryException; import org.forgerock.opendj.ldap.ResultCode; import com.forgerock.opendj.util.Pair; import static org.opends.messages.ReplicationMessages.*; /** * This object is used to store a list of ServerState object, one by replication opendj-sdk/opendj-server-legacy/src/main/java/org/opends/server/replication/server/changelog/file/BlockLogReader.java
@@ -21,7 +21,7 @@ * CDDL HEADER END * * * Copyright 2014 ForgeRock AS. * Copyright 2014-2015 ForgeRock AS. */ package org.opends.server.replication.server.changelog.file; @@ -37,14 +37,13 @@ import org.forgerock.opendj.ldap.ByteString; import org.forgerock.opendj.ldap.ByteStringBuilder; import org.forgerock.util.Pair; import org.forgerock.util.Reject; import org.opends.server.replication.server.changelog.api.ChangelogException; import org.opends.server.replication.server.changelog.api.DBCursor.KeyMatchingStrategy; import org.opends.server.replication.server.changelog.api.DBCursor.PositionStrategy; import org.opends.server.util.StaticUtils; import com.forgerock.opendj.util.Pair; /** * A log reader with binary search support. * <p> opendj-sdk/opendj-server-legacy/src/main/java/org/opends/server/replication/server/changelog/file/FileChangelogDB.java
@@ -21,10 +21,14 @@ * CDDL HEADER END * * * Copyright 2014 ForgeRock AS * Copyright 2014-2015 ForgeRock AS */ package org.opends.server.replication.server.changelog.file; import static org.opends.messages.ReplicationMessages.*; import static org.opends.server.replication.server.changelog.api.DBCursor.PositionStrategy.*; import static org.opends.server.util.StaticUtils.*; import java.io.File; import java.util.Collections; import java.util.Iterator; @@ -41,6 +45,7 @@ import org.forgerock.i18n.LocalizableMessageBuilder; import org.forgerock.i18n.slf4j.LocalizedLogger; import org.forgerock.opendj.config.server.ConfigException; import org.forgerock.util.Pair; import org.forgerock.util.time.TimeService; import org.opends.server.admin.std.server.ReplicationServerCfg; import org.opends.server.api.DirectoryThread; @@ -67,12 +72,6 @@ import org.opends.server.util.StaticUtils; import org.opends.server.util.TimeThread; import com.forgerock.opendj.util.Pair; import static org.opends.messages.ReplicationMessages.*; import static org.opends.server.replication.server.changelog.api.DBCursor.PositionStrategy.*; import static org.opends.server.util.StaticUtils.*; /** * Log file implementation of the ChangelogDB interface. */ opendj-sdk/opendj-server-legacy/src/main/java/org/opends/server/replication/server/changelog/file/Log.java
@@ -49,6 +49,7 @@ import org.forgerock.i18n.LocalizableMessage; import org.forgerock.i18n.slf4j.LocalizedLogger; import org.forgerock.util.Pair; import org.forgerock.util.Reject; import org.forgerock.util.Utils; import org.forgerock.util.time.TimeService; @@ -59,8 +60,6 @@ import org.opends.server.replication.server.changelog.file.LogFile.LogFileCursor; import org.opends.server.util.StaticUtils; import com.forgerock.opendj.util.Pair; /** * A multi-file log that features appending key-value records and reading them * using a {@code DBCursor}. @@ -1271,6 +1270,7 @@ } /** {@inheritDoc} */ @Override public String toString() { return actAsEmptyCursor ? opendj-sdk/opendj-server-legacy/src/main/java/org/opends/server/replication/server/changelog/file/LogFile.java
@@ -21,7 +21,7 @@ * CDDL HEADER END * * * Copyright 2014 ForgeRock AS. * Copyright 2014-2015 ForgeRock AS. */ package org.opends.server.replication.server.changelog.file; @@ -36,14 +36,13 @@ import org.forgerock.i18n.LocalizableMessage; import org.forgerock.i18n.slf4j.LocalizedLogger; import org.forgerock.util.Pair; import org.forgerock.util.Reject; import org.opends.server.replication.server.changelog.api.ChangelogException; import org.opends.server.replication.server.changelog.api.DBCursor; import org.opends.server.replication.server.changelog.file.Log.RepositionableCursor; import org.opends.server.util.StaticUtils; import com.forgerock.opendj.util.Pair; /** * A log file, containing part of a {@code Log}. The log file may be: * <ul> @@ -413,6 +412,7 @@ } /** {@inheritDoc} */ @Override public void close() { if (isWriteEnabled) @@ -599,6 +599,7 @@ } /** {@inheritDoc} */ @Override public String toString() { return String.format("Cursor on log file: %s, current record: %s", logFile.logfile, currentRecord); opendj-sdk/opendj-server-legacy/src/main/java/org/opends/server/replication/server/changelog/je/CompositeDBCursor.java
@@ -21,21 +21,20 @@ * CDDL HEADER END * * * Copyright 2013-2014 ForgeRock AS * Copyright 2013-2015 ForgeRock AS */ package org.opends.server.replication.server.changelog.je; import java.util.*; import java.util.Map.Entry; import org.forgerock.util.Pair; import org.opends.server.replication.common.CSN; import org.opends.server.replication.protocol.UpdateMsg; import org.opends.server.replication.server.changelog.api.ChangelogException; import org.opends.server.replication.server.changelog.api.DBCursor; import org.opends.server.util.StaticUtils; import com.forgerock.opendj.util.Pair; /** * {@link DBCursor} implementation that iterates across a Collection of * {@link DBCursor}s, advancing from the oldest to the newest change cross all opendj-sdk/opendj-server-legacy/src/main/java/org/opends/server/replication/server/changelog/je/ECLMultiDomainDBCursor.java
@@ -20,21 +20,20 @@ * * CDDL HEADER END * * Copyright 2014 ForgeRock AS * Copyright 2014-2015 ForgeRock AS */ package org.opends.server.replication.server.changelog.je; import java.util.ArrayList; import java.util.List; import org.forgerock.util.Pair; import org.opends.server.replication.common.MultiDomainServerState; import org.opends.server.replication.protocol.UpdateMsg; import org.opends.server.replication.server.changelog.api.ChangelogException; import org.opends.server.replication.server.changelog.api.DBCursor; import org.opends.server.types.DN; import com.forgerock.opendj.util.Pair; /** * Multi domain DB cursor that only returns updates for the domains which have * been enabled for the external changelog. opendj-sdk/opendj-server-legacy/src/main/java/org/opends/server/replication/server/changelog/je/JEChangelogDB.java
@@ -21,10 +21,13 @@ * CDDL HEADER END * * * Portions Copyright 2013-2014 ForgeRock AS * Portions Copyright 2013-2015 ForgeRock AS */ package org.opends.server.replication.server.changelog.je; import static org.opends.messages.ReplicationMessages.*; import static org.opends.server.util.StaticUtils.*; import java.io.File; import java.util.Collections; import java.util.Iterator; @@ -41,6 +44,7 @@ import org.forgerock.i18n.LocalizableMessageBuilder; import org.forgerock.i18n.slf4j.LocalizedLogger; import org.forgerock.opendj.config.server.ConfigException; import org.forgerock.util.Pair; import org.opends.server.admin.std.server.ReplicationServerCfg; import org.opends.server.api.DirectoryThread; import org.opends.server.backends.ChangelogBackend; @@ -62,11 +66,6 @@ import org.opends.server.util.StaticUtils; import org.opends.server.util.TimeThread; import com.forgerock.opendj.util.Pair; import static org.opends.messages.ReplicationMessages.*; import static org.opends.server.util.StaticUtils.*; /** * JE implementation of the ChangelogDB interface. */ opendj-sdk/opendj-server-legacy/src/test/java/org/opends/server/backends/ChangelogBackendTestCase.java
@@ -21,10 +21,22 @@ * CDDL HEADER END * * * Copyright 2014 ForgeRock AS. * Copyright 2014-2015 ForgeRock AS. */ package org.opends.server.backends; import static org.assertj.core.api.Assertions.*; import static org.forgerock.opendj.ldap.ResultCode.*; import static org.opends.messages.ReplicationMessages.*; import static org.opends.server.TestCaseUtils.*; import static org.opends.server.replication.protocol.OperationContext.*; import static org.opends.server.replication.server.changelog.api.DBCursor.KeyMatchingStrategy.*; import static org.opends.server.replication.server.changelog.api.DBCursor.PositionStrategy.*; import static org.opends.server.util.CollectionUtils.*; import static org.opends.server.util.ServerConstants.*; import static org.opends.server.util.StaticUtils.*; import static org.testng.Assert.*; import java.io.ByteArrayOutputStream; import java.util.ArrayList; import java.util.Collections; @@ -40,6 +52,7 @@ import org.forgerock.opendj.ldap.ModificationType; import org.forgerock.opendj.ldap.ResultCode; import org.forgerock.opendj.ldap.SearchScope; import org.forgerock.util.Pair; import org.opends.server.admin.std.server.ExternalChangelogDomainCfg; import org.opends.server.api.Backend; import org.opends.server.backends.ChangelogBackend.ChangeNumberRange; @@ -98,20 +111,6 @@ import org.testng.annotations.DataProvider; import org.testng.annotations.Test; import com.forgerock.opendj.util.Pair; import static org.assertj.core.api.Assertions.*; import static org.forgerock.opendj.ldap.ResultCode.*; import static org.opends.messages.ReplicationMessages.*; import static org.opends.server.TestCaseUtils.*; import static org.opends.server.replication.protocol.OperationContext.*; import static org.opends.server.replication.server.changelog.api.DBCursor.KeyMatchingStrategy.*; import static org.opends.server.replication.server.changelog.api.DBCursor.PositionStrategy.*; import static org.opends.server.util.CollectionUtils.*; import static org.opends.server.util.ServerConstants.*; import static org.opends.server.util.StaticUtils.*; import static org.testng.Assert.*; @SuppressWarnings("javadoc") public class ChangelogBackendTestCase extends ReplicationTestCase { opendj-sdk/opendj-server-legacy/src/test/java/org/opends/server/replication/common/MultiDomainServerStateTest.java
@@ -22,20 +22,19 @@ * * * Copyright 2013-2014 ForgeRock AS * Portions Copyright 2014 ForgeRock AS * Portions Copyright 2014-2015 ForgeRock AS */ package org.opends.server.replication.common; import static org.assertj.core.api.Assertions.*; import static org.testng.Assert.*; import org.forgerock.util.Pair; import org.opends.server.replication.ReplicationTestCase; import org.opends.server.types.DN; import org.testng.annotations.BeforeClass; import org.testng.annotations.Test; import com.forgerock.opendj.util.Pair; import static org.assertj.core.api.Assertions.*; import static org.testng.Assert.*; @SuppressWarnings("javadoc") public class MultiDomainServerStateTest extends ReplicationTestCase { opendj-sdk/opendj-server-legacy/src/test/java/org/opends/server/replication/server/changelog/file/BlockLogReaderWriterTest.java
@@ -21,7 +21,7 @@ * CDDL HEADER END * * * Copyright 2014 ForgeRock AS. * Copyright 2014-2015 ForgeRock AS. */ package org.opends.server.replication.server.changelog.file; @@ -40,6 +40,7 @@ import org.forgerock.opendj.ldap.ByteSequenceReader; import org.forgerock.opendj.ldap.ByteString; import org.forgerock.opendj.ldap.ByteStringBuilder; import org.forgerock.util.Pair; import org.opends.server.DirectoryServerTestCase; import org.opends.server.TestCaseUtils; import org.opends.server.replication.server.changelog.api.ChangelogException; @@ -52,8 +53,6 @@ import org.testng.annotations.DataProvider; import org.testng.annotations.Test; import com.forgerock.opendj.util.Pair; @SuppressWarnings("javadoc") public class BlockLogReaderWriterTest extends DirectoryServerTestCase { @@ -516,6 +515,7 @@ */ private static class IntRecordParser implements RecordParser<Integer, Integer> { @Override public Record<Integer, Integer> decodeRecord(final ByteString data) throws DecodingException { ByteSequenceReader reader = data.asReader(); @@ -524,6 +524,7 @@ return Record.from(key, value); } @Override public ByteString encodeRecord(Record<Integer, Integer> record) { return new ByteStringBuilder().append((int) record.getKey()).append((int) record.getValue()).toByteString(); opendj-sdk/opendj-server-legacy/src/test/java/org/opends/server/replication/server/changelog/je/CompositeDBCursorTest.java
@@ -21,10 +21,14 @@ * CDDL HEADER END * * * Copyright 2013-2014 ForgeRock AS * Copyright 2013-2015 ForgeRock AS */ package org.opends.server.replication.server.changelog.je; import static org.forgerock.util.Pair.*; import static org.testng.Assert.*; import org.forgerock.util.Pair; import org.opends.server.DirectoryServerTestCase; import org.opends.server.replication.protocol.UpdateMsg; import org.opends.server.replication.server.changelog.api.ChangelogException; @@ -32,12 +36,6 @@ import org.testng.annotations.BeforeClass; import org.testng.annotations.Test; import com.forgerock.opendj.util.Pair; import static com.forgerock.opendj.util.Pair.*; import static org.testng.Assert.*; @SuppressWarnings({ "javadoc", "unchecked" }) public class CompositeDBCursorTest extends DirectoryServerTestCase {