#!/usr/bin/perl # This Source Code Form is subject to the terms of the Mozilla Public # License, v. 2.0. If a copy of the MPL was not distributed with this # file, You can obtain one at http://mozilla.org/MPL/2.0/. # # This Source Code Form is "Incompatible With Secondary Licenses", as # defined by the Mozilla Public License, v. 2.0. use 5.10.1; use strict; use warnings; use File::Basename; use File::Spec; BEGIN { require lib; my $dir = File::Spec->rel2abs(File::Spec->catdir(dirname(__FILE__), '..')); lib->import( $dir, File::Spec->catdir($dir, 'lib'), File::Spec->catdir($dir, qw(local lib perl5)) ); } use Bugzilla::DaemonControl qw(catch_signal); use Future; use IO::Async::Loop; use IO::Async::Protocol::LineStream; use IO::Handle; $ENV{LOGGING_PORT} //= 5880; STDOUT->autoflush(1); my $loop = IO::Async::Loop->new; my $on_stream = sub { my ($stream) = @_; my $protocol = IO::Async::Protocol::LineStream->new( transport => $stream, on_read_line => sub { my ($self, $line) = @_; say $line; }, ); $loop->add($protocol); }; my @signals = qw( TERM INT KILL ); $loop->listen( host => '127.0.0.1', service => $ENV{LOGGING_PORT}, socktype => 'stream', on_stream => $on_stream, )->get; exit Future->wait_any(map { catch_signal($_, 0) } @signals)->get;