Class: Thinner::Purger

Inherits:

Object

• Object
• Thinner::Purger

show all

Defined in:

lib/thinner/purger.rb

Overview

Class Method Summary (collapse)

• + (Object) job_ids

  A list of Thinner::Client process ids — adapted from resque.

• + (Object) stop!

  Before we spin up a new client each running process is killed by pid.

Instance Method Summary (collapse)

• - (Purger) initialize(urls) constructor

  Each Purger accepts a list of urls to pass on to the client to purge.

• - (Object) purge!

  After the configuration is in place and the Purger has a list of urls, it can fork a client process to run in the background.

8
9
10

# File 'lib/thinner/purger.rb', line 8

def initialize(urls)
  @urls = urls
end

26
27
28
29
30

# File 'lib/thinner/purger.rb', line 26

def self.job_ids
  lines = `ps -A -o pid,command | grep #{PROCESS_IDENTIFIER}`.split("\n").map do |line|
    line.split(' ')[0].to_i
  end
end

34
35
36
37
38
39
40
41
42
43

# File 'lib/thinner/purger.rb', line 34

def self.stop!
  my_id = $$
  job_ids.each do |pid|
    begin
      Process.kill("KILL", pid.to_i) unless pid.to_i == my_id
      puts "==== Killing process: #{pid}"
    rescue Errno::ESRCH
    end
  end
end

16
17
18
19
20
21
22
23

# File 'lib/thinner/purger.rb', line 16

def purge!
  self.class.stop! unless Thinner.configuration.no_kill
  puts "==== Starting purge see: #{Thinner.configuration.log_file} for finished urls."
  client_id = fork {
    Client.new(@urls).run!
  }
  Process.detach(client_id)
end