proxmox-mirrors/pve-manager
1
0
Fork 0
mirror of https://git.proxmox.com/git/pve-manager synced 2025-08-15 09:22:03 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

implement service API using systemctl

Browse Source
This commit is contained in:
Dietmar Maurer 2015-06-05 15:32:14 +02:00
parent e8ee57105f
commit 50d4dc1749
1 changed files with 70 additions and 109 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

175
PVE/API2/Services.pm
View File

@ -16,24 +16,66 @@ use IO::File;
use base qw(PVE::RESTHandler); use base qw(PVE::RESTHandler);
my $service_list = { my $service_name_list = [
pveproxy => { name => 'WWW', desc => 'Web/API server' }, 'pveproxy',
postfix => { name => 'SMTP', desc => 'Simple Mail Tranfer Protocol' }, 'pvedaemon',
ntpd => { name => 'NTP', desc => 'Network time protocol' }, 'spiceproxy',
sshd => { name => 'SSH', desc => 'Secure shell daemon' }, 'pvestatd',
syslog => { name => 'Syslog', desc => 'Syslog daemon' }, 'pve-cluster',
cron => { name => 'CRON', desc => 'Daemon to execute scheduled commands' }, 'corosync',
pvedaemon => { name => 'NodeManager', desc => 'PVE node manager daemon' }, 'pve-firewall',
corosync => { name => 'CMan', desc => 'CMan/Corosync cluster daemon' }, 'pvefw-logger',
# clvm => { name => 'CLVM', desc => 'LVM cluster locking daemon' }, 'pve-ha-crm',
rgmanager => { name => 'RGManager', desc => 'Resource Group Manager daemon' }, 'pve-ha-lrm',
pvecluster => { name => 'PVECluster', desc => 'Proxmox VE cluster file system' }, 'sshd',
'syslog',
'cron',
'postfix',
];
my $get_full_service_state = sub {
my ($service) = @_;
my $res;
my $parser = sub {
my $line = shift;
if ($line =~ m/^([^=\s]+)=(.*)$/) {
$res->{$1} = $2;
}
}; };
PVE::Tools::run_command(['systemctl', 'show', $service], outfunc => $parser);
return $res;
};
my $static_service_list;
sub get_service_list {
return $static_service_list if $static_service_list;
my $list = {};
foreach my $name (@$service_name_list) {
my $ss;
eval { $ss = &$get_full_service_state($name); };
warn $@ if $@;
next if !$ss;
next if !defined($ss->{Description});
$list->{$name} = { name => $name, desc => $ss->{Description} };
}
$static_service_list = $list;
return $static_service_list;
}
my $service_prop_desc = { my $service_prop_desc = {
description => "Service ID", description => "Service ID",
type => 'string', type => 'string',
enum => [ keys %{$service_list} ], enum => $service_name_list,
}; };
my $service_cmd = sub { my $service_cmd = sub {
@ -44,106 +86,29 @@ my $service_cmd = sub {
die "unknown service command '$cmd'\n" die "unknown service command '$cmd'\n"
if $cmd !~ m/^(start|stop|restart|reload)$/; if $cmd !~ m/^(start|stop|restart|reload)$/;
if ($service eq 'postfix') { if ($service eq 'pvecluster' || $service eq 'pvedaemon' || $service eq 'pveproxy') {
$initd_cmd = '/etc/init.d/postfix';
} elsif ($service eq 'pvecluster') {
if ($cmd eq 'restart') { if ($cmd eq 'restart') {
$initd_cmd = '/etc/init.d/pve-cluster'; # OK
} else {
die "invalid service cmd 'pve-cluster $cmd': ERROR";
}
} elsif ($service eq 'pvedaemon') {
if ($cmd eq 'restart') {
$initd_cmd = '/etc/init.d/pvedaemon';
} else { } else {
die "invalid service cmd '$service $cmd': ERROR"; die "invalid service cmd '$service $cmd': ERROR";
} }
} elsif ($service eq 'pveproxy') {
if ($cmd eq 'restart') {
$initd_cmd = '/etc/init.d/pveproxy';
} else {
die "invalid service cmd '$service $cmd': ERROR";
}
} elsif ($service eq 'ntpd') {
# debian start/stop scripts does not work for us
if ($cmd eq 'stop') {
system ('/etc/init.d/ntp stop');
#system ('/usr/bin/killall /usr/sbin/ntpd');
} elsif ($cmd eq 'start') {
system ('/etc/init.d/ntp start');
system ('/sbin/hwclock --systohc');
} elsif ($cmd eq 'restart') {
system ('/etc/init.d/ntp restart');
system ('/sbin/hwclock --systohc');
# restart cron/syslog to get right schedules and log time/dates
system ('/etc/init.d/rsyslog restart');
system ('/etc/init.d/cron restart');
}
return 0;
} elsif ($service eq 'syslog') {
$initd_cmd = '/etc/init.d/rsyslog';
} elsif ($service eq 'cron') {
$initd_cmd = '/etc/init.d/cron';
} elsif ($service eq 'corosync') {
$cmd = 'start' if $cmd eq 'restart';
$initd_cmd = '/etc/init.d/cman';
} elsif ($service eq 'clvm') {
$initd_cmd = '/etc/init.d/clvm';
} elsif ($service eq 'rgmanager') {
$initd_cmd = '/etc/init.d/rgmanager';
} elsif ($service eq 'sshd') {
$initd_cmd = '/etc/init.d/ssh';
} else {
die "unknown service '$service': ERROR";
} }
PVE::Tools::run_command ([$initd_cmd, $cmd]); PVE::Tools::run_command(['systemctl', $cmd, $service]);
}; };
my $service_state = sub { my $service_state = sub {
my ($service) = @_; my ($service) = @_;
my $pid_file; my $ss;
eval { $ss = &$get_full_service_state($service); };
if ($service eq 'postfix') { if (my $err = $@) {
$pid_file = '/var/spool/postfix/pid/master.pid'; return 'unknown';
} elsif ($service eq 'pveproxy') {
$pid_file = '/var/run/pveproxy/pveproxy.pid';
} elsif ($service eq 'pvedaemon') {
$pid_file = '/var/run/pvedaemon.pid';
} elsif ($service eq 'pvecluster') {
$pid_file = '/var/run/pve-cluster.pid';
} elsif ($service eq 'ntpd') {
$pid_file = '/var/run/ntpd.pid';
} elsif ($service eq 'sshd') {
$pid_file = '/var/run/sshd.pid';
} elsif ($service eq 'cron') {
$pid_file = '/var/run/crond.pid';
} elsif ($service eq 'corosync') {
$pid_file = '/var/run/corosync.pid';
} elsif ($service eq 'clvm') {
$pid_file = '/var/run/clvmd.pid';
} elsif ($service eq 'rgmanager') {
$pid_file = '/var/run/rgmanager.pid';
} elsif ($service eq 'syslog') {
$pid_file = '/var/run/rsyslogd.pid';
} else {
die "unknown service '$service': ERROR";
} }
my $pid; return $ss->{SubState} if $ss->{SubState};
if (my $fh = IO::File->new ($pid_file, "r")) {
my $line = <$fh>;
chomp $line;
if ($line && ($line =~ m/^\s*(\d+)\s*$/)) { return 'unknown';
$pid = $1;
}
}
return 'running' if ($pid && kill (0, $pid));
return 'stopped';
}; };
__PACKAGE__->register_method ({ __PACKAGE__->register_method ({
@ -175,6 +140,8 @@ __PACKAGE__->register_method ({
my $res = []; my $res = [];
my $service_list = get_service_list();
foreach my $id (keys %{$service_list}) { foreach my $id (keys %{$service_list}) {
push @$res, { push @$res, {
service => $id, service => $id,
@ -250,6 +217,8 @@ __PACKAGE__->register_method ({
code => sub { code => sub {
my ($param) = @_; my ($param) = @_;
my $service_list = get_service_list();
my $si = $service_list->{$param->{service}}; my $si = $service_list->{$param->{service}};
return { return {
service => $param->{service}, service => $param->{service},
@ -286,8 +255,6 @@ __PACKAGE__->register_method ({
my $user = $rpcenv->get_user(); my $user = $rpcenv->get_user();
my $si = $service_list->{$param->{service}};
my $realcmd = sub { my $realcmd = sub {
my $upid = shift; my $upid = shift;
@ -327,8 +294,6 @@ __PACKAGE__->register_method ({
my $user = $rpcenv->get_user(); my $user = $rpcenv->get_user();
my $si = $service_list->{$param->{service}};
my $realcmd = sub { my $realcmd = sub {
my $upid = shift; my $upid = shift;
@ -368,8 +333,6 @@ __PACKAGE__->register_method ({
my $user = $rpcenv->get_user(); my $user = $rpcenv->get_user();
my $si = $service_list->{$param->{service}};
my $realcmd = sub { my $realcmd = sub {
my $upid = shift; my $upid = shift;
@ -409,8 +372,6 @@ __PACKAGE__->register_method ({
my $user = $rpcenv->get_user(); my $user = $rpcenv->get_user();
my $si = $service_list->{$param->{service}};
my $realcmd = sub { my $realcmd = sub {
my $upid = shift; my $upid = shift;