Class: LS4::DirectoryStorageService

Inherits:
StorageService show all
Defined in:
lib/ls4/service/storage_dir.rb

Class Method Summary collapse

Instance Method Summary collapse

Methods inherited from Service

init

Methods included from EventBus::SingletonMixin

#ebus_bind!, #ebus_connect, extended

Methods included from EventBus::BusMixin

#ebus_all_slots, #ebus_disconnect!

Methods included from EventBus::DeclarerBase::Methods

#connect, #ebus_all_slots, #ebus_call_log, #ebus_call_slots, #ebus_signal_error, #ebus_signal_log, #ebus_signal_slots

Methods included from EventBus::DeclarerBase

#call_slot, #signal_slot

Class Method Details

.encode_okey(okey) ⇒ Object

for DataServerURLService



168
169
170
171
 
# File 'lib/ls4/service/storage_dir.rb', line 168

def self.encode_okey(okey)
  subpath = key_to_subpath(okey.vtime, okey.key)
  File.join(*subpath)
end

.key_to_subpath(vtime, key) ⇒ Object 



178
179
180
181
182
183
184
 
# File 'lib/ls4/service/storage_dir.rb', line 178

def self.key_to_subpath(vtime, key)
  digest = Digest::MD5.digest(key)
  box = "%03d" % digest.unpack('C')[0]
  kdir = encode_path(key)
  fname = "v#{vtime}"
  return box, kdir, fname
end

Instance Method Details

#close ⇒ Object 



30
31
 
# File 'lib/ls4/service/storage_dir.rb', line 30

def close
end

#delete(vtime, key) ⇒ Object

def resize(vtime, key, size) $log.trace { “DirectoryStorage: resize vtime=#vtime key=#LS4::DirectoryStorageService.keykey.dump size=#size” }

path = key_to_path(vtime, key) make_dir(path)

File.open(path, File::WRONLY|File::CREAT) {|f| f.truncate(size) }

true end



132
133
134
135
136
137
138
139
140
141
142
143
 
# File 'lib/ls4/service/storage_dir.rb', line 132

def delete(vtime, key)
  $log.trace { "DirectoryStorage: delete vtime=#{vtime} key=#{key.dump}" }

  path = key_to_path(vtime, key)
  begin
    File.unlink(path)
    Dir.rmdir(File.dirname(path)) rescue nil
    return true
  rescue
    return false
  end
end

#exist(vtime, key) ⇒ Object 



145
146
147
148
149
150
 
# File 'lib/ls4/service/storage_dir.rb', line 145

def exist(vtime, key)
  $log.trace { "DirectoryStorage: exist vtime=#{vtime} key=#{key.dump}" }

  path = key_to_path(vtime, key)
  return File.exist?(path)
end

#get(vtime, key) ⇒ Object 



33
34
35
 
# File 'lib/ls4/service/storage_dir.rb', line 33

def get(vtime, key)
  read(vtime, key, nil, nil)
end

#get_items ⇒ Object 



152
153
154
155
156
157
158
159
160
161
162
163
164
165
 
# File 'lib/ls4/service/storage_dir.rb', line 152

def get_items
  num = 0
  (0..0xff).each {|d|
    box = "%03d" % d
    dirpath = File.join(@dir, "data", box)
    begin
      e = Dir.entries(dirpath).size
      e -= 2  # skip "." and ".."
      num += e if e > 0
    rescue
    end
  }
  num
end

#key_to_path(vtime, key) ⇒ Object 



173
174
175
176
 
# File 'lib/ls4/service/storage_dir.rb', line 173

def key_to_path(vtime, key)
  subpath = self.class.key_to_subpath(vtime, key)
  File.join(@dir, "data", *subpath)
end

#open(expr) ⇒ Object 



26
27
28
 
# File 'lib/ls4/service/storage_dir.rb', line 26

def open(expr)
  @dir = File.expand_path(expr)
end

#read(vtime, key, offset, size) ⇒ Object 



37
38
39
40
41
42
43
44
45
46
 
# File 'lib/ls4/service/storage_dir.rb', line 37

def read(vtime, key, offset, size)
  $log.trace { "DirectoryStorage: read vtime=#{vtime} key=#{key.dump} offset=#{offset} size=#{size}" }

  path = key_to_path(vtime, key)
  begin
    return File.read(path, size, offset)
  rescue
    return nil
  end
end

#set(vtime, key, data) ⇒ Object 



48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
 
# File 'lib/ls4/service/storage_dir.rb', line 48

def set(vtime, key, data)
  $log.trace { "DirectoryStorage: set vtime=#{vtime} key=#{key.dump} data=#{data.size}byte)" }

  path = key_to_path(vtime, key)
  make_dir(path)

  tmp_path = path+".tmp"
  File.open(tmp_path, File::WRONLY|File::CREAT|File::TRUNC) {|f|
    #f.write(data)
    while true
      n = f.syswrite(data)
      if data.size <= n
        break
      else
        data = data[n..-1]
        #data.slice!(0,n-1)
      end
    end
  }
  File.rename(tmp_path, path)

  true
end