Jelajahi Sumber

Notify the HostSelectionPolicy of the partioner

Fixes #724; adds back the call to SetPartitioner on the session's
HostSelectionPolicy. This is mostly needed so that the token
aware policy initializes and updates its token ring representation.
Justin Corpron 10 tahun lalu
induk
melakukan
178921d6b6
2 mengubah file dengan 2 tambahan dan 1 penghapusan
  1. 1 1
      AUTHORS
  2. 1 0
      host_source.go

+ 1 - 1
AUTHORS

@@ -43,7 +43,7 @@ James Maloney <jamessagan@gmail.com>
 Ashwin Purohit <purohit@gmail.com>
 Dan Kinder <dkinder.is.me@gmail.com>
 Oliver Beattie <oliver@obeattie.com>
-Justin Corpron <justin@retailnext.com>
+Justin Corpron <jncorpron@gmail.com>
 Miles Delahunty <miles.delahunty@gmail.com>
 Zach Badgett <zach.badgett@gmail.com>
 Maciek Sakrejda <maciek@heroku.com>

+ 1 - 0
host_source.go

@@ -391,5 +391,6 @@ func (r *ringDescriber) refreshRing() error {
 	}
 
 	r.session.metadata.setPartitioner(partitioner)
+	r.session.policy.SetPartitioner(partitioner)
 	return nil
 }