get/set_pool_size #1
Closed
Conversation
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Contributor
|
I'm not clear that set_size will work. When the pool is initialised, it uses the size to pre-populate the queue with the right number of workers: Lines 132 to 139 in 8c28a49 What will happen if we change the size (up or down) without changing the number of workers? Unless it is obvious, some sort of test is required. |
hmmr
force-pushed
the
tiot/openriak-3.2/tictacaae-and-nextgenrepl-cli-commands
branch
from
ffd51af to
a2fe397
Compare
This changeset introduces three new functions: * `poolboy:set_pool_size/2,3` and `poolboy:get_pool_size/1`, which can be used to resize a running poolboy process dynamically; * `poolboy:status_ext/1`, which in addition to the items returned by `status/1`, also reports the values of `size` and `latched_size`. The new size is assigned to a new state record field, `latched_size`. If it is greater than the current size, new checkouts will succeed even in a `full` state, until the actual size, incremented per checkout, grows and matches the latched_size. If `latched_size` is smaller than current size, no immediate action is taken on those currently checked-out workers which are now in excess of the latched size. Instead, as they are checked in, they are dismissed until the actual size decreases to match latched size. The `set_pool_size/3` variant also allows to set the value of max_overflow. One limitation is that after setting a new size, the state of the poolboy process (as returned by `poolboy:status` or `status_ext`), may not reflect the actual state of the pooloy fsm wrt its ability to accept new checkouts. This condition is temporary and the status will resume normal reporting once `size` converges with `latched_size`. This changeset is needed for tiot/openriak-3.4/tictacaae-and-nextgenrepl-cli-commands branches in riak_kv and riak_core. pool dynamic resize for overflow = 0 pool dynamic resize for overflow > 0, too wip towards more comprehensive tests wip reasonably good wip spurious wip need to tweak asserts in test wip finalizing more extensive test, with fixes resulting therefrom address possible case of pool stop returning too early before pool start
hmmr
force-pushed
the
tiot/openriak-3.2/tictacaae-and-nextgenrepl-cli-commands
branch
from
e111539 to
7c28495
Compare
Author
|
Now this is done with proper amount of attention, and a more meaningful test. More details in the squashed commit description above. |
This was referenced Sep 24, 2025
Author
|
No longer part of TicTacAAE set of PRs (OpenRiak/riak_kv#31, OpenRiak/riak#13) because the changes in this PR (required to enable the three poolsize-changing CLI commands) are touching parts that are too critical and best left alone, for the minor convenience of having an option to tweak worker poolsizes. So closing. |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
2 participants
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
This PR provides functions to get and set the size of core node worker pools, intended to be used by callbacks (implemented in OpenRiak/kv_index_tictactree#4) of riak admin tictacaae commands. See this discussion and eventually OpenRiak/riak#13.