Инструменты для Бизнеса

• Пингуем хост
• Демон
• Монитор
• Другие функции
• Сборка мусора
• Вкуснятинка
• Резюме

Ничего не происходит просто так. Вот и avanetd появился не просто так, а из-за того, что меня в очередной раз достали. И ладно бы наши офисные юзеры – на них хоть поорать можно. :) Так ведь стали приходить посетители интернет-салона, а на них уже не покричишь. Как говорится – клиент всегда прав. Устал я объяснять, что да почему и когда будет работать. Пришлось почесать в затылке и что нибудь придумать.

На шлюзе у меня, как и положено крутится Апач. Там же есть фича, показывающая состояние соединения с провайдером. Но вот в чем фишка, работает она, анализируя вывод ifconfig, а, следовательно, медленна и потенциально небезопасна. Все руки не доходят снести ее. Да к тому же порой ppp-watch так зависнет, что хрен поймешь: вроде интерфейс поднят, а связи нет. На тот момент чесание затылка в поисках решения уже довело меня до маленькой плеши. :) Тут нужно что-то до тупости элементарное, что бы работало как часы. Так, так... Что использует наш брат админ в первую очередь, когда что нибудь в сети валится? Правильно – ping. Хм... Юзать вывод от стандартного ping – ну нет уж, увольте. Так, смотрим стандартную перловую документацию. О! Есть такая буква – Net::Ping нас спасет.

Ну, пинг пингом, скажете вы, а на кой он нам? Ну, скромно ковыряя в стене дырку отвечу я, ничего лучшего, чем регулярно пинговать какой нибудь хост я не придумал. В качестве оправдания скажу еще, что пинговать будем не какой-то там левый хост, а DNS провайдера (ну или какой нить другой хост в провайдерской подсети) и парочку каких нибудь яндексо-рамблеров, за потенцию :) которых отвечают нехилые спецы.

Пора определиться с текущей задачей. Перво-наперво нас интересует доступны ли провайдерская подсеть и Интернет. Даю установку забыть о том, что конечной целью является нотификация юзеров, например интернет-салона. Если забыть не получается, посидите помедитируйте – должно помочь :) На данный момент нам нужен надежный монитор, который эффективно будет сигнализировать о том, доступен указанный хост или нет.

Пингуем хост

my $host = '127.0.0.1'; my ($refresh_count,$if_succ) = (20,15); my $timeout_succ,$timeout_fail) = (6,1); my $ping = Net::Ping->new('icmp'); my $work = 1; $SIG{INT} = $SIG{HUP} = $SIG{TERM} = sub{$work = undef}; my ($succ,$fail,$r) = (0,0); while ($work){ 	last unless defined($r = $ping->ping($host)); 	$r ? $succ ++ : $fail ++; 	if ($succ + $fail == $refresh_count){ 		if (open STAT,">indicator.file"){ 			select((select(STAT),$|=1)[0]); 			flock STAT,2; 			print STAT $succ >= $if_succ ? 1 : 0; 			flock STAT,8; 			close STAT; 		} 		$succ = $fail = 0; 	} 	sleep($r ? $timeout_succ : $timeout_fail); } $ping->close(); 

Итак, алгоритм... $refresh_count и $if_succ определяют пропорции удача/неудача, при которых считается, что связь с хостом есть. Иначе говоря, эти переменные определяют допустимый объем потерь пакетов. Если у вас какое-нибудь модное соединение с провайдером, то можно изменить значение $if_succ в сторону уменьшения допустимого объема потерь пакетов. Кроме того, переменная $refresh_count определяет количество проверок, через которое обновляется статистика. В нашем случае это отсылка 20 пакетов.

