use base qw(PVE::CLIHandler);
-$SIG{'__WARN__'} = sub {
- my $err = $@;
- my $t = $_[0];
- chomp $t;
- print "$t\n";
- syslog('warning', "WARNING: %s", $t);
- $@ = $err;
-};
-
$ENV{'PATH'} = '/sbin:/bin:/usr/sbin:/usr/bin';
my $daemon_initialized = 0; # we only allow one instance
delete $self->{daemon_lock_fh};
};
+my $log_err = sub {
+ my ($msg) = @_;
+ chomp $msg;
+ print STDERR "$msg\n";
+ syslog('err', "%s", $msg);
+};
+
# call this if you fork() from child
# Note: we already call this for workers, so it is only required
# if you fork inside a simple daemon (max_workers == 0).
my $lkfn = $self->{pidfile} . ".lock";
+ my $waittime = 0;
+
if (my $fd = $self->{env_pve_lock_fd}) {
$self->{daemon_lock_fh} = IO::Handle->new_from_fd($fd, "a");
-
+
} else {
+ $waittime = 5;
$self->{daemon_lock_fh} = IO::File->new(">>$lkfn");
}
die "can't open lock '$lkfn' - $!\n";
}
- for (my $i = 0; $i < 5; $i ++) {
+ for (my $i = 0; $i < $waittime; $i ++) {
return if flock ($self->{daemon_lock_fh}, LOCK_EX|LOCK_NB);
sleep(1);
}
if (!flock ($self->{daemon_lock_fh}, LOCK_EX|LOCK_NB)) {
&$close_daemon_lock($self);
- die "can't aquire lock '$lkfn' - $!\n";
+ my $err = $!;
+
+ my ($running, $pid) = $self->running();
+ if ($running) {
+ die "can't aquire lock '$lkfn' - daemon already started (pid = $pid)\n";
+ } else {
+ die "can't aquire lock '$lkfn' - $err\n";
+ }
}
};
my $pidfile = $self->{pidfile};
- if (!open (PIDFH, ">$pidfile")) {
- my $msg = "can't open pid file '$pidfile' - $!";
- syslog ('err', $msg);
- die "ERROR: $msg\n";
- }
+ die "can't open pid file '$pidfile' - $!\n" if !open (PIDFH, ">$pidfile");
+
print PIDFH "$$\n";
close (PIDFH);
};
$ENV{PVE_DAEMON_LOCK_FD} = $self->{daemon_lock_fh}->fileno;
-# my $fd = POSIX::dup($self->{daemon_lock_fh}) ||
-# die "unable to duplicate daemon_lock_fh\n";
-
-
# run in background
my $spid;
PVE::INotify::inotify_close();
$spid = fork();
if (!defined ($spid)) {
- my $msg = "can't put server into background - fork failed";
- syslog('err', $msg);
- die "ERROR: $msg\n";
+ die "can't put server into background - fork failed";
} elsif ($spid) { # parent
exit (0);
}
PVE::INotify::inotify_init();
}
- &$writepidfile($self);
-
- POSIX::setsid();
-
if ($self->{env_restart_pve_daemon}) {
syslog('info' , "restarting server");
} else {
+ &$writepidfile($self);
syslog('info' , "starting server");
}
+ POSIX::setsid();
+
open STDERR, '>&STDOUT' || die "can't close STDERR\n";
my $old_sig_term = $SIG{TERM};
sub new {
my ($this, $name, $cmdline, %params) = @_;
- die "missing name" if !$name;
+ $name = 'daemon' if !$name; # should not happen
initlog($name);
- my $restart = $ENV{RESTART_PVE_DAEMON};
- delete $ENV{RESTART_PVE_DAEMON};
+ my $self;
+
+ eval {
- my $lockfd = $ENV{PVE_DAEMON_LOCK_FD};
- delete $ENV{PVE_DAEMON_LOCK_FD};
+ my $restart = $ENV{RESTART_PVE_DAEMON};
+ delete $ENV{RESTART_PVE_DAEMON};
- die "please run as root\n" if !$restart && ($> != 0);
+ my $lockfd = $ENV{PVE_DAEMON_LOCK_FD};
+ delete $ENV{PVE_DAEMON_LOCK_FD};
- die "can't create more that one PVE::Daemon" if $daemon_initialized;
- $daemon_initialized = 1;
+ if (defined($lockfd)) {
+ $lockfd =~ m/^(\d+)$/;
+ $lockfd = $1; # untaint
+ }
- PVE::INotify::inotify_init();
+ die "please run as root\n" if !$restart && ($> != 0);
- my $class = ref($this) || $this;
+ die "can't create more that one PVE::Daemon" if $daemon_initialized;
+ $daemon_initialized = 1;
- my $self = bless {
- name => $name,
- run_dir => '/var/run',
- env_restart_pve_daemon => $restart,
- env_pve_lock_fd => $lockfd,
- workers => {},
- }, $class;
+ PVE::INotify::inotify_init();
- foreach my $opt (keys %params) {
- my $value = $params{$opt};
- if ($opt eq 'restart_on_error') {
- $self->{$opt} = $value;
- } elsif ($opt eq 'stop_wait_time') {
- $self->{$opt} = $value;
- } elsif ($opt eq 'run_dir') {
- $self->{$opt} = $value;
- } elsif ($opt eq 'max_workers') {
- $self->{$opt} = $value;
- } else {
- die "unknown option '$opt'";
+ my $class = ref($this) || $this;
+
+ $self = bless {
+ name => $name,
+ run_dir => '/var/run',
+ env_restart_pve_daemon => $restart,
+ env_pve_lock_fd => $lockfd,
+ workers => {},
+ }, $class;
+
+ foreach my $opt (keys %params) {
+ my $value = $params{$opt};
+ if ($opt eq 'restart_on_error') {
+ $self->{$opt} = $value;
+ } elsif ($opt eq 'stop_wait_time') {
+ $self->{$opt} = $value;
+ } elsif ($opt eq 'run_dir') {
+ $self->{$opt} = $value;
+ } elsif ($opt eq 'max_workers') {
+ $self->{$opt} = $value;
+ } else {
+ die "unknown daemon option '$opt'\n";
+ }
}
- }
- $self->{pidfile} = "$self->{run_dir}/${name}.pid";
+ $self->{pidfile} = "$self->{run_dir}/${name}.pid";
- $self->{nodename} = PVE::INotify::nodename();
+ $self->{nodename} = PVE::INotify::nodename();
- $self->{cmdline} = [];
+ $self->{cmdline} = [];
- foreach my $el (@$cmdline) {
- $el =~ m/^(.*)$/; # untaint
- push @{$self->{cmdline}}, $1;
- }
+ foreach my $el (@$cmdline) {
+ $el =~ m/^(.*)$/; # untaint
+ push @{$self->{cmdline}}, $1;
+ }
- $0 = $name;
+ $0 = $name;
+ };
+ if (my $err = $@) {
+ &$log_err($err);
+ exit(-1);
+ }
return $self;
}
eval { &$server_run($self, $debug); };
if (my $err = $@) {
- syslog('err', "start failed - $err");
+ &$log_err("start failed - $err");
+ exit(-1);
}
}
&$server_cleanup($self);
};
if (my $err = $@) {
- syslog('err', "cleanup failed - $err");
+ &$log_err("cleanup failed - $err");
}
}
}