1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
|
package IO::Stream::const;
use 5.010001;
use warnings;
use strict;
use utf8;
use Carp;
our $VERSION = 'v2.0.3';
use Scalar::Util qw( dualvar );
use Errno qw( EAGAIN );
use Fcntl ();
use Socket ();
use constant WIN32 => $^O =~ /Win32/msi ? 1 : 0;
use constant BUFSIZE => 8192;
# Events:
use constant RESOLVED => 1<<0;
use constant CONNECTED => 1<<1;
use constant IN => 1<<2;
use constant OUT => 1<<3;
use constant EOF => 1<<4;
use constant SENT => 1<<5;
# Timeouts:
use constant TOCONNECT => 30;
use constant TOWRITE => 30;
# Custom errors:
use constant EINBUFLIMIT => dualvar(-100, 'in_buf_limit reached');
use constant ETORESOLVE => dualvar(-101, 'dns timeout'); # unused, keep for compatibility
use constant ETOCONNECT => dualvar(-102, 'connect timeout');
use constant ETOWRITE => dualvar(-103, 'write timeout');
use constant EDNS => dualvar(-200, 'dns error');
use constant EDNSNXDOMAIN => dualvar(-201, 'dns nxdomain'); # unused, keep for compatibility
use constant EDNSNODATA => dualvar(-202, 'dns nodata'); # unused, keep for compatibility
use constant EREQINBUFLIMIT => dualvar(-300, 'in_buf_limit required');
use constant EREQINEOF => dualvar(-301, 'IN or EOF required in wait_for');
# Cache for speed:
## no critic (ProhibitStringyEval RequireCheckingReturnValueOfEval ProhibitImplicitNewlines)
BEGIN { if (!WIN32) { eval '
use constant F_SETFL => Fcntl::F_SETFL();
use constant O_NONBLOCK => Fcntl::O_NONBLOCK();
'} else { eval '
use constant FIONBIO => 0x8004667E;
'}}
## use critic
use constant PROTO_TCP => scalar getprotobyname 'tcp';
use constant AF_INET => Socket::AF_INET();
use constant SOCK_STREAM => Socket::SOCK_STREAM();
sub import {
my $pkg = caller;
no strict 'refs';
for my $const (qw(
WIN32 BUFSIZE
EAGAIN
RESOLVED CONNECTED IN OUT EOF SENT
TOCONNECT TOWRITE
EINBUFLIMIT ETORESOLVE ETOCONNECT ETOWRITE
EDNS EDNSNXDOMAIN EDNSNODATA
EREQINBUFLIMIT EREQINEOF
F_SETFL O_NONBLOCK FIONBIO PROTO_TCP AF_INET SOCK_STREAM
)) {
*{"${pkg}::$const"} = \&{$const};
}
return;
}
1;
|
