1 #!/usr/bin/perl

2

3 use strict;

4 use lib '.';

5 use l3config;

6 use IO::Socket;

7 use POSIX qw(:sys_wait_h);

8

9 sub main;

10

11 main();

12

13 sub REAPER {

14 1 until (-1 == waitpid(-1, WNOHANG));

15 $SIG{CHLD} = \&REAPER;

16 }

17

18 sub process_was_killed

19 {

20 # Здесь должна быть красивая процедура

21 # завершения демона

22 unlink $Config{backend_pidfile};

23 exit(0);

24 }

25

26 sub main {

27 init_config();

28

29

30 # Проверяем, возможно демон уже запущен

31 # Если он работает, просто завершаемся

32 if (open(PIDFILE, $Config{backend_pidfile})) {

33 my $pid = <PIDFILE>;

34 close(PIDFILE);

35 if ( ! -e "/proc/$pid" || !`grep $Config{"l3-backend"} /proc/$pid/cmdline && grep "uid:.*\b$<\b" /proc/$pid/status`) {

36 print "Removing stale pidfile\n";

37 unlink $Config{backend_pidfile}

38 or die "Can't remove stale pidfile ". $Config{backend_pidfile}. " : $!";

39 }

40 else {

41 print "l3-backend is already running\n";

42 exit(0);

43 }

44 }

45

46 # Уходим в background, если необходимо

47 if ($Config{detach} =~ /^y/i) {

48 #$Config{verbose} = "no";

49 my $pid = fork;

50 exit if $pid;

51 die "Couldn't fork: $!" unless defined ($pid);

52

53 open(PIDFILE, ">", $Config{backend_pidfile})

54 or die "Can't open pidfile ". $Config{backend_pidfile}. " for wrting: $!";

55 print PIDFILE $$;

56 close(PIDFILE);

57

58 for my $handle (*STDIN, *STDOUT, *STDERR) {

59 open ($handle, "+<", "/dev/null")

60 or die "can't reopen $handle to /dev/null: $!"

61 }

62

63 POSIX::setsid()

64 or die "Can't start a new session: $!";

65

66 $0 = $Config{"l3-backend"};

67

68 $SIG{INT} = $SIG{TERM} = $SIG{HUP} = \&process_was_killed;

69 }

70

71 # Открываем сетевой сокет и слушаем

72 my $server = IO::Socket::INET->new(

73 LocalPort => $Config{backend_port},

74 Type => SOCK_STREAM,

75 Reuse => 1,

76 Listen => 10 );

77

78 if (!$server) {

79 die "Couldn't bind to socket ".$Config{backend_port}."\n";

80 }

81

82 $SIG{CHLD} = 'IGNORE';

83

84 # При получении новых соединенений,

85 # порождаем дочерние процессы

86 while (my $client = $server->accept()) {

87 my $pid;

88 next if $pid = fork;

89 die "fork: $!" unless defined $pid;

90

91 # Это наш ответвлённый клиент

92 close($server);

93

94 # Считываем данные и передаём их в точку получения

95 open(OUT, ">>", $Config{"backend_datafile"});

96 select OUT; $|=1;

97 while(<$client>) {

98 print OUT $_;

99 }

100 close(OUT);

101 }

102 continue {

103 # Наш родитель

104 close ($client);

105 }

106 }