Conversation
arnaud-lb
left a comment
There was a problem hiding this comment.
This looks good to me
It's also possible to fix this in _php_stream_write_filtered() with an extra check, but since the user filter is the only one that has this bug and already checks for this condition, we fix it there instead.
Could we add an assertion in _php_stream_write_filtered() so we don't make this error when implementing new internal filters?
|
I will take a look in couple of weeks. |
|
Note to self: would need to remove the XFAIL of |
bukka
left a comment
There was a problem hiding this comment.
I think this is right place to do it because user filter breaks the contract (input brigade must be empty after processing) but I'm not sure about this change ff84cb0 that applies the same logic for PSFS_FEED_ME and PSFS_FEED_FATAL. I think it should be dropped there and applied only to user filter. I'm not sure if even the out part is needed anywhere else than user filter..?
|
@bukka Okay I agree. I've moved that logic to the user filter now. |
| } | ||
|
|
||
| /* Filter could've broken contract and added buckets anyway. */ | ||
| if (ret == PSFS_FEED_ME && buckets_out->head) { |
There was a problem hiding this comment.
I think I'd need to double check whether this ret check is too specific (e.g. do we also need to do anything on FATAL).
There was a problem hiding this comment.
No, I just checked this and it seems fine with other return values.
|
Ran into this same bucket family while looking at GH-22845. Two observations on the current patch. The The |
|
@ndossche, iliaal found a case on my duplicate of this fix (#23267) that also applies to this branch: the input-brigade drain in I stacked one commit on top of your 270ec55 at https://github.com/matthiasgoergens/php-src/tree/gh20058-feed-me-gating: the input drain gated on |
|
The |
|
I don't quite follow. @iliaal what do you like me to do here? Feel free to take this over. |
|
Sorry, that was unclear. Your drain fixes the leak but loses data in one case, and Matthias's fix for that case brings the leak back in other callers. A user filter can put buckets back on a7a81df skips the drain on Perhaps cherry-picking those 2 commits from https://github.com/iliaal/php-src/tree/gh20058-feed-me-callers is easiest (if approach/idea makes sense). |
…gade buckets Since the _php_stream_write_filtered() function assumes that the input brigade will be emptied (as it clears one of the bucket brigades), any unconsumed bucket will leak. The other filters do not suffer from this as they abort cleanly with an error code. It's also possible to fix this in _php_stream_write_filtered() with an extra check, but since the user filter is the only one that has this bug and already checks for this condition, we fix it there instead. For completeness, a fix in _php_stream_write_filtered() would look like this: ```diff diff --git a/main/streams/streams.c b/main/streams/streams.c index 372ed66..720f3c15dd7 100644 --- a/main/streams/streams.c +++ b/main/streams/streams.c @@ -1242,6 +1242,15 @@ static ssize_t _php_stream_write_filtered(php_stream *stream, const char *buf, s if (status != PSFS_PASS_ON) { break; } + /* If the filter did not process the entire input brigade, then the buckets need to be freed + * manually or they will be lost when setting up the brigades for next iteration. */ + if (UNEXPECTED(brig_inp->head)) { + do { + bucket = brig_inp->head; + php_stream_bucket_unlink(bucket); + php_stream_bucket_delref(bucket); + } while (brig_inp->head); + } /* brig_out becomes brig_in. * brig_in will always be empty here, as the filter MUST attach any un-consumed buckets * to its own brigade */ ``` Co-authored-by: Gina Peter Banyard <girgias@php.net>
…or any non-PASS_ON status _php_stream_fill_read_buffer() keeps the input brigade across calls, so a filter that returns PSFS_FEED_ME may put buckets back on $in to see them again with the next chunk. Draining the input brigade for every status frees those buckets and truncates the stream: a filter that defers twice on a three-chunk file returns 8192 bytes instead of 24576, as iliaal found while reviewing php#23267. Drain the input brigade only when the filter did not return PSFS_FEED_ME. Also drain leftover output buckets for any status other than PSFS_PASS_ON, so an out-of-range status cannot leave them linked to the stack brigade.
userfilter_filter() keeps the input brigade on PSFS_FEED_ME so the read loop can re-present it, but _php_stream_write_filtered(), php_stream_filter_append_ex() and _php_stream_filter_flush() discard their stack brigades on that status, and _php_stream_fill_read_buffer() drops them when its loop exits. Free what is left in each of those places.
270ec55 to
df4e0f3
Compare
|
@iliaal You're correct. |
| while ((bucket = brig_in.head)) { | ||
| php_stream_bucket_unlink(bucket); | ||
| php_stream_bucket_delref(bucket); | ||
| } |
There was a problem hiding this comment.
Is it possible to move this logic (that is repeated quite a few times) into a function?
Since the _php_stream_write_filtered() function assumes that the input brigade will be emptied (as it clears one of the bucket brigades), any unconsumed bucket will leak. The other filters do not suffer from this as they abort cleanly with an error code.
It's also possible to fix this in _php_stream_write_filtered() with an extra check, but since the user filter is the only one that has this bug and already checks for this condition, we fix it there instead.
For completeness, the alternative i.e. a fix in _php_stream_write_filtered() would look like this: