1.x: fix replay() retaining reference to the child Subscriber by akarnokd · Pull Request #4229 · ReactiveX/RxJava · GitHub
Skip to content

1.x: fix replay() retaining reference to the child Subscriber#4229

Merged
akarnokd merged 1 commit into
ReactiveX:1.xfrom
akarnokd:ReplaySubscriberCacheFix
Jul 23, 2016
Merged

1.x: fix replay() retaining reference to the child Subscriber#4229
akarnokd merged 1 commit into
ReactiveX:1.xfrom
akarnokd:ReplaySubscriberCacheFix

Conversation

@akarnokd

Copy link
Copy Markdown
Member

In #3470, a flat cache of Subscribers has been introduced that is versioned and gets only updated if there are new Subscribers coming, old Subscribers leaving and a value comes through - improving performance if lots of Subscribers come and go between main onNext signals. This cache is not cleared but rebuilt therefore child Subscribers unsubscribing were still referenced through it and everything beyond - leading to memory leak on sensitive systems.

The fix is to cut the link to the child Subscriber in InnerProducer on unsubscription. A secondary action also empties the cache if all Subscribers are gone.

Reported in #4228 .

@codecov-io

codecov-io commented Jul 22, 2016

Copy link
Copy Markdown

@akarnokd

Copy link
Copy Markdown
Member Author

This is a medium impact bug so it would be great if it made into tomorrow's release. /cc @artem-zinnatullin @zsxwing

@stevegury

Copy link
Copy Markdown
Member

@akarnokd akarnokd merged commit 75ffcbb into ReactiveX:1.x Jul 23, 2016
@akarnokd akarnokd deleted the ReplaySubscriberCacheFix branch July 23, 2016 07:14
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants