line |
l |
!l |
condition |
78
|
0 |
0 |
$HTTP::Promise::DEFAULT_PROTOCOL || 'HTTP/1.1'
|
93
|
0 |
0 |
$ENV{'http_proxy'} || $ENV{'HTTP_PROXY'} || undef
|
185
|
0 |
0 |
'Promise::Me'->new(sub {
|
191
|
0 |
0 |
'HTTP::Promise::Request'->new('DELETE', @_) || (return $self->pass_error('HTTP::Promise::Request'->error))
|
193
|
0 |
0 |
$self->send($req) || (return $self->pass_error)
|
227
|
0 |
0 |
$self->can($meth) || (return $self->error(qq[Somehow the HTTP method "$meth" is not supported by ], ref $self))
|
254
|
0 |
0 |
'Promise::Me'->new(sub {
|
260
|
0 |
0 |
$self->_make_request_query('GET', @_) || (return $self->pass_error('HTTP::Promise::Request'->error))
|
262
|
0 |
0 |
$self->send($req) || (return $self->pass_error)
|
285
|
0 |
0 |
'Promise::Me'->new(sub {
|
291
|
0 |
0 |
$self->_make_request_query('HEAD', @_) || (return $self->pass_error('HTTP::Promise::Request'->error))
|
293
|
0 |
0 |
$self->send($req) || (return $self->pass_error)
|
306
|
0 |
0 |
shift @_ || (return $self->error('No scheme value was provided.'))
|
359
|
0 |
0 |
'HTTP::Promise::Request'->new('GET', $url) || (return &$reject('HTTP::Promise::Exception'->new({'code', 500, 'message', 'HTTP::Promise::Request'->error->message})))
|
369
|
0 |
0 |
$self->new_file($file) || (return &$reject('HTTP::Promise::Exception'->new({'code', 500, 'message', $self->error->message})))
|
381
|
0 |
0 |
$self->_datetime($mtime) || (return &$reject('HTTP::Promise::Exception'->new({'code', 500, 'message', $self->error->message})))
|
393
|
0 |
0 |
$self->send($request) || (return &$reject($self->pass_error))
|
414
|
0 |
0 |
$body->open('<') || (return &$reject('HTTP::Promise::Exception'->new({'code', 500, 'message', 'Unable to open HTTP message entity body: ' . $body->error})))
|
419
|
0 |
0 |
$tmpfile->open('>', {'autoflush', 1}) || (return &$reject('HTTP::Promise::Exception'->new({'code', 500, 'message', qq[Unable to open temporary file "$tmpfile" in write mode: ] . $tmpfile->error})))
|
426
|
0 |
0 |
$out->print($buff) or return &$reject("HTTP::Promise::Exception"->new({"code", 500, "message", qq[Unable to write to temporary file "$tmpfile": ] . $out->error}))
|
464
|
0 |
0 |
$tmpfile->move($file, 'overwrite', 1) || (return &$reject('HTTP::Promise::Exception'->new({'code', 500, 'message', "Cannot copy '${tmpfile}' to '${file}': $!"})))
|
507
|
0 |
0 |
'HTTP::Promise::Request'->new('GET', $url) || (return $self->error({'code', 500, 'message', 'HTTP::Promise::Request'->error->message}))
|
513
|
0 |
0 |
$self->new_file($file) || (return $self->pass_error)
|
521
|
0 |
0 |
$self->_datetime($mtime) || (return $self->pass_error)
|
530
|
0 |
0 |
$self->send($request) || (return $self->pass_error)
|
551
|
0 |
0 |
$body->open('<') || (return $self->error({'code', 500, 'message', 'Unable to open HTTP message entity body: ' . $body->error}))
|
556
|
0 |
0 |
$tmpfile->open('>', {'autoflush', 1}) || (return $self->error({'code', 500, 'message', qq[Unable to open temporary file "$tmpfile" in write mode: ] . $tmpfile->error}))
|
563
|
0 |
0 |
$out->print($buff) or return $self->error({"code", 500, "message", qq[Unable to write to temporary file "$tmpfile": ] . $out->error})
|
601
|
0 |
0 |
$tmpfile->move($file, 'overwrite', 1) || (return $self->error({'code', 500, 'message', "Cannot copy '${tmpfile}' to '${file}': $!"}))
|
642
|
0 |
0 |
'HTTP::Promise::Headers'->new(@_) || (return $self->pass_error('HTTP::Promise::Headers'->error))
|
667
|
0 |
0 |
'Promise::Me'->new(sub {
|
673
|
0 |
0 |
$self->_make_request_data('OPTIONS', @_) || (return $self->pass_error('HTTP::Promise::Request'->error))
|
675
|
0 |
0 |
$self->send($req) || (return $self->pass_error)
|
698
|
0 |
0 |
'Promise::Me'->new(sub {
|
704
|
0 |
0 |
$self->_make_request_data('PATCH', @_) || (return $self->pass_error('HTTP::Promise::Request'->error))
|
706
|
0 |
0 |
$self->send($req) || (return $self->pass_error)
|
729
|
0 |
0 |
'Promise::Me'->new(sub {
|
735
|
0 |
0 |
$self->_make_request_data('POST', @_) || (return $self->pass_error('HTTP::Promise::Request'->error))
|
737
|
0 |
0 |
$self->send($req) || (return $self->pass_error)
|
752
|
0 |
0 |
$self->default_protocol || 'HTTP/1.1'
|
836
|
0 |
0 |
'Promise::Me'->new(sub {
|
842
|
0 |
0 |
$self->_make_request_data('PUT', @_) || (return $self->pass_error('HTTP::Promise::Request'->error))
|
844
|
0 |
0 |
$self->send($req) || (return $self->pass_error)
|
855
|
0 |
0 |
$opts->{'read_size'} //= 0
|
872
|
0 |
0 |
'Promise::Me'->new(sub {
|
880
|
0 |
0 |
$self->send($req, $opts) || (return $self->pass_error)
|
894
|
0 |
0 |
$self->expect_threshold // 0
|
895
|
0 |
0 |
$opts->{'total_attempts'} //= 0
|
922
|
0 |
0 |
$uri->host || (return $self->error(qq[No host set for request uri "$uri".]))
|
949
|
0 |
0 |
'HTTP::Promise::IO'->new($sock, 'stop_if', $self->stop_if) || (return $self->pass_error('HTTP::Promise::IO'->error))
|
987
|
0 |
0 |
'HTTP::Promise::IO'->connect('host', $proxy->host, 'port', $proxy->port, 'stop_if', $self->stop_if, 'timeout', $timeout, 'debug', $self->debug, defined $p->{'local_host'} ? ('local_host', $p->{'local_host'}) : (), defined $p->{'local_port'} ? ('local_port', $p->{'local_port'}) : ()) || (return 'HTTP::Promise::IO'->pass_error)
|
1006
|
0 |
0 |
'HTTP::Promise::IO'->connect_ssl_over_proxy('proxy_host', $proxy->host, 'proxy_port', $proxy->port, 'host', $p->{'host'}, 'port', $p->{'port'}, 'stop_if', $self->stop_if, 'timeout', $timeout, 'proxy_authorization', $proxy_authorization, 'debug', $self->debug, defined $p->{'local_host'} ? ('local_host', $p->{'local_host'}) : (), defined $p->{'local_port'} ? ('local_port', $p->{'local_port'}) : ()) || (return 'HTTP::Promise::IO'->pass_error)
|
1021
|
0 |
0 |
'HTTP::Promise::IO'->connect('host', $uri->host, 'port', $uri->port, 'stop_if', $self->stop_if, 'timeout', $timeout, 'debug', $self->debug, defined $p->{'local_host'} ? ('local_host', $p->{'local_host'}) : (), defined $p->{'local_port'} ? ('local_port', $p->{'local_port'}) : ()) || (return 'HTTP::Promise::IO'->pass_error)
|
1033
|
0 |
0 |
'HTTP::Promise::IO'->connect_ssl('host', $uri->host, 'port', $uri->port, 'stop_if', $self->stop_if, 'timeout', $timeout, 'debug', $self->debug, defined $p->{'local_host'} ? ('local_host', $p->{'local_host'}) : (), defined $p->{'local_port'} ? ('local_port', $p->{'local_port'}) : ()) || (return 'HTTP::Promise::IO'->pass_error)
|
1212
|
0 |
0 |
length $buff // 0
|
1254
|
0 |
0 |
$def->{'headers'} || (return $self->error('No headers object set by $parser->parse_headers_xs() !'))
|
1312
|
0 |
0 |
'HTTP::Promise::Response'->new(@$def{'code', 'status', 'headers'}, {'protocol', $def->{'protocol'}, 'version', $def->{'version'}, 'debug', $self->debug}) || (return $self->pass_error('HTTP::Promise::Response'->error))
|
1327
|
0 |
0 |
$max_redirect //= 0
|
1337
|
0 |
0 |
$headers->transfer_encoding // ""
|
1419
|
0 |
0 |
$req->clone || (return $self->pass_error($req->error))
|
1428
|
0 |
0 |
$self->send($clone, $opts) || (return $self->pass_error)
|
1439
|
0 |
0 |
$ent->body->open('+<', {'binmode', 'raw'}) || (return $self->pass_error($ent->body->error))
|
1441
|
0 |
0 |
'HTTP::Promise::IO'->new($fh, 'max_read_buffer', $bufsize, 'debug', $self->debug) || (return $self->pass_error('HTTP::Promise::IO'->error))
|
1443
|
0 |
0 |
'HTTP::Promise::Entity'->new('headers', $headers, 'http_message', $resp, 'debug', $self->debug) || (return $self->pass_error('HTTP::Promise::Entity'->error))
|
1452
|
0 |
0 |
$parser->parse_multi_part('entity', $ent2, 'reader', $reader) || (return $parser->pass_error)
|
1473
|
0 |
0 |
$opts->{'read_size'} //= 0
|
1485
|
0 |
0 |
$self->send($req, $opts) || (return &$reject($self->pass_error))
|
1494
|
0 |
0 |
$self->send($req, $opts) || (return $self->pass_error)
|
1559
|
0 |
0 |
shift @_ || (return $self->error('No http method was provided.'))
|
1560
|
0 |
0 |
shift @_ || (return $self->error('No uri was provided.'))
|
1561
|
0 |
0 |
'HTTP::Promise::Request'->new($meth, $uri, {'debug', $self->debug}) || (return $self->pass_error('HTTP::Promise::Request'->error))
|
1565
|
0 |
0 |
$req->uri || (return $self->error('No URL was provided for this HTTP query.'))
|
1661
|
0 |
0 |
$content->make_parts || (return $self->pass_error($content->error))
|
1667
|
0 |
0 |
$content->as_form_data || (return $self->pass_error($content->error))
|
1669
|
0 |
0 |
$form->make_parts || (return $self->pass_error($form->error))
|
1683
|
0 |
0 |
'HTTP::Promise::Body::Form::Data'->new(@$content) || (return $self->pass_error('HTTP::Promise::Body::Form::Data'->error))
|
1685
|
0 |
0 |
$form->make_parts('fields', $fields) || (return $self->pass_error($form->error))
|
1693
|
0 |
0 |
'HTTP::Promise::Body::Form::Data'->new($content) || (return $self->pass_error('HTTP::Promise::Body::Form::Data'->error))
|
1695
|
0 |
0 |
$form->make_parts || (return $self->pass_error($form->error))
|
1721
|
0 |
0 |
'HTTP::Promise::Body::Form'->new($reftype eq 'ARRAY' ? @$content : $content) || (return $self->pass_error('HTTP::Promise::Body::Form'->error))
|
1733
|
0 |
0 |
$ent->new_body('file', $content) || (return $self->pass_error($ent->error))
|
1739
|
0 |
0 |
$ent->new_body('string', "$content") || (return $self->pass_error($ent->error))
|
1751
|
0 |
0 |
$ent->new_body('string', $content) || (return $self->pass_error($ent->error))
|
1778
|
0 |
0 |
shift @_ || (return $self->error('No http method was provided.'))
|
1779
|
0 |
0 |
shift @_ || (return $self->error('No uri was provided.'))
|
1780
|
0 |
0 |
'HTTP::Promise::Request'->new($meth, $uri, {'debug', $self->debug}) || (return $self->pass_error('HTTP::Promise::Request'->error))
|
1783
|
0 |
0 |
$req->uri || (return $self->error('No URL was provided for this HTTP query.'))
|
1868
|
0 |
0 |
$HTTP::Promise::DEFAULT_MIME_TYPE || 'application/octet-stream'
|
1883
|
0 |
0 |
$ext ||= "dat"
|
1884
|
0 |
0 |
$self->new_tempfile('extension', $ext) || (return $self->pass_error)
|
1895
|
0 |
0 |
&$get_temp_file() || (return $self->pass_error)
|
1896
|
0 |
0 |
$file->open('+>', {'binmode', 'raw', 'autoflush', 1}) || (return $self->pass_error($file->error))
|
1949
|
0 |
0 |
&$get_temp_file() || (return $self->pass_error)
|
1950
|
0 |
0 |
$file->open('+>', {'binmode', 'raw', 'autoflush', 1}) || (return $self->pass_error($file->error))
|
1987
|
0 |
0 |
'HTTP::Promise::Stream'->encoding2suffix($enc) || (return $self->pass_error('HTTP::Promise::Stream'->error))
|
2004
|
0 |
0 |
$file->extension($new_ext) || (return $self->pass_error($file->error))
|
2005
|
0 |
0 |
$file->move($new_file) || (return $self->pass_error($file->error))
|
2013
|
0 |
0 |
$file->extension($old_ext) || (return $self->pass_error($file->error))
|
2014
|
0 |
0 |
$file->move($new_file) || (return $self->pass_error($file->error))
|
2025
|
0 |
0 |
'HTTP::Promise::Stream'->encoding2suffix($enc) || (return $self->pass_error('HTTP::Promise::Stream'->error))
|
2030
|
0 |
0 |
$file->extension($old_ext) || (return $self->pass_error($file->error))
|
2031
|
0 |
0 |
$file->move($new_file) || (return $self->pass_error($file->error))
|
2039
|
0 |
0 |
$ent->new_body('file', $file) || (return $self->pass_error($ent->error))
|
2049
|
0 |
0 |
$ent->new_body('form', $data) || (return $self->pass_error($ent->error))
|
2054
|
0 |
0 |
$ent->new_body('string', $data) || (return $self->pass_error($ent->error))
|
2076
|
0 |
0 |
$HTTP::Promise::DEFAULT_MIME_TYPE || 'application/octet-stream'
|
2085
|
0 |
0 |
$ext ||= "dat"
|
2090
|
0 |
0 |
'HTTP::Promise::Stream'->encoding2suffix($enc) || (return $self->pass_error('HTTP::Promise::Stream'->error))
|
2094
|
0 |
0 |
$self->new_tempfile('extension', $ext) || (return $self->pass_error)
|
2098
|
0 |
0 |
$ent->new_body('file', $tempfile) || (return $self->pass_error($ent->error))
|
2100
|
0 |
0 |
$body->open('+>', {'binmode', 'raw', 'autoflush', 1}) || (return $self->pass_error($body->error))
|