Module: Memcache::Segmented
- Included in:
- SegmentedNativeServer, SegmentedServer
- Defined in:
- lib/memcache/segmented.rb
Constant Summary collapse
- MAX_SIZE =
bytes
1000000
- PARTIAL_VALUE =
0x40000000
Instance Method Summary collapse
- #add(key, value, expiry = 0, flags = 0) ⇒ Object
- #cas(key, value, cas, expiry = 0, flags = 0) ⇒ Object
- #delete(key) ⇒ Object
- #get(keys, cas = nil) ⇒ Object
- #replace(key, value, expiry = 0, flags = 0) ⇒ Object
- #set(key, value, expiry = 0, flags = 0) ⇒ Object
Instance Method Details
#add(key, value, expiry = 0, flags = 0) ⇒ Object
53 54 55 56 |
# File 'lib/memcache/segmented.rb', line 53 def add(key, value, expiry = 0, flags = 0) hash, flags = store_segments(key, value, expiry, flags) super(key, hash, expiry, flags) && value end |
#cas(key, value, cas, expiry = 0, flags = 0) ⇒ Object
46 47 48 49 50 51 |
# File 'lib/memcache/segmented.rb', line 46 def cas(key, value, cas, expiry = 0, flags = 0) delete(key) do hash, flags = store_segments(key, value, expiry, flags) super(key, hash, cas, expiry, flags) && value end end |
#delete(key) ⇒ Object
65 66 67 68 69 70 71 72 |
# File 'lib/memcache/segmented.rb', line 65 def delete(key) result = super_get(key) enable = block_given? ? yield : super if enable and result and segmented?(result) segment_keys(result).each {|k| super(k)} end enable end |
#get(keys, cas = nil) ⇒ Object
8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 |
# File 'lib/memcache/segmented.rb', line 8 def get(keys, cas = nil) return get([keys], cas)[keys.to_s] unless keys.kind_of?(Array) return {} if keys.empty? results = super(keys, cas) keys = {} keys_to_fetch = [] results.each do |key, result| next unless segmented?(result) keys[key] = segment_keys(result) keys_to_fetch.concat keys[key] end parts = super(keys_to_fetch) keys.each do |key, hashes| value = '' hashes.each do |hash_key| if part = parts[hash_key][:value] value << part else value = nil break end end results[key][:value] = value results[key][:flags] ^= PARTIAL_VALUE end results end |
#replace(key, value, expiry = 0, flags = 0) ⇒ Object
58 59 60 61 62 63 |
# File 'lib/memcache/segmented.rb', line 58 def replace(key, value, expiry = 0, flags = 0) delete(key) do hash, flags = store_segments(key, value, expiry, flags) super(key, hash, expiry, flags) && value end end |
#set(key, value, expiry = 0, flags = 0) ⇒ Object
39 40 41 42 43 44 |
# File 'lib/memcache/segmented.rb', line 39 def set(key, value, expiry = 0, flags = 0) delete(key) do hash, flags = store_segments(key, value, expiry, flags) super(key, hash, expiry, flags) && value end end |