IsNbrPeerAddr return result whether the address is under connecting
(addr string)
| 476 | |
| 477 | //IsNbrPeerAddr return result whether the address is under connecting |
| 478 | func (this *NetServer) IsNbrPeerAddr(addr string) bool { |
| 479 | var addrNew string |
| 480 | this.Np.RLock() |
| 481 | defer this.Np.RUnlock() |
| 482 | for _, p := range this.Np.List { |
| 483 | if p.GetState() == common.HAND || p.GetState() == common.HAND_SHAKE || |
| 484 | p.GetState() == common.ESTABLISH { |
| 485 | addrNew = p.Link.GetAddr() |
| 486 | if strings.Compare(addrNew, addr) == 0 { |
| 487 | return true |
| 488 | } |
| 489 | } |
| 490 | } |
| 491 | return false |
| 492 | } |
| 493 | |
| 494 | //AddPeerAddress add sync addr to peer-addr map |
| 495 | func (this *NetServer) AddPeerAddress(addr string, p *peer.Peer) { |