puppetlabs/vmpooler
2
0
Fork 0
mirror of https://github.com/puppetlabs/vmpooler.git synced 2026-01-26 10:08:40 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

Add a counter for vsphere connections

Browse source
This commit is contained in:
kirby@puppetlabs.com 2016-11-23 10:14:32 -08:00
parent 4faeb6a9ba
commit c43c02bf55
2 changed files with 9 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

6
lib/vmpooler/pool_manager.rb
View file

@ -413,7 +413,7 @@ module Vmpooler
def check_disk_queue def check_disk_queue
$logger.log('d', "[*] [disk_manager] starting worker thread") $logger.log('d', "[*] [disk_manager] starting worker thread")
$vsphere['disk_manager'] ||= Vmpooler::VsphereHelper.new $config[:vsphere] $vsphere['disk_manager'] ||= Vmpooler::VsphereHelper.new $config[:vsphere], $metrics
$threads['disk_manager'] = Thread.new do $threads['disk_manager'] = Thread.new do
loop do loop do
@ -439,7 +439,7 @@ module Vmpooler
def check_snapshot_queue def check_snapshot_queue
$logger.log('d', "[*] [snapshot_manager] starting worker thread") $logger.log('d', "[*] [snapshot_manager] starting worker thread")
$vsphere['snapshot_manager'] ||= Vmpooler::VsphereHelper.new $config[:vsphere] $vsphere['snapshot_manager'] ||= Vmpooler::VsphereHelper.new $config[:vsphere], $metrics
$threads['snapshot_manager'] = Thread.new do $threads['snapshot_manager'] = Thread.new do
loop do loop do
@ -547,7 +547,7 @@ module Vmpooler
def check_pool(pool) def check_pool(pool)
$logger.log('d', "[*] [#{pool['name']}] starting worker thread") $logger.log('d', "[*] [#{pool['name']}] starting worker thread")
$vsphere[pool['name']] ||= Vmpooler::VsphereHelper.new $config[:vsphere] $vsphere[pool['name']] ||= Vmpooler::VsphereHelper.new $config[:vsphere], $metrics
$threads[pool['name']] = Thread.new do $threads[pool['name']] = Thread.new do
loop do loop do

12
lib/vmpooler/vsphere_helper.rb
View file

@ -6,16 +6,16 @@ module Vmpooler
DISK_TYPE = 'thin' DISK_TYPE = 'thin'
DISK_MODE = 'persistent' DISK_MODE = 'persistent'
def initialize(credentials) def initialize(credentials, metrics)
$credentials = credentials $credentials = credentials
$metrics = metrics
end end
def ensure_connected(connection, credentials) def ensure_connected(connection, credentials)
begin connection.serviceInstance.CurrentTime
connection.serviceInstance.CurrentTime rescue
rescue $metrics.increment("connect.open")
connect_to_vsphere $credentials connect_to_vsphere $credentials
end
end end
def connect_to_vsphere(credentials) def connect_to_vsphere(credentials)