mirror of
https://github.com/moparisthebest/curl
synced 2024-08-13 17:03:50 -04:00
a72ce23f16
given file, serverpid sub is renamed to pidfromfile. In addition it is enhanced to make sure that it always returns zero unless a numerical positive value is returned. - To better reflect that only process existance is actually checked, checkserver sub is renamed to processexists. In addition it is enhanced making it remove the given pid file when the extracted pid is no longer alive.
127 lines
3.7 KiB
Perl
127 lines
3.7 KiB
Perl
#***************************************************************************
|
|
# _ _ ____ _
|
|
# Project ___| | | | _ \| |
|
|
# / __| | | | |_) | |
|
|
# | (__| |_| | _ <| |___
|
|
# \___|\___/|_| \_\_____|
|
|
#
|
|
# Copyright (C) 1998 - 2009, Daniel Stenberg, <daniel@haxx.se>, et al.
|
|
#
|
|
# This software is licensed as described in the file COPYING, which
|
|
# you should have received as part of this distribution. The terms
|
|
# are also available at http://curl.haxx.se/docs/copyright.html.
|
|
#
|
|
# You may opt to use, copy, modify, merge, publish, distribute and/or sell
|
|
# copies of the Software, and permit persons to whom the Software is
|
|
# furnished to do so, under the terms of the COPYING file.
|
|
#
|
|
# This software is distributed on an "AS IS" basis, WITHOUT WARRANTY OF ANY
|
|
# KIND, either express or implied.
|
|
#
|
|
# $Id$
|
|
###########################################################################
|
|
|
|
#######################################################################
|
|
# pidfromfile returns the pid stored in the given pidfile. The value
|
|
# of the returned pid will never be a negative value. It will be zero
|
|
# on any file related error or if a pid can not be extracted from the
|
|
# given file.
|
|
#
|
|
sub pidfromfile {
|
|
my $pidfile = $_[0];
|
|
my $pid = 0;
|
|
|
|
if(-f $pidfile && -s $pidfile && open(PIDFH, "<$pidfile")) {
|
|
$pid = 0 + <PIDFH>;
|
|
close(PIDFH);
|
|
$pid = 0 unless($pid > 0);
|
|
}
|
|
return $pid;
|
|
}
|
|
|
|
#######################################################################
|
|
# processexists checks if a process with the pid stored in the given
|
|
# pidfile exists and is alive. This will return 0 on any file related
|
|
# error or if a pid can not be extracted from the given file. When a
|
|
# process with the same pid as the one extracted from the given file
|
|
# is currently alive this returns that positive pid. Otherwise, when
|
|
# the process is not alive, will return the negative value of the pid.
|
|
#
|
|
sub processexists {
|
|
# use POSIX ":sys_wait_h";
|
|
my $pidfile = $_[0];
|
|
|
|
# fetch pid from pidfile
|
|
my $pid = pidfromfile($pidfile);
|
|
|
|
if($pid > 0) {
|
|
# verify if currently alive
|
|
if(kill(0, $pid)) {
|
|
return $pid;
|
|
}
|
|
else {
|
|
# reap it if this has not already been done
|
|
# waitpid($pid, &WNOHANG);
|
|
# get rid of the certainly invalid pidfile
|
|
unlink($pidfile) if($pid == pidfromfile($pidfile));
|
|
return -$pid; # negative means dead process
|
|
}
|
|
}
|
|
return 0;
|
|
}
|
|
|
|
#############################################################################
|
|
# Kill a specific slave
|
|
#
|
|
sub ftpkillslave {
|
|
my ($id, $ext, $verbose)=@_;
|
|
my $base;
|
|
for $base (('filt', 'data')) {
|
|
my $f = ".sock$base$id$ext.pid";
|
|
my $pid = processexists($f);
|
|
if($pid > 0) {
|
|
printf ("* kill pid for %s => %d\n", "ftp-$base$id$ext", $pid) if($verbose);
|
|
kill (9, $pid); # die!
|
|
waitpid($pid, 0);
|
|
}
|
|
unlink($f);
|
|
}
|
|
}
|
|
|
|
|
|
#############################################################################
|
|
# Make sure no FTP leftovers are still running. Kill all slave processes.
|
|
# This uses pidfiles since it might be used by other processes.
|
|
#
|
|
sub ftpkillslaves {
|
|
my ($versbose) = @_;
|
|
for $ext (("", "ipv6")) {
|
|
for $id (("", "2")) {
|
|
ftpkillslave ($id, $ext, $verbose);
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
sub set_advisor_read_lock {
|
|
my ($filename) = @_;
|
|
|
|
if(open(FILEH, ">$filename")) {
|
|
close(FILEH);
|
|
return;
|
|
}
|
|
printf "Error creating lock file $filename error: $!";
|
|
}
|
|
|
|
|
|
sub clear_advisor_read_lock {
|
|
my ($filename) = @_;
|
|
|
|
if(-f $filename) {
|
|
unlink($filename);
|
|
}
|
|
}
|
|
|
|
|
|
1;
|