Package aQute.bnd.resource.repository

Class ResourceRepositoryImpl

java.lang.Object

aQute.bnd.resource.repository.ResourceRepositoryImpl

All Implemented Interfaces:

ResourceRepository

public class ResourceRepositoryImpl
extends Object
implements ResourceRepository

This class implements a hidden repository. This repo is kept in a text file that is under scm control. Files are fetched on demand. The idea is that bnd will bootstrap from this repo and downloads plugins. These plugins then provide faces on this hidden repository.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ResourceRepositoryImpl.FileLayout	Class maintains the info stored in the text file in the cnf directory that holds our contents.

Nested classes/interfaces inherited from interface aQute.bnd.service.repository.ResourceRepository

ResourceRepository.Listener, ResourceRepository.ResourceRepositoryEvent, ResourceRepository.TYPE

Field Summary

Fields

Modifier and Type	Field	Description
private File	cache
(package private) static JSONCodec	codec
private URLConnectionHandler	connector
private boolean	dirty
protected static final RepositoryPlugin.DownloadListener[]	EMPTY_LISTENER
private Executor	executor
private Map<URI,Long>	failures
private File	hosting
private ResourceRepositoryImpl.FileLayout	index
private File	indexFile
(package private) final Semaphore	limitDownloads
private final List<ResourceRepository.Listener>	listeners
private static final org.slf4j.Logger	logger
(package private) final MultiMap<File,RepositoryPlugin.DownloadListener>	queues
private Reporter	reporter
private static Comparator<SearchableRepository.ResourceDescriptor>	RESOURCE_DESCRIPTOR_COMPARATOR
private static final long	THRESHOLD

Fields inherited from interface aQute.bnd.service.repository.ResourceRepository

FILENAME

Constructor Summary

Constructors

Constructor	Description
ResourceRepositoryImpl()

Method Summary

Modifier and Type	Method	Description
boolean	add(String repoId, SearchableRepository.ResourceDescriptor rd)	Add a resource descriptor to the index.
void	addListener(ResourceRepository.Listener rrl)	Add a new event listener
(package private) void	delete(byte[] id)	Delete a resource from the text file (not from the cache)
boolean	delete(String repoId, byte[] id)
boolean	deleteCache(byte[] id)	Delete a cache entry
(package private) void	download(SearchableRepository.ResourceDescriptor rds, File path)
(package private) void	download0(URI url, File path, byte[] sha)
private void	event(ResourceRepository.TYPE type, SearchableRepository.ResourceDescriptor rds, Exception exception)	Dispatch the events
(package private) void	fail(Exception e, RepositoryPlugin.DownloadListener[] blockers, File file)
List<ResourceDescriptorImpl>	filter(String repoId, String filter)	List the resources.
SortedSet<SearchableRepository.ResourceDescriptor>	find(String repoId, String bsn, VersionRange range)
File	getCacheDir(String name)
private ResourceRepositoryImpl.FileLayout	getIndex()	Get the index, load it if necessary
File	getResource(byte[] rd, RepositoryPlugin.DownloadListener... blockers)	Get the file belonging to a Resource Descriptor
ResourceDescriptorImpl	getResourceDescriptor(byte[] rd)	List the resources.
(package private) void	ok(RepositoryPlugin.DownloadListener[] blockers, File file)	Just report success to all download listeners
void	removeListener(ResourceRepository.Listener rrl)	Remove an event listener
private void	save()	Save the index file.
void	setCache(File cache)
private void	setDirty()	Set dirty for save.
void	setExecutor(Executor executor)
void	setIndexFile(File file)
void	setReporter(Reporter processor)
void	setURLConnector(URLConnectionHandler connector)
private boolean	sleep(int i)	Sleep function that does not throw InterruptedException
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Details

logger

private static final org.slf4j.Logger logger

RESOURCE_DESCRIPTOR_COMPARATOR

private static Comparator<SearchableRepository.ResourceDescriptor> RESOURCE_DESCRIPTOR_COMPARATOR

THRESHOLD

private static final long THRESHOLD

See Also:

• Constant Field Values

EMPTY_LISTENER

protected static final RepositoryPlugin.DownloadListener[] EMPTY_LISTENER

