diff --git a/p2pfs/core/peer.py b/p2pfs/core/peer.py index 07431b7..9fc32ee 100644 --- a/p2pfs/core/peer.py +++ b/p2pfs/core/peer.py @@ -106,6 +106,7 @@ class Peer(MessageServer): totalchunknum = math.ceil(fileinfo['size'] / Peer._CHUNK_SIZE) # TODO: decide which peer to request chunk + # peer_address -> (reader, writer) peers = {} # TODO: make it parallel for chunknum in range(totalchunknum):