Sha256: 1313f50bfa683cc7f5913e3ea78deb9acb382578f819bb32c20bcf6babf799a9
Contents?: true
Size: 1.57 KB
Versions: 11
Compression:
Stored size: 1.57 KB
Contents
module Moneta
# 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
class Shared < Wrapper
# @param [Hash] options
# @option options [Integer] :port (9000) TCP port
# @option options [String] :host Server hostname
# @option options [String] :socket Unix socket file name
def initialize(options = {}, &block)
@options = options
@builder = Builder.new(&block)
end
# (see Proxy#close)
def close
if @server
@server.stop
@thread.join
@server = @thread = nil
end
if @adapter
@adapter.close
@adapter = nil
end
end
protected
def wrap(*args)
@adapter ||= Adapters::Client.new(@options)
yield
rescue Errno::ECONNREFUSED, Errno::ENOENT => ex
tries ||= 0
warn "Moneta::Shared - Failed to connect: #{ex.message}" if tries > 0
begin
# TODO: Implement this using forking (MRI) and threading (JRuby)
# to get maximal performance
@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
warn "Moneta::Shared - Failed to start server: #{ex.message}"
@adapter.close if @adapter
@adapter = nil
end
(tries += 1) < 3 ? retry : raise
end
end
end
Version data entries
11 entries across 11 versions & 1 rubygems