anchor.diff:  handle_backpressure_for_chunk(NewData, From, State=#state{reply_pid=undefined,
                                                             buffer_queue=BufferQueue,
                                                             remainder_data=RemainderData,
  +                                                          current_buffer_size=CurrentBufferSize,
                                                             num_bytes_received=PreviousBytesReceived,
                                                             content_length=ContentLength}) ->
   
       NewRemainderData = combine_new_and_remainder_data(NewData, RemainderData),
       UpdatedBytesReceived = PreviousBytesReceived + size(NewData),
   
  +    NewCurrentBufferSize = CurrentBufferSize + size(NewData),
  +
       {NewBufferQueue, NewRemainderData2} =
       data_blocks(NewRemainderData, ContentLength, UpdatedBytesReceived, BufferQueue),
   
       NewStateData = maybe_write_blocks(State#state{buffer_queue=NewBufferQueue,
                                                     remainder_data=NewRemainderData2,
  +                                                  current_buffer_size=NewCurrentBufferSize,
                                                     num_bytes_received=UpdatedBytesReceived}),
   
       {next_state, full, NewStateData#state{reply_pid=From}}.
   
   handle_receiving_last_chunk(NewData, State=#state{buffer_queue=BufferQueue,
                                                     remainder_data=RemainderData,
  +                                                  current_buffer_size=CurrentBufferSize,
                                                     num_bytes_received=PreviousBytesReceived,
                                                     content_length=ContentLength}) ->
   
       NewRemainderData = combine_new_and_remainder_data(NewData, RemainderData),
       UpdatedBytesReceived = PreviousBytesReceived + size(NewData),
   
  +    NewCurrentBufferSize = CurrentBufferSize + size(NewData),
  +
       {NewBufferQueue, NewRemainderData2} =
       data_blocks(NewRemainderData, ContentLength, UpdatedBytesReceived, BufferQueue),
   
       NewStateData = maybe_write_blocks(State#state{buffer_queue=NewBufferQueue,
                                                     remainder_data=NewRemainderData2,
  +                                                  current_buffer_size=NewCurrentBufferSize,
                                                     num_bytes_received=UpdatedBytesReceived}),
   
       Reply = ok,
  
positive.code: handle_accept_chunk(NewData, State=#state{buffer_queue=BufferQueue,
                                            remainder_data=RemainderData,
                                            num_bytes_received=PreviousBytesReceived,
                                            content_length=ContentLength}) ->
  
      NewRemainderData = combine_new_and_remainder_data(NewData, RemainderData),
      UpdatedBytesReceived = PreviousBytesReceived + size(NewData),
  
      {NewBufferQueue, NewRemainderData2} =
      data_blocks(NewRemainderData, ContentLength, UpdatedBytesReceived, BufferQueue),
  
      NewStateData = maybe_write_blocks(State#state{buffer_queue=NewBufferQueue,
                                                    remainder_data=NewRemainderData2,
                                                    num_bytes_received=UpdatedBytesReceived}),
      Reply = ok,
      {reply, Reply, not_full, NewStateData}.
  
negative.code:     %% Also, use poolboy :)
      WriterPids = start_writer_servers(1),
      FreeWriters = ordsets:from_list(WriterPids),
      %% TODO:
      %% we should get this
      %% from the app.config
      MaxBufferSize = riak_moss_lfs_utils:block_size(),
      UUID = druuid:v4(),
      Manifest =
  