Class: RSMP::Site

Inherits:
Node
  • Object
show all
Includes:
Components
Defined in:
lib/rsmp/node/site/site.rb,
lib/rsmp/options/site_options.rb

Overview

RSMP site implementation that manages proxies and components.

Direct Known Subclasses

TLC::TrafficControllerSite

Defined Under Namespace

Classes: Options

Instance Attribute Summary collapse

Attributes included from Components

#components, #main

Attributes inherited from Node

#archive, #clock, #collector, #deferred, #error_queue, #task

Attributes included from Task

#task

Attributes included from Logging

#archive

Class Method Summary collapse

Instance Method Summary collapse

Methods included from Components

#add_component, #check_main_component, #clear_alarm_timestamps, #find_component, #infer_component_type, #initialize_components, #setup_components

Methods inherited from Node

#author, #check_required_settings, #clear_deferred, #defer, #distribute_error, #do_deferred, #ignore_errors, #now, #process_deferred, #stop_subtasks

Methods included from Task

#initialize_task, #restart, #start, #stop_subtasks, #stop_task, #task_status, #wait, #wait_for_condition

Methods included from Inspect

#inspect, #inspector

Methods included from Logging

#author, #initialize_logging, #log

Constructor Details

#initialize(options = {}) ⇒ Site

Returns a new instance of Site.



12
13
14
15
16
17
18
19
20
 
# File 'lib/rsmp/node/site/site.rb', line 12

def initialize(options = {})
  super
  initialize_components
  handle_site_settings options
  @proxies = []
  @sleep_condition = Async::Notification.new
  @proxies_condition = Async::Notification.new
  build_proxies
end

Instance Attribute Details

#core_version ⇒ Object (readonly)

Returns the value of attribute core_version.



6
7
8
 
# File 'lib/rsmp/node/site/site.rb', line 6

def core_version
  @core_version
end

#logger ⇒ Object (readonly)

Returns the value of attribute logger.



6
7
8
 
# File 'lib/rsmp/node/site/site.rb', line 6

def logger
  @logger
end

#proxies ⇒ Object (readonly)

Returns the value of attribute proxies.



6
7
8
 
# File 'lib/rsmp/node/site/site.rb', line 6

def proxies
  @proxies
end

#site_settings ⇒ Object (readonly)

Returns the value of attribute site_settings.



6
7
8
 
# File 'lib/rsmp/node/site/site.rb', line 6

def site_settings
  @site_settings
end

Class Method Details

.options_class ⇒ Object 



8
9
10
 
# File 'lib/rsmp/node/site/site.rb', line 8

def self.options_class
  RSMP::Site::Options
end

Instance Method Details

#aggregated_status_changed(component, _options = {}) ⇒ Object 



96
97
98
99
100
 
# File 'lib/rsmp/node/site/site.rb', line 96

def aggregated_status_changed(component, _options = {})
  @proxies.each do |proxy|
    proxy.send_aggregated_status component if proxy.ready?
  end
end

#alarm_acknowledged(alarm_state) ⇒ Object 



102
103
104
 
# File 'lib/rsmp/node/site/site.rb', line 102

def alarm_acknowledged(alarm_state)
  send_alarm AlarmAcknowledged.new(alarm_state.to_hash)
end

#alarm_activated_or_deactivated(alarm_state) ⇒ Object 



110
111
112
 
# File 'lib/rsmp/node/site/site.rb', line 110

def alarm_activated_or_deactivated(alarm_state)
  send_alarm AlarmIssue.new(alarm_state.to_hash)
end

#alarm_suspended_or_resumed(alarm_state) ⇒ Object 



106
107
108
 
# File 'lib/rsmp/node/site/site.rb', line 106

def alarm_suspended_or_resumed(alarm_state)
  send_alarm AlarmSuspended.new(alarm_state.to_hash)
end

#build_component(id:, type:, settings:) ⇒ Object 



158
159
160
161
162
163
164
165
166
 
# File 'lib/rsmp/node/site/site.rb', line 158

def build_component(id:, type:, settings:)
  settings ||= {}
  if type == 'main'
    Component.new id: id, node: self, grouped: true,
                  ntsoid: settings['ntsOId'], xnid: settings['xNId']
  else
    Component.new id: id, node: self, grouped: false
  end
end

#build_proxies ⇒ Object 



81
82
83
84
85
86
87
88
89
90
91
92
93
94
 
# File 'lib/rsmp/node/site/site.rb', line 81