Переменные $timeout_succ и $timeout_fail определяют время задержки между повторными проверками в случаях, соответственно, удачного и проваленного результата ping. Зачем? А за тем, что есть такое понятие как таймаут соединения. Это значит, что попытка связаться с удаленным хостом признается проваленной, если прошло указанное время, а связи нет. Так вот, в нашем случае, если пропинговать хост не удалось, то ко времени ожидания между повторными попытками пинга прибавляется время таймаута. Дефолтный таймаут равен 5 секундам. Прибавим одну секунду на ожидание следующего пинга и получим время между удачными проверками, то есть 6, что полностью соответствует значению переменной $timeout_succ. Таким макаром мы пытаемся уравнять время обновления статистики для доступных и недоступных хостов. Хотя на самом деле, все эти усилия приведут к относительному выравниванию. То есть разница будет в любом случае, так как даже в случае удачи пинг не выполняется мгновенно.

Метод ping объекта Net::Ping возвращает неопределенное значение в случае если пропинговать хост не удалось. Это происходит тогда, когда не удается определить IP-адрес хоста. По этому сразу хочу предупредить, не ленитесь, определите IP-хостов и юзайте их. В противном случае программа будет пахать вхолостую.

Следующая за вызовом метода ping интересная конструкция инкрементирует счетчики удач/провалов. Вообще-то, можно организовать цикл for внутри while, тогда счетчик провалов будет не нужен. Ну да пусть будет так, как есть.

Далее программа проверяет, сколько проверок было выполнено и если это количество совпадает со значением переменной $refresh_count, выполняется сохранение статистики по хосту. Вот здесь нам и понадобится переменная $if_succ, с помощью которой мы определяем, что записывать в файл индикации. В случае если потери пакетов выше дозволенного, хост признается недоступным и в индикатор записывается 0. Иначе, в индикатор записывается 1.

Ну и после всего этого, выбираем соответствующий результату пинга таймаут и засыпаем на время. Цикл прерывается, когда программа получает сигналы INT, TERM или HUP. Вот такая незамысловатая схема работы.

Демон

Демонов мы уже писали не вспомню даже сколько раз, по этому весь нижеприведенный код не должен вас шокировать. Прежде всего определимся с используемыми переменными

#!/usr/bin/perl -w use strict; use POSIX qw/setsid/; use Net::Ping; use vars qw/$timeout_succ $timeout_fail $refresh_count $stat_dir $if_succ $waitp_timeout $pid_file $log_file @childs/; $stat_dir		= './stat'; $pid_file		= './avanetd.pid'; $log_file		= './avanetd.log'; $timeout_succ	= 6; # seconds $timeout_fail	= 1; # seconds $refresh_count	= 20; # * ping_timeout = refresh time $if_succ		= 15; $waitp_timeout	= 5; 

if ($#ARGV < 0){ print "Usage: ./avanetd.pl host_ip host2_ip ...\n"; exit; } if (&IsRunning){ Log("Already running!\n"); exit} -d $stat_dir or die "Stat directory not exists"; my $pid = fork; die "Couldn't fork!" unless defined($pid); exit if $pid; die "Can't start new session: $!" unless POSIX::setsid(); &StorePid; 

С помощью функции IsRunning() мы проверяем не запущена ли копия демона. Если запущена, то работать напрочь отказываемся, предварительно пожаловавшись функции Log() о попытке сверхурочного напряга.

Следующая проверка тестирует каталог, указанный в качестве каталога сохранения индикаторов. И это вроде бы логично – нафига работать, если записывать результаты некуда.

Последующие четыре строки глаза уже намозолили. Превращение в демона не меняется от решения к решению. С функцией StorePid() то же все ясно – она сохраняет идентификатор процесса в pid-файл, что бы нам потом не лазить по всяким там ps-ам, а просто глянуть в pid-файл и пришибить программу.

За-то дальше начинается уже что то более интересное

$SIG{CHLD} = 'IGNORE'; foreach my $host (@ARGV){ 	push @childs,StartMonitor($host); } my $wait = 1; $SIG{INT} = $SIG{HUP} = $SIG{TERM} = sub{$wait = undef}; sleep 1 while $wait; Log("Terminating childs...\n"); 

Далее мы перебираем @ARGV, предполагая что в нем перечислены IP-адреса хостов, которые нужно пинговать. Для каждого хоста создается отдельный процесс. Выполняется это с помощью вызова функции StartMonitor() с адресом хоста в качестве аргумента. Идентификаторы потомков складываются в массив @childs, для того, что бы впоследствии родитель мог всех пришибить (прям как Иван Грозный :).

Ну и после всех этих манипуляций родительский процесс входит в цикл ожидания одного из сигналов INT, HUP или TERM.

На этом бы хотелось с демоном закончить... Нет шучу. Что самое главное в нашем деле? Правильно, чистоплотность. А что такое чистоплотность? Чисто масса на чисто объем? Нет, не в нашем случай. Программная чистоплотность – это когда после программы не остается хлама, который потом воняет на всю систему (ниче, что так откровенно?). :)

