(ring1, ring2 *Desc, nowUnixTime int64)
| 495 | } |
| 496 | |
| 497 | func mergeLocalCAS(ring1, ring2 *Desc, nowUnixTime int64) (*Desc, *Desc) { |
| 498 | change, err := ring1.mergeWithTime(ring2, true, time.Unix(nowUnixTime, 0)) |
| 499 | if err != nil { |
| 500 | panic(err) |
| 501 | } |
| 502 | |
| 503 | if change == nil { |
| 504 | return ring1, nil |
| 505 | } |
| 506 | |
| 507 | changeRing := change.(*Desc) |
| 508 | return ring1, changeRing |
| 509 | } |
no test coverage detected