Files

Class/Module Index [+]

Quicksearch

Moneta::Shared

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

Public Class Methods

new(options = {}, &block) click to toggle source

@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

Public Instance Methods

close() click to toggle source

(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

Protected Instance Methods

connect() click to toggle source
# 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
start_server() click to toggle source

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
wrap(*args) click to toggle source
# File lib/moneta/shared.rb, line 38
def wrap(*args)
  connect
  yield
end

[Validate]

Generated with the Darkfish Rdoc Generator 2.