You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
{{ message }}
This repository was archived by the owner on Aug 13, 2026. It is now read-only.
Repository navigation
This repository was archived by the owner on Aug 13, 2026. It is now read-only.
Add a client timeout for synchronous command execution [JIRA: CLIENTS-818] #609
The synchronous execute method() in the RiakCommand is actually a wrapper around the asynchronous executeAsync() method. But it has no possibility to specify a timeout on the underlying Future.
As the future.get() is currently done without any timeout this might result in calling thread hanging forever if the future is never resolved (for whatever reason).
To allow isolating the caller thread from the internal retry and pooling mechanism of the client, we propose to add another execute() to the RiakCommand and RiakClient with the timeout.
changed the title [-]Add a client timeout for synchronous command execution[/-][+]Add a client timeout for synchronous command execution [JIRA: CLIENTS-818][/+]on Apr 6, 2016
The command timeout is the Riak-side timeout. It will be sent to Riak as part of the PB message (example: https://github.com/basho/riak_pb/blob/develop/src/riak_kv.proto#L56).
Here the proposal is a pure client-side timeout: if a connection to Riak is in progress or established when a node shutdowns, it might results in them not being handled nicely.
Hello,
The synchronous execute method() in the RiakCommand is actually a wrapper around the asynchronous executeAsync() method. But it has no possibility to specify a timeout on the underlying Future.
As the future.get() is currently done without any timeout this might result in calling thread hanging forever if the future is never resolved (for whatever reason).
To allow isolating the caller thread from the internal retry and pooling mechanism of the client, we propose to add another execute() to the RiakCommand and RiakClient with the timeout.
Thanks.
Kind regards.
Bernard.