code: func (p *Peer) Connected() bool {
  	return atomic.LoadInt32(&p.connected) != 0 &&
  		atomic.LoadInt32(&p.disconnect) == 0
  }
docs: // Connected returns whether or not the peer is currently connected.
  //
  // This function is safe for concurrent access.