mirror of
https://github.com/MariaDB/server.git
synced 2025-01-16 20:12:31 +01:00
145 lines
3.5 KiB
Perl
145 lines
3.5 KiB
Perl
# -*- cperl -*-
|
|
# Copyright (C) 2004-2006 MySQL AB
|
|
#
|
|
# This program is free software; you can redistribute it and/or modify
|
|
# it under the terms of the GNU General Public License as published by
|
|
# the Free Software Foundation; version 2 of the License.
|
|
#
|
|
# This program is distributed in the hope that it will be useful,
|
|
# but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
# GNU General Public License for more details.
|
|
#
|
|
# You should have received a copy of the GNU General Public License
|
|
# along with this program; if not, write to the Free Software
|
|
# Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
|
|
|
|
# This is a library file used by the Perl version of mysql-test-run,
|
|
# and is part of the translation of the Bourne shell script with the
|
|
# same name.
|
|
|
|
use strict;
|
|
use Socket;
|
|
use Errno;
|
|
use My::Platform;
|
|
use if IS_WINDOWS, "Net::Ping";
|
|
|
|
# Ancient perl might not have port_number method for Net::Ping.
|
|
# Check it and use fallback to connect() if it is not present.
|
|
BEGIN
|
|
{
|
|
my $use_netping= 0;
|
|
if (IS_WINDOWS)
|
|
{
|
|
my $ping = Net::Ping->new();
|
|
if ($ping->can("port_number"))
|
|
{
|
|
$use_netping= 1;
|
|
}
|
|
}
|
|
eval 'sub USE_NETPING { $use_netping }';
|
|
}
|
|
|
|
sub sleep_until_file_created ($$$);
|
|
sub mtr_ping_port ($);
|
|
|
|
sub mtr_ping_port ($) {
|
|
my $port= shift;
|
|
|
|
mtr_verbose("mtr_ping_port: $port");
|
|
|
|
if (IS_WINDOWS && USE_NETPING)
|
|
{
|
|
# Under Windows, connect to a port that is not open is slow
|
|
# It takes ~1sec. Net::Ping with small timeout is much faster.
|
|
my $ping = Net::Ping->new();
|
|
$ping->port_number($port);
|
|
if ($ping->ping("localhost",0.1))
|
|
{
|
|
mtr_verbose("USED");
|
|
return 1;
|
|
}
|
|
else
|
|
{
|
|
mtr_verbose("FREE");
|
|
return 0;
|
|
}
|
|
}
|
|
|
|
my $remote= "localhost";
|
|
my $iaddr= inet_aton($remote);
|
|
if ( ! $iaddr )
|
|
{
|
|
mtr_error("can't find IP number for $remote");
|
|
}
|
|
my $paddr= sockaddr_in($port, $iaddr);
|
|
my $proto= getprotobyname('tcp');
|
|
if ( ! socket(SOCK, PF_INET, SOCK_STREAM, $proto) )
|
|
{
|
|
mtr_error("can't create socket: $!");
|
|
}
|
|
|
|
mtr_debug("Pinging server (port: $port)...");
|
|
|
|
if ( connect(SOCK, $paddr) )
|
|
{
|
|
close(SOCK); # FIXME check error?
|
|
mtr_verbose("USED");
|
|
return 1;
|
|
}
|
|
else
|
|
{
|
|
mtr_verbose("FREE");
|
|
return 0;
|
|
}
|
|
}
|
|
|
|
##############################################################################
|
|
#
|
|
# Wait for a file to be created
|
|
#
|
|
##############################################################################
|
|
|
|
# FIXME check that the pidfile contains the expected pid!
|
|
|
|
sub sleep_until_file_created ($$$) {
|
|
my $pidfile= shift;
|
|
my $timeout= shift;
|
|
my $proc= shift;
|
|
my $sleeptime= 100; # Milliseconds
|
|
my $loops= ($timeout * 1000) / $sleeptime;
|
|
|
|
for ( my $loop= 1; $loop <= $loops; $loop++ )
|
|
{
|
|
if ( -r $pidfile )
|
|
{
|
|
return 1;
|
|
}
|
|
|
|
# Check if it died after the fork() was successful
|
|
if ( defined $proc and ! $proc->wait_one(0) )
|
|
{
|
|
mtr_warning("Process $proc died");
|
|
return 0;
|
|
}
|
|
|
|
mtr_debug("Sleep $sleeptime milliseconds waiting for $pidfile");
|
|
|
|
# Print extra message every 60 seconds
|
|
my $seconds= ($loop * $sleeptime) / 1000;
|
|
if ( $seconds > 1 and int($seconds * 10) % 600 == 0 )
|
|
{
|
|
my $left= $timeout - $seconds;
|
|
mtr_warning("Waited $seconds seconds for $pidfile to be created, " .
|
|
"still waiting for $left seconds...");
|
|
}
|
|
|
|
mtr_milli_sleep($sleeptime);
|
|
|
|
}
|
|
|
|
return 0;
|
|
}
|
|
|
|
|
|
1;
|