瀏覽代碼

add the host to the fallback policy as well as the token aware one

Chris Bannister 10 年之前
父節點
當前提交
af634bb091
共有 1 個文件被更改,包括 1 次插入0 次删除
  1. 1 0
      policies.go

+ 1 - 0
policies.go

@@ -285,6 +285,7 @@ func (t *tokenAwareHostPolicy) SetPartitioner(partitioner string) {
 
 
 func (t *tokenAwareHostPolicy) AddHost(host *HostInfo) {
 func (t *tokenAwareHostPolicy) AddHost(host *HostInfo) {
 	t.hosts.add(host)
 	t.hosts.add(host)
+	t.fallback.AddHost(host)
 
 
 	t.mu.Lock()
 	t.mu.Lock()
 	t.resetTokenRing()
 	t.resetTokenRing()