import org.apache.archiva.common.plexusbridge.DigesterUtils;
import org.apache.archiva.common.plexusbridge.PlexusSisuBridge;
import org.apache.archiva.common.plexusbridge.PlexusSisuBridgeException;
-import org.apache.commons.io.FileUtils;
-import org.apache.commons.io.IOUtils;
import org.apache.archiva.transaction.FileTransaction;
import org.apache.archiva.transaction.TransactionException;
+import org.apache.commons.io.FileUtils;
+import org.apache.commons.io.IOUtils;
import org.apache.maven.artifact.Artifact;
import org.apache.maven.artifact.factory.ArtifactFactory;
import org.apache.maven.artifact.handler.manager.ArtifactHandlerManager;
{
/**
* {@link List}<{@link Digester}
- *
*/
private List<? extends Digester> digesters;
List<String> messages = warnings.get( artifact );
if ( messages == null )
{
- messages = new ArrayList<String>();
+ messages = new ArrayList<String>( 1 );
}
messages.add( message );
warnings.put( artifact, messages );
* under the License.
*/
+import org.apache.commons.io.FileUtils;
+import org.apache.commons.io.IOUtils;
+import org.apache.commons.lang.StringUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
-import org.apache.commons.io.FileUtils;
-import org.apache.commons.io.IOUtils;
-import org.apache.commons.lang.StringUtils;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
/**
* ChecksummedFile
- *
+ * <p/>
* <dl>
- * <lh>Terminology:</lh>
- * <dt>Checksum File</dt>
- * <dd>The file that contains the previously calculated checksum value for the reference file.
- * This is a text file with the extension ".sha1" or ".md5", and contains a single entry
- * consisting of an optional reference filename, and a checksum string.
- * </dd>
- * <dt>Reference File</dt>
- * <dd>The file that is being referenced in the checksum file.</dd>
+ * <lh>Terminology:</lh>
+ * <dt>Checksum File</dt>
+ * <dd>The file that contains the previously calculated checksum value for the reference file.
+ * This is a text file with the extension ".sha1" or ".md5", and contains a single entry
+ * consisting of an optional reference filename, and a checksum string.
+ * </dd>
+ * <dt>Reference File</dt>
+ * <dd>The file that is being referenced in the checksum file.</dd>
* </dl>
*
* @version $Id$
/**
* Construct a ChecksummedFile object.
- *
+ *
* @param referenceFile
*/
public ChecksummedFile( final File referenceFile )
/**
* Calculate the checksum based on a given checksum.
- *
+ *
* @param checksumAlgorithm the algorithm to use.
* @return the checksum string for the file.
* @throws IOException if unable to calculate the checksum.
/**
* Creates a checksum file of the provided referenceFile.
+ *
* @param checksumAlgorithm the hash to use.
- *
* @return the checksum File that was created.
* @throws IOException if there was a problem either reading the referenceFile, or writing the checksum file.
*/
/**
* Get the checksum file for the reference file and hash.
- *
+ *
* @param checksumAlgorithm the hash that we are interested in.
* @return the checksum file to return
*/
* <p>
* Given a checksum file, check to see if the file it represents is valid according to the checksum.
* </p>
- *
+ * <p/>
* <p>
* NOTE: Only supports single file checksums of type MD5 or SHA1.
* </p>
- *
+ *
* @param checksumFile the algorithms to check for.
* @return true if the checksum is valid for the file it represents. or if the checksum file does not exist.
* @throws IOException if the reading of the checksumFile or the file it refers to fails.
public boolean isValidChecksum( ChecksumAlgorithm algorithm )
throws IOException
{
- return isValidChecksums( new ChecksumAlgorithm[] { algorithm } );
+ return isValidChecksums( new ChecksumAlgorithm[]{ algorithm } );
}
/**
* Of any checksum files present, validate that the reference file conforms
- * the to the checksum.
- *
+ * the to the checksum.
+ *
* @param algorithms the algorithms to check for.
* @return true if the checksums report that the the reference file is valid, false if invalid.
*/
FileInputStream fis = null;
try
{
- List<Checksum> checksums = new ArrayList<Checksum>();
+ List<Checksum> checksums = new ArrayList<Checksum>( algorithms.length );
// Create checksum object for each algorithm.
for ( ChecksumAlgorithm checksumAlgorithm : algorithms )
{
/**
* Fix or create checksum files for the reference file.
- *
+ *
* @param algorithms the hashes to check for.
* @return true if checksums were created successfully.
*/
- public boolean fixChecksums( ChecksumAlgorithm algorithms[] )
+ public boolean fixChecksums( ChecksumAlgorithm[] algorithms )
{
- List<Checksum> checksums = new ArrayList<Checksum>();
+ List<Checksum> checksums = new ArrayList<Checksum>( algorithms.length );
// Create checksum object for each algorithm.
for ( ChecksumAlgorithm checksumAlgorithm : algorithms )
{
String rawChecksum = FileUtils.readFileToString( checksumFile );
String expectedChecksum = parseChecksum( rawChecksum, checksumAlgorithm, referenceFile.getName() );
- if ( ! StringUtils.equalsIgnoreCase( expectedChecksum, actualChecksum ) )
+ if ( !StringUtils.equalsIgnoreCase( expectedChecksum, actualChecksum ) )
{
// create checksum (again)
FileUtils.writeStringToFile( checksumFile, actualChecksum + " " + referenceFile.getName() );
// check if it is a remote metadata file
Pattern pattern = Pattern.compile( "maven-metadata-\\S*.xml" );
Matcher m = pattern.matcher( path );
- if( m.matches() )
+ if ( m.matches() )
{
- return filename.endsWith( path ) || ( "-".equals( filename ) )
- || filename.endsWith( "maven-metadata.xml" );
+ return filename.endsWith( path ) || ( "-".equals( filename ) ) || filename.endsWith( "maven-metadata.xml" );
}
-
+
return filename.endsWith( path ) || ( "-".equals( filename ) );
}
/**
* Parse a checksum string.
- *
+ * <p/>
* Validate the expected path, and expected checksum algorithm, then return
- * the trimmed checksum hex string.
- *
+ * the trimmed checksum hex string.
+ *
* @param rawChecksumString
* @param expectedHash
* @param expectedPath
String filename = m.group( 1 );
if ( !isValidChecksumPattern( filename, expectedPath ) )
{
- throw new IOException( "Supplied checksum file '" + filename + "' does not match expected file: '"
- + expectedPath + "'" );
+ throw new IOException(
+ "Supplied checksum file '" + filename + "' does not match expected file: '" + expectedPath + "'" );
}
trimmedChecksum = m.group( 2 );
}
String filename = m.group( 2 );
if ( !isValidChecksumPattern( filename, expectedPath ) )
{
- throw new IOException( "Supplied checksum file '" + filename + "' does not match expected file: '"
- + expectedPath + "'" );
+ throw new IOException(
+ "Supplied checksum file '" + filename + "' does not match expected file: '" + expectedPath
+ + "'" );
}
trimmedChecksum = m.group( 1 );
}
public VersionComparator()
{
- specialWords = new ArrayList<String>();
+ specialWords = new ArrayList<String>( 23 );
// ids that refer to LATEST
specialWords.add( "final" );
{
// Fix Proxy Connector Settings.
- List<ProxyConnectorConfiguration> proxyConnectorList = new ArrayList<ProxyConnectorConfiguration>();
// Create a copy of the list to read from (to prevent concurrent modification exceptions)
- proxyConnectorList.addAll( config.getProxyConnectors() );
+ List<ProxyConnectorConfiguration> proxyConnectorList =
+ new ArrayList<ProxyConnectorConfiguration>( config.getProxyConnectors() );
// Remove the old connector list.
config.getProxyConnectors().clear();
if ( !intersec.isEmpty() )
{
- List<String> knowContentConsumers = new ArrayList<String>();
+ List<String> knowContentConsumers =
+ new ArrayList<String>( configuration.getRepositoryScanning().getKnownContentConsumers().size() );
for ( String knowContentConsumer : configuration.getRepositoryScanning().getKnownContentConsumers() )
{
if ( !dbConsumers.contains( knowContentConsumer ) )
List<String> patterns = defaultTypeMap.get( filetype.getId() );
if ( patterns == null )
{
- patterns = new ArrayList<String>();
+ patterns = new ArrayList<String>( filetype.getPatterns().size() );
}
patterns.addAll( filetype.getPatterns() );
private File repositoryDir;
- private List<String> includes = new ArrayList<String>( );
+ private List<String> includes = new ArrayList<String>( 0 );
@Inject
- public ArtifactMissingChecksumsConsumer( ArchivaConfiguration configuration,
- FileTypes filetypes )
+ public ArtifactMissingChecksumsConsumer( ArchivaConfiguration configuration, FileTypes filetypes )
{
this.configuration = configuration;
this.filetypes = filetypes;
configuration.addChangeListener( this );
- initIncludes( );
+ initIncludes();
}
- public String getId( )
+ public String getId()
{
return this.id;
}
- public String getDescription( )
+ public String getDescription()
{
return this.description;
}
- public boolean isPermanent( )
+ public boolean isPermanent()
{
return false;
}
public void beginScan( ManagedRepository repo, Date whenGathered )
throws ConsumerException
{
- this.repositoryDir = new File( repo.getLocation( ) );
+ this.repositoryDir = new File( repo.getLocation() );
}
public void beginScan( ManagedRepository repo, Date whenGathered, boolean executeOnEntireRepo )
beginScan( repo, whenGathered );
}
- public void completeScan( )
+ public void completeScan()
{
/* do nothing */
}
public void completeScan( boolean executeOnEntireRepo )
{
- completeScan( );
+ completeScan();
}
- public List<String> getExcludes( )
+ public List<String> getExcludes()
{
- return getDefaultArtifactExclusions( );
+ return getDefaultArtifactExclusions();
}
- public List<String> getIncludes( )
+ public List<String> getIncludes()
{
return includes;
}
private void createFixChecksum( String path, ChecksumAlgorithm checksumAlgorithm[] )
{
File artifactFile = new File( this.repositoryDir, path );
- File checksumFile = new File( this.repositoryDir, path + checksumAlgorithm[0].getExt( ) );
+ File checksumFile = new File( this.repositoryDir, path + checksumAlgorithm[0].getExt() );
- if ( checksumFile.exists( ) )
+ if ( checksumFile.exists() )
{
checksum = new ChecksummedFile( artifactFile );
try
if ( !checksum.isValidChecksum( checksumAlgorithm[0] ) )
{
checksum.fixChecksums( checksumAlgorithm );
- triggerConsumerInfo( "Fixed checksum file " + checksumFile.getAbsolutePath( ) );
+ triggerConsumerInfo( "Fixed checksum file " + checksumFile.getAbsolutePath() );
}
}
catch ( IOException e )
{
triggerConsumerError( TYPE_CHECKSUM_CANNOT_CALC, "Cannot calculate checksum for file " + checksumFile +
- ": " + e.getMessage( ) );
+ ": " + e.getMessage() );
}
}
- else if ( !checksumFile.exists( ) )
+ else if ( !checksumFile.exists() )
{
checksum = new ChecksummedFile( artifactFile );
try
{
checksum.createChecksum( checksumAlgorithm[0] );
- triggerConsumerInfo( "Created missing checksum file " + checksumFile.getAbsolutePath( ) );
+ triggerConsumerInfo( "Created missing checksum file " + checksumFile.getAbsolutePath() );
}
catch ( IOException e )
{
triggerConsumerError( TYPE_CHECKSUM_CANNOT_CREATE, "Cannot create checksum for file " + checksumFile +
- ": " + e.getMessage( ) );
+ ": " + e.getMessage() );
}
}
else
{
triggerConsumerWarning( TYPE_CHECKSUM_NOT_FILE,
- "Checksum file " + checksumFile.getAbsolutePath( ) + " is not a file." );
+ "Checksum file " + checksumFile.getAbsolutePath() + " is not a file." );
}
}
{
if ( ConfigurationNames.isRepositoryScanning( propertyName ) )
{
- initIncludes( );
+ initIncludes();
}
}
/* do nothing */
}
- private void initIncludes( )
+ private void initIncludes()
{
- includes.clear( );
+ includes = new ArrayList<String>( filetypes.getFileTypePatterns( FileTypes.ARTIFACTS ) );
- includes.addAll( filetypes.getFileTypePatterns( FileTypes.ARTIFACTS ) );
}
@PostConstruct
- public void initialize( )
+ public void initialize()
{
configuration.addChangeListener( this );
- initIncludes( );
+ initIncludes();
}
}
*
* @version $Id$
*/
-@Service("knownRepositoryContentConsumer#auto-remove")
-@Scope("prototype")
+@Service( "knownRepositoryContentConsumer#auto-remove" )
+@Scope( "prototype" )
public class AutoRemoveConsumer
extends AbstractMonitoredConsumer
implements KnownRepositoryContentConsumer, RegistryListener
private FileTypes filetypes;
private File repositoryDir;
-
- private List<String> includes = new ArrayList<String>();
+
+ private List<String> includes = new ArrayList<String>( 0 );
public String getId()
{
public void processFile( String path, boolean executeOnEntireRepo )
throws ConsumerException
{
- processFile( path );
+ processFile( path );
}
public void afterConfigurationChange( Registry registry, String propertyName, Object propertyValue )
- {
+ {
if ( ConfigurationNames.isRepositoryScanning( propertyName ) )
{
initIncludes();
private void initIncludes()
{
- includes.clear();
-
- includes.addAll( filetypes.getFileTypePatterns( FileTypes.AUTO_REMOVE ) );
+ includes = new ArrayList<String>( filetypes.getFileTypePatterns( FileTypes.AUTO_REMOVE ) );
}
@PostConstruct
*/
import org.apache.archiva.admin.model.beans.ManagedRepository;
-import org.apache.commons.io.FileUtils;
import org.apache.archiva.consumers.AbstractMonitoredConsumer;
import org.apache.archiva.consumers.ConsumerException;
import org.apache.archiva.consumers.KnownRepositoryContentConsumer;
+import org.apache.commons.io.FileUtils;
import org.springframework.context.annotation.Scope;
import org.springframework.stereotype.Service;
*
* @version $Id$
*/
-@Service("knownRepositoryContentConsumer#auto-rename")
-@Scope("prototype")
+@Service( "knownRepositoryContentConsumer#auto-rename" )
+@Scope( "prototype" )
public class AutoRenameConsumer
extends AbstractMonitoredConsumer
implements KnownRepositoryContentConsumer
private File repositoryDir;
- private List<String> includes = new ArrayList<String>();
+ private List<String> includes = new ArrayList<String>( 3 );
private Map<String, String> extensionRenameMap = new HashMap<String, String>();
public void processFile( String path, boolean executeOnEntireRepo )
throws ConsumerException
{
- processFile( path );
+ processFile( path );
}
}
*
* @version $Id$
*/
-@Service("knownRepositoryContentConsumer#metadata-updater")
-@Scope("prototype")
+@Service( "knownRepositoryContentConsumer#metadata-updater" )
+@Scope( "prototype" )
public class MetadataUpdaterConsumer
extends AbstractMonitoredConsumer
implements KnownRepositoryContentConsumer, RegistryListener
{
private Logger log = LoggerFactory.getLogger( MetadataUpdaterConsumer.class );
-
+
/**
* default-value="metadata-updater"
*/
private File repositoryDir;
- private List<String> includes = new ArrayList<String>();
+ private List<String> includes = new ArrayList<String>( 0 );
private long scanStartTimestamp = 0;
}
catch ( LayoutException e )
{
- triggerConsumerWarning( TYPE_METADATA_BAD_INTERNAL_REF, "Unable to convert path [" + path
- + "] to an internal project reference: " + e.getMessage() );
+ triggerConsumerWarning( TYPE_METADATA_BAD_INTERNAL_REF,
+ "Unable to convert path [" + path + "] to an internal project reference: "
+ + e.getMessage() );
}
catch ( RepositoryMetadataException e )
{
- triggerConsumerError( TYPE_METADATA_WRITE_FAILURE, "Unable to write project metadata for artifact [" + path
- + "]: " + e.getMessage() );
+ triggerConsumerError( TYPE_METADATA_WRITE_FAILURE,
+ "Unable to write project metadata for artifact [" + path + "]: " + e.getMessage() );
}
catch ( IOException e )
{
- triggerConsumerWarning( TYPE_METADATA_IO, "Project metadata not written due to IO warning: "
- + e.getMessage() );
+ triggerConsumerWarning( TYPE_METADATA_IO,
+ "Project metadata not written due to IO warning: " + e.getMessage() );
}
catch ( ContentNotFoundException e )
{
}
catch ( LayoutException e )
{
- triggerConsumerWarning( TYPE_METADATA_BAD_INTERNAL_REF, "Unable to convert path [" + path
- + "] to an internal version reference: " + e.getMessage() );
+ triggerConsumerWarning( TYPE_METADATA_BAD_INTERNAL_REF,
+ "Unable to convert path [" + path + "] to an internal version reference: "
+ + e.getMessage() );
}
catch ( RepositoryMetadataException e )
{
- triggerConsumerError( TYPE_METADATA_WRITE_FAILURE, "Unable to write version metadata for artifact [" + path
- + "]: " + e.getMessage() );
+ triggerConsumerError( TYPE_METADATA_WRITE_FAILURE,
+ "Unable to write version metadata for artifact [" + path + "]: " + e.getMessage() );
}
catch ( IOException e )
{
- triggerConsumerWarning( TYPE_METADATA_IO, "Version metadata not written due to IO warning: "
- + e.getMessage() );
+ triggerConsumerWarning( TYPE_METADATA_IO,
+ "Version metadata not written due to IO warning: " + e.getMessage() );
}
catch ( ContentNotFoundException e )
{
private void initIncludes()
{
- includes.clear();
-
- includes.addAll( filetypes.getFileTypePatterns( FileTypes.ARTIFACTS ) );
+ includes = new ArrayList<String>( filetypes.getFileTypePatterns( FileTypes.ARTIFACTS ) );
}
@PostConstruct
private File repositoryDir;
- private List<String> includes = new ArrayList<String>();
+ private List<String> includes;
public String getId()
{
{
checksum = plexusSisuBridge.lookup( ChecksumFile.class );
List<Digester> allDigesters = new ArrayList<Digester>( digesterUtils.getAllDigesters() );
+ includes = new ArrayList<String>( allDigesters.size() );
for ( Digester digester : allDigesters )
{
includes.add( "**/*" + digester.getFilenameExtension() );
import org.apache.archiva.admin.model.beans.ManagedRepository;
import org.apache.archiva.admin.model.managed.ManagedRepositoryAdmin;
-import org.apache.archiva.metadata.repository.RepositorySession;
-import org.apache.archiva.metadata.repository.RepositorySessionFactory;
-import org.apache.archiva.repository.events.RepositoryListener;
import org.apache.archiva.configuration.ArchivaConfiguration;
import org.apache.archiva.configuration.ConfigurationNames;
import org.apache.archiva.configuration.FileTypes;
import org.apache.archiva.consumers.AbstractMonitoredConsumer;
import org.apache.archiva.consumers.ConsumerException;
import org.apache.archiva.consumers.KnownRepositoryContentConsumer;
+import org.apache.archiva.metadata.repository.RepositorySession;
+import org.apache.archiva.metadata.repository.RepositorySessionFactory;
import org.apache.archiva.repository.ManagedRepositoryContent;
import org.apache.archiva.repository.RepositoryContentFactory;
import org.apache.archiva.repository.RepositoryException;
import org.apache.archiva.repository.RepositoryNotFoundException;
+import org.apache.archiva.repository.events.RepositoryListener;
import org.apache.archiva.repository.metadata.MetadataTools;
import org.codehaus.plexus.registry.Registry;
import org.codehaus.plexus.registry.RegistryListener;
private void initIncludes()
{
- includes.clear();
-
- includes.addAll( filetypes.getFileTypePatterns( FileTypes.ARTIFACTS ) );
+ includes = new ArrayList<String>( filetypes.getFileTypePatterns( FileTypes.ARTIFACTS ) );
}
@PostConstruct
public void initialize()
{
- //this.listeners =
- // new ArrayList<RepositoryListener>( applicationContext.getBeansOfType( RepositoryListener.class ).values() );
configuration.addChangeListener( this );
initIncludes();
private NexusIndexer nexusIndexer;
- private List<String> includes = new ArrayList<String>();
+ private List<String> includes = new ArrayList<String>( 0 );
private ManagedRepository repository;
private void initIncludes()
{
- includes.clear();
+ List<String> indexable = filetypes.getFileTypePatterns( FileTypes.INDEXABLE_CONTENT );
+ List<String> artifacts = filetypes.getFileTypePatterns( FileTypes.ARTIFACTS );
- includes.addAll( filetypes.getFileTypePatterns( FileTypes.INDEXABLE_CONTENT ) );
+ includes = new ArrayList<String>( indexable.size() + artifacts.size() );
- includes.addAll( filetypes.getFileTypePatterns( FileTypes.ARTIFACTS ) );
+ includes.addAll( indexable );
+
+ includes.addAll( artifacts );
}
@PostConstruct
*/
import org.apache.archiva.admin.model.beans.ManagedRepository;
+import org.apache.archiva.common.utils.VersionUtil;
+import org.apache.archiva.configuration.ArchivaConfiguration;
+import org.apache.archiva.configuration.ConfigurationNames;
+import org.apache.archiva.configuration.FileTypes;
+import org.apache.archiva.consumers.AbstractMonitoredConsumer;
+import org.apache.archiva.consumers.ConsumerException;
+import org.apache.archiva.consumers.KnownRepositoryContentConsumer;
import org.apache.archiva.metadata.model.ArtifactMetadata;
import org.apache.archiva.metadata.model.ProjectMetadata;
import org.apache.archiva.metadata.model.ProjectVersionMetadata;
import org.apache.archiva.metadata.repository.storage.RepositoryStorage;
import org.apache.archiva.metadata.repository.storage.RepositoryStorageMetadataInvalidException;
import org.apache.archiva.metadata.repository.storage.RepositoryStorageMetadataNotFoundException;
-import org.apache.archiva.common.utils.VersionUtil;
-import org.apache.archiva.configuration.ArchivaConfiguration;
-import org.apache.archiva.configuration.ConfigurationNames;
-import org.apache.archiva.configuration.FileTypes;
-import org.apache.archiva.consumers.AbstractMonitoredConsumer;
-import org.apache.archiva.consumers.ConsumerException;
-import org.apache.archiva.consumers.KnownRepositoryContentConsumer;
import org.codehaus.plexus.registry.Registry;
import org.codehaus.plexus.registry.RegistryListener;
import org.slf4j.Logger;
*
* @version $Id: ArtifactUpdateDatabaseConsumer.java 718864 2008-11-19 06:33:35Z brett $
*/
-@Service("knownRepositoryContentConsumer#create-archiva-metadata")
-@Scope("prototype")
+@Service( "knownRepositoryContentConsumer#create-archiva-metadata" )
+@Scope( "prototype" )
public class ArchivaMetadataCreationConsumer
extends AbstractMonitoredConsumer
implements KnownRepositoryContentConsumer, RegistryListener
private Date whenGathered;
- private List<String> includes = new ArrayList<String>();
+ private List<String> includes = new ArrayList<String>( 0 );
/**
* FIXME: can be of other types
- *
*/
@Inject
private RepositorySessionFactory repositorySessionFactory;
/**
* FIXME: this needs to be configurable based on storage type - and could also be instantiated per repo. Change to a
* factory.
- *
*/
@Inject
- @Named(value = "repositoryStorage#maven2")
+ @Named( value = "repositoryStorage#maven2" )
private RepositoryStorage repositoryStorage;
private static final Logger log = LoggerFactory.getLogger( ArchivaMetadataCreationConsumer.class );
private void initIncludes()
{
- includes.clear();
-
- includes.addAll( filetypes.getFileTypePatterns( FileTypes.ARTIFACTS ) );
+ includes = new ArrayList<String>( filetypes.getFileTypePatterns( FileTypes.ARTIFACTS ) );
}
@PostConstruct
import org.apache.archiva.admin.model.beans.ManagedRepository;
import org.apache.archiva.common.plexusbridge.PlexusSisuBridge;
import org.apache.archiva.common.plexusbridge.PlexusSisuBridgeException;
-import org.apache.archiva.converter.RepositoryConversionException;
-import org.apache.archiva.repository.scanner.RepositoryScanner;
-import org.apache.archiva.repository.scanner.RepositoryScannerException;
import org.apache.archiva.common.utils.PathUtil;
import org.apache.archiva.consumers.InvalidRepositoryContentConsumer;
import org.apache.archiva.consumers.KnownRepositoryContentConsumer;
+import org.apache.archiva.converter.RepositoryConversionException;
+import org.apache.archiva.repository.scanner.RepositoryScanner;
+import org.apache.archiva.repository.scanner.RepositoryScannerException;
import org.apache.maven.artifact.repository.ArtifactRepository;
import org.apache.maven.artifact.repository.ArtifactRepositoryFactory;
import org.apache.maven.artifact.repository.layout.ArtifactRepositoryLayout;
legacyConverterConsumer.setExcludes( fileExclusionPatterns );
legacyConverterConsumer.setDestinationRepository( repository );
- List<KnownRepositoryContentConsumer> knownConsumers = new ArrayList<KnownRepositoryContentConsumer>();
+ List<KnownRepositoryContentConsumer> knownConsumers = new ArrayList<KnownRepositoryContentConsumer>( 1 );
knownConsumers.add( legacyConverterConsumer );
List<InvalidRepositoryContentConsumer> invalidConsumers = Collections.emptyList();
- List<String> ignoredContent = new ArrayList<String>();
- ignoredContent.addAll( Arrays.asList( RepositoryScanner.IGNORABLE_CONTENT ) );
+ List<String> ignoredContent = new ArrayList<String>( Arrays.asList( RepositoryScanner.IGNORABLE_CONTENT ) );
repoScanner.scan( legacyRepository, knownConsumers, invalidConsumers, ignoredContent,
RepositoryScanner.FRESH_SCAN );
public LegacyConverterArtifactConsumer( PlexusSisuBridge plexusSisuBridge )
throws PlexusSisuBridgeException
{
- includes = new ArrayList<String>();
+ includes = new ArrayList<String>( 3 );
includes.add( "**/*.jar" );
includes.add( "**/*.ear" );
includes.add( "**/*.war" );
import java.util.Properties;
/**
- * Utility methods for cloning various Archiva Model objects.
+ * Utility methods for cloning various Archiva Model objects.
*
* @version $Id$
*/
return cloned;
}
- @SuppressWarnings("unchecked")
+ @SuppressWarnings( "unchecked" )
public static Properties clone( Properties properties )
{
if ( properties == null )
return null;
}
- List<ArtifactReference> ret = new ArrayList<ArtifactReference>();
+ List<ArtifactReference> ret = new ArrayList<ArtifactReference>( artifactReferenceList.size() );
for ( ArtifactReference ref : artifactReferenceList )
{
return null;
}
- List<String> ret = new ArrayList<String>();
+ List<String> ret = new ArrayList<String>( simple.size() );
for ( String txt : simple )
{
* under the License.
*/
+import org.apache.archiva.common.utils.VersionUtil;
+import org.apache.commons.lang.StringUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
import java.io.File;
import java.util.ArrayList;
import java.util.Calendar;
import java.util.List;
import java.util.Properties;
-import org.apache.commons.lang.StringUtils;
-import org.apache.archiva.common.utils.VersionUtil;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
/**
- * AbstractUpdatePolicy
+ * AbstractUpdatePolicy
*
* @version $Id$
*/
implements PreDownloadPolicy
{
private Logger log = LoggerFactory.getLogger( AbstractUpdatePolicy.class );
-
+
/**
* The ALWAYS policy setting means that the artifact is always uipdated from the remote repo.
*/
public static final String ALWAYS = "always";
-
+
/**
* The NEVER policy setting means that the artifact is never updated from the remote repo.
*/
* the following conditions are met...
* </p>
* <ul>
- * <li>The local artifact is not present.</li>
- * <li>The local artifact has a last modified timestamp older than (now - 1 day).</li>
+ * <li>The local artifact is not present.</li>
+ * <li>The local artifact has a last modified timestamp older than (now - 1 day).</li>
* </ul>
*/
public static final String DAILY = "daily";
* the following conditions are met...
* </p>
* <ul>
- * <li>The local artifact is not present.</li>
- * <li>The local artifact has a last modified timestamp older than (now - 1 hour).</li>
+ * <li>The local artifact is not present.</li>
+ * <li>The local artifact has a last modified timestamp older than (now - 1 hour).</li>
* </ul>
*/
public static final String HOURLY = "hourly";
*/
public static final String ONCE = "once";
- private List<String> options = new ArrayList<String>();
+ private List<String> options = new ArrayList<String>( 5 );
public AbstractUpdatePolicy()
{
}
protected abstract boolean isSnapshotPolicy();
-
+
protected abstract String getUpdateMode();
-
+
public List<String> getOptions()
{
return options;
// Only process artifact file types.
return;
}
-
+
String version = request.getProperty( "version", "" );
boolean isSnapshotVersion = false;
if ( !options.contains( policySetting ) )
{
// Not a valid code.
- throw new PolicyConfigurationException( "Unknown " + getUpdateMode() + " policy setting [" + policySetting
- + "], valid settings are [" + StringUtils.join( options.iterator(), "," ) + "]" );
+ throw new PolicyConfigurationException(
+ "Unknown " + getUpdateMode() + " policy setting [" + policySetting + "], valid settings are ["
+ + StringUtils.join( options.iterator(), "," ) + "]" );
}
if ( ALWAYS.equals( policySetting ) )
if ( ONCE.equals( policySetting ) )
{
// File exists, but policy is once.
- throw new PolicyViolationException( "NO to update " + getUpdateMode() + ", policy is ONCE, and local file exist." );
+ throw new PolicyViolationException(
+ "NO to update " + getUpdateMode() + ", policy is ONCE, and local file exist." );
}
if ( DAILY.equals( policySetting ) )
Calendar fileCal = Calendar.getInstance();
fileCal.setTimeInMillis( localFile.lastModified() );
- if( cal.after( fileCal ) )
+ if ( cal.after( fileCal ) )
{
// Its ok.
return;
else
{
throw new PolicyViolationException( "NO to update " + getUpdateMode()
- + ", policy is DAILY, local file exist, and has been updated within the last day." );
+ + ", policy is DAILY, local file exist, and has been updated within the last day." );
}
}
Calendar fileCal = Calendar.getInstance();
fileCal.setTimeInMillis( localFile.lastModified() );
- if( cal.after( fileCal ) )
+ if ( cal.after( fileCal ) )
{
// Its ok.
return;
else
{
throw new PolicyViolationException( "NO to update " + getUpdateMode()
- + ", policy is HOURLY, local file exist, and has been updated within the last hour." );
+ + ", policy is HOURLY, local file exist, and has been updated within the last hour." );
}
}
- throw new PolicyConfigurationException( "Unable to process " + getUpdateMode()
- + " policy of [" + policySetting + "], please file a bug report." );
+ throw new PolicyConfigurationException(
+ "Unable to process " + getUpdateMode() + " policy of [" + policySetting + "], please file a bug report." );
}
}
* under the License.
*/
-import java.io.File;
-import java.util.ArrayList;
-import java.util.List;
-import java.util.Properties;
-
-import org.apache.commons.lang.StringUtils;
import org.apache.archiva.policies.urlcache.UrlFailureCache;
+import org.apache.commons.lang.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Service;
import javax.inject.Inject;
+import java.io.File;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Properties;
/**
* {@link PreDownloadPolicy} to check if the requested url has failed before.
*
* @version $Id$
*/
-@Service("preDownloadPolicy#cache-failures")
+@Service( "preDownloadPolicy#cache-failures" )
public class CachedFailuresPolicy
implements PreDownloadPolicy
{
private Logger log = LoggerFactory.getLogger( CachedFailuresPolicy.class );
-
+
/**
* The NO policy setting means that the the existence of old failures is <strong>not</strong> checked.
* All resource requests are allowed thru to the remote repo.
@Inject
private UrlFailureCache urlFailureCache;
- private List<String> options = new ArrayList<String>();
+ private List<String> options = new ArrayList<String>( 2 );
public CachedFailuresPolicy()
{
{
// Not a valid code.
throw new PolicyConfigurationException( "Unknown cache-failues policy setting [" + policySetting +
- "], valid settings are [" + StringUtils.join( options.iterator(), "," ) + "]" );
+ "], valid settings are [" + StringUtils.join(
+ options.iterator(), "," ) + "]" );
}
if ( NO.equals( policySetting ) )
* under the License.
*/
-import java.io.File;
-import java.util.ArrayList;
-import java.util.List;
-import java.util.Properties;
-
import org.apache.archiva.checksum.ChecksumAlgorithm;
import org.apache.archiva.checksum.ChecksummedFile;
import org.apache.commons.lang.StringUtils;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Service;
+import java.io.File;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Properties;
+
/**
* ChecksumPolicy - a policy applied after the download to see if the file has been downloaded
* successfully and completely (or not).
*
* @version $Id$
*/
-@Service("postDownloadPolicy#checksum")
+@Service( "postDownloadPolicy#checksum" )
public class ChecksumPolicy
implements PostDownloadPolicy
{
private Logger log = LoggerFactory.getLogger( ChecksumPolicy.class );
-
+
/**
* The IGNORE policy indicates that if the checksum policy is ignored, and
* the state of, contents of, or validity of the checksum files are not
* checked.
*/
public static final String IGNORE = "ignore";
-
+
/**
* The FAIL policy indicates that if the checksum does not match the
* downloaded file, then remove the downloaded artifact, and checksum
*/
public static final String FIX = "fix";
- private ChecksumAlgorithm[] algorithms = new ChecksumAlgorithm[] { ChecksumAlgorithm.SHA1, ChecksumAlgorithm.MD5 };
+ private ChecksumAlgorithm[] algorithms = new ChecksumAlgorithm[]{ ChecksumAlgorithm.SHA1, ChecksumAlgorithm.MD5 };
- private List<String> options = new ArrayList<String>();
+ private List<String> options = new ArrayList<String>( 3 );
public ChecksumPolicy()
{
{
return;
}
-
+
if ( !options.contains( policySetting ) )
{
// Not a valid code.
- throw new PolicyConfigurationException( "Unknown checksum policy setting [" + policySetting
- + "], valid settings are [" + StringUtils.join( options.iterator(), "," ) + "]" );
+ throw new PolicyConfigurationException(
+ "Unknown checksum policy setting [" + policySetting + "], valid settings are [" + StringUtils.join(
+ options.iterator(), "," ) + "]" );
}
if ( IGNORE.equals( policySetting ) )
if ( !localFile.exists() )
{
// Local File does not exist.
- throw new PolicyViolationException( "Checksum policy failure, local file " + localFile.getAbsolutePath()
- + " does not exist to check." );
+ throw new PolicyViolationException(
+ "Checksum policy failure, local file " + localFile.getAbsolutePath() + " does not exist to check." );
}
if ( FAIL.equals( policySetting ) )
file.delete();
}
}
-
+
localFile.delete();
- throw new PolicyViolationException( "Checksums do not match, policy set to FAIL, "
- + "deleting checksum files and local file " + localFile.getAbsolutePath() + "." );
+ throw new PolicyViolationException(
+ "Checksums do not match, policy set to FAIL, " + "deleting checksum files and local file "
+ + localFile.getAbsolutePath() + "." );
}
if ( FIX.equals( policySetting ) )
{
ChecksummedFile checksum = new ChecksummedFile( localFile );
- if( checksum.fixChecksums( algorithms ) )
+ if ( checksum.fixChecksums( algorithms ) )
{
log.debug( "Checksum policy set to FIX, checksum files have been updated." );
return;
}
else
{
- throw new PolicyViolationException( "Checksum policy set to FIX, "
- + "yet unable to update checksums for local file " + localFile.getAbsolutePath() + "." );
+ throw new PolicyViolationException(
+ "Checksum policy set to FIX, " + "yet unable to update checksums for local file "
+ + localFile.getAbsolutePath() + "." );
}
}
- throw new PolicyConfigurationException( "Unable to process checksum policy of [" + policySetting
- + "], please file a bug report." );
+ throw new PolicyConfigurationException(
+ "Unable to process checksum policy of [" + policySetting + "], please file a bug report." );
}
public String getDefaultOption()
* under the License.
*/
+import org.apache.commons.lang.StringUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.stereotype.Service;
+
import java.io.File;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.Properties;
-import org.apache.commons.lang.StringUtils;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.springframework.stereotype.Service;
-
/**
* PropagateErrorsPolicy - a policy applied on error to determine how to treat the error.
*/
-@Service("downloadErrorPolicy#propagate-errors")
+@Service( "downloadErrorPolicy#propagate-errors" )
public class PropagateErrorsDownloadPolicy
implements DownloadErrorPolicy
{
private Logger log = LoggerFactory.getLogger( PropagateErrorsDownloadPolicy.class );
-
+
/**
* Signifies any error should stop searching for other proxies.
*/
*/
public static final String IGNORE = "ignore";
- private List<String> options = new ArrayList<String>();
+ private List<String> options = new ArrayList<String>( 3 );
public PropagateErrorsDownloadPolicy()
{
{
// Not a valid code.
throw new PolicyConfigurationException( "Unknown error policy setting [" + policySetting +
- "], valid settings are [" + StringUtils.join( options.iterator(), "," ) + "]" );
+ "], valid settings are [" + StringUtils.join(
+ options.iterator(), "," ) + "]" );
}
if ( IGNORE.equals( policySetting ) )
* under the License.
*/
+import org.apache.commons.lang.StringUtils;
+import org.springframework.stereotype.Service;
+
import java.io.File;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.Properties;
-import org.apache.commons.lang.StringUtils;
-import org.springframework.stereotype.Service;
-
/**
* PropagateErrorsPolicy - a policy applied on error to determine how to treat the error.
*/
-@Service("downloadErrorPolicy#propagate-errors-on-update")
+@Service( "downloadErrorPolicy#propagate-errors-on-update" )
public class PropagateErrorsOnUpdateDownloadPolicy
implements DownloadErrorPolicy
{
*/
public static final String NOT_PRESENT = "artifact not already present";
- private List<String> options = new ArrayList<String>();
+ private List<String> options = new ArrayList<String>( 2 );
public PropagateErrorsOnUpdateDownloadPolicy()
{
}
public boolean applyPolicy( String policySetting, Properties request, File localFile, Exception exception,
- Map<String,Exception> previousExceptions )
+ Map<String, Exception> previousExceptions )
throws PolicyConfigurationException
{
if ( !options.contains( policySetting ) )
{
// Not a valid code.
- throw new PolicyConfigurationException( "Unknown error policy setting [" + policySetting
- + "], valid settings are [" + StringUtils.join( options.iterator(), "," ) + "]" );
+ throw new PolicyConfigurationException(
+ "Unknown error policy setting [" + policySetting + "], valid settings are [" + StringUtils.join(
+ options.iterator(), "," ) + "]" );
}
if ( ALWAYS.equals( policySetting ) )
return !localFile.exists();
}
- throw new PolicyConfigurationException( "Unable to process checksum policy of [" + policySetting
- + "], please file a bug report." );
+ throw new PolicyConfigurationException(
+ "Unable to process checksum policy of [" + policySetting + "], please file a bug report." );
}
public String getDefaultOption()
*/
import com.google.common.collect.Lists;
-import org.apache.archiva.proxy.common.WagonFactory;
-import org.apache.archiva.proxy.common.WagonFactoryException;
-import org.apache.archiva.scheduler.ArchivaTaskScheduler;
-import org.apache.archiva.scheduler.repository.RepositoryTask;
-import org.apache.commons.collections.CollectionUtils;
-import org.apache.commons.io.FileUtils;
-import org.apache.commons.lang.StringUtils;
import org.apache.archiva.configuration.ArchivaConfiguration;
import org.apache.archiva.configuration.ConfigurationNames;
import org.apache.archiva.configuration.NetworkProxyConfiguration;
import org.apache.archiva.policies.PreDownloadPolicy;
import org.apache.archiva.policies.ProxyDownloadException;
import org.apache.archiva.policies.urlcache.UrlFailureCache;
+import org.apache.archiva.proxy.common.WagonFactory;
+import org.apache.archiva.proxy.common.WagonFactoryException;
import org.apache.archiva.repository.ManagedRepositoryContent;
import org.apache.archiva.repository.RemoteRepositoryContent;
import org.apache.archiva.repository.RepositoryContentFactory;
import org.apache.archiva.repository.RepositoryNotFoundException;
import org.apache.archiva.repository.metadata.MetadataTools;
import org.apache.archiva.repository.metadata.RepositoryMetadataException;
+import org.apache.archiva.scheduler.ArchivaTaskScheduler;
+import org.apache.archiva.scheduler.repository.RepositoryTask;
+import org.apache.commons.collections.CollectionUtils;
+import org.apache.commons.io.FileUtils;
+import org.apache.commons.lang.StringUtils;
import org.apache.maven.wagon.ConnectionException;
import org.apache.maven.wagon.ResourceDoesNotExistException;
import org.apache.maven.wagon.Wagon;
connector.setDisabled( proxyConfig.isDisabled() );
// Copy any blacklist patterns.
- List<String> blacklist = new ArrayList<String>();
+ List<String> blacklist = new ArrayList<String>( 0 );
if ( CollectionUtils.isNotEmpty( proxyConfig.getBlackListPatterns() ) )
{
blacklist.addAll( proxyConfig.getBlackListPatterns() );
connector.setBlacklist( blacklist );
// Copy any whitelist patterns.
- List<String> whitelist = new ArrayList<String>();
+ List<String> whitelist = new ArrayList<String>( 0 );
if ( CollectionUtils.isNotEmpty( proxyConfig.getWhiteListPatterns() ) )
{
whitelist.addAll( proxyConfig.getWhiteListPatterns() );
if ( connectors == null )
{
// Create if we are the first.
- connectors = new ArrayList<ProxyConnector>();
+ connectors = new ArrayList<ProxyConnector>( 1 );
}
// Add the connector.
previousExceptions.remove( content.getId() );
}
- log.warn( "Transfer error from repository \"" + content.getRepository().getId() + "\" for artifact "
- + Keys.toKey( artifact ) + ", continuing to next repository. Error message: "
- + exception.getMessage() );
+ log.warn(
+ "Transfer error from repository \"" + content.getRepository().getId() + "\" for artifact " + Keys.toKey(
+ artifact ) + ", continuing to next repository. Error message: " + exception.getMessage() );
log.debug( "Full stack trace", exception );
}
public void afterConfigurationChange( Registry registry, String propertyName, Object propertyValue )
{
- if ( ConfigurationNames.isNetworkProxy( propertyName )
- || ConfigurationNames.isManagedRepositories( propertyName )
- || ConfigurationNames.isRemoteRepositories( propertyName ) || ConfigurationNames.isProxyConnector(
- propertyName ) )
+ if ( ConfigurationNames.isNetworkProxy( propertyName ) || ConfigurationNames.isManagedRepositories(
+ propertyName ) || ConfigurationNames.isRemoteRepositories( propertyName )
+ || ConfigurationNames.isProxyConnector( propertyName ) )
{
initConnectorsAndNetworkProxies();
}
{
if ( this.blackListPatterns == null )
{
- this.blackListPatterns = new ArrayList<String>();
+ this.blackListPatterns = new ArrayList<String>( 0 );
}
return this.blackListPatterns;
{
if ( this.whiteListPatterns == null )
{
- this.whiteListPatterns = new ArrayList<String>();
+ this.whiteListPatterns = new ArrayList<String>( 0 );
}
return this.whiteListPatterns;
{
if ( patterns == null )
{
- this.patterns = new ArrayList<String>();
+ this.patterns = new ArrayList<String>( 0 );
}
return patterns;
}
*
* @return List
*/
- public java.util.List<String> getRepositories()
+ public List<String> getRepositories()
{
if ( this.repositories == null )
{
- this.repositories = new ArrayList<String>();
+ this.repositories = new ArrayList<String>( 0 );
}
return this.repositories;
public List<LegacyArtifactPath> getLegacyArtifactPaths()
throws RepositoryAdminException
{
- List<LegacyArtifactPath> legacyArtifactPaths = new ArrayList<LegacyArtifactPath>();
+ List<LegacyArtifactPath> legacyArtifactPaths = new ArrayList<LegacyArtifactPath>(
+ getArchivaConfiguration().getConfiguration().getLegacyArtifactPaths().size() );
for ( org.apache.archiva.configuration.LegacyArtifactPath legacyArtifactPath : getArchivaConfiguration().getConfiguration().getLegacyArtifactPaths() )
{
legacyArtifactPaths.add(
if ( fileType.getPatterns().contains( pattern ) )
{
- throw new RepositoryAdminException( "File type [" + fileTypeId + "] already contains pattern [" + pattern + "]" );
+ throw new RepositoryAdminException(
+ "File type [" + fileTypeId + "] already contains pattern [" + pattern + "]" );
}
fileType.addPattern( pattern );
{
return Collections.emptyList();
}
- List<FileType> fileTypes = new ArrayList<FileType>();
+ List<FileType> fileTypes = new ArrayList<FileType>( configFileTypes.size() );
for ( org.apache.archiva.configuration.FileType fileType : configFileTypes )
{
fileTypes.add( new BeanReplicator().replicateBean( fileType, FileType.class ) );
import org.apache.archiva.admin.model.managed.ManagedRepositoryAdmin;
import org.apache.archiva.admin.repository.AbstractRepositoryAdmin;
import org.apache.archiva.audit.AuditEvent;
-import org.apache.commons.lang.StringUtils;
import org.apache.archiva.configuration.Configuration;
import org.apache.archiva.configuration.RepositoryGroupConfiguration;
+import org.apache.commons.lang.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Service;
public List<RepositoryGroup> getRepositoriesGroups()
throws RepositoryAdminException
{
- List<RepositoryGroup> repositoriesGroups = new ArrayList<RepositoryGroup>();
+ List<RepositoryGroup> repositoriesGroups =
+ new ArrayList<RepositoryGroup>( getArchivaConfiguration().getConfiguration().getRepositoryGroups().size() );
for ( RepositoryGroupConfiguration repositoryGroupConfiguration : getArchivaConfiguration().getConfiguration().getRepositoryGroups() )
{
import org.apache.archiva.admin.model.networkproxy.NetworkProxyAdmin;
import org.apache.archiva.admin.repository.AbstractRepositoryAdmin;
import org.apache.archiva.audit.AuditEvent;
-import org.apache.archiva.configuration.RemoteRepositoryConfiguration;
-import org.apache.commons.lang.StringUtils;
import org.apache.archiva.configuration.Configuration;
import org.apache.archiva.configuration.NetworkProxyConfiguration;
+import org.apache.archiva.configuration.RemoteRepositoryConfiguration;
+import org.apache.commons.lang.StringUtils;
import org.springframework.stereotype.Service;
-import java.rmi.Remote;
import java.util.ArrayList;
import java.util.List;
public List<NetworkProxy> getNetworkProxies()
throws RepositoryAdminException
{
- List<NetworkProxy> networkProxies = new ArrayList<NetworkProxy>();
+ List<NetworkProxy> networkProxies =
+ new ArrayList<NetworkProxy>( getArchivaConfiguration().getConfiguration().getNetworkProxies().size() );
for ( NetworkProxyConfiguration networkProxyConfiguration : getArchivaConfiguration().getConfiguration().getNetworkProxies() )
{
networkProxies.add( getNetworkProxy( networkProxyConfiguration ) );
NetworkProxyConfiguration networkProxyConfiguration = getNetworkProxyConfiguration( networkProxy );
configuration.removeNetworkProxy( networkProxyConfiguration );
- for ( RemoteRepositoryConfiguration rrc : configuration.getRemoteRepositories())
+ for ( RemoteRepositoryConfiguration rrc : configuration.getRemoteRepositories() )
{
- if (StringUtils.equals( rrc.getRemoteDownloadNetworkProxyId(), networkProxyId ))
+ if ( StringUtils.equals( rrc.getRemoteDownloadNetworkProxyId(), networkProxyId ) )
{
rrc.setRemoteDownloadNetworkProxyId( null );
}
import org.apache.archiva.admin.model.remote.RemoteRepositoryAdmin;
import org.apache.archiva.admin.repository.AbstractRepositoryAdmin;
import org.apache.archiva.audit.AuditEvent;
-import org.apache.commons.collections.CollectionUtils;
-import org.apache.commons.lang.StringUtils;
import org.apache.archiva.configuration.Configuration;
import org.apache.archiva.configuration.ProxyConnectorConfiguration;
import org.apache.archiva.configuration.functors.ProxyConnectorSelectionPredicate;
+import org.apache.commons.collections.CollectionUtils;
+import org.apache.commons.lang.StringUtils;
import org.springframework.stereotype.Service;
import javax.inject.Inject;
protected List<String> unescapePatterns( List<String> patterns )
{
- List<String> rawPatterns = new ArrayList<String>();
if ( patterns != null )
{
+ List<String> rawPatterns = new ArrayList<String>( patterns.size() );
for ( String pattern : patterns )
{
rawPatterns.add( StringUtils.replace( pattern, "\\\\", "\\" ) );
}
+ return rawPatterns;
}
- return rawPatterns;
+ return Collections.emptyList();
}
public Map<String, List<ProxyConnector>> getProxyConnectorAsMap()
List<ProxyConnector> connectors = proxyConnectorMap.get( key );
if ( connectors == null )
{
- connectors = new ArrayList<ProxyConnector>();
+ connectors = new ArrayList<ProxyConnector>( 1 );
proxyConnectorMap.put( key, connectors );
}
public List<RemoteRepository> getRemoteRepositories()
throws RepositoryAdminException
{
- List<RemoteRepository> remoteRepositories = new ArrayList<RemoteRepository>();
+ List<RemoteRepository> remoteRepositories = new ArrayList<RemoteRepository>(
+ getArchivaConfiguration().getConfiguration().getRemoteRepositories().size() );
for ( RemoteRepositoryConfiguration repositoryConfiguration : getArchivaConfiguration().getConfiguration().getRemoteRepositories() )
{
RemoteRepository remoteRepository =
{
try
{
- List<RepositoryGroup> repositoriesGroups = new ArrayList<RepositoryGroup>();
+ List<RepositoryGroup> repositoriesGroups =
+ new ArrayList<RepositoryGroup>( repositoryGroupAdmin.getRepositoriesGroups().size() );
for ( org.apache.archiva.admin.model.beans.RepositoryGroup repoGroup : repositoryGroupAdmin.getRepositoriesGroups() )
{
repositoriesGroups.add(
projects / archiva.git / commitdiff