Class PeerExchangerItem


  • public class PeerExchangerItem
    extends java.lang.Object
    • Field Detail

      • base_peer

        private final PeerItem base_peer
      • network

        private final java.lang.String network
      • connections_added

        private final java.util.LinkedHashSet<PeerItem> connections_added
      • connections_dropped

        private final java.util.LinkedHashSet<PeerItem> connections_dropped
      • connected_peers

        private final java.util.Map<PeerItem,​java.lang.Object> connected_peers
      • peers_mon

        private final AEMonitor peers_mon
      • maintain_peers_state

        private boolean maintain_peers_state
    • Method Detail

      • getBasePeer

        protected PeerItem getBasePeer()
      • addConnectedPeer

        public void addConnectedPeer​(PeerItem peer)
        Add peer info obtained via peer exchange.
        Parameters:
        peer - to add
      • dropConnectedPeer

        public void dropConnectedPeer​(PeerItem peer)
        Remove peer info obtained via peer exchange.
        Parameters:
        peer - to remove
      • notifyAdded

        protected void notifyAdded​(PeerItem peer_connection)
      • notifyDropped

        protected void notifyDropped​(PeerItem peer_connection)
      • seedStatusChanged

        public void seedStatusChanged()
      • getNewlyAddedPeerConnections

        public PeerItem[] getNewlyAddedPeerConnections()
        Get the list of peer connections added since this method was last called.
        Returns:
        new peer connections
      • getNewlyAddedPeerConnections

        public PeerItem[] getNewlyAddedPeerConnections​(java.lang.String network)
      • getNewlyDroppedPeerConnections

        public PeerItem[] getNewlyDroppedPeerConnections()
        Get the list of peer connections dropped since this method was last called.
        Returns:
        dropped peer connections
      • getNewlyDroppedPeerConnections

        public PeerItem[] getNewlyDroppedPeerConnections​(java.lang.String network)
      • disableStateMaintenance

        public void disableStateMaintenance()
        Clears all current peer state records and stops any future state maintenance.
      • enableStateMaintenance

        public void enableStateMaintenance()
      • isConnectedToPeer

        protected boolean isConnectedToPeer​(PeerItem peer)
      • getConnectedPeers

        protected PeerItem[] getConnectedPeers()
      • destroy

        public void destroy()