Module: EventCache

Included in:
DrbDb
Defined in:
lib/DrbDB/EventCache.rb

Overview

this file is part of manqod manqod is distributed under the CDDL licence the owner of manqod is Dobai-Pataky Balint([email protected])

Instance Method Summary collapse

Instance Method Details

#events(gtk_object_id, force_load = false) ⇒ Object 



21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
 
# File 'lib/DrbDB/EventCache.rb', line 21

def events(gtk_object_id,force_load=false)
  if force_load
    begin
      cache.delete("ev#{gtk_object_id}") 
    rescue Memcached::NotFound
    end
    cnt=0
    a=Hash.new
    admin.rows("select * from events where gtkobjectid = '#{gtk_object_id}'").each{|row|
      a[row['event']]=Array.new unless a.has_key?(row['event'])
      a[row['event']].push(row['command'])
      cnt+=1
    }
    cache.set("ev#{gtk_object_id}",a) if a.size>0

    einfo("loaded #{cnt.inspect} events for #{gtk_object_id.inspect}")
  end
  begin
    a=cache.set("ev#{gtk_object_id}",a)
  rescue Memcached::NotFound
    a=Array.new
  end
  a
end

#load_all_events ⇒ Object 



7
8
9
10
11
12
13
14
15
16
17
18
19
 
# File 'lib/DrbDB/EventCache.rb', line 7

def load_all_events
  cnt=0
  admin.rows("select distinct gtkobjectid from events").each{|evid|
    a=Hash.new
    admin.rows("select * from events where gtkobjectid = '#{evid['gtkobjectid']}'").each{|row|
      a[row['event']]=Array.new unless a.has_key?(row['event'])
      a[row['event']].push(row['command'])
      cnt+=1
    }
    cache.set("ev#{evid['gtkobjectid']}",a)
  }
  einfo("loaded #{cnt} events")
end