| line |
stmt |
bran |
cond |
sub |
pod |
time |
code |
|
1
|
|
|
|
|
|
|
=head1 NAME |
|
2
|
|
|
|
|
|
|
|
|
3
|
|
|
|
|
|
|
Bio::Prospect::Client -- base class for Bio::Prospect::LocalClient and |
|
4
|
|
|
|
|
|
|
Bio::Prospect::SoapClient. |
|
5
|
|
|
|
|
|
|
S<$Id: Client.pm,v 1.16 2003/11/18 19:45:45 rkh Exp $> |
|
6
|
|
|
|
|
|
|
|
|
7
|
|
|
|
|
|
|
=head1 SYNOPSIS |
|
8
|
|
|
|
|
|
|
|
|
9
|
|
|
|
|
|
|
This is an abstract class and is intended only for subclassing. |
|
10
|
|
|
|
|
|
|
|
|
11
|
|
|
|
|
|
|
=head1 DESCRIPTION |
|
12
|
|
|
|
|
|
|
|
|
13
|
|
|
|
|
|
|
B<Bio::Prospect::Client> is the abstract base class for Bio::Prospect::LocalClient and |
|
14
|
|
|
|
|
|
|
Bio::Prospect::SoapClient. Not intended to be instantiated directly. |
|
15
|
|
|
|
|
|
|
|
|
16
|
|
|
|
|
|
|
=head1 ROUTINES & METHODS |
|
17
|
|
|
|
|
|
|
|
|
18
|
|
|
|
|
|
|
=cut |
|
19
|
|
|
|
|
|
|
|
|
20
|
|
|
|
|
|
|
package Bio::Prospect::Client; |
|
21
|
1
|
|
|
1
|
|
5
|
use strict; |
|
|
1
|
|
|
|
|
3
|
|
|
|
1
|
|
|
|
|
28
|
|
|
22
|
1
|
|
|
1
|
|
5
|
use warnings; |
|
|
1
|
|
|
|
|
2
|
|
|
|
1
|
|
|
|
|
24
|
|
|
23
|
1
|
|
|
1
|
|
1226
|
use File::Temp; |
|
|
1
|
|
|
|
|
27948
|
|
|
|
1
|
|
|
|
|
89
|
|
|
24
|
1
|
|
|
1
|
|
9
|
use vars qw( $VERSION ); |
|
|
1
|
|
|
|
|
12
|
|
|
|
1
|
|
|
|
|
715
|
|
|
25
|
|
|
|
|
|
|
$VERSION = sprintf( "%d.%02d", q$Revision: 1.16 $ =~ /(\d+)\.(\d+)/ ); |
|
26
|
|
|
|
|
|
|
|
|
27
|
|
|
|
|
|
|
|
|
28
|
|
|
|
|
|
|
#------------------------------------------------------------------------------- |
|
29
|
|
|
|
|
|
|
# new() |
|
30
|
|
|
|
|
|
|
#------------------------------------------------------------------------------- |
|
31
|
|
|
|
|
|
|
|
|
32
|
|
|
|
|
|
|
=head2 new() |
|
33
|
|
|
|
|
|
|
|
|
34
|
|
|
|
|
|
|
Name: new() |
|
35
|
|
|
|
|
|
|
Purpose: constructor |
|
36
|
|
|
|
|
|
|
Arguments: 'tempdir' => directory to create temporary files (optional) |
|
37
|
|
|
|
|
|
|
Returns: Bio::Prospect::Client |
|
38
|
|
|
|
|
|
|
|
|
39
|
|
|
|
|
|
|
=cut |
|
40
|
|
|
|
|
|
|
|
|
41
|
|
|
|
|
|
|
sub new { |
|
42
|
1
|
|
|
1
|
1
|
3
|
my $type = shift; |
|
43
|
1
|
|
|
|
|
2
|
my $self = {}; |
|
44
|
1
|
50
|
|
|
|
4
|
if (ref $_[0]) |
|
45
|
1
|
|
|
|
|
2
|
{ %{$self} = %{$_[0]}; } |
|
|
1
|
|
|
|
|
2
|
|
|
|
1
|
|
|
|
|
4
|
|
|
46
|
|
|
|
|
|
|
else |
|
47
|
0
|
|
|
|
|
0
|
{ %{$self} = @_; } |
|
|
0
|
|
|
|
|
0
|
|
|
48
|
1
|
|
|
|
|
4
|
bless($self,$type); |
|
49
|
|
|
|
|
|
|
|
|
50
|
1
|
50
|
|
|
|
9
|
if ( ! defined $self->{'tempdir'} ) { |
|
51
|
1
|
|
|
|
|
8
|
$self->{tempdir} = File::Temp::tempdir( |
|
52
|
|
|
|
|
|
|
'/tmp/'.__PACKAGE__.'-XXXX', |
|
53
|
|
|
|
|
|
|
CLEANUP=>!$ENV{DEBUG} ); |
|
54
|
1
|
50
|
|
|
|
528
|
defined $self->{tempdir} |
|
55
|
|
|
|
|
|
|
or throw Bio::Prospect::RuntimeError( "couldn't create temporary directory" ); |
|
56
|
|
|
|
|
|
|
} |
|
57
|
1
|
50
|
|
|
|
17
|
if ( ! -w $self->{tempdir} ) { |
|
58
|
0
|
|
|
|
|
0
|
throw Bio::Prospect::RuntimeError( "tempdir (" . $self->{tempdir} . ") is not writeable" ); |
|
59
|
|
|
|
|
|
|
} |
|
60
|
|
|
|
|
|
|
|
|
61
|
1
|
50
|
|
|
|
3
|
print(STDERR "tempdir: " . $self->{tempdir} . "\n") if $ENV{'DEBUG'}; |
|
62
|
|
|
|
|
|
|
|
|
63
|
1
|
50
|
|
|
|
4
|
if (not defined $self->{cacheLimit}) |
|
64
|
1
|
|
|
|
|
2
|
{ $self->{cacheLimit} = 25; } |
|
65
|
|
|
|
|
|
|
|
|
66
|
1
|
|
|
|
|
3
|
return $self; |
|
67
|
|
|
|
|
|
|
} |
|
68
|
|
|
|
|
|
|
|
|
69
|
|
|
|
|
|
|
|
|
70
|
|
|
|
|
|
|
|
|
71
|
|
|
|
|
|
|
#------------------------------------------------------------------------------- |
|
72
|
|
|
|
|
|
|
# _tempfile() |
|
73
|
|
|
|
|
|
|
#------------------------------------------------------------------------------- |
|
74
|
|
|
|
|
|
|
|
|
75
|
|
|
|
|
|
|
=head2 _tempfile() |
|
76
|
|
|
|
|
|
|
|
|
77
|
|
|
|
|
|
|
Name: _tempfile() |
|
78
|
|
|
|
|
|
|
Purpose: return the filename of a temporary file |
|
79
|
|
|
|
|
|
|
Arguments: suffix for filename (optional) |
|
80
|
|
|
|
|
|
|
Returns: filename |
|
81
|
|
|
|
|
|
|
|
|
82
|
|
|
|
|
|
|
=cut |
|
83
|
|
|
|
|
|
|
|
|
84
|
|
|
|
|
|
|
sub _tempfile { |
|
85
|
0
|
|
|
0
|
|
|
my $self = shift; |
|
86
|
0
|
0
|
|
|
|
|
my $sfx = @_ ? ".$_[0]" : undef; |
|
87
|
0
|
|
|
|
|
|
return File::Temp::tempfile( DIR=>$self->{tempdir}, SUFFIX=>$sfx, UNLINK=>0 ); |
|
88
|
|
|
|
|
|
|
} |
|
89
|
|
|
|
|
|
|
|
|
90
|
|
|
|
|
|
|
|
|
91
|
|
|
|
|
|
|
#------------------------------------------------------------------------------- |
|
92
|
|
|
|
|
|
|
# _get_cache_file() |
|
93
|
|
|
|
|
|
|
#------------------------------------------------------------------------------- |
|
94
|
|
|
|
|
|
|
|
|
95
|
|
|
|
|
|
|
=head2 _get_cache_file() |
|
96
|
|
|
|
|
|
|
|
|
97
|
|
|
|
|
|
|
Name: _get_cache_file() |
|
98
|
|
|
|
|
|
|
Purpose: return the value for a given key in a given cache |
|
99
|
|
|
|
|
|
|
Arguments: key, cache name |
|
100
|
|
|
|
|
|
|
Returns: value |
|
101
|
|
|
|
|
|
|
|
|
102
|
|
|
|
|
|
|
=cut |
|
103
|
|
|
|
|
|
|
|
|
104
|
|
|
|
|
|
|
sub _get_cache_file { |
|
105
|
0
|
|
|
0
|
|
|
my ($self,$key,$cacheName) = @_; |
|
106
|
|
|
|
|
|
|
|
|
107
|
0
|
0
|
|
|
|
|
if ( defined $self->{'cache'}{$cacheName}{$key}{'fn'}) { |
|
108
|
0
|
|
|
|
|
|
return $self->{'cache'}{$cacheName}{$key}{'fn'}; |
|
109
|
|
|
|
|
|
|
} else { |
|
110
|
0
|
|
|
|
|
|
return; |
|
111
|
|
|
|
|
|
|
} |
|
112
|
|
|
|
|
|
|
} |
|
113
|
|
|
|
|
|
|
|
|
114
|
|
|
|
|
|
|
|
|
115
|
|
|
|
|
|
|
#------------------------------------------------------------------------------- |
|
116
|
|
|
|
|
|
|
# _put_cache_file() |
|
117
|
|
|
|
|
|
|
#------------------------------------------------------------------------------- |
|
118
|
|
|
|
|
|
|
|
|
119
|
|
|
|
|
|
|
=head2 _put_cache_file() |
|
120
|
|
|
|
|
|
|
|
|
121
|
|
|
|
|
|
|
Name: _put_cache_file() |
|
122
|
|
|
|
|
|
|
Purpose: put a filename into a given cache using a given key |
|
123
|
|
|
|
|
|
|
Arguments: key, cache name, value |
|
124
|
|
|
|
|
|
|
Returns: value |
|
125
|
|
|
|
|
|
|
|
|
126
|
|
|
|
|
|
|
=cut |
|
127
|
|
|
|
|
|
|
|
|
128
|
|
|
|
|
|
|
sub _put_cache_file { |
|
129
|
0
|
|
|
0
|
|
|
my ($self,$key,$cacheName,$fn) = @_; |
|
130
|
|
|
|
|
|
|
|
|
131
|
0
|
0
|
|
|
|
|
if ( !defined $self->{'cache'}{$cacheName} ) { |
|
132
|
0
|
|
|
|
|
|
$self->{'cache'}{$cacheName} = {}; |
|
133
|
|
|
|
|
|
|
} |
|
134
|
0
|
|
|
|
|
|
my $cache = $self->{'cache'}{$cacheName}; |
|
135
|
|
|
|
|
|
|
|
|
136
|
|
|
|
|
|
|
# cache this result |
|
137
|
0
|
0
|
|
|
|
|
print(STDERR "## caching $fn in '$cacheName' file cache using a key of $key ...\n") if $ENV{DEBUG}; |
|
138
|
0
|
|
|
|
|
|
$cache->{$key}{'fn'} = $fn; |
|
139
|
0
|
|
|
|
|
|
$cache->{$key}{'timestamp'} = time; |
|
140
|
|
|
|
|
|
|
|
|
141
|
|
|
|
|
|
|
# expire oldest |
|
142
|
0
|
0
|
0
|
|
|
|
if ( defined $cache and ( exists $self->{cacheLimit} ) and ( scalar keys %{$cache} >= $self->{cacheLimit} ) ) { |
|
|
0
|
|
0
|
|
|
|
|
|
143
|
0
|
|
|
|
|
|
foreach my $key ( sort { $cache->{$a}{'timestamp'} <=> $cache->{$b}{'timestamp'} } keys %{$cache} ) { |
|
|
0
|
|
|
|
|
|
|
|
|
0
|
|
|
|
|
|
|
|
144
|
0
|
0
|
|
|
|
|
print STDERR "deleting $key because it is the oldest key: " . $cache->{$key}{'timestamp'} . "\n" if $ENV{DEBUG}; |
|
145
|
0
|
0
|
|
|
|
|
print STDERR "unlinking " . $cache->{$key}{'fn'} . "\n" if $ENV{DEBUG}; |
|
146
|
0
|
|
|
|
|
|
unlink $cache->{$key}{'fn'}; |
|
147
|
0
|
|
|
|
|
|
delete $cache->{$key}; |
|
148
|
0
|
|
|
|
|
|
last; |
|
149
|
|
|
|
|
|
|
} |
|
150
|
|
|
|
|
|
|
} |
|
151
|
0
|
|
|
|
|
|
return; |
|
152
|
|
|
|
|
|
|
} |
|
153
|
|
|
|
|
|
|
|
|
154
|
|
|
|
|
|
|
|
|
155
|
|
|
|
|
|
|
=pod |
|
156
|
|
|
|
|
|
|
|
|
157
|
|
|
|
|
|
|
=head1 BUGS |
|
158
|
|
|
|
|
|
|
|
|
159
|
|
|
|
|
|
|
=head1 SEE ALSO |
|
160
|
|
|
|
|
|
|
|
|
161
|
|
|
|
|
|
|
Bio::Prospect::LocalClient |
|
162
|
|
|
|
|
|
|
Bio::Prospect::SoapClient |
|
163
|
|
|
|
|
|
|
|
|
164
|
|
|
|
|
|
|
=cut |
|
165
|
|
|
|
|
|
|
|
|
166
|
|
|
|
|
|
|
1; |