File Coverage

blib/lib/Search/Elasticsearch/CxnPool/Async/Simple/Static.pm

Criterion	Covered	Total	%
statement	12	37	32.4
branch	0	12	0.0
condition	0	3	0.0
subroutine	4	6	66.6
pod	0	1	0.0
total	16	59	27.1

package Search::Elasticsearch::CxnPool::Async::Simple::Static;

use Moo;

use Search::Elasticsearch::Role::Is_Async::Loader ();
use Search::Elasticsearch::Util qw(new_error);

use namespace::clean;

with 'Search::Elasticsearch::Role::CxnPool::Static',
     'Search::Elasticsearch::Role::Is_Async';


sub next_cxn {
	my ($self, $cb) = @_;

	my $cxns = $self->cxns;
	my (%seen, @skip);

	my $sub; $sub = sub {
		my $cnt = @$cxns;
		my $fnd;

		if ($cnt > keys(%seen)) {
			while ($cnt--) {
				my $cxn = $cxns->[$self->next_cxn_num];

				next if $seen{$cxn}++;

				return $cb->($cxn) if $cxn->is_live;

				if ($cxn->next_ping <= time()) {
					$fnd = $cxn;
					last;
				}
				push(@skip, $cxn);
			}
		}

		if ($fnd ||= shift(@skip)) {
			return $fnd->pings_ok(sub {
				return $cb->($fnd) if $_[0];
				$sub->();
			});
		}

		$_->force_ping() for @$cxns;

		local $@ = new_error('NoNodes', 'No nodes are available: [' . $self->cxns_str . ']');

		$cb->();
	};

	$sub->();

	return;
}


1;


__END__