Однако, процесс завершения работы пока рассматривать рано. Давайте сначала глянем на монитор и на другие нерассмотренные функции, а вкусненькое оставим на потом. :)

Монитор

sub StartMonitor{ 	my $host = shift; 	return undef unless $host; 	my $pid = fork; 	return undef unless defined($pid); 	return $pid if $pid != 0; 	# Child code 	Log("Starting for $host\n"); 	my $ping = Net::Ping->new('icmp'); 	my $work = 1; 	$SIG{INT} = $SIG{HUP} = $SIG{TERM} = sub{$work = undef}; 	my ($succ,$fail,$r) = (0,0); 	while ($work){ 		last unless defined($r = $ping->ping($host)); 		$r ? $succ ++ : $fail ++; 		if ($succ + $fail == $refresh_count){ 			if (open STAT,">$stat_dir/avanetd.$host"){ Log("Refresh for $host: ". ($succ >= $if_succ ? "available" : "unreachable").".\n"); 				select((select(STAT),$|=1)[0]); 				flock STAT,2; 				print STAT $succ >= $if_succ ? 1 : 0; 				flock STAT,8; 				close STAT; 			} 			$succ = $fail = 0; 		} 		sleep($r ? $timeout_succ : $timeout_fail); 	} 	$ping->close(); 	exit; } 

Другие функции

sub IsRunning{ 	return 0 unless -f $pid_file; 	open PID,$pid_file or die "Can't open pid file"; 	chomp(my $prev_pid = <PID>); 	close PID; 	return 1 if kill 0 => $prev_pid; 	return 0; } 

Оставшиеся две функции не заслуживают пристального внимания. По этому привожу их код, без каких либо комментариев.

sub StorePid{ 	open PID,">$pid_file" or die "Can't open pid file"; 	select((select(PID),$|=1)[0]); 	print PID $$; 	close PID; } sub Log{ return unless $_[0]; return unless open LOG,">>$log_file"; select((select(LOG),$|=1)[0]); flock LOG,2; print LOG scalar(localtime)," Avanetd $$: $_[0]"; flock LOG,8; close LOG; } 

Сборка мусора

foreach $pid (@childs){ 	if ($pid){ 		Log("Killing $pid...\n"); 		kill INT => $pid; 		undef $@; 		eval { 		 local $SIG{ALRM} = sub{die"waitpid($pid) timeout\n"}; 		 alarm $waitp_timeout; 		 waitpid($pid,0); 		 alarm 0; 		}; 		if ($@){ 		 Log($@); 		 kill KILL => $pid; 		 waitpid $pid,0; 		} 	} } if (opendir STAT,$stat_dir){ 	while (my $file = readdir STAT){ 		next if !-f "$stat_dir/$file" || !$file =~ /^avanetd\./; 		Log("Unlinking $file\n"); 		unlink "$stat_dir/$file"; 	} 	closedir STAT; } unlink $pid_file; Log("Shutdown avanetd.\n"); exit; 

Вкуснятинка

0 while $wait; 

#top –p pid 

#kill pid 

Резюме