|Constructor and Description|
|Modifier and Type||Method and Description|
Prior to 3.0.0, Curator did not try to manage session expiration other than the functionality provided by ZooKeeper itself.
public int getSimulatedSessionExpirationPercent()
Prior to 3.0.0, Curator did not try to manage session expiration other than the functionality provided by ZooKeeper itself. Starting with 3.0.0, Curator has the option of attempting to monitor session expiration above what is provided by ZooKeeper. The percentage returned by this method determines how and if Curator will check for session expiration.
If this method returns 0, Curator does not do any additional checking for session expiration.
If a positive number is returned, Curator will check for session expiration as follows: when ZooKeeper sends a Disconnect event, Curator will start a timer. If re-connection is not achieved before the elapsed time exceeds the negotiated session time multiplied by the session expiration percent, Curator will simulate a session expiration. Due to timing/network issues, it is not possible for a client to match the server's session timeout with complete accuracy. Thus, the need for a session expiration percentage.
public <T> T callWithRetry(CuratorZookeeperClient client, Callable<T> proc) throws Exception
RetryLoop.callWithRetry(CuratorZookeeperClient, Callable)to do the work of retrying
public ConnectionHandlingPolicy.CheckTimeoutsResult checkTimeouts(Callable<String> hasNewConnectionString, long connectionStartMs, int sessionTimeoutMs, int connectionTimeoutMs) throws Exception
hasNewConnectionString- proc to call to check if there is a new connection string. Important: the internal state is cleared after this is called so you MUST handle the new connection string if non null is returned
connectionStartMs- the epoch/ms time that the connection was first initiated
sessionTimeoutMs- the configured/negotiated session timeout in milliseconds
connectionTimeoutMs- the configured connection timeout in milliseconds
Copyright © 2011–2017 The Apache Software Foundation. All rights reserved.