Class: LS4::MDSCacheService

Inherits:
Service show all
Extended by:
Forwardable
Defined in:
lib/ls4/service/mds_cache.rb

Instance Method Summary collapse

Methods inherited from Service

init

Methods included from EventBus::SingletonMixin

#ebus_bind!, #ebus_connect, extended

Methods included from EventBus::BusMixin

#ebus_all_slots, #ebus_disconnect!

Methods included from EventBus::DeclarerBase::Methods

#connect, #ebus_all_slots, #ebus_call_log, #ebus_call_slots, #ebus_signal_error, #ebus_signal_log, #ebus_signal_slots

Methods included from EventBus::DeclarerBase

#call_slot, #signal_slot

Constructor Details

#initialize ⇒ MDSCacheService

Returns a new instance of MDSCacheService.



64
65
66
67
 
# File 'lib/ls4/service/mds_cache.rb', line 64

def initialize
	@uri = ""
	@cache = NullMDSCache.new
end

Instance Method Details

#reopen(uri) ⇒ Object 



85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
 
# File 'lib/ls4/service/mds_cache.rb', line 85

def reopen(uri)
	klass, expr = MDSCacheSelector.select_class(uri)

	cache = klass.new
	cache.open(expr)

	old_cache = @cache
	@cache = cache

	$log.info "using MDS cache: #{@cache}"

	begin
		old_cache.close
	rescue
		$log.error "MDSCache close error: #{$!}"
		$log.error_backtrace $!.backtrace
	end
end

#run ⇒ Object 



69
70
71
72
73
74
75
76
77
 
# File 'lib/ls4/service/mds_cache.rb', line 69

def run
	SyncBus.register_callback(SYNC_MDS_CACHE_URI,
						MDSCacheConfigService.hash_uri(@uri)) do |obj|
		uri = obj
		reopen(uri)
		@uri = uri
		MDSCacheConfigService.hash_uri(@uri)
	end
end

#shutdown ⇒ Object 



79
80
81
82
83
 
# File 'lib/ls4/service/mds_cache.rb', line 79

def shutdown
	if @cache
		@cache.close rescue nil
	end
end