Sha256: 145dd4eef7dc6a253ea576ce5a6dc166e1e3ca14971cd8e2521bef6707a4cd05

Contents?: true

Size: 993 Bytes

Versions: 1

Compression:

Stored size: 993 Bytes

Contents

require 'spec_helper'

Thread.abort_on_exception = true

RSpec.describe Sidekiq::LimitFetch::Global::Monitor do
  let(:queues) { double dynamic?: false }
  let(:monitor) { described_class.start! queues, ttl, timeout }
  let(:ttl) { 1 }
  let(:queue) { Sidekiq::Queue[name] }
  let(:name) { 'default' }

  before :each do
    monitor
  end

  after :each do
    monitor.kill
  end

  context 'old locks' do
    let(:timeout) { 0.5 }

    it 'should remove invalidated old locks' do
      2.times { queue.acquire }
      sleep 2*ttl
      expect(queue.probed).to eq 2

      allow(described_class).to receive(:update_heartbeat)
      sleep 2*ttl
      expect(queue.probed).to eq 0
    end

    it 'should remove invalid locks' do
      2.times { queue.acquire }
      allow(described_class).to receive(:update_heartbeat)
      Sidekiq.redis do |it|
        it.del Sidekiq::LimitFetch::Global::Monitor::PROCESS_SET
      end
      sleep 2*ttl
      expect(queue.probed).to eq 0
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version Path
sidekiq-limit_fetch-2.4.2 spec/sidekiq/limit_fetch/global/monitor_spec.rb