Class: Mongoid::Bolt

Inherits:

Object

• Object
• Mongoid::Bolt

Includes:

Document, Timestamps

Defined in:

lib/mongoid-bolt.rb,
lib/mongoid-bolt.rb

Defined Under Namespace

Modules: Ability Classes: Error

Class Method Summary

• .ability ⇒ Object
• .dependencies ⇒ Object
• .for(name, options = {}, &block) ⇒ Object
• .hostname ⇒ Object
• .identifier ⇒ Object
• .libdir(*args, &block) ⇒ Object
• .load(*libs) ⇒ Object
• .pid ⇒ Object
• .ppid ⇒ Object
• .process_alive?(*pids) ⇒ Boolean
• .thread_alive?(*tids) ⇒ Boolean
• .tid ⇒ Object
• .version ⇒ Object

Instance Method Summary

• #name ⇒ Object

Class Method Details

.ability ⇒ Object

# File 'lib/mongoid-bolt.rb', line 295

def Bolt.ability
  Ability
end

.dependencies ⇒ Object

# File 'lib/mongoid-bolt.rb', line 14

def dependencies
  {
    'mongoid'         => [ 'mongoid'         , ' >= 3.0.1' ] ,
  }
end

.for(name, options = {}, &block) ⇒ Object

# File 'lib/mongoid-bolt.rb', line 310

def Bolt.for(name, options = {}, &block)
  name = name.to_s
  conditions = {:name => name}

  attributes = conditions.dup
  attributes[:created_at] || attributes[:updated_at] = Time.now.utc

  lock =
    begin
      where(conditions).first or create!(attributes)
    rescue Object => e
      sleep(rand)
      where(conditions).first or create!(attributes)
    end

  block ? lock.lock(options, &block) : lock
end

.hostname ⇒ Object

# File 'lib/mongoid-bolt.rb', line 339

def Bolt.hostname
  @hostname ||= Socket.gethostname
end

.identifier ⇒ Object

# File 'lib/mongoid-bolt.rb', line 355

def Bolt.identifier
  {:hostname => hostname, :ppid => ppid, :pid => pid, :tid => tid}
end

.libdir(*args, &block) ⇒ Object

# File 'lib/mongoid-bolt.rb', line 20

def libdir(*args, &block)
  @libdir ||= File.expand_path(__FILE__).sub(/\.rb$/,'')
  args.empty? ? @libdir : File.join(@libdir, *args)
ensure
  if block
    begin
      $LOAD_PATH.unshift(@libdir)
      block.call()
    ensure
      $LOAD_PATH.shift()
    end
  end
end

.load(*libs) ⇒ Object

# File 'lib/mongoid-bolt.rb', line 34

def load(*libs)
  libs = libs.join(' ').scan(/[^\s+]+/)
  libdir{ libs.each{|lib| Kernel.load(lib) } }
end

.pid ⇒ Object

# File 'lib/mongoid-bolt.rb', line 347

def Bolt.pid
  Process.pid
end

.ppid ⇒ Object

# File 'lib/mongoid-bolt.rb', line 343

def Bolt.ppid
  Process.ppid
end

.process_alive?(*pids) ⇒ Boolean

Returns:

• (Boolean)

# File 'lib/mongoid-bolt.rb', line 359

def Bolt.process_alive?(*pids)
  pids.flatten.compact.all? do |pid|
    begin
      Process.kill(0, Integer(pid))
      true
    rescue Object
      false
    end
  end
end

.thread_alive?(*tids) ⇒ Boolean

Returns:

• (Boolean)

# File 'lib/mongoid-bolt.rb', line 370

def Bolt.thread_alive?(*tids)
  tids.flatten.compact.all? do |tid|
    Thread.list.detect{|thread| thread.object_id == tid}
  end
end

.tid ⇒ Object

# File 'lib/mongoid-bolt.rb', line 351

def Bolt.tid
  Thread.current.object_id
end

.version ⇒ Object

# File 'lib/mongoid-bolt.rb', line 10

def version
  const_get :Version
end

Instance Method Details

#name ⇒ Object

# File 'lib/mongoid-bolt.rb', line 330

field(:name)