[libanyevent-handle-udp-perl] 29/60: Moved out add_watcher

[Jonas Smedegaard]

This is an automated email from the git hooks/post-receive script.

js pushed a commit to branch master
in repository libanyevent-handle-udp-perl.

commit 2dbe36768d5c6d694543a74b99304a7940c77641
Author: Leon Timmermans <fawaka at gmail.com>
Date:   Sun May 27 14:26:53 2012 +0200

    Moved out add_watcher
---
 lib/AnyEvent/Handle/UDP.pm |   25 +++++++++++++++----------
 1 file changed, 15 insertions(+), 10 deletions(-)

diff --git a/lib/AnyEvent/Handle/UDP.pm b/lib/AnyEvent/Handle/UDP.pm
index 50414a9..fd5902c 100644
--- a/lib/AnyEvent/Handle/UDP.pm
+++ b/lib/AnyEvent/Handle/UDP.pm
@@ -217,16 +217,7 @@ sub _on_addr {
 			}
 
 			$on_success->($sockaddr);
-
-			$self->{reader} = AE::io $self->fh, 0, sub {
-				while (defined (my $addr = recv $self->fh, my ($buffer), $self->{receive_size}, 0)) {
-					$self->timeout_reset;
-					$self->rtimeout_reset;
-					$self->on_recv->($buffer, $self, $addr);
-				}
-				$self->_error(1, "Couldn't recv: $!") if $! != EAGAIN and $! != EWOULDBLOCK;
-				return;
-			};
+			$self->_add_watcher;
 
 			last;
 		}
@@ -234,6 +225,20 @@ sub _on_addr {
 	return;
 }
 
+sub _add_watcher {
+	my $self = shift;
+
+	$self->{reader} = AE::io $self->fh, 0, sub {
+		while (defined (my $addr = recv $self->fh, my ($buffer), $self->{receive_size}, 0)) {
+			$self->timeout_reset;
+			$self->rtimeout_reset;
+			$self->on_recv->($buffer, $self, $addr);
+		}
+		$self->_error(1, "Couldn't recv: $!") if $! != EAGAIN and $! != EWOULDBLOCK;
+		return;
+	};
+}
+
 sub _error {
 	my ($self, $fatal, $message) = @_;
 

-- 
Alioth's /usr/local/bin/git-commit-notice on /srv/git.debian.org/git/pkg-perl/packages/libanyevent-handle-udp-perl.git