Method: ContentServer::FileCopyManager#initialize

Defined in:
lib/content_server/queue_copy.rb

#initialize(copy_input_queue, file_streamer) ⇒ FileCopyManager

Returns a new instance of FileCopyManager.



25
26
27
28
29
30
31
32
33
34
 
# File 'lib/content_server/queue_copy.rb', line 25

def initialize(copy_input_queue, file_streamer)
  @copy_input_queue = copy_input_queue
  @file_streamer = file_streamer
  @max_contents_under_copy = Params['max_copy_streams']
  @contents_under_copy = {}
  @contents_to_copy = {}
  @contents_to_copy_queue = Queue.new
  @keeper = Mutex.new
  @clean_time_out_thread = clean_time_out_thread
end