Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Worker script itself is not shutdown gracefully, but hangs #1226

Open
calvinalkan opened this issue Dec 5, 2024 · 9 comments · May be fixed by #1242
Open

Worker script itself is not shutdown gracefully, but hangs #1226

calvinalkan opened this issue Dec 5, 2024 · 9 comments · May be fixed by #1242
Labels
bug Something isn't working

Comments

@calvinalkan
Copy link

calvinalkan commented Dec 5, 2024

What happened?

During graceful shutdown of FrankenPHP via SIGTERM or admin API, in-flight requests complete gracefully, but the worker script itself does not.

This means that it's impossible to perform cleanup tasks after a worker is stopped (for example, sending telemetry data)

Minimal Reproducer

<?php
ignore_user_abort(true);

$log_file = dirname(__DIR__).'/storage/logs/worker.log';
file_put_contents($log_file, "Starting worker\n", FILE_APPEND);

// Simple request handler
$handler = static function () use($log_file) {
    if (str_contains($_SERVER['REQUEST_URI'], 'slow')) {
        sleep(10);
        file_put_contents($log_file, "Slow response done\n", FILE_APPEND);
    } else {
        file_put_contents($log_file, "Normal response done\n", FILE_APPEND);
    }
    echo 'Done';
};

$maxRequests = (int)($_SERVER['MAX_REQUESTS'] ?? 0);
for ($nbRequests = 0; !$maxRequests || $nbRequests < $maxRequests; ++$nbRequests) {
    $keepRunning = \frankenphp_handle_request($handler);
    file_put_contents($log_file, "Request processed. Keep running: $keepRunning\n", FILE_APPEND);
    gc_collect_cycles();
    if (!$keepRunning) break;
}

file_put_contents($log_file, "Worker stopped - Cleaning up\n", FILE_APPEND);

Current Behaviour

When initiating a graceful shutdown during a slow request, the log file might show this:

Starting worker
Normal response done
Request processed. Keep running: 1
Normal response done
Request processed. Keep running: 1
Slow response done              # In-flight request completes
Request processed. Keep running: 1
[Hangs here indefinitely - or threat is killed]

Expected Behaviour

The log output should be:

Starting worker
Normal response done
Request processed. Keep running: 1
Normal response done
Request processed. Keep running: 1
Slow response done 
Request processed. Keep running: 1
Worker stopped - Cleaning up

And only once that script exists, the pthread is killed.

Best guess on why

Maybe there is a race condition, starting here:

func Shutdown() {
	drainWorkers()
	drainThreads()
	metrics.Shutdown()
	requestChan = nil

	// Remove the installed app
	if EmbeddedAppPath != "" {
		_ = os.RemoveAll(EmbeddedAppPath)
	}

	logger.Debug("FrankenPHP shut down")
}

When workersDone is closed, this select in go_frankenphp_worker_handle_request_start should trigger:

select {
case <-workersDone:
    if c := logger.Check(zapcore.DebugLevel, "shutting down"); c != nil {
        c.Write(zap.String("worker", thread.worker.fileName))
    }
    thread.worker = nil
    C.frankenphp_reset_opcache()
    return C.bool(false)
case r = <-thread.worker.requestChan:
case r = <-thread.requestChan:
}

and return false to the frankenphp_handle_request_function
which breaks the loop.

But, I never see "shutting down" in the server output (debug enabled), nor do I see FrankenPHP shut down.
This might be a separate problem, maybe because shutdown() runs as a destructor (idk?)

So either the above code never runs, or if it does run, PHP does not finish fast enough before this returns false (caused by drainThreads)

