This commit is contained in:
iamqizhao
2016-07-06 17:18:01 -07:00

View File

@ -164,7 +164,8 @@ func (rr *roundRobin) watchAddrUpdates() error {
defer rr.mu.Unlock()
for _, update := range updates {
addr := Address{
Addr: update.Addr,
Addr: update.Addr,
Metadata: update.Metadata,
}
switch update.Op {
case naming.Add: