xref: /openbsd/regress/usr.sbin/syslogd/Server.pm (revision 1f53c19f)
1#	$OpenBSD: Server.pm,v 1.1.1.1 2014/08/20 20:52:14 bluhm Exp $
2
3# Copyright (c) 2010-2014 Alexander Bluhm <bluhm@openbsd.org>
4#
5# Permission to use, copy, modify, and distribute this software for any
6# purpose with or without fee is hereby granted, provided that the above
7# copyright notice and this permission notice appear in all copies.
8#
9# THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
10# WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
11# MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
12# ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
13# WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
14# ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
15# OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
16
17use strict;
18use warnings;
19
20package Server;
21use parent 'Proc';
22use Carp;
23use Socket;
24use Socket6;
25use IO::Socket;
26use IO::Socket::INET6;
27use IO::Socket::SSL;
28
29sub new {
30	my $class = shift;
31	my %args = @_;
32	$args{ktracefile} ||= "server.ktrace";
33	$args{logfile} ||= "server.log";
34	$args{up} ||= "Accepted";
35	my $self = Proc::new($class, %args);
36	$self->{listenprotocol} ||= "udp";
37	$self->{listendomain}
38	    or croak "$class listen domain not given";
39	$SSL_ERROR = "";
40	my $iosocket = $self->{listenprotocol} eq "tls" ?
41	    "IO::Socket::SSL" : "IO::Socket::INET6";
42	my $proto = $self->{listenprotocol};
43	$proto = "tcp" if $proto eq "tls";
44	my $ls = $iosocket->new(
45	    Proto		=> $proto,
46	    ReuseAddr		=> 1,
47	    Domain		=> $self->{listendomain},
48	    $self->{listenaddr} ? (LocalAddr => $self->{listenaddr}) : (),
49	    $self->{listenport} ? (LocalPort => $self->{listenport}) : (),
50	    SSL_key_file	=> "server-key.pem",
51	    SSL_cert_file	=> "server-cert.pem",
52	    SSL_verify_mode	=> SSL_VERIFY_NONE,
53	) or die ref($self), " $iosocket socket listen failed: $!,$SSL_ERROR";
54	if ($self->{listenprotocol} eq "tcp") {
55		listen($ls, 1)
56		    or die ref($self), " socket failed: $!";
57	}
58	my $log = $self->{log};
59	print $log "listen sock: ",$ls->sockhost()," ",$ls->sockport(),"\n";
60	$self->{listenaddr} = $ls->sockhost() unless $self->{listenaddr};
61	$self->{listenport} = $ls->sockport() unless $self->{listenport};
62	$self->{ls} = $ls;
63	return $self;
64}
65
66sub child {
67	my $self = shift;
68
69	my $iosocket = $self->{ssl} ? "IO::Socket::SSL" : "IO::Socket::INET6";
70	my $as = $self->{ls};
71	if ($self->{listenprotocol} ne "udp") {
72		$as = $self->{ls}->accept()
73		    or die ref($self), " $iosocket socket accept failed: $!";
74		print STDERR "accept sock: ",$as->sockhost()," ",
75		    $as->sockport(),"\n";
76		print STDERR "accept peer: ",$as->peerhost()," ",
77		    $as->peerport(),"\n";
78	}
79
80	*STDIN = *STDOUT = $self->{as} = $as;
81}
82
831;
84