root/lang/perl/Isoginner/trunk/lib/Isoginner/Plugin/Listener/Inotify.pm @ 3381

package Isoginner::Plugin::Listener::Inotify;
use strict;
use warnings;
use base 'Isoginner::Plugin::Listener';

use Linux::Inotify2;

sub init {
    my $self = shift;
    $self->{inotify} = Linux::Inotify2->new;
}

sub attach : Hook('listener.attach') {
    my($self, $c) = @_;

    my $provider_id = $self->conf->{provider} or return;
    my @providers   = $c->listener->by_id($provider_id);

    for my $listener (@providers) {
        next unless $listener->type eq 'path';
        for my $path ($listener->objects) {
            $c->log( debug => "atacched $path by " . $listener->id);
            $self->{inotify}->watch($path, IN_ALL_EVENTS);
        }
        $listener->add_watcher( $self );
    }

    $c->call( engine_add_fd => $self->{inotify}->fileno => sub {
        my @events = $self->{inotify}->read;
        for my $event (@events) {
            $c->action($provider_id, $event);
        }
    });
}
1;