func go_handle_request(threadIndex C.uintptr_t) bool {
    select {
    case <-done:
       return false
  // more
}
func drainThreads() {
	close(done)
	shutdownWG.Wait()
	phpThreads = nil
}

The return false causes this C code to call ts_free_thread

static void *php_thread(void *arg) {
    // ...
    while (go_handle_request(thread_index)) {
    }
    go_frankenphp_release_known_variable_keys(thread_index);
    #ifdef ZTS
    ts_free_thread();
    #endif
    return NULL;
}

Build Type

Docker (Debian Bookworm)

Worker Mode

Yes

Operating System

GNU/Linux

CPU Architecture

x86_64

PHP configuration

PHP Version => 8.3.13

System => Linux f856ef7a1044 6.8.0-49-generic #49~22.04.1-Ubuntu SMP PREEMPT_DYNAMIC Wed Nov  6 17:42:15 UTC 2 x86_64
Build Date => Nov 12 2024 02:06:31
Build System => Linux - Docker
Build Provider => https://github.com/docker-library/php
Configure Command =>  './configure'  '--build=x86_64-linux-gnu' '--with-config-file-path=/usr/local/etc/php' '--with-config-file-scan-dir=/usr/local/etc/php/conf.d' '--enable-option-checking=fatal' '--with-mhash' '--with-pic' '--enable-mbstring' '--enable-mysqlnd' '--with-password-argon2' '--with-sodium=shared' '--with-pdo-sqlite=/usr' '--with-sqlite3=/usr' '--with-curl' '--with-iconv' '--with-openssl' '--with-readline' '--with-zlib' '--enable-phpdbg' '--enable-phpdbg-readline' '--with-pear' '--with-libdir=lib/x86_64-linux-gnu' '--enable-embed' '--enable-zts' '--disable-zend-signals' 'build_alias=x86_64-linux-gnu'
Server API => Command Line Interface
Virtual Directory Support => enabled
Configuration File (php.ini) Path => /usr/local/etc/php
Loaded Configuration File => /usr/local/etc/php/php.ini
Scan this dir for additional .ini files => /usr/local/etc/php/conf.d
Additional .ini files parsed => /usr/local/etc/php/conf.d/docker-php-ext-opcache.ini,
/usr/local/etc/php/conf.d/docker-php-ext-pcntl.ini,
/usr/local/etc/php/conf.d/docker-php-ext-sodium.ini,
/usr/local/etc/php/conf.d/docker-php-ext-zip.ini

PHP API => 20230831
PHP Extension => 20230831
Zend Extension => 420230831
Zend Extension Build => API420230831,TS
PHP Extension Build => API20230831,TS
Debug Build => no
Thread Safety => enabled
Thread API => POSIX Threads
Zend Signal Handling => disabled
Zend Memory Manager => enabled
Zend Multibyte Support => provided by mbstring
Zend Max Execution Timers => enabled
IPv6 Support => enabled
DTrace Support => disabled

Registered PHP Streams => https, ftps, compress.zlib, php, file, glob, data, http, ftp, phar, zip
Registered Stream Socket Transports => tcp, udp, unix, udg, ssl, tls, tlsv1.0, tlsv1.1, tlsv1.2, tlsv1.3
Registered Stream Filters => zlib.*, convert.iconv.*, string.rot13, string.toupper, string.tolower, convert.*, consumed, dechunk

This program makes use of the Zend Scripting Language Engine:
Zend Engine v4.3.13, Copyright (c) Zend Technologies
    with Zend OPcache v8.3.13, Copyright (c), by Zend Technologies


 _______________________________________________________________________


Configuration

Core

PHP Version => 8.3.13

Directive => Local Value => Master Value
allow_url_fopen => Off => Off
allow_url_include => Off => Off
arg_separator.input => & => &
arg_separator.output => & => &
auto_append_file => no value => no value
auto_globals_jit => On => On
auto_prepend_file => no value => no value
browscap => no value => no value
default_charset => UTF-8 => UTF-8
default_mimetype => text/html => text/html
disable_classes => no value => no value
disable_functions => no value => no value
display_errors => Off => Off
display_startup_errors => Off => Off
doc_root => no value => no value
docref_ext => no value => no value
docref_root => no value => no value
enable_dl => On => On
enable_post_data_reading => On => On
error_append_string => no value => no value
error_log => /dev/stderr => /dev/stderr
error_log_mode => 0644 => 0644
error_prepend_string => no value => no value
error_reporting => 32767 => 32767
expose_php => Off => Off
extension_dir => /usr/local/lib/php/extensions/no-debug-zts-20230831 => /usr/local/lib/php/extensions/no-debug-zts-20230831
fiber.stack_size => no value => no value
file_uploads => On => On
hard_timeout => 2 => 2
highlight.comment => <font style="color: #FF8000">#FF8000</font> => <font style="color: #FF8000">#FF8000</font>
highlight.default => <font style="color: #0000BB">#0000BB</font> => <font style="color: #0000BB">#0000BB</font>
highlight.html => <font style="color: #000000">#000000</font> => <font style="color: #000000">#000000</font>
highlight.keyword => <font style="color: #007700">#007700</font> => <font style="color: #007700">#007700</font>
highlight.string => <font style="color: #DD0000">#DD0000</font> => <font style="color: #DD0000">#DD0000</font>
html_errors => Off => Off
ignore_repeated_errors => Off => Off
ignore_repeated_source => Off => Off
ignore_user_abort => Off => Off
implicit_flush => On => On
include_path => .:/usr/local/lib/php => .:/usr/local/lib/php
input_encoding => no value => no value
internal_encoding => no value => no value
log_errors => On => On
mail.add_x_header => Off => Off
mail.force_extra_parameters => no value => no value
mail.log => no value => no value
mail.mixed_lf_and_crlf => Off => Off
max_execution_time => 0 => 0
max_file_uploads => 20 => 20
max_input_nesting_level => 64 => 64
max_input_time => -1 => -1
max_input_vars => 1000 => 1000
max_multipart_body_parts => -1 => -1
memory_limit => 8G => 8G
open_basedir => no value => no value
output_buffering => 0 => 0
output_encoding => no value => no value
output_handler => no value => no value
post_max_size => 10M => 10M
precision => 14 => 14
realpath_cache_size => 16M => 16M
realpath_cache_ttl => 360 => 360
register_argc_argv => On => On
report_memleaks => On => On
report_zend_debug => Off => Off
request_order => no value => no value
sendmail_from => no value => no value
sendmail_path => /usr/sbin/sendmail -t -i => /usr/sbin/sendmail -t -i
serialize_precision => -1 => -1
short_open_tag => On => On
SMTP => localhost => localhost
smtp_port => 25 => 25
sys_temp_dir => no value => no value
syslog.facility => LOG_USER => LOG_USER
syslog.filter => no-ctrl => no-ctrl
syslog.ident => php => php
unserialize_callback_func => no value => no value
upload_max_filesize => 8M => 8M
upload_tmp_dir => no value => no value
user_dir => no value => no value
user_ini.cache_ttl => 300 => 300
user_ini.filename => no value => no value
variables_order => EGPCS => EGPCS
xmlrpc_error_number => 0 => 0
xmlrpc_errors => Off => Off
zend.assertions => 1 => 1
zend.detect_unicode => On => On
zend.enable_gc => On => On
zend.exception_ignore_args => Off => Off
zend.exception_string_param_max_len => 15 => 15
zend.max_allowed_stack_size => 0 => 0
zend.multibyte => Off => Off
zend.reserved_stack_size => 0 => 0
zend.script_encoding => no value => no value

ctype

ctype functions => enabled

curl

cURL support => enabled
cURL Information => 7.88.1
Age => 10
Features
AsynchDNS => Yes
CharConv => No
Debug => No
GSS-Negotiate => No
IDN => Yes
IPv6 => Yes
krb4 => No
Largefile => Yes
libz => Yes
NTLM => Yes
NTLMWB => Yes
SPNEGO => Yes
SSL => Yes
SSPI => No
TLS-SRP => Yes
HTTP2 => Yes
GSSAPI => Yes
KERBEROS5 => Yes
UNIX_SOCKETS => Yes
PSL => Yes
HTTPS_PROXY => Yes
MULTI_SSL => No
BROTLI => Yes
ALTSVC => Yes
HTTP3 => No
UNICODE => No
ZSTD => Yes
HSTS => Yes
GSASL => No
Protocols => dict, file, ftp, ftps, gopher, gophers, http, https, imap, imaps, ldap, ldaps, mqtt, pop3, pop3s, rtmp, rtmpe, rtmps, rtmpt, rtmpte, rtmpts, rtsp, scp, sftp, smb, smbs, smtp, smtps, telnet, tftp
Host => x86_64-pc-linux-gnu
SSL Version => OpenSSL/3.0.15
ZLib Version => 1.2.13
libSSH Version => libssh2/1.10.0

Directive => Local Value => Master Value
curl.cainfo => no value => no value

date

date/time support => enabled
timelib version => 2022.12
"Olson" Timezone Database Version => 2024.2
Timezone Database => internal
Default timezone => UTC

Directive => Local Value => Master Value
date.default_latitude => 31.7667 => 31.7667
date.default_longitude => 35.2333 => 35.2333
date.sunrise_zenith => 90.833333 => 90.833333
date.sunset_zenith => 90.833333 => 90.833333
date.timezone => UTC => UTC

dom

DOM/XML => enabled
DOM/XML API Version => 20031129
libxml Version => 2.9.14
HTML Support => enabled
XPath Support => enabled
XPointer Support => enabled
Schema Support => enabled
RelaxNG Support => enabled

fileinfo

fileinfo support => enabled
libmagic => 543

filter

Input Validation and Filtering => enabled

Directive => Local Value => Master Value
filter.default => unsafe_raw => unsafe_raw
filter.default_flags => no value => no value

hash

hash support => enabled
Hashing Engines => md2 md4 md5 sha1 sha224 sha256 sha384 sha512/224 sha512/256 sha512 sha3-224 sha3-256 sha3-384 sha3-512 ripemd128 ripemd160 ripemd256 ripemd320 whirlpool tiger128,3 tiger160,3 tiger192,3 tiger128,4 tiger160,4 tiger192,4 snefru snefru256 gost gost-crypto adler32 crc32 crc32b crc32c fnv132 fnv1a32 fnv164 fnv1a64 joaat murmur3a murmur3c murmur3f xxh32 xxh64 xxh3 xxh128 haval128,3 haval160,3 haval192,3 haval224,3 haval256,3 haval128,4 haval160,4 haval192,4 haval224,4 haval256,4 haval128,5 haval160,5 haval192,5 haval224,5 haval256,5 

MHASH support => Enabled
MHASH API Version => Emulated Support

iconv

iconv support => enabled
iconv implementation => glibc
iconv library version => 2.36

Directive => Local Value => Master Value
iconv.input_encoding => no value => no value
iconv.internal_encoding => no value => no value
iconv.output_encoding => no value => no value

json

json support => enabled

libxml

libXML support => active
libXML Compiled Version => 2.9.14
libXML Loaded Version => 20914
libXML streams => enabled

mbstring

Multibyte Support => enabled
Multibyte string engine => libmbfl
HTTP input encoding translation => disabled
libmbfl version => 1.3.2

mbstring extension makes use of "streamable kanji code filter and converter", which is distributed under the GNU Lesser General Public License version 2.1.

Multibyte (japanese) regex support => enabled
Multibyte regex (oniguruma) version => 6.9.8

Directive => Local Value => Master Value
mbstring.detect_order => no value => no value
mbstring.encoding_translation => Off => Off
mbstring.http_input => no value => no value
mbstring.http_output => no value => no value
mbstring.http_output_conv_mimetypes => ^(text/|application/xhtml\+xml) => ^(text/|application/xhtml\+xml)
mbstring.internal_encoding => no value => no value
mbstring.language => neutral => neutral
mbstring.regex_retry_limit => 1000000 => 1000000
mbstring.regex_stack_limit => 100000 => 100000
mbstring.strict_detection => Off => Off
mbstring.substitute_character => no value => no value

mysqlnd

mysqlnd => enabled
Version => mysqlnd 8.3.13
Compression => supported
core SSL => supported
extended SSL => supported
Command buffer size => 4096
Read buffer size => 32768
Read timeout => 86400
Collecting statistics => Yes
Collecting memory statistics => No
Tracing => n/a
Loaded plugins => mysqlnd,debug_trace,auth_plugin_mysql_native_password,auth_plugin_mysql_clear_password,auth_plugin_caching_sha2_password,auth_plugin_sha256_password
API Extensions =>  

openssl

OpenSSL support => enabled
OpenSSL Library Version => OpenSSL 3.0.15 3 Sep 2024
OpenSSL Header Version => OpenSSL 3.0.15 3 Sep 2024
Openssl default config => /usr/lib/ssl/openssl.cnf

Directive => Local Value => Master Value
openssl.cafile => no value => no value
openssl.capath => no value => no value

pcntl

pcntl support => enabled

pcre

PCRE (Perl Compatible Regular Expressions) Support => enabled
PCRE Library Version => 10.42 2022-12-12
PCRE Unicode Version => 14.0.0
PCRE JIT Support => enabled
PCRE JIT Target => x86 64bit (little endian + unaligned)

Directive => Local Value => Master Value
pcre.backtrack_limit => 1000000 => 1000000
pcre.jit => On => On
pcre.recursion_limit => 100000 => 100000

PDO

PDO support => enabled
PDO drivers => sqlite

pdo_sqlite

PDO Driver for SQLite 3.x => enabled
SQLite Library => 3.40.1

Phar

Phar: PHP Archive support => enabled
Phar API version => 1.1.1
Phar-based phar archives => enabled
Tar-based phar archives => enabled
ZIP-based phar archives => enabled
gzip compression => enabled
bzip2 compression => disabled (install ext/bz2)
Native OpenSSL support => enabled


Phar based on pear/PHP_Archive, original concept by Davey Shafik.
Phar fully realized by Gregory Beaver and Marcus Boerger.
Portions of tar implementation Copyright (c) 2003-2009 Tim Kientzle.
Directive => Local Value => Master Value
phar.cache_list => no value => no value
phar.readonly => On => On
phar.require_hash => On => On

posix

POSIX support => enabled

random

Version => 8.3.13

readline

Readline Support => enabled
Readline library => 8.2

Directive => Local Value => Master Value
cli.pager => no value => no value
cli.prompt => \b \>  => \b \> 

Reflection

Reflection => enabled

session

Session Support => enabled
Registered save handlers => files user 
Registered serializer handlers => php_serialize php php_binary 

Directive => Local Value => Master Value
session.auto_start => Off => Off
session.cache_expire => 180 => 180
session.cache_limiter => nocache => nocache
session.cookie_domain => no value => no value
session.cookie_httponly => Off => Off
session.cookie_lifetime => 0 => 0
session.cookie_path => / => /
session.cookie_samesite => no value => no value
session.cookie_secure => Off => Off
session.gc_divisor => 100 => 100
session.gc_maxlifetime => 1440 => 1440
session.gc_probability => 1 => 1
session.lazy_write => On => On
session.name => PHPSESSID => PHPSESSID
session.referer_check => no value => no value
session.save_handler => files => files
session.save_path => no value => no value
session.serialize_handler => php => php
session.sid_bits_per_character => 4 => 4
session.sid_length => 32 => 32
session.upload_progress.cleanup => On => On
session.upload_progress.enabled => On => On
session.upload_progress.freq => 1% => 1%
session.upload_progress.min_freq => 1 => 1
session.upload_progress.name => PHP_SESSION_UPLOAD_PROGRESS => PHP_SESSION_UPLOAD_PROGRESS
session.upload_progress.prefix => upload_progress_ => upload_progress_
session.use_cookies => On => On
session.use_only_cookies => On => On
session.use_strict_mode => Off => Off
session.use_trans_sid => Off => Off

SimpleXML

SimpleXML support => enabled
Schema support => enabled

sodium

sodium support => enabled
libsodium headers version => 1.0.18
libsodium library version => 1.0.18

SPL

SPL support => enabled
Interfaces => OuterIterator, RecursiveIterator, SeekableIterator, SplObserver, SplSubject
Classes => AppendIterator, ArrayIterator, ArrayObject, BadFunctionCallException, BadMethodCallException, CachingIterator, CallbackFilterIterator, DirectoryIterator, DomainException, EmptyIterator, FilesystemIterator, FilterIterator, GlobIterator, InfiniteIterator, InvalidArgumentException, IteratorIterator, LengthException, LimitIterator, LogicException, MultipleIterator, NoRewindIterator, OutOfBoundsException, OutOfRangeException, OverflowException, ParentIterator, RangeException, RecursiveArrayIterator, RecursiveCachingIterator, RecursiveCallbackFilterIterator, RecursiveDirectoryIterator, RecursiveFilterIterator, RecursiveIteratorIterator, RecursiveRegexIterator, RecursiveTreeIterator, RegexIterator, RuntimeException, SplDoublyLinkedList, SplFileInfo, SplFileObject, SplFixedArray, SplHeap, SplMinHeap, SplMaxHeap, SplObjectStorage, SplPriorityQueue, SplQueue, SplStack, SplTempFileObject, UnderflowException, UnexpectedValueException

sqlite3

SQLite3 support => enabled
SQLite Library => 3.40.1

Directive => Local Value => Master Value
sqlite3.defensive => On => On
sqlite3.extension_dir => no value => no value

standard

Dynamic Library Support => enabled
Path to sendmail => /usr/sbin/sendmail -t -i

Directive => Local Value => Master Value
assert.active => On => On
assert.bail => Off => Off
assert.callback => no value => no value
assert.exception => On => On
assert.warning => On => On
auto_detect_line_endings => Off => Off
default_socket_timeout => 60 => 60
from => no value => no value
session.trans_sid_hosts => no value => no value
session.trans_sid_tags => a=href,area=href,frame=src,form= => a=href,area=href,frame=src,form=
unserialize_max_depth => 4096 => 4096
url_rewriter.hosts => no value => no value
url_rewriter.tags => form= => form=
user_agent => no value => no value

tokenizer

Tokenizer Support => enabled

xml

XML Support => active
XML Namespace Support => active
libxml2 Version => 2.9.14

xmlreader

XMLReader => enabled

xmlwriter

XMLWriter => enabled

Zend OPcache

Opcode Caching => Disabled
Optimization => Disabled
SHM Cache => Enabled
File Cache => Disabled
JIT => On
Startup Failed => Opcode Caching is disabled for CLI

Directive => Local Value => Master Value
opcache.blacklist_filename => no value => no value
opcache.dups_fix => Off => Off
opcache.enable => On => On
opcache.enable_cli => Off => Off
opcache.enable_file_override => Off => Off
opcache.error_log => no value => no value
opcache.file_cache => no value => no value
opcache.file_cache_consistency_checks => On => On
opcache.file_cache_only => Off => Off
opcache.file_update_protection => 2 => 2
opcache.force_restart_timeout => 180 => 180
opcache.huge_code_pages => Off => Off
opcache.interned_strings_buffer => 64 => 64
opcache.jit => tracing => tracing
opcache.jit_bisect_limit => 0 => 0
opcache.jit_blacklist_root_trace => 16 => 16
opcache.jit_blacklist_side_trace => 8 => 8
opcache.jit_buffer_size => 64M => 64M
opcache.jit_debug => 0 => 0
opcache.jit_hot_func => 127 => 127
opcache.jit_hot_loop => 64 => 64
opcache.jit_hot_return => 8 => 8
opcache.jit_hot_side_exit => 8 => 8
opcache.jit_max_exit_counters => 8192 => 8192
opcache.jit_max_loop_unrolls => 8 => 8
opcache.jit_max_polymorphic_calls => 2 => 2
opcache.jit_max_recursive_calls => 2 => 2
opcache.jit_max_recursive_returns => 2 => 2
opcache.jit_max_root_traces => 1024 => 1024
opcache.jit_max_side_traces => 128 => 128
opcache.jit_max_trace_length => 1024 => 1024
opcache.jit_prof_threshold => 0.005 => 0.005
opcache.lockfile_path => /tmp => /tmp
opcache.log_verbosity_level => 1 => 1
opcache.max_accelerated_files => 50000 => 50000
opcache.max_file_size => 0 => 0
opcache.max_wasted_percentage => 5 => 5
opcache.memory_consumption => 2000 => 2000
opcache.opt_debug_level => 0 => 0
opcache.optimization_level => 0x7FFFBFFF => 0x7FFFBFFF
opcache.preferred_memory_model => no value => no value
opcache.preload => no value => no value
opcache.preload_user => no value => no value
opcache.protect_memory => Off => Off
opcache.record_warnings => Off => Off
opcache.restrict_api => no value => no value
opcache.revalidate_freq => 0 => 0
opcache.revalidate_path => Off => Off
opcache.save_comments => On => On
opcache.use_cwd => On => On
opcache.validate_permission => Off => Off
opcache.validate_root => Off => Off
opcache.validate_timestamps => Off => Off

zip

Zip => enabled
Zip version => 1.22.3
Libzip version => 1.7.3
BZIP2 compression => Yes
XZ compression => No
ZSTD compression => No
AES-128 encryption => Yes
AES-192 encryption => Yes
AES-256 encryption => Yes

zlib

ZLib Support => enabled
Stream Wrapper => compress.zlib://
Stream Filter => zlib.inflate, zlib.deflate
Compiled Version => 1.2.13
Linked Version => 1.2.13

Directive => Local Value => Master Value
zlib.output_compression => Off => Off
zlib.output_compression_level => -1 => -1
zlib.output_handler => no value => no value

Relevant log output

No response

@AlliBalliBaba
Copy link
Collaborator

Hey thanks for the reproducer! Looks like a thread might not be properly shutting down, I'll have a look when I have time

@AlliBalliBaba
Copy link
Collaborator

Are you using the latest FrankenPHP version (1.3.3)? I didn't really see the same behavior with your minimal reproducer. it will wait for the long request to finish and then shut down, as expected.

@calvinalkan
Copy link
Author

Thanks for looking into this.

I did test with 1.3.1, but just bumped to 1.3.3 and same result.

FROM dunglas/frankenphp:1.3.3-php8.3.14-bookworm

This still yields the same result when stop the process via SIGTERM (via docker compose stop) during the slow request:

Starting worker
Normal response done
Request processed. Keep running: 1
Slow response done
Request processed. Keep running: 1

Debug logs, note: num_threads=2, and worker.num=1

web  | {"level":"info","ts":1733518853.888352,"msg":"using config from file","file":"/etc/caddy/Caddyfile"}
web  | {"level":"info","ts":1733518853.8891642,"msg":"adapted config to JSON","adapter":"caddyfile"}
web  | {"level":"warn","ts":1733518853.8891695,"msg":"Caddyfile input is not formatted; run 'caddy fmt --overwrite' to fix inconsistencies","adapter":"caddyfile","file":"/etc/caddy/Caddyfile","line":2}
web  | {"level":"info","ts":1733518853.8896801,"logger":"admin","msg":"admin endpoint started","address":"localhost:2019","enforce_origin":false,"origins":["//[::1]:2019","//127.0.0.1:2019","//localhost:2019"]}
web  | {"level":"info","ts":1733518853.8899047,"logger":"http.auto_https","msg":"automatic HTTPS is completely disabled for server","server_name":"srv0"}
web  | {"level":"info","ts":1733518853.8899865,"logger":"tls.cache.maintenance","msg":"started background certificate maintenance","cache":"0xc000577680"}
web  | {"level":"debug","ts":1733518853.8899155,"logger":"http.auto_https","msg":"adjusted config","tls":{"automation":{"policies":[{}]}},"http":{"servers":{"srv0":{"listen":[":80"],"routes":[{"handle":[{"handler":"headers","response":{"set":{"Cache-Control":["public, max-age=31536000, immutable"]}}}]},{"handle":[{"handler":"headers","response":{"set":{"Content-Security-Policy":["default-src 'self'; script-src 'self' 'unsafe-inline' 'unsafe-eval'; style-src 'self' 'unsafe-inline'"],"Referrer-Policy":["strict-origin-when-cross-origin"],"Strict-Transport-Security":["max-age=63072000; includeSubDomains; preload"],"X-Content-Type-Options":["nosniff"],"X-Frame-Options":["DENY"]}}}]},{"handle":[{"handler":"subroute","routes":[{"handle":[{"body":"app pong","handler":"static_response","status_code":200}]}]}]},{"handle":[{"handler":"subroute","routes":[{"handle":[{"handler":"vars","root":"public"},{"encodings":{"br":{},"gzip":{},"zstd":{}},"handler":"encode","prefer":["zstd","br","gzip"]}]},{"handle":[{"handler":"static_response","headers":{"Location":["{http.request.orig_uri.path}/"]},"status_code":308}],"match":[{"file":{"try_files":["{http.request.uri.path}/frankenphp-worker.php"]},"not":[{"path":["*/"]}]}]},{"handle":[{"handler":"rewrite","uri":"{http.matchers.file.relative}"}],"match":[{"file":{"split_path":[".php"],"try_files":["{http.request.uri.path}","{http.request.uri.path}/frankenphp-worker.php","frankenphp-worker.php"]}}]},{"handle":[{"handler":"php","split_path":[".php"]}],"match":[{"path":["*.php"]}]},{"handle":[{"handler":"file_server"}]}]}]}],"automatic_https":{"disable":true},"logs":{"default_logger_name":"log0"}}}}}
web  | {"level":"debug","ts":1733518853.8903763,"msg":"starting","worker":"/app/public/frankenphp-worker.php","num":1}
web  | {"level":"debug","ts":1733518853.9034488,"msg":"waiting for request","worker":"/app/public/frankenphp-worker.php"}
web  | {"level":"debug","ts":1733518853.9037228,"msg":"watching","dir":"/app","patterns":["","*.{php,yaml,yml,twig,env}"]}
web  | {"level":"info","ts":1733518853.9037435,"msg":"FrankenPHP started 🐘","php_version":"8.3.14","num_threads":2}
web  | {"level":"debug","ts":1733518853.9038827,"logger":"http","msg":"starting server loop","address":"[::]:80","tls":false,"http3":false}
web  | {"level":"debug","ts":1733518853.9038842,"msg":"special edant/watcher event","fileName":"s/self/live@/app"}
web  | {"level":"info","ts":1733518853.9039037,"logger":"http.log","msg":"server running","name":"srv0","protocols":["h1","h2","h3"]}
web  | {"level":"info","ts":1733518853.9039106,"logger":"pki.ca.local","msg":"root certificate trust store installation disabled; unconfigured clients may show warnings","path":"storage:pki/authorities/local/root.crt"}
web  | {"level":"info","ts":1733518853.9041743,"msg":"autosaved config (load with --resume flag)","file":"/config/caddy/autosave.json"}
web  | {"level":"info","ts":1733518853.904188,"msg":"serving initial configuration"}
web  | {"level":"info","ts":1733518853.905581,"logger":"tls","msg":"storage cleaning happened too recently; skipping for now","storage":"FileStorage:/data/caddy","instance":"81b3e04c-e1d0-4ac5-8e10-4ac7586b041f","try_again":1733605253.9055798,"try_again_in":86399.999999617}
web  | {"level":"info","ts":1733518853.90563,"logger":"tls","msg":"finished cleaning storage units"}
web  | {"level":"debug","ts":1733518858.6989202,"logger":"http.handlers.rewrite","msg":"rewrote request","request":{"remote_ip":"172.21.0.2","remote_port":"52134","client_ip":"172.21.0.2","proto":"HTTP/1.1","method":"GET","host":"my.snicco.local","uri":"/","headers":{"Accept-Encoding":["gzip, deflate, br, zstd"],"Dnt":["1"],"Priority":["u=0, i"],"Sec-Fetch-Mode":["navigate"],"Upgrade-Insecure-Requests":["1"],"X-Forwarded-For":["172.21.0.1"],"X-Forwarded-Host":["my.snicco.local"],"User-Agent":["Mozilla/5.0 (X11; Ubuntu; Linux x86_64; rv:133.0) Gecko/20100101 Firefox/133.0"],"Sec-Fetch-Site":["none"],"Sec-Fetch-User":["?1"],"Sec-Gpc":["1"],"Te":["trailers"],"X-Forwarded-Proto":["https"],"Accept":["text/html,application/xhtml+xml,application/xml;q=0.9,*/*;q=0.8"],"Accept-Language":["en-US,en;q=0.5"],"Sec-Fetch-Dest":["document"]}},"method":"GET","uri":"/frankenphp-worker.php"}
web  | {"level":"debug","ts":1733518858.6989987,"msg":"request handling started","worker":"/app/public/frankenphp-worker.php","url":"/frankenphp-worker.php"}
web  | {"level":"debug","ts":1733518858.6993625,"msg":"request handling finished","worker":"/app/public/frankenphp-worker.php","url":"/frankenphp-worker.php"}
web  | {"level":"debug","ts":1733518858.6994429,"msg":"waiting for request","worker":"/app/public/frankenphp-worker.php"}
web  | {"level":"debug","ts":1733518870.10906,"logger":"http.handlers.rewrite","msg":"rewrote request","request":{"remote_ip":"172.21.0.2","remote_port":"52134","client_ip":"172.21.0.2","proto":"HTTP/1.1","method":"GET","host":"my.snicco.local","uri":"/?slow=1","headers":{"Accept-Language":["en-US,en;q=0.5"],"Te":["trailers"],"X-Forwarded-Proto":["https"],"Dnt":["1"],"Sec-Fetch-Dest":["document"],"Sec-Gpc":["1"],"Sec-Fetch-User":["?1"],"X-Forwarded-For":["172.21.0.1"],"Accept":["text/html,application/xhtml+xml,application/xml;q=0.9,*/*;q=0.8"],"Accept-Encoding":["gzip, deflate, br, zstd"],"Sec-Fetch-Mode":["navigate"],"Sec-Fetch-Site":["none"],"Upgrade-Insecure-Requests":["1"],"X-Forwarded-Host":["my.snicco.local"],"User-Agent":["Mozilla/5.0 (X11; Ubuntu; Linux x86_64; rv:133.0) Gecko/20100101 Firefox/133.0"],"Priority":["u=0, i"]}},"method":"GET","uri":"/frankenphp-worker.php?slow=1"}
web  | {"level":"debug","ts":1733518870.1091907,"msg":"request handling started","worker":"/app/public/frankenphp-worker.php","url":"/frankenphp-worker.php?slow=1"}
web  | {"level":"info","ts":1733518873.83176,"msg":"shutting down apps, then terminating","signal":"SIGTERM"}
web  | {"level":"warn","ts":1733518873.8317943,"msg":"exiting; byeee!! 👋","signal":"SIGTERM"}
web  | {"level":"info","ts":1733518873.831807,"msg":"FrankenPHP stopped 🐘"}
web  | {"level":"info","ts":1733518873.831849,"logger":"http","msg":"servers shutting down with eternal grace period"}
web  | {"level":"debug","ts":1733518880.1100168,"msg":"request handling finished","worker":"/app/public/frankenphp-worker.php","url":"/frankenphp-worker.php?slow=1"}
web  | {"level":"debug","ts":1733518880.110219,"msg":"waiting for request","worker":"/app/public/frankenphp-worker.php"}
web  | {"level":"info","ts":1733518880.1706736,"logger":"admin","msg":"stopped previous server","address":"localhost:2019"}
web  | {"level":"info","ts":1733518880.1706991,"msg":"shutdown complete","signal":"SIGTERM","exit_code":0}
web exited with code 0

The debug output does not contain this though:

 if c := logger.Check(zapcore.DebugLevel, "shutting down"); c != nil {
        c.Write(zap.String("worker", thread.worker.fileName))
    }

nor this:

logger.Debug("FrankenPHP shut down"

@calvinalkan
Copy link
Author

Particularly, this part:

web  | {"level":"info","ts":1733518873.831849,"logger":"http","msg":"servers shutting down with eternal grace period"}
web  | {"level":"debug","ts":1733518880.1100168,"msg":"request handling finished","worker":"/app/public/frankenphp-worker.php","url":"/frankenphp-worker.php?slow=1"}
web  | {"level":"debug","ts":1733518880.110219,"msg":"waiting for request","worker":"/app/public/frankenphp-worker.php"}
web  | {"level":"info","ts":1733518880.1706736,"logger":"admin","msg":"stopped previous server","address":"localhost:2019"}
web  | {"level":"info","ts":1733518880.1706991,"msg":"shutdown complete","signal":"SIGTERM","exit_code":0}

Seems to highlight that the worker is not shutdown?

Because there is a new waiting for request

@calvinalkan
Copy link
Author

My caddyfile in docker (mostly irrelevant stuff)

{
        # The server only runs on port 80 behind a reverse proxy.
        # We don't https.
        auto_https off

        # No reason to add certificates in local dev.
        # Caddy only runs in docker.
        skip_install_trust

        log {
                level {$CADDY_GLOBAL_LOG_LEVEL}
                output stderr
        }

        frankenphp {
                # num_threads 2 is inserted here.
                {$CADDY_FRANKENPHP_OPTIONS}
                worker {
                        file public/frankenphp-worker.php
                        {$CADDY_FRANKENPHP_WORKER_WATCH_OPTIONS}
                        # num 1 is inserted here.
                        {$CADDY_FRANKENPHP_WORKER_NUM_THREADS}
                }
        }
}

http://:80 {
        log {
                level {$CADDY_SERVER_LOG_LEVEL}
                output stderr
        }

        route {
                root public

                # Perform compression here, so that we need to send less data to the reverse proxy.
                encode zstd br gzip

                php_server {
                        index frankenphp-worker.php
                        # Required for the public/storage/ directory...
                        resolve_root_symlink
                }
        }
}

@AlliBalliBaba
Copy link
Collaborator

Ah I think now I get it. It looks like this was always the case, no matter if you are shutting down during a long request or not. @dunglas is there a reason why the graceful shutdown is not triggered when stopping the process via the admin API? In other words: why is frankenphp.Shutdown() not called here?

frankenphp/caddy/caddy.go

Lines 115 to 122 in fc6be5d

func (f *FrankenPHPApp) Stop() error {
caddy.Log().Info("FrankenPHP stopped 🐘")
// reset configuration so it doesn't bleed into later tests
f.Workers = nil
f.NumThreads = 0
return nil
}

@calvinalkan
Copy link
Author

calvinalkan commented Dec 7, 2024

Yeah, you don't need the slow request, that's just to show that in-flight requests shut down gracefully, while the script does not.

Regarding shutdown, it seems that it's only called in a destructor in the main frankenphp file.
But I don't know how destructors work in go, so can't comment.

frankenphp.Shutdown()

@withinboredom
Copy link
Collaborator

is there a reason why the graceful shutdown is not triggered when stopping the process via the admin API?

Probably just an oversight or potential changes in caddy since it was originally written. We should add a test for this.

@dunglas
Copy link
Owner

dunglas commented Dec 7, 2024

This probably never worker properly. The Shutdown() method is called too late in the Caddy module.

@Alliballibaba2 Alliballibaba2 linked a pull request Dec 12, 2024 that will close this issue
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
bug Something isn't working
Projects
None yet
Development

Successfully merging a pull request may close this issue.

4 participants