anchor.diff:  -type chunk_offset() :: etorrent_types:chunk_offset().
   -type piece_index() :: etorrent_types:piece_index().
   
  +-record(pieceprio, {
  +    tag :: atom(),
  +    ref :: reference(),
  +    pieces :: [pos_integer()]}).
  +
   -record(state, {
       torrent_id      :: pos_integer(),
       torrent_pid     :: pid(),
  
positive.code:         %% Initially, the sets of assigned and stored chunks are equal
          chunks_assigned=ChunkSets,
          chunks_stored=ChunkSets,
          peer_monitors=etorrent_monitorset:new()},
      {ok, InitState}.
  
  
  
negative.code:             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,
  