| 331 | } |
| 332 | |
| 333 | func (s *MockServer) Add(host MockHost) { |
| 334 | s.mu.Lock() |
| 335 | defer s.mu.Unlock() |
| 336 | if host.equal(s.local) { |
| 337 | return |
| 338 | } |
| 339 | for _, peer := range s.peers { |
| 340 | if host.equal(peer) { |
| 341 | return |
| 342 | } |
| 343 | } |
| 344 | s.peers = append(s.peers, host) |
| 345 | s.Event(&message.TopologyChangeEvent{ |
| 346 | ChangeType: primitive.TopologyChangeTypeNewNode, |
| 347 | Address: &primitive.Inet{ |
| 348 | Addr: net.ParseIP(host.IP), |
| 349 | Port: int32(host.Port), |
| 350 | }, |
| 351 | }) |
| 352 | } |
| 353 | |
| 354 | func (s *MockServer) Remove(host MockHost) { |
| 355 | if host.equal(s.local) { |