view release on metacpan or  search on metacpan

Changes  view on Meta::CPAN

	- Add documentation of the pipeline protocol, to facilitate
	  the development of indepedent implementations in other
	  languages.

0.07  Tue Nov 22 15:05:30 GMT 2005
	- Add notes to the documentation about record identity and
	  indentifier.

0.06  Mon Oct 24 15:25:32 BST 2005
	- Both Read and Write pipes are now Unicode-clean, along with
	  the the temporary files spooled by the background reader.
	- New test-script t/2-unicode.t.

0.05  Mon Oct 10 15:18:29 BST 2005
	- Remove a test from t/0-creation.t that required a listening
	  server on localhost port 80 -- too many people inexplicably
	  do not run web servers :-)

0.04  Mon Oct  3 14:14:43 BST 2005
	- Total rewrite, not using OAI.  Much simpler and more reliable.
	- Better debugging output.

lib/Alvis/Pipeline.pm  view on Meta::CPAN

most are optional but some are mandatory:

=over 4

=item *

Read-pipes must specify both the C<host> and C<port> of the component
that they will read from, and C<spooldir>,
a directory that is writable to the user the process is running as.
(When files become available by being written down a write-pipe, they
are immediately read in the background, then stored in the
specified spool directory until picked up by a reader.)

=item *

Pipes may specify C<loglevel> [default 0]: higher levels
providing some commentary on under-the-hood behaviour.

=back

=head2 option()

lib/Alvis/Pipeline/Read.pm  view on Meta::CPAN

					Proto => "tcp",
					ReuseAddr => 1)
	or die("can't listen on port '" . $this->{port} . "': $!");

    while (1) {
	$this->log(1, "accepting connection");
	$this->{socket} = $listener->accept()
	    or die "can't accept connection: $!";

	binmode $this->{socket}, ":utf8";
	$this->log(1, "started background process, pid $$");
	while (1) {
	    my $doc = $this->_read();
	    last if !defined $doc;
	    $this->_store_file($doc);
	}
    }
}


sub _read {