package async_inotify

  1. Overview
  2. Docs

Module Async_inotifySource

Async-friendly bindings to inotify, see man 7 inotify.

Be aware that the interface of inotify makes it easy to write code with race conditions or other subtle pitfalls. For instance, stat'ing a file then watching it means you have lost any events between the stat and the watch. Or the behavior when watching a path whose inode has multiple hardlinks is non-obvious.

Sourcetype t
Sourcetype file_info = string * Async.Unix.Stats.t
Sourcemodule Event : sig ... end
Sourcetype modify_event_selector = [
  1. | `Any_change
    (*

    Send a Modified event whenever the contents of the file changes (which can be very often when writing a large file)

    *)
  2. | `Closed_writable_fd
    (*

    Only send a Modify event when someone with a file descriptor with write permission to that file is closed. There are usually many fewer of these events (for large files), but they come later.

    *)
]
Sourceval create : ?modify_event_selector:modify_event_selector -> ?recursive:bool -> ?watch_new_dirs:bool -> string -> (t * file_info list) Async.Deferred.t

create path creates an inotify watching path. Returns the inotify type t itself and the list of files currently being watched. By default, recursively watches all subdirectories of the given path. See add_all for caveats.

Sourceval create_empty : modify_event_selector:modify_event_selector -> t Async.Deferred.t

create_empty modify_event_selector creates an inotify that watches nothing until add or add_all is called.

Sourceval stop : t -> unit Async.Deferred.t

stop t stop watching t

Sourceval add : t -> string -> unit Async.Deferred.t

add t path add the path to t to be watched

Sourceval add_all : ?skip_dir:((string * Async.Unix.Stats.t) -> bool Async.Deferred.t) -> t -> string -> file_info list Async.Deferred.t

add_all t path watches path and all its current subdirectories recursively. This may generate events in the event pipe that are older than the returned file info, in the presence of concurrent modification to the filesystem.

Sourceval remove : t -> string -> unit Async.Deferred.t

remove t path remove the path from t

Sourceval stream : t -> Event.t Async.Stream.t

stream t returns a stream of filesystem events

Sourceval pipe : t -> Event.t Async.Pipe.Reader.t

pipe t returns a pipe of filesystem events