POE/jobs-tasks/followtail.pl


#sub POE::Kernel::ASSERT_DEFAULT () { 1 }
#sub POE::Kernel::TRACE_DEFAULT () { 1 }

use POE qw ( Wheel::FollowTail Driver::SysRW Filter::Line Filter::Stream );
use IO::File;

my $input_event_name = 'got_input';
my $error_event_name = 'got_error';
my $reset_event_name = 'got_reset';
my $offset = 0;

sub _start {
  my ($kernel, $session, $heap) = @_[ KERNEL, SESSION, HEAP ];

      $file_name = 'c:\var\home\amo\.mjamcmd';
      
      if (!-f $file_name) {
        open(FH, '>' . $file_name);
        print FH "hello world", "\n";
        close(FH);
      }
      
      #my $file_handle;
      #open($file_handle, '<' . $file_name);
      my $file_handle = IO::File->new("<$file_name");
      
      $heap->{wheel} = POE::Wheel::FollowTail->new(
        #Filename     => $file_name,                    # File to tail
        Handle     => $file_handle,                    # File to tail
        Driver       => POE::Driver::SysRW->new(), # How to read it
        Filter       => POE::Filter::Line->new(), # How to parse it
        PollInterval => 1,                  # How often to check it
        InputEvent   => $input_event_name,  # Event to emit upon input
        ErrorEvent   => $error_event_name,  # Event to emit upon error
        #ResetEvent   => $reset_event_name,  # Event to emit on file reset
        #SeekBack     => $offset,            # How far from EOF to start
      );
}

sub _stop {
  print "stopped", "\n";
}

sub got_input {
  print "====== input", "\n";
}
sub got_error {
  print "====== error", "\n";
}
sub got_reset {
  print "====== reset", "\n";
}

my @handlers = qw( 
  _start
  _stop
  got_input
  got_error
  got_reset
);

# the main session for the query-agent
POE::Session->create( 
  package_states => [ main => \@handlers ],
);

POE::Session->new
  ( _start => sub
    { my ($kernel, $session) = @_[KERNEL, SESSION];
      $kernel->post($session, 'spin a wheel');
    },
    'spin a wheel' => sub
    { my $kernel = $_[KERNEL];
      print "*** spin! ***\n";
      $kernel->delay('spin a wheel', 0.5);
    },
);

$poe_kernel->run();
1	joko	1.1
2			#sub POE::Kernel::ASSERT_DEFAULT () { 1 }
3			#sub POE::Kernel::TRACE_DEFAULT () { 1 }
4
5			use POE qw ( Wheel::FollowTail Driver::SysRW Filter::Line Filter::Stream );
6			use IO::File;
7
8			my $input_event_name = 'got_input';
9			my $error_event_name = 'got_error';
10			my $reset_event_name = 'got_reset';
11			my $offset = 0;
12
13			sub _start {
14			my ($kernel, $session, $heap) = @_[ KERNEL, SESSION, HEAP ];
15
16			$file_name = 'c:\var\home\amo\.mjamcmd';
17
18			if (!-f $file_name) {
19			open(FH, '>' . $file_name);
20			print FH "hello world", "\n";
21			close(FH);
22			}
23
24			#my $file_handle;
25			#open($file_handle, '<' . $file_name);
26			my $file_handle = IO::File->new("<$file_name");
27
28			$heap->{wheel} = POE::Wheel::FollowTail->new(
29			#Filename => $file_name, # File to tail
30			Handle => $file_handle, # File to tail
31			Driver => POE::Driver::SysRW->new(), # How to read it
32			Filter => POE::Filter::Line->new(), # How to parse it
33			PollInterval => 1, # How often to check it
34			InputEvent => $input_event_name, # Event to emit upon input
35			ErrorEvent => $error_event_name, # Event to emit upon error
36			#ResetEvent => $reset_event_name, # Event to emit on file reset
37			#SeekBack => $offset, # How far from EOF to start
38			);
39			}
40
41			sub _stop {
42			print "stopped", "\n";
43			}
44
45			sub got_input {
46			print "====== input", "\n";
47			}
48			sub got_error {
49			print "====== error", "\n";
50			}
51			sub got_reset {
52			print "====== reset", "\n";
53			}
54
55			my @handlers = qw(
56			_start
57			_stop
58			got_input
59			got_error
60			got_reset
61			);
62
63			# the main session for the query-agent
64			POE::Session->create(
65			package_states => [ main => \@handlers ],
66			);
67
68			POE::Session->new
69			( _start => sub
70			{ my ($kernel, $session) = @_[KERNEL, SESSION];
71			$kernel->post($session, 'spin a wheel');
72			},
73			'spin a wheel' => sub
74			{ my $kernel = $_[KERNEL];
75			print "* spin! *\n";
76			$kernel->delay('spin a wheel', 0.5);
77			},
78			);
79
80			$poe_kernel->run();
MailToCvsAdmin">MailToCvsAdmin	ViewVC Help
Powered by ViewVC 1.1.26