Module: Hive

Defined in:
lib/hive.rb,
lib/hive/log.rb,
lib/hive/device.rb,
lib/hive/worker.rb,
lib/hive/results.rb,
lib/hive/register.rb,
lib/hive/controller.rb,
lib/hive/diagnostic.rb,
lib/hive/file_system.rb,
lib/hive/device/shell.rb,
lib/hive/worker/shell.rb,
lib/hive/port_allocator.rb,
lib/hive/controller/shell.rb,
lib/hive/execution_script.rb,
lib/hive/diagnostic_runner.rb

Overview

The Hive automated testing framework

Defined Under Namespace

Classes: Controller, Device, Diagnostic, DiagnosticRunner, ExecutionScript, FileSystem, Log, PortAllocator, Register, Results, Worker

Constant Summary collapse

DAEMON_NAME = 
Chamber.env.daemon_name? ? Chamber.env.daemon_name : 'HIVE'
LOG_DIRECTORY = 
Chamber.env.logging.directory
PIDS_DIRECTORY = 
LOG_DIRECTORY

Class Method Summary collapse

Class Method Details

.config ⇒ Object 



43
44
45
 
# File 'lib/hive.rb', line 43

def self.config
  Chamber.env
end

.hive_mind ⇒ Object 



61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
 
# File 'lib/hive.rb', line 61

def self.hive_mind
  Hive.logger.debug "Sysname: #{Sys::Uname.sysname}"
  Hive.logger.debug "Release: #{Sys::Uname.release}"
  if ! @hive_mind
    if @hive_mind = MindMeld::Hive.new(
      url: Chamber.env.network.hive_mind? ? Chamber.env.network.hive_mind : nil,
      pem: Chamber.env.network.cert ? Chamber.env.network.cert : nil,
      ca_file: Chamber.env.network.cafile ? Chamber.env.network.cafile : nil,
      verify_mode: Chamber.env.network.verify_mode ? Chamber.env.network.verify_mode : nil,
      device: {
        hostname: Hive.hostname,
        version: Gem::Specification.find_by_name('hive-runner').version.to_s,
        runner_plugins: Hash[Gem::Specification.all.select{ |g| g.name =~ /hive-runner-/ }.map { |p| [p.name, p.version.to_s] }],
        macs: Mac.addrs,
        ips: [Hive.ip_address],
        brand: Hive.config.brand? ? Hive.config.brand : 'BBC',
        model: Hive.config.model? ? Hive.config.model : 'Hive',
        operating_system_name: Sys::Uname.sysname,
        operating_system_version: Sys::Uname.release,
        device_type: 'Hive'
      }
    ) and Etc.respond_to?(:nprocessors) # Require Ruby >= 2.2
      @hive_mind.add_statistics(
        label: 'Processor count',
        value: Etc.nprocessors,
        format: 'integer'
      )
       
      if Chamber.env.has_key?('diagnostics') && Chamber.env.diagnostics.hive.load_warning? && Chamber.env.diagnostics.hive.load_error?
        @hive_mind.add_statistics(
          [
            {
              label: 'Load average warning threshold',
              value: Chamber.env.diagnostics.hive.load_warning,
              format: 'float'
            },
            {
              label: 'Load average error threshold',
              value: Chamber.env.diagnostics.hive.load_error,
              format: 'float'
            }
          ]
        )
      end
      @hive_mind.flush_statistics
    end
  end

  @hive_mind
end

.hostname ⇒ Object

Get the hostname of the Hive



145
146
147
 
# File 'lib/hive.rb', line 145

def self.hostname
  Socket.gethostname.split('.').first
end

.ip_address ⇒ Object

Get the IP address of the Hive



139
140
141
142
 
# File 'lib/hive.rb', line 139

def self.ip_address
  ip = Socket.ip_address_list.detect { |intf| intf.ipv4_private? }
  ip.ip_address
end

.logger ⇒ Object 



47
48
49
50
51
52
53
54
55
56
57
58
59
 
# File 'lib/hive.rb', line 47

def self.logger
  if ! @logger
    @logger = Hive::Log.new

    if Hive.config.logging.main_filename?
      @logger.add_logger("#{LOG_DIRECTORY}/#{Hive.config.logging.main_filename}", Chamber.env.logging.main_level? ? Chamber.env.logging.main_level : 'INFO')
    end
    if Hive.config.logging.console_level?
      @logger.add_logger(STDOUT, Hive.config.logging.console_level)
    end
  end
  @logger
end

.poll ⇒ Object

Poll the device database



117
118
119
120
121
122
123
124
125
126
 
# File 'lib/hive.rb', line 117

def self.poll
  Hive.logger.debug "Polling hive"
  rtn = Hive.hive_mind.poll
  Hive.logger.debug "Return data: #{rtn}"
  if rtn.has_key? 'error'
    Hive.logger.warn "Hive polling failed: #{rtn['error']}"
  else
    Hive.logger.info "Successfully polled hive"
  end
end

.register ⇒ Object 



112
113
114
 
# File 'lib/hive.rb', line 112

def self.register
  @register ||= Hive::Register.new
end

.send_statistics ⇒ Object

Gather and send statistics



129
130
131
132
133
134
135
136
 
# File 'lib/hive.rb', line 129

def self.send_statistics
  Hive.hive_mind.add_statistics(
    label: 'Load average',
    value: Sys::CPU.load_avg[0],
    format: 'float'
  )
  Hive.hive_mind.flush_statistics
end