removed misplaced "my"

[OpenSRF.git] / src / perl / lib / OpenSRF / AppSession.pm

diff --git a/src/perl/lib/OpenSRF/AppSession.pm b/src/perl/lib/OpenSRF/AppSession.pm
index d6bc91a..b322665 100644 (file)
--- a/src/perl/lib/OpenSRF/AppSession.pm
+++ b/src/perl/lib/OpenSRF/AppSession.pm
@@ -737,6 +737,7 @@ sub recv {
                        $avail = @{ $self->{recv_queue} };
        }
 
+    $self->timed_out(1) if ( $self->{remaining_recv_timeout} <= 0 );
 
        my @list;
        while ( my $msg = shift @{ $self->{recv_queue} } ) {
@@ -751,6 +752,13 @@ sub recv {
        return @list;
 }
 
+sub timed_out {
+    my $self = shift;
+    my $out = shift;
+    $self->{timed_out} = $out if (defined $out);
+    return $self->{timed_out};
+}
+
 sub push_resend {
        my $self = shift;
        push @OpenSRF::AppSession::_RESEND_QUEUE, @_;