Shares a store between processes
@example Share a store
Moneta.build do use :Transformer, :key => :marshal, :value => :marshal use :Shared do adapter :GDBM, :file => 'shared.db' end end
@api public
@param [Hash] options @option options [Integer] :port (9000) TCP port @option options [String] :host Server hostname @option options [String] :socket Unix socket file name
# File lib/moneta/shared.rb, line 18 def initialize(options = {}, &block) @options = options @builder = Builder.new(&block) end
(see Proxy#close)
# File lib/moneta/shared.rb, line 24 def close if @server @server.stop @thread.join @server = @thread = nil end if @adapter @adapter.close @adapter = nil end end
# File lib/moneta/shared.rb, line 43 def connect @adapter ||= Adapters::Client.new(@options) rescue Errno::ECONNREFUSED, Errno::ENOENT => ex start_server tries ||= 0 warn "Moneta::Shared - Failed to connect: #{ex.message}" if tries > 0 (tries += 1) < 3 ? retry : raise end
TODO: Implement this using forking (MRI) and threading (JRuby) to get maximal performance
# File lib/moneta/shared.rb, line 54 def start_server @adapter = Lock.new(@builder.build.last) @server = Server.new(@adapter, @options) @thread = Thread.new { @server.run } sleep 0.1 until @server.running? rescue Exception => ex @adapter.close if @adapter @adapter = nil @server = nil @thread = nil warn "Moneta::Shared - Failed to start server: #{ex.message}" end
Generated with the Darkfish Rdoc Generator 2.