Class: Goat::UpdateDispatcher

Inherits:

Object

• Object
• Goat::UpdateDispatcher

Defined in:

lib/goat.rb

Class Method Summary

• .component_updated(pgid, update) ⇒ Object
• .dispatch_update(update) ⇒ Object
• .dispatch_updates(txn, pgid, ups) ⇒ Object
• .enable ⇒ Object
• .finish_txn(txn_id) ⇒ Object
• .txn_complete(n) ⇒ Object
• .txn_start(n) ⇒ Object

Class Method Details

.component_updated(pgid, update) ⇒ Object

# File 'lib/goat.rb', line 1102

def self.component_updated(pgid, update)
  if Dynamic.variable?(:txn)
    txn = Dynamic[:txn]
    txn_pgid = Dynamic[:txn_pgid]
    if updates = @active_txns[txn]
      if pgid == txn_pgid
        updates[:page_updates] << update
      else
        updates[:other_updates] << update
      end
    else
      raise "Got an update for an un-started txn (#{txn.inspect}, #{pgid})"
    end
  else
    dispatch_update(update)
  end
end

.dispatch_update(update) ⇒ Object

# File 'lib/goat.rb', line 1098

def self.dispatch_update(update)
  StateSrvClient.component_updated(nil, update.skel.pgid, update)
end

.dispatch_updates(txn, pgid, ups) ⇒ Object

# File 'lib/goat.rb', line 1090

def self.dispatch_updates(txn, pgid, ups)
  StateSrvClient.components_updated(
    txn,
    pgid,
    ups
  )
end

.enable ⇒ Object

# File 'lib/goat.rb', line 1063

def self.enable
  Goat::NotificationCenter.subscribe(self, :txn_start, 'type' => 'txn_start')
  Goat::NotificationCenter.subscribe(self, :txn_complete, 'type' => 'txn_complete')
end

.finish_txn(txn_id) ⇒ Object

# File 'lib/goat.rb', line 1082

def self.finish_txn(txn_id)
  if txn = @active_txns[txn_id]
    pgid = txn[:pgid]
    dispatch_updates(txn_id, pgid, txn[:page_updates])
    txn[:other_updates].each{|u| dispatch_update(u)}
  end
end

.txn_complete(n) ⇒ Object

# File 'lib/goat.rb', line 1078

def self.txn_complete(n)
  finish_txn(n['txn'])
end

.txn_start(n) ⇒ Object

# File 'lib/goat.rb', line 1070

def self.txn_start(n)
  @active_txns[n['txn']] = {
    :page_updates => [],
    :other_updates => [],
    :pgid => n['pgid']
  }
end