Method: ContentServer::FileCopyManager#remove_content

Defined in:
lib/content_server/queue_copy.rb

#remove_content(checksum) ⇒ Object 



84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
 
# File 'lib/content_server/queue_copy.rb', line 84

def remove_content(checksum)
  @keeper.synchronize{
    Log.debug3("removing checksum:%s from contents under copy", checksum)
    @contents_under_copy.delete(checksum)
    $process_vars.set('contents under copy', @contents_under_copy.size)
    #1 place is became available. Put another file in copy process if waiting
    if (@contents_to_copy_queue.size > 0)
      new_content = @contents_to_copy_queue.pop
      $process_vars.set('contents to copy queue', @contents_to_copy_queue.size)
      @contents_to_copy.delete(new_content[0])
      @contents_under_copy[new_content[0]] = [new_content[1], false, Time.now]
      $process_vars.set('contents under copy', @contents_under_copy.size)
      @copy_input_queue.push([:SEND_ACK_MESSAGE, new_content[0]])
      $process_vars.set('Copy File Queue Size', @copy_input_queue.size)
    end
  }
end