com.facebook.buck.io.watchman

Class WatchmanWatcher

java.lang.Object

com.facebook.buck.io.watchman.WatchmanWatcher

public class WatchmanWatcher
extends Object

Queries Watchman for changes to a path.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	WatchmanWatcher.CursorType
static class	WatchmanWatcher.FreshInstanceAction

Constructor Summary

Constructors

Constructor and Description
WatchmanWatcher(Watchman watchman, com.google.common.eventbus.EventBus fileChangeEventBus, com.google.common.collect.ImmutableSet<PathMatcher> ignorePaths, Map<AbsPath,WatchmanCursor> cursors, int numThreads)

Method Summary

Modifier and Type	Method and Description
void	postEvents(BuckEventBus buckEventBus, WatchmanWatcher.FreshInstanceAction freshInstanceAction) Query Watchman for file change events.

Methods inherited from class java.lang.Object

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

Constructor Detail

WatchmanWatcher

public WatchmanWatcher(Watchman watchman,
                       com.google.common.eventbus.EventBus fileChangeEventBus,
                       com.google.common.collect.ImmutableSet<PathMatcher> ignorePaths,
                       Map<AbsPath,WatchmanCursor> cursors,
                       int numThreads)

Method Detail

postEvents

public void postEvents(BuckEventBus buckEventBus,
                       WatchmanWatcher.FreshInstanceAction freshInstanceAction)
                throws IOException,
                       InterruptedException

Query Watchman for file change events. If too many events are pending or an error occurs an overflow event is posted to the EventBus signalling that events may have been lost (and so typically caches must be cleared to avoid inconsistency). Interruptions and IOExceptions are propagated to callers, but typically if overflow events are handled conservatively by subscribers then no other remedial action is required.

Any diagnostics posted by Watchman are added to watchmanDiagnosticCache.

Throws:

IOException

InterruptedException