anchor.diff:                    pos_integer(), pos_integer()) -> ok.
   mark_stored(TorrentID, Index, Offset, Length) ->
       ChunkSrv = lookup_chunk_server(TorrentID),
  -    Call = {mark_stored, self(), Index, Offset, Length},
  -    gen_server:call(ChunkSrv, Call).
  +    call(ChunkSrv, {mark_stored, self(), Index, Offset, Length}).
   
   %& @doc
   %% Reinsert a chunk into the request queue.
  
positive.code:                 piece_chunks=NewChunks,
                  peer_monitors=NewPeers},
              {reply, {ok, [{PieceIndex, Offs, Len}]}, NewState}
      end;
  
  handle_call({mark_fetched, Pid, PieceIndex, Offset, Length}, _, State) ->
  
negative.code:     ok  = receive {'DOWN', _, process, Pid, _} -> ok end,
      ?assertMatch({ok, [{0, 0, 1}]}, ?chunk_server:request_chunks(10, Has, 1)).
  
  
  mark_valid_not_stored_case() ->
      Srv = initial_chunk_server(11),
      Has = etorrent_pieceset:from_list([0], 3),
      Ret = ?chunk_server:mark_valid(11, 0),
      ?assertEqual({error, not_stored}, Ret).
  
  mark_valid_stored_case() ->
      Srv = initial_chunk_server(12),
      Has = etorrent_pieceset:from_list([0,1], 3),
      {ok, [{0, 0, 1}]} = ?chunk_server:request_chunks(12, Has, 1),
      {ok, [{0, 1, 1}]} = ?chunk_server:request_chunks(12, Has, 1),
      ok  = ?chunk_server:mark_stored(12, 0, 0, 1),
      ok  = ?chunk_server:mark_stored(12, 0, 1, 1),
      ?assertEqual(ok, ?chunk_server:mark_valid(12, 0)).
  
  -endif.
  