Class: Bosh::Director::ProblemResolver

Inherits:
Object
  • Object
show all
Defined in:
lib/bosh/director/problem_resolver.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(deployment) ⇒ ProblemResolver

Returns a new instance of ProblemResolver.



6
7
8
9
10
11
12
13
 
# File 'lib/bosh/director/problem_resolver.rb', line 6

def initialize(deployment)
  @deployment = deployment
  @resolved_count = 0

  #temp
  @event_log = Config.event_log
  @logger = Config.logger
end

Instance Attribute Details

#event_log ⇒ Object (readonly)

Returns the value of attribute event_log.



4
5
6
 
# File 'lib/bosh/director/problem_resolver.rb', line 4

def event_log
  @event_log
end

#logger ⇒ Object (readonly)

Returns the value of attribute logger.



4
5
6
 
# File 'lib/bosh/director/problem_resolver.rb', line 4

def logger
  @logger
end

Instance Method Details

#apply_resolution(problem) ⇒ Object 



71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
 
# File 'lib/bosh/director/problem_resolver.rb', line 71

def apply_resolution(problem)
  handler = ProblemHandlers::Base.create_from_model(problem)
  handler.job = self

  resolution = @resolutions[problem.id.to_s] || handler.auto_resolution
  problem_summary = "#{problem.type} #{problem.resource_id}"
  resolution_summary = handler.resolution_plan(resolution)
  resolution_summary ||= "no resolution"

  begin
    track_and_log("#{problem_summary}: #{resolution_summary}") do
      handler.apply_resolution(resolution)
    end
  rescue Bosh::Director::ProblemHandlerError => e
    log_resolution_error(problem, e)
  end

  problem.state = "resolved"
  problem.save
  @resolved_count += 1

rescue => e
  log_resolution_error(problem, e)
end

#apply_resolutions(resolutions) ⇒ Object 



27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
 
# File 'lib/bosh/director/problem_resolver.rb', line 27

def apply_resolutions(resolutions)
  @resolutions = resolutions
  problems = Models::DeploymentProblem.filter(deployment: @deployment, state: 'open').all
  problem_ids = Set.new

  problems.each do |problem|
    problem_ids << problem.id.to_s
    unless @resolutions.has_key?(problem.id.to_s)
      raise CloudcheckResolutionNotProvided,
            "Resolution for problem #{problem.id} (#{problem.type}) is not provided"
    end
  end

  # We might have some resolutions for problems that are no longer open
  # or just some bogus problem ids, in that case we still need to mention
  # them in event log so end user understands what actually happened.
  missing_problem_ids = @resolutions.keys.to_set - problem_ids

  begin_stage("Applying problem resolutions", problems.size + missing_problem_ids.size)
  problems.each do |problem|
    apply_resolution(problem)
  end

  missing_problem_ids.each do |problem_id|
    if problem_id !~ /^\d+$/
      reason = "malformed id"
    else
      problem = Models::DeploymentProblem[problem_id.to_i]
      if problem.nil?
        reason = "not found"
      elsif problem.state != "open"
        reason = "state is '#{problem.state}'"
      elsif problem.deployment_id != @deployment.id
        reason = "not a part of this deployment"
      else
        reason = "reason unknown"
      end
    end

    track_and_log("Ignoring problem #{problem_id} (#{reason})") { }
  end
  @resolved_count
end

#begin_stage(stage_name, n_steps) ⇒ Object 



15
16
17
18
 
# File 'lib/bosh/director/problem_resolver.rb', line 15

def begin_stage(stage_name, n_steps)
  event_log.begin_stage(stage_name, n_steps)
  logger.info(stage_name)
end

#track_and_log(task, log = true) ⇒ Object 



20
21
22
23
24
25
 
# File 'lib/bosh/director/problem_resolver.rb', line 20

def track_and_log(task, log = true)
  event_log.track(task) do |ticker|
    logger.info(task) if log
    yield ticker if block_given?
  end
end