class Concurrent::Transaction

def read(tvar)
  Concurrent::abort_transaction unless valid?
  if @write_log.has_key? tvar
    @write_log[tvar]
  else
    @read_log.push(ReadLogEntry.new(tvar, tvar.unsafe_version))
    tvar.unsafe_value
  end
end