Class: LS4::FileUpdateLog::LogFile

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

Instance Method Summary collapse

Constructor Details

#initialize(path, atime) ⇒ LogFile

Returns a new instance of LogFile.



184
185
186
187
188
189
190
191
192
 
# File 'lib/ls4/service/ulog_file.rb', line 184

def initialize(path, atime)
  @path = path
  @file = File.open(@path, File::RDWR|File::CREAT)
  if @file.stat.size == 0
    init_file(atime)
  else
    read_file
  end
end

Instance Method Details

#append(atime, data, &block) ⇒ Object 



198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
 
# File 'lib/ls4/service/ulog_file.rb', line 198

def append(atime, data, &block)
  reltime = atime - @atime
  if reltime <= @last_reltime
    reltime = @last_reltime+1
  end
  @last_reltime = reltime

  pos = get_offset

  r = Record.new(reltime, data)
  ref = RecordRef.new(reltime, pos)

  @file.pos = pos
  r.write(@file)
  noffset = @file.pos

  block.call

  @index << ref
  set_offset(noffset)

  reltime + @atime
end

#close ⇒ Object 



194
195
196
 
# File 'lib/ls4/service/ulog_file.rb', line 194

def close
  @file.close
end

#get(time) ⇒ Object 



222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
 
# File 'lib/ls4/service/ulog_file.rb', line 222

def get(time)
  reltime = time - @atime

  while true
    # FIXME binary search
    ref = @index.find {|ref|
      ref.reltime > reltime
    }

    unless ref
      break
    end

    r = ref.read_body(@file)

    return r.data, r.reltime + @atime
  end

  return nil, reltime + @atime
end