anchor.diff:                                            content_length=ContentLength}) ->
   
       NewRemainderData = combine_new_and_remainder_data(NewData, RemainderData),
  +    lager:debug("previous is ~p and size of new data is ~p", [PreviousBytesReceived, size(NewData)]),
       UpdatedBytesReceived = PreviousBytesReceived + size(NewData),
   
       {NewBufferQueue, NewRemainderData2} =
  
positive.code:     gen_fsm:sync_send_event(Pid, finalize).
  
  block_written(Pid, BlockID) ->
      gen_fsm:sync_send_event(Pid, {block_written, BlockID, self()}).
  
  %%%===================================================================
  %%% gen_fsm callbacks
  
negative.code:         State;
  maybe_write_blocks(State=#state{free_writers=[]}) ->
          State;
  maybe_write_blocks(State=#state{buffer_queue=[ToWrite | RestBuffer],
                                  free_writers=FreeWriters,
                                  unacked_writes=UnackedWrites,
                                  bucket=Bucket,
  