/usr/share/perl5/Net/Server/Proto/UNIX.pm is in libnet-server-perl 2.009-1.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
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 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 | # -*- perl -*-
#
# Net::Server::Proto::UNIX - Net::Server Protocol module
#
# Copyright (C) 2001-2017
#
# Paul Seamons <paul@seamons.com>
#
# This package may be distributed under the terms of either the
# GNU General Public License
# or the
# Perl Artistic License
#
# All rights reserved.
#
################################################################
package Net::Server::Proto::UNIX;
use strict;
use base qw(IO::Socket::UNIX);
use Socket qw(SOCK_STREAM SOCK_DGRAM);
sub NS_proto { 'UNIX' }
sub NS_port { my $sock = shift; ${*$sock}{'NS_port'} = shift if @_; return ${*$sock}{'NS_port'} }
sub NS_host { '*' }
sub NS_ipv { '*' }
sub NS_listen { my $sock = shift; ${*$sock}{'NS_listen'} = shift if @_; return ${*$sock}{'NS_listen'} }
sub NS_unix_type { 'SOCK_STREAM' }
sub NS_unix_path { shift->NS_port } # legacy systems used this
sub object {
my ($class, $info, $server) = @_;
if ($class eq __PACKAGE__) {
$server->configure({
unix_type => \$server->{'server'}->{'unix_type'},
unix_path => \$server->{'server'}->{'unix_path'}, # I don't believe this ever worked since a valid port specification also has to exist
}) if ! exists $server->{'server'}->{'unix_type'};
my $u_type = uc( defined($info->{'unix_type'}) ? $info->{'unix_type'}
: defined($server->{'server'}->{'unix_type'}) ? $server->{'server'}->{'unix_type'}
: 'SOCK_STREAM');
if ($u_type eq 'SOCK_DGRAM' || $u_type eq ''.SOCK_DGRAM()) { # allow for legacy invocations passing unix_type to UNIX - now just use proto UNIXDGRAM
require Net::Server::Proto::UNIXDGRAM;
return Net::Server::Proto::UNIXDGRAM->object($info, $server);
} elsif ($u_type ne 'SOCK_STREAM' && $u_type ne ''.SOCK_STREAM()) {
$server->fatal("Invalid type for UNIX socket ($u_type)... must be SOCK_STREAM or SOCK_DGRAM");
}
$info->{'port'} ||= $info->{'unix_path'} = $server->{'server'}->{'unix_path'};
}
my $sock = $class->SUPER::new();
my $port = $info->{'port'} =~ m{^ ([\w\.\-\*\/]+) $ }x ? $1 : $server->fatal("Insecure filename");
$sock->NS_port($port);
$sock->NS_listen(defined($info->{'listen'}) ? $info->{'listen'}
: defined($server->{'server'}->{'listen'}) ? $server->{'server'}->{'listen'}
: Socket::SOMAXCONN());
return $sock;
}
sub connect {
my ($sock, $server) = @_;
my $path = $sock->NS_port;
$server->fatal("Can't connect to UNIX socket at file $path [$!]") if -e $path && ! unlink $path;
$sock->SUPER::configure({
Local => $path,
Type => SOCK_STREAM,
Listen => $sock->NS_listen,
}) or $server->fatal("Can't connect to UNIX socket at file $path [$!]");
}
sub log_connect {
my ($sock, $server) = @_;
$server->log(2, "Binding to ".$sock->NS_proto." socket file \"".$sock->NS_port."\"");
}
sub reconnect { # connect on a sig -HUP
my ($sock, $fd, $server) = @_;
$sock->fdopen($fd, 'w') or $server->fatal("Error opening to file descriptor ($fd) [$!]");
}
# a string containing any information necessary for restarting the server
# via a -HUP signal
# a newline is not allowed
# the hup_string must be a unique identifier based on configuration info
sub hup_string {
my $sock = shift;
return join "|", $sock->NS_host, $sock->NS_port, $sock->NS_proto, $sock->NS_ipv;
}
sub show {
my $sock = shift;
return "Ref = \"".ref($sock). "\" (".$sock->hup_string.")\n";
}
###----------------------------------------------------------------###
sub read_until { # only sips the data - but it allows for compatibility with SSLEAY
my ($client, $bytes, $end_qr) = @_;
die "One of bytes or end_qr should be defined for UNIX read_until\n" if !defined($bytes) && !defined($end_qr);
my $content = '';
my $ok = 0;
while (1) {
$client->read($content, 1, length($content));
if (defined($bytes) && length($content) >= $bytes) {
$ok = 2;
last;
} elsif (defined($end_qr) && $content =~ $end_qr) {
$ok = 1;
last;
}
}
return wantarray ? ($ok, $content) : $content;
}
1;
__END__
=head1 NAME
Net::Server::Proto::UNIX - Net::Server UNIX protocol.
=head1 SYNOPSIS
See L<Net::Server::Proto>.
=head1 DESCRIPTION
Protocol module for Net::Server. This module implements the UNIX
SOCK_STREAM socket type. See L<Net::Server::Proto>.
Any sockets created during startup will be chown'ed to the user and
group specified in the startup arguments.
=head1 PARAMETERS
The following parameters may be specified in addition to normal
command line parameters for a Net::Server. See L<Net::Server> for
more information on reading arguments.
=over 4
=item unix_type
Can be either SOCK_STREAM or SOCK_DGRAM (default is SOCK_STREAM).
This can also be passed on the port line (see L<Net::Server::Proto>).
However, this method is deprecated. If you want SOCK_STREAM - just
use proto UNIX without any other arguments. If you'd like SOCK_DGRAM,
use the new proto UNIXDGRAM.
=back
=head1 METHODS
=over 4
=item NS_unix_path/NS_unix_type
In addition to the standard NS_ methods of Net::Server::Proto classes,
the UNIX types also have legacy calls to NS_unix_path and
NS_unix_type.
Since version 2.000, NS_unix_path is simply an alias to NS_port.
NS_unix_type is now redundant with NS_proto.
These methods were missing between version 2.000 and 2.003 but have
been returned as legacy bridges.
=back
=head1 QUICK PARAMETER LIST
Key Value Default
# deprecated UNIX socket parameters
unix_type (SOCK_STREAM|SOCK_DGRAM) SOCK_STREAM
port "filename" undef
# more recent usage
port "filename / UNIX"
port "filename / UNIXDGRAM"
=head1 LICENCE
Distributed under the same terms as Net::Server
=cut
|