codec

static JSONCodec codec

listeners

private final List<ResourceRepository.Listener> listeners

dirty

private boolean dirty

index

private ResourceRepositoryImpl.FileLayout index

failures

private Map<URI,Long> failures

cache

private File cache

hosting

private File hosting

reporter

private Reporter reporter

executor

private Executor executor

indexFile

private File indexFile

connector

private URLConnectionHandler connector

queues

final MultiMap<File,RepositoryPlugin.DownloadListener> queues

limitDownloads

final Semaphore limitDownloads

Constructor Details

ResourceRepositoryImpl

public ResourceRepositoryImpl()

Method Details

filter

public List<ResourceDescriptorImpl> filter(String repoId,
 String filter)
                                    throws Exception

List the resources. We skip the filter for now.

Specified by:

filter in interface ResourceRepository

filter - An OSGi filter matched against the SearchableRepository.ResourceDescriptor

Returns:

an immutable list of resource descriptors

Throws:

Exception

delete

void delete(byte[] id)
     throws Exception

Delete a resource from the text file (not from the cache)

Throws:

Exception

delete

public boolean delete(String repoId,
 byte[] id)
               throws Exception

Specified by:

delete in interface ResourceRepository

Throws:

Exception

deleteCache

public boolean deleteCache(byte[] id)
                    throws Exception

Delete a cache entry

Specified by:

deleteCache in interface ResourceRepository

Throws:

Exception

add

public boolean add(String repoId,
 SearchableRepository.ResourceDescriptor rd)
            throws Exception

Add a resource descriptor to the index.

Specified by:

add in interface ResourceRepository

Throws:

Exception

getResource

public File getResource(byte[] rd,
 RepositoryPlugin.DownloadListener... blockers)
                 throws Exception

Get the file belonging to a Resource Descriptor

Specified by:

getResource in interface ResourceRepository

Throws:

Exception

addListener

public void addListener(ResourceRepository.Listener rrl)

Add a new event listener

Specified by:

addListener in interface ResourceRepository

removeListener

public void removeListener(ResourceRepository.Listener rrl)

Remove an event listener

setDirty

private void setDirty()

Set dirty for save. Save is a noop if not dirty

getResourceDescriptor

public ResourceDescriptorImpl getResourceDescriptor(byte[] rd)
                                             throws Exception

List the resources. We skip the filter for now.

Specified by:

getResourceDescriptor in interface ResourceRepository

Throws:

Exception

ok

void ok(RepositoryPlugin.DownloadListener[] blockers,
 File file)

Just report success to all download listeners

Parameters:

blockers -

file -

fail

void fail(Exception e,
 RepositoryPlugin.DownloadListener[] blockers,
 File file)

download

void download(SearchableRepository.ResourceDescriptor rds,
 File path)
       throws Exception

Throws:

Exception

download0

void download0(URI url,
 File path,
 byte[] sha)
        throws Exception

Throws:

Exception

event

private void event(ResourceRepository.TYPE type,
 SearchableRepository.ResourceDescriptor rds,
 Exception exception)

Dispatch the events

Parameters:

type -

rds -

exception -

sleep

private boolean sleep(int i)

Sleep function that does not throw InterruptedException

Parameters:

i -

save

private void save()
           throws Exception

Save the index file.

Throws:

Exception

getIndex

private ResourceRepositoryImpl.FileLayout getIndex()
                                            throws Exception

Get the index, load it if necessary

Throws:

Exception

setReporter

public void setReporter(Reporter processor)

setIndexFile

public void setIndexFile(File file)

setCache

public void setCache(File cache)

setExecutor

public void setExecutor(Executor executor)
                 throws Exception

Throws:

Exception

setURLConnector

public void setURLConnector(URLConnectionHandler connector)
                     throws Exception

Throws:

Exception

find

public SortedSet<SearchableRepository.ResourceDescriptor> find(String repoId,
 String bsn,
 VersionRange range)
                                                        throws Exception

Specified by:

find in interface ResourceRepository

Throws:

Exception

getCacheDir

public File getCacheDir(String name)

Specified by:

getCacheDir in interface ResourceRepository

toString

public String toString()

Overrides:

toString in class Object