anchor.diff:              InitTorrentPid
       end,
   
  +    %% TODO - initiate priority watch
  +    PriorityBegun = #pieceprio{
  +        tag=begun,
  +        ref=make_ref(),
  +        pieces=[]},
  +    PriorityUnassigned = #pieceprio{
  +        tag=unassigned,
  +        ref=make_ref(),
  +        pieces=[]},
  +
       InitState = #state{
           torrent_id=TorrentID,
           torrent_pid=TorrentPid,
  
positive.code: -type chunk_offset() :: etorrent_types:chunk_offset().
  -type piece_index() :: etorrent_types:piece_index().
  
  -record(state, {
      torrent_id      :: pos_integer(),
      torrent_pid     :: pid(),
  
negative.code:     chunks_assigned :: array(),
      chunks_stored   :: array(),
      %% Chunks assigned to peers
      peer_monitors   :: monitorset(),
      %% Piece priority lists
      prio_begun :: #pieceprio{},
      prio_unassigned :: #pieceprio{}}).
  
  %% # Open requests
  %% A gb_tree mapping {PieceIndex, Offset} to Chunklength
  