remove duplicates

1 files changed, 0 insertions, 120 deletions

diff --git a/src/Network/BitTorrent/Sessions/Types.lhs b/src/Network/BitTorrent/Sessions/Types.lhs
index 1a945613..dea47405 100644
--- a/src/Network/BitTorrent/Sessions/Types.lhs
+++ b/src/Network/BitTorrent/Sessions/Types.lhs
@@ -314,123 +314,3 @@ INVARIANT: max_sessions_count - sizeof connectedPeers = value vacantPeers
 > getClientBitfield :: SwarmSession -> IO Bitfield
 > getClientBitfield SwarmSession {..} = atomically $ getCompleteBitfield storage
 
-Peer sessions
-------------------------------------------------------------------------
-
-> -- | Peer session contain all data necessary for peer to peer
-> -- communication.
-> data PeerSession = PeerSession {
->     -- | Used as unique 'PeerSession' identifier within one
->     -- 'SwarmSession'.
->     connectedPeerAddr :: !PeerAddr
-
->     -- | The swarm to which both end points belong to.
->   , swarmSession      :: !SwarmSession
-
->     -- | Extensions such that both peer and client support.
->   , enabledExtensions :: [Extension]
-
->     -- | Broadcast messages waiting to be sent to peer.
->   , pendingMessages    :: !(TChan   Message)
-
->     -- | Dymanic P2P data.
->   , sessionState       :: !(IORef  SessionState)
->   }
-
-> instance Eq PeerSession where
->   (==) = (==) `on` connectedPeerAddr
-
-> instance Ord PeerSession where
->   compare = comparing connectedPeerAddr
-
-> findPieceCount :: PeerSession -> PieceCount
-> findPieceCount = pieceCount . tInfo . torrentMeta . swarmSession
-
-Peer session state
-------------------------------------------------------------------------
-
-> data SessionState = SessionState {
->     _bitfield :: !Bitfield        -- ^ Other peer Have bitfield.
->   , _status   :: !SessionStatus   -- ^ Status of both peers.
->   } deriving (Show, Eq)
-
-> $(makeLenses ''SessionState)
-
-> initialSessionState :: PieceCount -> SessionState
-> initialSessionState pc = SessionState (haveNone pc) def
-
-> getSessionState :: PeerSession -> IO SessionState
-> getSessionState PeerSession {..} = readIORef sessionState
-
-Peer session exceptions
-------------------------------------------------------------------------
-
-> -- | Exceptions used to interrupt the current P2P session. This
-> -- exceptions will NOT affect other P2P sessions, DHT, peer <->
-> -- tracker, or any other session.
-> --
-> data SessionException = PeerDisconnected
->                       | ProtocolError  Doc
->                       | UnknownTorrent InfoHash
->                         deriving (Show, Typeable)
-
-> instance Exception SessionException
-
-
-> -- | Do nothing with exception, used with 'handle' or 'try'.
-> isSessionException :: Monad m => SessionException -> m ()
-> isSessionException _ = return ()
-
-> -- | The same as 'isSessionException' but output to stdout the catched
-> -- exception, for debugging purposes only.
-> putSessionException :: SessionException -> IO ()
-> putSessionException = print
-
-Broadcasting: Have, Cancel, Bitfield, SuggestPiece
-------------------------------------------------------------------------
-
-Here we should enqueue broadcast messages and keep in mind that:
-  * We should enqueue broadcast events as they are appear.
-  * We should yield broadcast messages as fast as we get them.
-
-these 2 phases might differ in time significantly
-
-**TODO**: do this; but only when it'll be clean which other broadcast
-messages & events we should send.
-
-1. Update client have bitfield --\____ in one transaction;
-2. Update downloaded stats     --/
-3. Signal to the all other peer about this.
-
-> available :: Bitfield -> SwarmSession -> STM ()
-> available bf SwarmSession {..} = {-# SCC available #-} do
->     updateProgress >> broadcast
->   where
->     updateProgress = do
->       let piLen = ciPieceLength $ tInfo $ torrentMeta
->       let bytes = piLen * BF.haveCount bf
->       modifyTVar' (currentProgress clientSession) (downloadedProgress bytes)
->
->     broadcast = mapM_ (writeTChan broadcastMessages . Have) (BF.toList bf)
-
--- TODO compute size of messages: if it's faster to send Bitfield
--- instead many Have do that
-
--- Also if there is single Have message in queue then the
--- corresponding piece is likely still in memory or disc cache,
--- when we can send SuggestPiece.
-
--- | Get pending messages queue appeared in result of asynchronously
---   changed client state. Resulting queue should be sent to a peer
--- immediately.
-
-> getPending :: PeerSession -> IO [Message]
-> getPending PeerSession {..} = {-# SCC getPending #-} do
->  atomically (readAvail pendingMessages)
-
-> readAvail :: TChan a -> STM [a]
-> readAvail chan = do
->   m <- tryReadTChan chan
->   case m of
->     Just a  -> (:) <$> pure a <*> readAvail chan
->     Nothing -> return []