anchor.diff:      Obj2 = riak_object:update_metadata(Obj1, MetaData1),
       
       % Store the object...
  -    Response = Client:put(Obj2,1,1,900000),
  +    Response = Client:put(Obj2,1,1,1200000),
       {continue, Response}.
      
   %%% DATA CLEANING %%% 
  
positive.code: 
      % Make sure all nodes in the cluster agree on the ring...
      ensure_synchronized(Ring, Members),
      
      % Backup the data...
      {ok, ?TABLE} = dets:open_file(?TABLE, [{file, Filename}]),
      [backup_node(Node) || Node <- Members],
      ok = dets:sync(?TABLE),
      ok = dets:close(?TABLE),
      
      % Make sure the nodes are still synchronized...
      ensure_synchronized(Ring, Members),
  
negative.code:     {ok, Client} = riak:client_connect(EntryNode),
      
      % Open the table, write it out, close the table...
      {ok, ?TABLE} = disk_log:open([{name, ?TABLE},
                                    {file, Filename},
                                    {mode, read_only},
                                     {type, halt}]),
      Count = traverse_backup(
                  disk_log:chunk(?TABLE, start), 
                  fun(Entry) -> read_and_restore_function(Client, Entry) end, 0),
      ok = disk_log:close(?TABLE),
      io:format("Restored ~p records.~n", [Count]),
      ok.
  
  traverse_backup(eof, _VisitorFun, Count) ->
      Count;
  traverse_backup({Cont, Terms}, VisitorFun, Count) when is_list(Terms) ->
      [VisitorFun(T) || T <- Terms],
      traverse_backup(disk_log:chunk(?TABLE, Cont), 
                      VisitorFun, Count+length(Terms)).
      
  
  read_and_restore_function(Client, BinTerm) ->
      Obj = binary_to_term(BinTerm),
      Bucket = riak_object:bucket(Obj),
      Key = riak_object:key(Obj),
      % Data Cleaning...
      Obj1 = make_binary_bucket(Bucket, Key, Obj),
  
  