Class: CheckThread

Inherits:
BaseThread show all
Defined in:
lib/daemon/check_thread.rb

Constant Summary collapse

HTTP_RETRIES = 
3
@@storage_http_check = 
{}

Instance Method Summary collapse

Methods inherited from BaseThread

#initialize

Constructor Details

This class inherits a constructor from BaseThread

Instance Method Details

#check_http(storage) ⇒ Object 



21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
 
# File 'lib/daemon/check_thread.rb', line 21

def check_http(storage)
  url = "#{storage.url}healthcheck"
  uri = URI.parse(url.sub(%r{^\/\/}, 'http://'))
  request = Net::HTTP.new(uri.host, uri.port)
  request.read_timeout = request.open_timeout = 2
  resp = request.start { |http| http.get(uri.path) } rescue nil
  if resp && resp.code.to_i == 200 && resp.body.to_s.chomp == 'OK'
    storage.update_http_check_time
    @@storage_http_check[storage.name] = 0
  else
    @@storage_http_check[storage.name] = @@storage_http_check[storage.name].to_i + 1
    error("Storage #{storage.name} with url #{storage.url} not readable") if @@storage_http_check[storage.name] > HTTP_RETRIES
  end
rescue => err
  $log.error("CheckThread: check_http error: #{err}")
end

#go(storage_name) ⇒ Object 



7
8
9
10
11
12
13
14
15
16
17
18
19
 
# File 'lib/daemon/check_thread.rb', line 7

def go(storage_name)
  $log.debug("CheckThread: Run stotage check for #{storage_name}")
  storage = $storages.detect{|s| s.name == storage_name}
  if File.writable?(storage.path)
    storage.size_limit = storage.get_real_size if storage.auto_size?
    # also saves size_limit
    storage.update_check_time
  else 
    error "Storage #{storage.name} with path #{storage.path} not writable"
  end
  check_http(storage) if storage.http_check_enabled?
  $log.debug("CheckThread: Finish stotage check for #{storage_name}")
end