Class: OpenC3::ReactionSnoozeManager

Inherits:
Object
  • Object
show all
Defined in:
lib/openc3/microservices/reaction_microservice.rb

Overview

The reaction snooze manager starts a thread pool and keeps track of when a reaction is activated and to evalute triggers when the snooze is complete.

Constant Summary collapse

SNOOZE_METRIC_NAME = 
'snooze_manager_duration_seconds'.freeze

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(name:, logger:, scope:, share:) ⇒ ReactionSnoozeManager

Returns a new instance of ReactionSnoozeManager.



361
362
363
364
365
366
367
368
369
370
371
 
# File 'lib/openc3/microservices/reaction_microservice.rb', line 361

def initialize(name:, logger:, scope:, share:)
  @name = name
  @logger = logger
  @scope = scope
  @share = share
  @worker_count = 3
  @thread_pool = nil
  @cancel_thread = false
  @metric = Metric.new(microservice: @name, scope: @scope)
  @metric_output_time = 0
end

Instance Attribute Details

#name ⇒ Object (readonly)

Returns the value of attribute name.



359
360
361
 
# File 'lib/openc3/microservices/reaction_microservice.rb', line 359

def name
  @name
end

#scope ⇒ Object (readonly)

Returns the value of attribute scope.



359
360
361
 
# File 'lib/openc3/microservices/reaction_microservice.rb', line 359

def scope
  @scope
end

#share ⇒ Object (readonly)

Returns the value of attribute share.



359
360
361
 
# File 'lib/openc3/microservices/reaction_microservice.rb', line 359

def share
  @share
end

#thread_pool ⇒ Object (readonly)

Returns the value of attribute thread_pool.



359
360
361
 
# File 'lib/openc3/microservices/reaction_microservice.rb', line 359

def thread_pool
  @thread_pool
end

Instance Method Details

#active_triggers(reaction:) ⇒ Object 



407
408
409
410
411
412
413
 
# File 'lib/openc3/microservices/reaction_microservice.rb', line 407

def active_triggers(reaction:)
  reaction.triggers.each do | trigger |
    t = TriggerModel.get(name: trigger['name'], group: trigger['group'], scope: @scope)
    return true if t && t.state
  end
  return false
end

#generate_thread_pool ⇒ Object 



373
374
375
376
377
378
379
380
 
# File 'lib/openc3/microservices/reaction_microservice.rb', line 373

def generate_thread_pool()
  thread_pool = []
  @worker_count.times do | i |
    worker = ReactionWorker.new(name: @name, logger: @logger, scope: @scope, share: @share, ident: i)
    thread_pool << Thread.new { worker.run }
  end
  return thread_pool
end

#manage_snoozed_reactions(current_time:) ⇒ Object 



415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
 
# File 'lib/openc3/microservices/reaction_microservice.rb', line 415

def manage_snoozed_reactions(current_time:)
  @share.reaction_base.get_snoozed.each do | reaction |
    time_difference = reaction.snoozed_until - current_time
    if time_difference <= 0 && @share.snooze_base.not_queued?(reaction: reaction)
      @logger.info "#{reaction.name} current: #{current_time}, vs #{reaction.snoozed_until}, #{time_difference}"
      unless reaction.review
        @logger.debug "#{reaction.name} review set to false, setting snoozed_until back to nil"
        @share.reaction_base.wake(name: reaction.name)
        next
      end
      if active_triggers(reaction: reaction)
        @share.queue_base.enqueue(kind: 'reaction', data: reaction.as_json(:allow_nan => true))
      else
        @share.reaction_base.wake(name: reaction.name)
      end
    end
  end
end

#run ⇒ Object 



382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
 
# File 'lib/openc3/microservices/reaction_microservice.rb', line 382

def run
  @logger.info "ReactionSnoozeManager running"
  @thread_pool = generate_thread_pool()
  loop do
    begin
      current_time = Time.now.to_i
      start = Process.clock_gettime(Process::CLOCK_MONOTONIC)
      manage_snoozed_reactions(current_time: current_time)
      diff = Process.clock_gettime(Process::CLOCK_MONOTONIC) - start # seconds as a float
      metric_labels = { 'type' => 'snooze', 'thread' => "manager" }
      @metric.add_sample(name: SNOOZE_METRIC_NAME, value: diff, labels: metric_labels)
      if @metric_output_time < current_time
        @metric.output
        @metric_output_time = current_time + 120
      end
    rescue StandardError => e
      @logger.error "ReactionSnoozeManager failed to snooze reactions.\n#{e.formatted}"
    end
    break if @cancel_thread
    sleep(1)
    break if @cancel_thread
  end
  @logger.info "ReactionSnoozeManager exiting"
end

#shutdown ⇒ Object 



434
435
436
437
438
439
 
# File 'lib/openc3/microservices/reaction_microservice.rb', line 434

def shutdown
  @cancel_thread = true
  @worker_count.times do | i |
    @share.queue_base.enqueue(kind: nil, data: nil)
  end
end