xref: /openbsd/regress/usr.sbin/syslogd/Server.pm (revision 15bf65a9)
1#	$OpenBSD: Server.pm,v 1.9 2016/09/21 12:01:17 bluhm Exp $
2
3# Copyright (c) 2010-2015 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->{listenproto} ||= "udp";
37	defined($self->{listendomain})
38	    or croak "$class listen domain not given";
39	return $self->listen();
40}
41
42sub listen {
43	my $self = shift;
44	$SSL_ERROR = "";
45	my $iosocket = $self->{listenproto} eq "tls" ?
46	    "IO::Socket::SSL" : "IO::Socket::INET6";
47	my $proto = $self->{listenproto};
48	$proto = "tcp" if $proto eq "tls";
49	my $ls = $iosocket->new(
50	    Proto		=> $proto,
51	    ReuseAddr		=> 1,
52	    Domain		=> $self->{listendomain},
53	    $self->{listenaddr}	? (LocalAddr => $self->{listenaddr}) : (),
54	    $self->{listenport}	? (LocalPort => $self->{listenport}) : (),
55	    SSL_key_file	=> "server.key",
56	    SSL_cert_file	=> "server.crt",
57	    SSL_ca_file		=> ($self->{sslca} || "ca.crt"),
58	    SSL_verify_mode     => ($self->{sslca} ?
59		SSL_VERIFY_PEER : SSL_VERIFY_NONE),
60	    $self->{sslca}	? (SSL_verifycn_scheme => "none") : (),
61	    $self->{sslversion}	? (SSL_version => $self->{sslversion}) : (),
62	    $self->{sslciphers}	? (SSL_cipher_list => $self->{sslciphers}) : (),
63	) or die ref($self), " $iosocket socket failed: $!,$SSL_ERROR";
64	if ($self->{listenproto} ne "udp") {
65		listen($ls, 1)
66		    or die ref($self), " socket listen failed: $!";
67	}
68	my $log = $self->{log};
69	print $log "listen sock: ",$ls->sockhost()," ",$ls->sockport(),"\n";
70	$self->{listenaddr} = $ls->sockhost() unless $self->{listenaddr};
71	$self->{listenport} = $ls->sockport() unless $self->{listenport};
72	$self->{ls} = $ls;
73	return $self;
74}
75
76sub close {
77	my $self = shift;
78	$self->{ls}->close()
79	    or die ref($self)," ",ref($self->{ls}),
80	    " socket close failed: $!,$SSL_ERROR";
81	delete $self->{ls};
82	return $self;
83}
84
85sub run {
86	my $self = shift;
87	Proc::run($self, @_);
88	return $self->close();
89}
90
91sub child {
92	my $self = shift;
93
94	my $as = $self->{ls};
95	if ($self->{listenproto} ne "udp") {
96		$as = $self->{ls}->accept()
97		    or die ref($self)," ",ref($self->{ls}),
98		    " socket accept failed: $!,$SSL_ERROR";
99		print STDERR "accept sock: ",$as->sockhost()," ",
100		    $as->sockport(),"\n";
101		print STDERR "accept peer: ",$as->peerhost()," ",
102		    $as->peerport(),"\n";
103	}
104	if ($self->{listenproto} eq "tls") {
105		print STDERR "ssl version: ",$as->get_sslversion(),"\n";
106		print STDERR "ssl cipher: ",$as->get_cipher(),"\n";
107		print STDERR "ssl subject: ", $as->peer_certificate("subject")
108		    ,"\n" if $self->{sslca};
109	}
110
111	*STDIN = *STDOUT = $self->{as} = $as;
112}
113
1141;
115