Class: LS4::TokyoTyrantMDS

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

Defined Under Namespace

Classes: HADB

Constant Summary collapse

COL_PK = 
''
COL_KEY = 
'_key'
COL_VTIME = 
'_time'
COL_RSID = 
'_rsid'
COL_VNAME = 
'_vname'
COL_REMOVED = 
'_removed'
COLS_RESERVED = 
[COL_PK, COL_KEY, COL_VTIME, COL_RSID, COL_VNAME, COL_REMOVED]
COLS_REQUIRED = 
[COL_PK, COL_KEY, COL_VTIME, COL_RSID]

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize ⇒ TokyoTyrantMDS

Returns a new instance of TokyoTyrantMDS.



83
84
85
86
87
 
# File 'lib/ls4/service/mds_tt.rb', line 83

def initialize
	self.class.define_consts
	@random = Random.new
	@pid = Process.pid
end

Class Method Details

.define_consts ⇒ Object 



34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
 
# File 'lib/ls4/service/mds_tt.rb', line 34

def self.define_consts
	unless const_defined?(:QRY)
		require 'tokyotyrant'
		const_set(:QRY, TokyoTyrant::RDBQRY)
		HADB.const_set(:TBL, TokyoTyrant::RDBTBL)
		HADB.const_set(:FATAL_ERROR, [
			TokyoTyrant::RDB::EINVALID,
			TokyoTyrant::RDB::ENOHOST,
			TokyoTyrant::RDB::EREFUSED,
			TokyoTyrant::RDB::ESEND,
			TokyoTyrant::RDB::ERECV,
			TokyoTyrant::RDB::EMISC
		])
	end
end

Instance Method Details

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



147
148
149
150
151
152
 
# File 'lib/ls4/service/mds_tt.rb', line 147

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

#close ⇒ Object 



106
107
108
 
# File 'lib/ls4/service/mds_tt.rb', line 106

def close
	@hadb.close
end

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



200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
 
# File 'lib/ls4/service/mds_tt.rb', line 200

def delete(key, version=nil, &cb)
	map = get_impl(key, version, COLS_RESERVED)
	if map && !is_removed(map)
		okey = to_okey(map)

		pk = map[COL_PK]
		@hadb.write(key) {|rdb| rdb.delete(pk) }

		cb.call(okey, nil) rescue nil

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

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



122
123
124
125
126
127
128
129
130
131
132
 
# File 'lib/ls4/service/mds_tt.rb', line 122

def get_attrs(key, version=nil, &cb)
	map = get_impl(key, version)
	if map && !is_removed(map)
		attrs = to_attrs(map)
		cb.call(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 



110
111
112
113
114
115
116
117
118
119
120
 
# File 'lib/ls4/service/mds_tt.rb', line 110

def get_okey(key, version=nil, &cb)
	map = get_impl(key, version, COLS_RESERVED)
	if map && !is_removed(map)
		okey = to_okey(map)
		cb.call(okey, 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 



134
135
136
137
138
139
140
141
142
143
144
145
 
# File 'lib/ls4/service/mds_tt.rb', line 134

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

#open(expr) ⇒ Object 



102
103
104
 
# File 'lib/ls4/service/mds_tt.rb', line 102

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

#remove(key, &cb) ⇒ Object

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



172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
 
# File 'lib/ls4/service/mds_tt.rb', line 172

def remove(key, &cb)
	map = get_impl_head(key, COLS_REQUIRED)
	if map && !is_removed(map)
		okey = to_okey(map)

		# optional: inherit rsid
		rsid = map[COL_RSID].to_i

		# get current vtime later than old vtime
		vtime = get_current_vtime(map[COL_VTIME].to_i)

		remove_okey = new_okey(key, vtime, rsid)

		# insert
		pk = new_pk(map[COL_PK])
		map = to_map({}, remove_okey, nil, true)
		@hadb.write(key) {|rdb| rdb.put(pk, map) }

		cb.call(okey, nil) rescue nil

	else
		cb.call(nil, nil) rescue nil
	end

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

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



154
155
156
157
158
159
160
161
 
# File 'lib/ls4/service/mds_tt.rb', line 154

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

#util_locate(key, &cb) ⇒ Object 



217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
 
# File 'lib/ls4/service/mds_tt.rb', line 217

def util_locate(key, &cb)
	array = @hadb.read(key) {|rdb|
		qry = QRY.new(rdb)
		qry.addcond(COL_KEY, QRY::QCSTREQ, key)
		qry.searchget(COLS_RESERVED)
	}

	array.reject! {|map|
		!is_valid_map(map) || is_removed(map)
	}

	array.map! {|map|
		[to_okey(map), map[COL_VNAME]]
	}

	cb.call(array, nil) rescue nil

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