def build_proxies
  @site_settings['supervisors'].each do |supervisor_settings|
    @proxies << SupervisorProxy.new({
                                      site: self,
                                      task: @task,
                                      settings: @site_settings,
                                      ip: supervisor_settings['ip'],
                                      port: supervisor_settings['port'],
                                      logger: @logger,
                                      archive: @archive,
                                      collect: @collect
                                    })
  end
end

#check_core_versions ⇒ Object

Raises:



47
48
49
50
51
52
53
54
55
 
# File 'lib/rsmp/node/site/site.rb', line 47

def check_core_versions
  version = @site_settings['core_version']
  return unless version

  return if RSMP::Schema.core_versions.include? version

  error_str = "Unknown core version: #{version}"
  raise RSMP::ConfigurationError, error_str
end

#check_sxl_version ⇒ Object 



41
42
43
44
45
 
# File 'lib/rsmp/node/site/site.rb', line 41

def check_sxl_version
  sxl = @site_settings['sxl']
  version = @site_settings['sxl_version'].to_s
  RSMP::Schema.find_schema! sxl, version, lenient: true
end

#connect_to_supervisor(_task, supervisor_settings) ⇒ Object 



120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
 
# File 'lib/rsmp/node/site/site.rb', line 120

def connect_to_supervisor(_task, supervisor_settings)
  proxy = build_proxy({
                        site: self,
                        task: @task,
                        settings: @site_settings,
                        ip: supervisor_settings['ip'],
                        port: supervisor_settings['port'],
                        logger: @logger,
                        archive: @archive,
                        collect: @collect
                      })
  @proxies << proxy
  proxy.start
  @proxies_condition.signal
end

#find_supervisor(ip) ⇒ Object 



151
152
153
154
155
156
 
# File 'lib/rsmp/node/site/site.rb', line 151

def find_supervisor(ip)
  @proxies.each do |supervisor|
    return supervisor if ip == :any || supervisor.ip == ip
  end
  nil
end

#handle_site_settings(options = {}) ⇒ Object 



30
31
32
33
34
35
36
37
38
39
 
# File 'lib/rsmp/node/site/site.rb', line 30

def handle_site_settings(options = {})
  options_class = self.class.options_class
  settings = options[:site_settings] || {}
  @site_options = options_class.new(settings)
  @site_settings = @site_options.to_h

  check_sxl_version
  check_core_versions
  setup_components @site_settings['components']
end

#log_site_starting ⇒ Object 



61
62
63
64
65
66
67
68
69
70
71
 
# File 'lib/rsmp/node/site/site.rb', line 61

def log_site_starting
  log "Starting #{site_type_name} #{@site_settings['site_id']}", level: :info, timestamp: @clock.now
  sxl = "Using #{@site_settings['sxl']} sxl #{@site_settings['sxl_version']}"
  version = @site_settings['core_version']
  core = if version
           "accepting only core version #{version}"
         else
           "accepting all core versions [#{RSMP::Schema.core_versions.join(', ')}]"
         end
  log "#{sxl}, #{core}", level: :info, timestamp: @clock.now
end

#run ⇒ Object 



73
74
75
76
77
78
79
 
# File 'lib/rsmp/node/site/site.rb', line 73

def run
  log_site_starting
  @proxies.each do |proxy|
    proxy.start
    proxy.wait
  end
end

#send_alarm(alarm) ⇒ Object 



114
115
116
117
118
 
# File 'lib/rsmp/node/site/site.rb', line 114

def send_alarm(alarm)
  @proxies.each do |proxy|
    proxy.send_message alarm if proxy.ready?
  end
end

#site_id ⇒ Object 



26
27
28
 
# File 'lib/rsmp/node/site/site.rb', line 26

def site_id
  @site_settings['site_id']
end

#site_type_name ⇒ Object 



57
58
59
 
# File 'lib/rsmp/node/site/site.rb', line 57

def site_type_name
  'site'
end

#stop ⇒ Object

stop



137
138
139
140
 
# File 'lib/rsmp/node/site/site.rb', line 137

def stop
  log "Stopping site #{@site_settings['site_id']}", level: :info
  super
end

#sxl_version ⇒ Object 



22
23
24
 
# File 'lib/rsmp/node/site/site.rb', line 22

def sxl_version
  @site_settings['sxl_version']
end

#wait_for_supervisor(ip, timeout) ⇒ Object 



142
143
144
145
146
147
148
149
 
# File 'lib/rsmp/node/site/site.rb', line 142

def wait_for_supervisor(ip, timeout)
  supervisor = find_supervisor ip
  return supervisor if supervisor

  wait_for_condition(@proxy_condition, timeout: timeout) { find_supervisor ip }
rescue Async::TimeoutError
  raise RSMP::TimeoutError, "Supervisor '#{ip}' did not connect within #{timeout}s"
end