X-Git-Url: http://wagnertech.de/git?a=blobdiff_plain;f=dispatcher.fpl;h=5e384ce68c3639396569e7fa02db8001b28c3979;hb=2a51537014d67c1f97a37b18548506f3e15549b5;hp=afe1bc6edec6aa912ab6890e417421e8c7c5b1ef;hpb=f5bc233522743646b118d0756b0041b16418fbdf;p=kivitendo-erp.git diff --git a/dispatcher.fpl b/dispatcher.fpl index afe1bc6ed..5e384ce68 100755 --- a/dispatcher.fpl +++ b/dispatcher.fpl @@ -3,13 +3,68 @@ use strict; use FCGI; +use IO::File; use SL::Dispatcher; use SL::FCGIFixes; +use SL::LXDebug; +sub _parse_number_with_unit { + my ($number) = @_; + + return undef unless defined $number; + return $number unless $number =~ m{^ \s* (\d+) \s* ([kmg])b \s* $}xi; + + my %factors = (K => 1024, M => 1024 * 1024, G => 1024 * 1024 * 1024); + + return $1 * $factors{uc $2}; +} + +sub _memory_usage_is_too_high { + return undef unless $::lx_office_conf{system}; + + my %limits = ( + rss => _parse_number_with_unit($::lx_office_conf{system}->{memory_limit_rss}), + size => _parse_number_with_unit($::lx_office_conf{system}->{memory_limit_vsz}), + ); + + # $::lxdebug->dump(0, "limits", \%limits); + + return undef unless $limits{rss} || $limits{vsz}; + + my %usage; + + my $in = IO::File->new("/proc/$$/status", "r") or return undef; + + while (<$in>) { + chomp; + $usage{lc $1} = _parse_number_with_unit($2) if m{^ vm(rss|size): \s* (\d+ \s* [kmg]b) \s* $}ix; + } + + $in->close; + + # $::lxdebug->dump(0, "usage", \%usage); + + foreach my $type (keys %limits) { + next if !$limits{$type}; + next if $limits{$type} >= ($usage{$type} // 0); + + $::lxdebug->message(LXDebug::WARN(), "Exiting due to memory size limit reached for type '${type}': limit " . $limits{$type} . " bytes, usage " . $usage{$type} . " bytes"); + + return 1; + } + + return 0; +} + +our $dispatcher = SL::Dispatcher->new('FastCGI'); +$dispatcher->pre_startup_setup; SL::FCGIFixes::apply_fixes(); +$dispatcher->pre_startup_checks; -SL::Dispatcher::pre_startup(); my $request = FCGI::Request(); -SL::Dispatcher::handle_request('FastCGI') while $request->Accept() >= 0; +while ($request->Accept() >= 0) { + $dispatcher->handle_request($request); + exit if _memory_usage_is_too_high(); +} 1;