File Coverage

blib/lib/Coro/PatchSet/Handle.pm

Criterion	Covered	Total	%
statement	4	6	66.6
branch			n/a
condition			n/a
subroutine	2	2	100.0
pod			n/a
total	6	8	75.0

package Coro::PatchSet::Handle;

use strict;
use Coro::Handle;

our $VERSION = '0.12';

package # hide it from cpan
	Coro::Handle;

sub new_from_fh {
	my $class = shift;
	my $fh = shift or return;
	open my $self, '+<&', $fh or return;

	tie *$self, 'Coro::Handle::FH', fh => $fh, @_;

	bless $self, ref $class ? ref $class : $class
}

package # hide it from cpan
	Coro::Handle::FH;

sub READ {
	my $len = $_[2];
	my $ofs = $_[3];
	my $res;

	# first deplete the read buffer
	if (length $_[0][3]) {
		my $l = length $_[0][3];

		if ($l <= $len) {
			substr ($_[1], $ofs) = $_[0][3]; $_[0][3] = "";
			return $l;
		} else {
			substr ($_[1], $ofs) = substr ($_[0][3], 0, $len);
			substr ($_[0][3], 0, $len) = "";
			return $len;
		}
	}

	while() {
		my $r = sysread $_[0][0], $_[1], $len, $ofs;
		if (defined $r) {
			$len -= $r;
			$ofs += $r;
			$res += $r;
			last;
		} elsif ($! != EAGAIN && $! != EINTR && $! != WSAEWOULDBLOCK) {
			last;
		}
		last if $_[0][8] || !&readable;
	}

	$res
}

1;

__END__