Class: LS4::MemcacheMDS

Inherits:
MDS
  • Object
show all
Defined in:
lib/ls4/service/mds_memcache.rb

Defined Under Namespace

Classes: Entry, HADB

Instance Method Summary collapse

Methods inherited from MDS

#util_locate

Constructor Details

#initialize ⇒ MemcacheMDS 



40
41
42
 
# File 'lib/ls4/service/mds_memcache.rb', line 40

def initialize
  require 'memcache'
end

Instance Method Details

#add(key, attrs = {}, vname = nil, &cb) ⇒ Object 



85
86
87
88
89
90
 
# File 'lib/ls4/service/mds_memcache.rb', line 85

def add(key, attrs={}, vname=nil, &cb)
  okey = set_impl(key, attrs, vname)
  cb.call(okey, nil) rescue nil
rescue
  cb.call(nil, $!) rescue nil
end

#close ⇒ Object 



48
49
50
 
# File 'lib/ls4/service/mds_memcache.rb', line 48

def close
  @hadb.close
end

#delete(key, version = nil, &cb) ⇒ Object 



122
123
124
125
 
# File 'lib/ls4/service/mds_memcache.rb', line 122

def delete(key, version=nil, &cb)
  raise "version is not supported on memcache MDS" if version
  remove(key, &cb)
end

#get_attrs(key, version = nil, &cb) ⇒ Object 



63
64
65
66
67
68
69
70
71
72
 
# File 'lib/ls4/service/mds_memcache.rb', line 63

def get_attrs(key, version=nil, &cb)
  e = get_impl(key, version)
  if e
    cb.call(e.attrs, nil) rescue nil
  else
    cb.call(nil, nil) rescue nil
  end
rescue
  cb.call(nil, $!) rescue nil
end

#get_okey(key, version = nil, &cb) ⇒ Object 



52
53
54
55
56
57
58
59
60
61
 
# File 'lib/ls4/service/mds_memcache.rb', line 52

def get_okey(key, version=nil, &cb)
  e = get_impl(key, version)
  if e
    cb.call(e.to_okey(key), nil) rescue nil
  else
    cb.call(nil, nil) rescue nil
  end
rescue
  cb.call(nil, $!) rescue nil
end

#get_okey_attrs(key, version = nil, &cb) ⇒ Object 



74
75
76
77
78
79
80
81
82
83
 
# File 'lib/ls4/service/mds_memcache.rb', line 74

def get_okey_attrs(key, version=nil, &cb)
  e = get_impl(key, version)
  if e
    cb.call([e.to_okey(key), e.attrs], nil) rescue nil
  else
    cb.call(nil, nil) rescue nil
  end
rescue
  cb.call(nil, $!) rescue nil
end

#open(expr) ⇒ Object 



44
45
46
 
# File 'lib/ls4/service/mds_memcache.rb', line 44

def open(expr)
  @hadb = HADB.new(expr)
end

#remove(key, &cb) ⇒ Object 



101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
 
# File 'lib/ls4/service/mds_memcache.rb', line 101

def remove(key, &cb)
  e = get_impl(key)

  if e
    result = nil
    @hadb.write(key) {|mc|
      result = mc.delete(key)
    }
    #if result !~ /DELETED/
    # TODO
    #end

    cb.call(e.to_okey(key), nil) rescue nil
  else
    cb.call(nil, nil) rescue nil
  end

rescue
  cb.call(nil, $!) rescue nil
end

#update_attrs(key, attrs, &cb) ⇒ Object 



92
93
94
95
96
97
98
99
 
# File 'lib/ls4/service/mds_memcache.rb', line 92

def update_attrs(key, attrs, &cb)
  okey = update_impl(key) {|old_attrs|
    attrs
  }
  cb.call(okey, nil) rescue nil
rescue
  cb.call(nil, $!) rescue nil
end