Method: Fairy::FileMarshaledQueue#initialize

Defined in:
lib/fairy/share/port-marshaled-queue.rb

#initialize(policy, queues_mon = Monitor.new, queues_cv = queues_mon.new_cond) ⇒ FileMarshaledQueue

Returns a new instance of FileMarshaledQueue.



184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
 
# File 'lib/fairy/share/port-marshaled-queue.rb', line 184

def initialize(policy, queues_mon = Monitor.new, queues_cv = queues_mon.new_cond)
  @policy = policy

  @chunk_size = CONF.MARSHAL_QUEUE_CHUNK_SIZE
  @min_chunk_no = @policy[:min_chunk_no]
  @min_chunk_no ||= CONF.MARSHAL_QUEUE_MIN_CHUNK_NO

  @push_queue = []
  @push_queue_mutex = Mutex.new
  
  @buffers_queue = []
  @buffers_queue_mon = queues_mon
  @buffers_queue_cv = queues_cv

  @pop_queue = nil

  @buffer_dir = @policy[:buffer_dir]
  @buffer_dir ||= CONF.TMP_DIR
end