This file is indexed.

/usr/lib/one/ruby/acct/acctd.rb is in opennebula 3.2.1-2.

This file is owned by root:root, with mode 0o755.

The actual contents of the file can be viewed below.

  1
  2
  3
  4
  5
  6
  7
  8
  9
 10
 11
 12
 13
 14
 15
 16
 17
 18
 19
 20
 21
 22
 23
 24
 25
 26
 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
 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
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
#!/usr/bin/env ruby

# -------------------------------------------------------------------------- #
# Copyright 2002-2012, OpenNebula Project Leads (OpenNebula.org)             #
#                                                                            #
# Licensed under the Apache License, Version 2.0 (the "License"); you may    #
# not use this file except in compliance with the License. You may obtain    #
# a copy of the License at                                                   #
#                                                                            #
# http://www.apache.org/licenses/LICENSE-2.0                                 #
#                                                                            #
# Unless required by applicable law or agreed to in writing, software        #
# distributed under the License is distributed on an "AS IS" BASIS,          #
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.   #
# See the License for the specific language governing permissions and        #
# limitations under the License.                                             #
#--------------------------------------------------------------------------- #

ONE_LOCATION=ENV["ONE_LOCATION"]

if !ONE_LOCATION
    RUBY_LIB_LOCATION="/usr/lib/one/ruby"
    ACCTD_CONF="/etc/one/acctd.conf"
else
    RUBY_LIB_LOCATION=ONE_LOCATION+"/lib/ruby"
    ACCTD_CONF=ONE_LOCATION+"/etc/acctd.conf"
end

$: << RUBY_LIB_LOCATION
$: << RUBY_LIB_LOCATION+"/acct"

require 'yaml'

require 'OpenNebula'
require 'watch_helper'

class Watcher
    def initialize
        @monitors = Array.new
    end

    def add(resource, steps, pools)
        @monitors <<    {   :resource => resource,
                            :steps    => steps,
                            :pools    => [pools].flatten
                        }
    end

    def log(msg)
        STDERR.puts "#{Time.now} #{msg}"
    end

    def update(step)
        # clear pool cache
        @pool_cache = Hash.new

        @monitors.each do |monitor|
            if monitor[:steps] > 0 and step % monitor[:steps] == 0
                monitor[:pools].each do |pool|
                    resource = monitor[:resource]

                    log "#{resource.class}"

                    if pool_hash = @pool_cache[pool]
                    else
                        rc = pool.info
                        if OpenNebula.is_error?(rc)
                            log "Error: " + rc.message
                            log "Shutting down"
                            exit 1
                        end

                        pool_hash = pool.to_hash
                        @pool_cache[pool] = pool_hash
                    end

                    resource.insert(pool_hash)
                end
            end
        end
    end
end

watcher = Watcher.new

# OpenNebula variables
one_client  = OpenNebula::Client.new
vm_pool     = nil # common for accounting and monitoring
host_pool   = nil

# Initialize VM monitoring
if vm_steps = WatchHelper::get_config(:VM_MONITORING, :STEPS) and
    vm_steps > 0

    require 'monitoring'
    vm_monitoring       = OneWatch::VmMonitoring.new
    vm_pool     ||= OpenNebula::VirtualMachinePool.new(one_client, -2)
    watcher.add(vm_monitoring,   vm_steps, vm_pool)
end

# Initialize Host monitoring
if host_steps = WatchHelper::get_config(:HOST_MONITORING, :STEPS) and
    host_steps > 0

    require 'monitoring'
    host_monitoring     = OneWatch::HostMonitoring.new
    host_pool   ||= OpenNebula::HostPool.new(one_client)
    watcher.add(host_monitoring, host_steps, host_pool)
end

# Initialize accounting
if accounting_steps = WatchHelper::get_config(:ACCOUNTING, :STEPS) and
    accounting_steps > 0

    require 'accounting'
    accounting  = OneWatch::Accounting.new(one_client)
    vm_pool     ||= OpenNebula::VirtualMachinePool.new(one_client, -2)
    watcher.add(accounting, accounting_steps, vm_pool)
end

step_time = WatchHelper::get_config(:STEP)

step = 0
loop do
    start_time  = Time.now
    expected_end_time = start_time + step_time

    step += 1
    watcher.update(step)

    end_time  = Time.now
    sleep_time = start_time + step_time - end_time

    if sleep_time >= 1
        sleep sleep_time
    else
        sleep 1
    end
end