lilalo
annotate l3-backend @ 87:c70be67ed3d4
Наведение порядка в коде.
Обработка чуть лучше отделена от представления.
+ добавлено три совета в документацию
Обработка чуть лучше отделена от представления.
+ добавлено три совета в документацию
author | devi |
---|---|
date | Tue Feb 28 13:11:26 2006 +0200 (2006-02-28) |
parents | |
children | 4c02cf4123ee |
rev | line source |
---|---|
devi@27 | 1 #!/usr/bin/perl |
devi@27 | 2 |
devi@27 | 3 use strict; |
devi@27 | 4 use lib '.'; |
devi@27 | 5 use l3config; |
devi@27 | 6 use IO::Socket; |
devi@27 | 7 use POSIX qw(:sys_wait_h); |
devi@27 | 8 |
devi@27 | 9 sub main; |
devi@27 | 10 |
devi@27 | 11 main(); |
devi@27 | 12 |
devi@27 | 13 sub REAPER { |
devi@27 | 14 1 until (-1 == waitpid(-1, WNOHANG)); |
devi@27 | 15 $SIG{CHLD} = \&REAPER; |
devi@27 | 16 } |
devi@27 | 17 |
devi@27 | 18 sub process_was_killed |
devi@27 | 19 { |
devi@27 | 20 # Здесь должна быть красивая процедура |
devi@27 | 21 # завершения демона |
devi@27 | 22 unlink $Config{backend_pidfile}; |
devi@27 | 23 exit(0); |
devi@27 | 24 } |
devi@27 | 25 |
devi@27 | 26 sub main { |
devi@27 | 27 init_config(); |
devi@27 | 28 |
devi@27 | 29 |
devi@27 | 30 # Проверяем, возможно демон уже запущен |
devi@27 | 31 # Если он работает, просто завершаемся |
devi@27 | 32 if (open(PIDFILE, $Config{backend_pidfile})) { |
devi@27 | 33 my $pid = <PIDFILE>; |
devi@27 | 34 close(PIDFILE); |
devi@27 | 35 if ( ! -e "/proc/$pid" || !`grep $Config{"l3-backend"} /proc/$pid/cmdline && grep "uid:.*\b$<\b" /proc/$pid/status`) { |
devi@27 | 36 print "Removing stale pidfile\n"; |
devi@27 | 37 unlink $Config{backend_pidfile} |
devi@27 | 38 or die "Can't remove stale pidfile ". $Config{backend_pidfile}. " : $!"; |
devi@27 | 39 } |
devi@27 | 40 else { |
devi@27 | 41 print "l3-backend is already running\n"; |
devi@27 | 42 exit(0); |
devi@27 | 43 } |
devi@27 | 44 } |
devi@27 | 45 |
devi@27 | 46 # Уходим в background, если необходимо |
devi@27 | 47 if ($Config{detach} =~ /^y/i) { |
devi@27 | 48 #$Config{verbose} = "no"; |
devi@27 | 49 my $pid = fork; |
devi@27 | 50 exit if $pid; |
devi@27 | 51 die "Couldn't fork: $!" unless defined ($pid); |
devi@27 | 52 |
devi@27 | 53 open(PIDFILE, ">", $Config{backend_pidfile}) |
devi@27 | 54 or die "Can't open pidfile ". $Config{backend_pidfile}. " for wrting: $!"; |
devi@27 | 55 print PIDFILE $$; |
devi@27 | 56 close(PIDFILE); |
devi@27 | 57 |
devi@27 | 58 for my $handle (*STDIN, *STDOUT, *STDERR) { |
devi@27 | 59 open ($handle, "+<", "/dev/null") |
devi@27 | 60 or die "can't reopen $handle to /dev/null: $!" |
devi@27 | 61 } |
devi@27 | 62 |
devi@27 | 63 POSIX::setsid() |
devi@27 | 64 or die "Can't start a new session: $!"; |
devi@27 | 65 |
devi@27 | 66 $0 = $Config{"l3-backend"}; |
devi@27 | 67 |
devi@27 | 68 $SIG{INT} = $SIG{TERM} = $SIG{HUP} = \&process_was_killed; |
devi@27 | 69 } |
devi@27 | 70 |
devi@27 | 71 # Открываем сетевой сокет и слушаем |
devi@27 | 72 my $server = IO::Socket::INET->new( |
devi@27 | 73 LocalPort => $Config{backend_port}, |
devi@27 | 74 Type => SOCK_STREAM, |
devi@27 | 75 Reuse => 1, |
devi@27 | 76 Listen => 10 ); |
devi@27 | 77 |
devi@27 | 78 if (!$server) { |
devi@27 | 79 die "Couldn't bind to socket ".$Config{backend_port}."\n"; |
devi@27 | 80 } |
devi@27 | 81 |
devi@27 | 82 $SIG{CHLD} = 'IGNORE'; |
devi@27 | 83 |
devi@27 | 84 # При получении новых соединенений, |
devi@27 | 85 # порождаем дочерние процессы |
devi@27 | 86 while (my $client = $server->accept()) { |
devi@27 | 87 my $pid; |
devi@27 | 88 next if $pid = fork; |
devi@27 | 89 die "fork: $!" unless defined $pid; |
devi@27 | 90 |
devi@27 | 91 # Это наш ответвлённый клиент |
devi@27 | 92 close($server); |
devi@27 | 93 |
devi@27 | 94 # Считываем данные и передаём их в точку получения |
devi@27 | 95 open(OUT, ">>", $Config{"backend_datafile"}); |
devi@27 | 96 select OUT; $|=1; |
devi@27 | 97 while(<$client>) { |
devi@27 | 98 print OUT $_; |
devi@27 | 99 } |
devi@27 | 100 close(OUT); |
devi@27 | 101 } |
devi@27 | 102 continue { |
devi@27 | 103 # Наш родитель |
devi@27 | 104 close ($client); |
devi@27 | 105 } |
devi@27 | 106 } |