From: miker Date: Thu, 6 Apr 2006 05:02:26 +0000 (+0000) Subject: adding duration timing to requests X-Git-Tag: osrf_rel_2_0_1~1193 X-Git-Url: https://old-git.evergreen-ils.org/?a=commitdiff_plain;h=c3249eb83f7f465797d0719a508a38b31bc02a64;p=OpenSRF.git adding duration timing to requests git-svn-id: svn://svn.open-ils.org/OpenSRF/trunk@680 9efc2488-bf62-4759-914b-345cdb29e865 --- diff --git a/src/perlmods/OpenSRF/AppSession.pm b/src/perlmods/OpenSRF/AppSession.pm index 9afb003..9f5099a 100644 --- a/src/perlmods/OpenSRF/AppSession.pm +++ b/src/perlmods/OpenSRF/AppSession.pm @@ -543,7 +543,9 @@ sub send { $self->state( DISCONNECTED ); } - return $self->app_request( $tT ); + my $req = $self->app_request( $tT ); + $req->{_start} = time; + return $req } sub app_request { @@ -792,6 +794,7 @@ package OpenSRF::AppRequest; use base qw/OpenSRF::AppSession/; use OpenSRF::Utils::Logger qw/:level/; use OpenSRF::DomainObject::oilsResponse qw/:status/; +use Time::HiRes qw/time usleep/; sub new { my $class = shift; @@ -846,15 +849,22 @@ sub complete { return $self->{complete} if ($self->{complete}); if (defined $complete) { $self->{complete} = $complete; + $self->{_duration} = time - $self->{_start} if ($self->{complete}); } else { $self->session->queue_wait(0); } return $self->{complete}; } +sub duration { + my $self = shift; + $self->wait_complete; + return $self->{_duration}; +} + sub wait_complete { my $self = shift; - my $timeout = shift || 1; + my $timeout = shift || 10; my $time_remaining = $timeout; while ( ! $self->complete and $time_remaining > 0 ) {