ch.sourcepond.io.fileobserver.impl.fs

Class DedicatedFileSystem

java.lang.Object

ch.sourcepond.io.fileobserver.impl.fs.DedicatedFileSystem

All Implemented Interfaces:

Closeable, AutoCloseable, Runnable

public class DedicatedFileSystem
extends Object
implements Closeable, Runnable

Field Summary

Fields

Modifier and Type	Field and Description
static Runnable	EMPTY_CALLBACK

Method Summary

Modifier and Type	Method and Description
void	close() Stops the scanner thread which observes the watched directories for changes.
void	destinationChanged(ch.sourcepond.io.fileobserver.spi.WatchedDirectory pWatchedDirectory, Path pPrevious)
void	forceInform(EventDispatcher pDispatcher) Iterates through all registered directories and passes all their files to the PathChangeListener.modified(PathChangeEvent) of the observer specified.
Directory	getDirectory(Path pPath)
void	registerRootDirectory(ch.sourcepond.io.fileobserver.spi.WatchedDirectory pWatchedDirectory) This method is not thread-safe and must be synchronized externally.
void	run()
void	start() Starts the scanner thread which observes the watched directories for changes.
String	toString()
void	unregisterRootDirectory(Path pToBeUnregistered, ch.sourcepond.io.fileobserver.spi.WatchedDirectory pWatchedDirectory) This method is not thread-safe and must be synchronized externally.

Methods inherited from class java.lang.Object

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

Field Detail

EMPTY_CALLBACK

public static final Runnable EMPTY_CALLBACK

Method Detail

forceInform

public void forceInform(EventDispatcher pDispatcher)

Iterates through all registered directories and passes all their files to the PathChangeListener.modified(PathChangeEvent) of the observer specified. This is necessary for newly registered observers who need to know about all watched files. See registerRootDirectory(EventDispatcher, WatchedDirectory) and PathChangeHandler.pathModified(EventDispatcher, Path, Runnable, boolean) to get an idea how directories are registered with this object.

Note: it's guaranteed that the Path instances passed to the observer are regular files (not directories).

registerRootDirectory

public void registerRootDirectory(ch.sourcepond.io.fileobserver.spi.WatchedDirectory pWatchedDirectory)
                           throws IOException

This method is not thread-safe and must be synchronized externally.

Parameters:

pWatchedDirectory -

Throws:

IOException

unregisterRootDirectory

public void unregisterRootDirectory(Path pToBeUnregistered,
                                    ch.sourcepond.io.fileobserver.spi.WatchedDirectory pWatchedDirectory)

This method is not thread-safe and must be synchronized externally.

Parameters:

pWatchedDirectory -

getDirectory

public Directory getDirectory(Path pPath)

destinationChanged

public void destinationChanged(ch.sourcepond.io.fileobserver.spi.WatchedDirectory pWatchedDirectory,
                               Path pPrevious)
                        throws IOException

Throws:

IOException

close

public void close()

Stops the scanner thread which observes the watched directories for changes.

This must be named "stop" in order to be called from Felix DM (see Dependency Manager - Components)

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

toString

public String toString()

Overrides:

toString in class Object

start

public void start()

Starts the scanner thread which observes the watched directories for changes.

This must be named "start" in order to be called from Felix DM (see Dependency Manager - Components)

run

public void run()

Specified by:

run in interface Runnable