mirror of
https://git.proxmox.com/git/pve-manager
synced 2025-08-16 14:43:10 +00:00
convert pvedaemon into a PVE::Service class
This commit is contained in:
parent
d4e40874dd
commit
ab4ae3dcfd
@ -1,6 +1,6 @@
|
|||||||
include ../../defines.mk
|
include ../../defines.mk
|
||||||
|
|
||||||
SOURCES=pvestatd.pm pveproxy.pm
|
SOURCES=pvestatd.pm pveproxy.pm pvedaemon.pm
|
||||||
|
|
||||||
.PHONY: install
|
.PHONY: install
|
||||||
install: ${SOURCES}
|
install: ${SOURCES}
|
||||||
|
84
PVE/Service/pvedaemon.pm
Executable file
84
PVE/Service/pvedaemon.pm
Executable file
@ -0,0 +1,84 @@
|
|||||||
|
package PVE::Service::pvedaemon;
|
||||||
|
|
||||||
|
use strict;
|
||||||
|
use warnings;
|
||||||
|
|
||||||
|
use PVE::SafeSyslog;
|
||||||
|
use PVE::Daemon;
|
||||||
|
use PVE::API2;
|
||||||
|
use PVE::API2::Formatter::Standard;
|
||||||
|
use PVE::API2::Formatter::HTML;
|
||||||
|
use PVE::HTTPServer;
|
||||||
|
|
||||||
|
use base qw(PVE::Daemon);
|
||||||
|
|
||||||
|
my $cmdline = [$0, @ARGV];
|
||||||
|
|
||||||
|
my %daemon_options = (
|
||||||
|
max_workers => 3,
|
||||||
|
restart_on_error => 5,
|
||||||
|
stop_wait_time => 15,
|
||||||
|
leave_children_open_on_reload => 1,
|
||||||
|
);
|
||||||
|
|
||||||
|
my $daemon = __PACKAGE__->new('pvedaemon', $cmdline, %daemon_options);
|
||||||
|
|
||||||
|
sub init {
|
||||||
|
my ($self) = @_;
|
||||||
|
|
||||||
|
my $accept_lock_fn = "/var/lock/pvedaemon.lck";
|
||||||
|
|
||||||
|
my $lockfh = IO::File->new(">>${accept_lock_fn}") ||
|
||||||
|
die "unable to open lock file '${accept_lock_fn}' - $!\n";
|
||||||
|
|
||||||
|
my $socket = $self->create_reusable_socket(85, '127.0.0.1');
|
||||||
|
|
||||||
|
$self->{server_config} = {
|
||||||
|
base_handler_class => 'PVE::API2',
|
||||||
|
keep_alive => 100,
|
||||||
|
max_conn => 500,
|
||||||
|
max_requests => 1000,
|
||||||
|
lockfile => $accept_lock_fn,
|
||||||
|
socket => $socket,
|
||||||
|
lockfh => $lockfh,
|
||||||
|
debug => $self->{debug},
|
||||||
|
trusted_env => 1,
|
||||||
|
};
|
||||||
|
}
|
||||||
|
|
||||||
|
sub run {
|
||||||
|
my ($self) = @_;
|
||||||
|
|
||||||
|
my $server = PVE::HTTPServer->new(%{$self->{server_config}});
|
||||||
|
$server->run();
|
||||||
|
}
|
||||||
|
|
||||||
|
$daemon->register_start_command();
|
||||||
|
$daemon->register_restart_command(1);
|
||||||
|
$daemon->register_stop_command();
|
||||||
|
$daemon->register_status_command();
|
||||||
|
|
||||||
|
our $cmddef = {
|
||||||
|
start => [ __PACKAGE__, 'start', []],
|
||||||
|
restart => [ __PACKAGE__, 'restart', []],
|
||||||
|
stop => [ __PACKAGE__, 'stop', []],
|
||||||
|
status => [ __PACKAGE__, 'status', [], undef, sub { print shift . "\n";} ],
|
||||||
|
};
|
||||||
|
|
||||||
|
1;
|
||||||
|
|
||||||
|
__END__
|
||||||
|
|
||||||
|
=head1 NAME
|
||||||
|
|
||||||
|
pvedaemon - the PVE configuration server
|
||||||
|
|
||||||
|
=include synopsis
|
||||||
|
|
||||||
|
=head1 DESCRIPTION
|
||||||
|
|
||||||
|
All configuration is done using this Server. The Server only
|
||||||
|
listens to a local address 127.0.0.1 port 85 for security
|
||||||
|
reasons.
|
||||||
|
|
||||||
|
=include pve_copyright
|
@ -2,7 +2,7 @@ include ../defines.mk
|
|||||||
|
|
||||||
SUBDIRS = init.d ocf test
|
SUBDIRS = init.d ocf test
|
||||||
|
|
||||||
SERVICES = pvestatd pveproxy
|
SERVICES = pvestatd pveproxy pvedaemon
|
||||||
CLITOOLS = vzdump pvesubscription
|
CLITOOLS = vzdump pvesubscription
|
||||||
|
|
||||||
SCRIPTS = \
|
SCRIPTS = \
|
||||||
@ -12,7 +12,6 @@ SCRIPTS = \
|
|||||||
pvesh \
|
pvesh \
|
||||||
pveam \
|
pveam \
|
||||||
pvebanner \
|
pvebanner \
|
||||||
pvedaemon \
|
|
||||||
spiceproxy \
|
spiceproxy \
|
||||||
pveversion \
|
pveversion \
|
||||||
pvemailforward.pl \
|
pvemailforward.pl \
|
||||||
@ -25,7 +24,6 @@ SERVICE_MANS = $(addsuffix .8, ${SERVICES})
|
|||||||
CLI_MANS = \
|
CLI_MANS = \
|
||||||
$(addsuffix .1, ${CLITOOLS}) \
|
$(addsuffix .1, ${CLITOOLS}) \
|
||||||
pveceph.1 \
|
pveceph.1 \
|
||||||
pvedaemon.1 \
|
|
||||||
spiceproxy.1 \
|
spiceproxy.1 \
|
||||||
pveversion.1 \
|
pveversion.1 \
|
||||||
pveupgrade.1 \
|
pveupgrade.1 \
|
||||||
@ -71,9 +69,6 @@ pveperf.1.pod: pveperf
|
|||||||
perl -I.. -T -e "use PVE::CLI::$*; PVE::CLI::$*->generate_bash_completions();" >$@.tmp
|
perl -I.. -T -e "use PVE::CLI::$*; PVE::CLI::$*->generate_bash_completions();" >$@.tmp
|
||||||
mv $@.tmp $@
|
mv $@.tmp $@
|
||||||
|
|
||||||
pvedaemon.1.pod: pvedaemon
|
|
||||||
perl -I.. -T ./pvedaemon printmanpod >$@
|
|
||||||
|
|
||||||
spiceproxy.1.pod: spiceproxy
|
spiceproxy.1.pod: spiceproxy
|
||||||
perl -I.. -T ./spiceproxy printmanpod >$@
|
perl -I.. -T ./spiceproxy printmanpod >$@
|
||||||
|
|
||||||
|
@ -7,14 +7,7 @@ delete @ENV{qw(IFS CDPATH ENV BASH_ENV)};
|
|||||||
use strict;
|
use strict;
|
||||||
use warnings;
|
use warnings;
|
||||||
|
|
||||||
use PVE::SafeSyslog;
|
use PVE::Service::pvedaemon;
|
||||||
use PVE::Daemon;
|
|
||||||
use PVE::API2;
|
|
||||||
use PVE::API2::Formatter::Standard;
|
|
||||||
use PVE::API2::Formatter::HTML;
|
|
||||||
use PVE::HTTPServer;
|
|
||||||
|
|
||||||
use base qw(PVE::Daemon);
|
|
||||||
|
|
||||||
$SIG{'__WARN__'} = sub {
|
$SIG{'__WARN__'} = sub {
|
||||||
my $err = $@;
|
my $err = $@;
|
||||||
@ -25,82 +18,9 @@ $SIG{'__WARN__'} = sub {
|
|||||||
$@ = $err;
|
$@ = $err;
|
||||||
};
|
};
|
||||||
|
|
||||||
my $cmdline = [$0, @ARGV];
|
my $prepare = sub {
|
||||||
|
|
||||||
my %daemon_options = (
|
|
||||||
max_workers => 3,
|
|
||||||
restart_on_error => 5,
|
|
||||||
stop_wait_time => 15,
|
|
||||||
leave_children_open_on_reload => 1,
|
|
||||||
);
|
|
||||||
|
|
||||||
my $daemon = __PACKAGE__->new('pvedaemon', $cmdline, %daemon_options);
|
|
||||||
|
|
||||||
sub prepare {
|
|
||||||
# create dir for dtach sockets
|
# create dir for dtach sockets
|
||||||
mkdir "/var/run/dtach";
|
mkdir "/var/run/dtach";
|
||||||
}
|
|
||||||
|
|
||||||
sub init {
|
|
||||||
my ($self) = @_;
|
|
||||||
|
|
||||||
my $accept_lock_fn = "/var/lock/pvedaemon.lck";
|
|
||||||
|
|
||||||
my $lockfh = IO::File->new(">>${accept_lock_fn}") ||
|
|
||||||
die "unable to open lock file '${accept_lock_fn}' - $!\n";
|
|
||||||
|
|
||||||
my $socket = $self->create_reusable_socket(85, '127.0.0.1');
|
|
||||||
|
|
||||||
$self->{server_config} = {
|
|
||||||
base_handler_class => 'PVE::API2',
|
|
||||||
keep_alive => 100,
|
|
||||||
max_conn => 500,
|
|
||||||
max_requests => 1000,
|
|
||||||
lockfile => $accept_lock_fn,
|
|
||||||
socket => $socket,
|
|
||||||
lockfh => $lockfh,
|
|
||||||
debug => $self->{debug},
|
|
||||||
trusted_env => 1,
|
|
||||||
};
|
|
||||||
}
|
|
||||||
|
|
||||||
sub run {
|
|
||||||
my ($self) = @_;
|
|
||||||
|
|
||||||
my $server = PVE::HTTPServer->new(%{$self->{server_config}});
|
|
||||||
$server->run();
|
|
||||||
}
|
|
||||||
|
|
||||||
$daemon->register_start_command();
|
|
||||||
$daemon->register_restart_command(1);
|
|
||||||
$daemon->register_stop_command();
|
|
||||||
$daemon->register_status_command();
|
|
||||||
|
|
||||||
my $cmddef = {
|
|
||||||
start => [ __PACKAGE__, 'start', []],
|
|
||||||
restart => [ __PACKAGE__, 'restart', []],
|
|
||||||
stop => [ __PACKAGE__, 'stop', []],
|
|
||||||
status => [ __PACKAGE__, 'status', [], undef, sub { print shift . "\n";} ],
|
|
||||||
};
|
};
|
||||||
|
|
||||||
my $cmd = shift;
|
PVE::Service::pvedaemon->run_cli(undef, undef, $prepare);
|
||||||
|
|
||||||
PVE::CLIHandler::handle_cmd($cmddef, $0, $cmd, \@ARGV, undef, $0, \&prepare);
|
|
||||||
|
|
||||||
exit (0);
|
|
||||||
|
|
||||||
__END__
|
|
||||||
|
|
||||||
=head1 NAME
|
|
||||||
|
|
||||||
pvedaemon - the PVE configuration server
|
|
||||||
|
|
||||||
=include synopsis
|
|
||||||
|
|
||||||
=head1 DESCRIPTION
|
|
||||||
|
|
||||||
All configuration is done using this Server. The Server only
|
|
||||||
listens to a local address 127.0.0.1 port 85 for security
|
|
||||||
reasons.
|
|
||||||
|
|
||||||
=include pve_copyright
|
|
||||||
|
Loading…
Reference in New Issue
Block a user