mirror of https://github.com/apache/cassandra
don't perform HH to client-mode
patch by jbellis; reviewed by brandonwilliams for CASSANDRA-2668 git-svn-id: https://svn.apache.org/repos/asf/cassandra/branches/cassandra-0.7@1125002 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
4e6c0f6c6b
commit
050d129179
|
|
@ -3,6 +3,7 @@
|
|||
(CASSANDRA-2652)
|
||||
* mark BRAF buffer invalid post-flush so we don't re-flush partial
|
||||
buffers again, especially on CL writes (CASSANDRA-2660)
|
||||
* don't perform HH to client-mode [storageproxy] nodes (CASSANDRA-2668)
|
||||
|
||||
|
||||
0.7.6
|
||||
|
|
|
|||
|
|
@ -136,7 +136,7 @@ public class EndpointState
|
|||
hasToken_ = value;
|
||||
}
|
||||
|
||||
public boolean getHasToken()
|
||||
public boolean hasToken()
|
||||
{
|
||||
return hasToken_;
|
||||
}
|
||||
|
|
|
|||
|
|
@ -431,7 +431,7 @@ public class Gossiper implements IFailureDetectionEventListener
|
|||
|
||||
// check if this is a fat client. fat clients are removed automatically from
|
||||
// gosip after FatClientTimeout
|
||||
if (!epState.getHasToken() && !epState.isAlive() && (duration > FatClientTimeout_))
|
||||
if (!epState.hasToken() && !epState.isAlive() && (duration > FatClientTimeout_))
|
||||
{
|
||||
if (StorageService.instance.getTokenMetadata().isMember(endpoint))
|
||||
epState.setHasToken(true);
|
||||
|
|
|
|||
|
|
@ -1130,7 +1130,7 @@ public class StorageService implements IEndpointStateChangeSubscriber, StorageSe
|
|||
|
||||
public void onAlive(InetAddress endpoint, EndpointState state)
|
||||
{
|
||||
if (!isClientMode)
|
||||
if (!isClientMode && state.hasToken())
|
||||
deliverHints(endpoint);
|
||||
}
|
||||
|
||||
|
|
|
|||
Loading…
Reference in New Issue