Class: Gem::Package::TarReader::Entry

Inherits:
Object
  • Object
show all
Defined in:
lib/rubygems/package/tar_reader/entry.rb

Overview

Class for reading entries out of a tar file

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(header, io) ⇒ Entry

Creates a new tar entry for header that will be read from io



34
35
36
37
38
39
40
41
 
# File 'lib/rubygems/package/tar_reader/entry.rb', line 34

def initialize(header, io)
  @closed = false
  @header = header
  @io = io
  @orig_pos = @io.pos
  @end_pos = @orig_pos + @header.size
  @read = 0
end

Instance Attribute Details

#header ⇒ Object (readonly)

Header for this tar entry



29
30
31
 
# File 'lib/rubygems/package/tar_reader/entry.rb', line 29

def header
  @header
end

Class Method Details

.open(header, io, &block) ⇒ Object

Creates a new tar entry for header that will be read from io If a block is given, the entry is yielded and then closed.



16
17
18
19
20
21
22
23
24
 
# File 'lib/rubygems/package/tar_reader/entry.rb', line 16

def self.open(header, io, &block)
  entry = new header, io
  return entry unless block_given?
  begin
    yield entry
  ensure
    entry.close
  end
end

Instance Method Details

#bytes_read ⇒ Object

Number of bytes read out of the tar entry



50
51
52
 
# File 'lib/rubygems/package/tar_reader/entry.rb', line 50

def bytes_read
  @read
end

#check_closed ⇒ Object

:nodoc:

Raises:

  • (IOError) 


43
44
45
 
# File 'lib/rubygems/package/tar_reader/entry.rb', line 43

def check_closed # :nodoc:
  raise IOError, "closed #{self.class}" if closed?
end

#close ⇒ Object

Closes the tar entry



57
58
59
60
61
62
63
64
65
66
 
# File 'lib/rubygems/package/tar_reader/entry.rb', line 57

def close
  return if closed?
  # Seek to the end of the entry if it wasn't fully read
  seek(0, IO::SEEK_END)
  # discard trailing zeros
  skip = (512 - (@header.size % 512)) % 512
  @io.read(skip)
  @closed = true
  nil
end

#closed? ⇒ Boolean

Is the tar entry closed?

Returns:

  • (Boolean) 


71
72
73
 
# File 'lib/rubygems/package/tar_reader/entry.rb', line 71

def closed?
  @closed
end

#directory? ⇒ Boolean

Is this tar entry a directory?

Returns:

  • (Boolean) 


116
117
118
 
# File 'lib/rubygems/package/tar_reader/entry.rb', line 116

def directory?
  @header.typeflag == "5"
end

#eof? ⇒ Boolean

Are we at the end of the tar entry?

Returns:

  • (Boolean) 


78
79
80
81
82
 
# File 'lib/rubygems/package/tar_reader/entry.rb', line 78

def eof?
  check_closed

  @read >= @header.size
end

#file? ⇒ Boolean

Is this tar entry a file?

Returns:

  • (Boolean) 


123
124
125
 
# File 'lib/rubygems/package/tar_reader/entry.rb', line 123

def file?
  @header.typeflag == "0"
end

#full_name ⇒ Object

Full name of the tar entry



87
88
89
90
91
92
93
94
95
96
97
 
# File 'lib/rubygems/package/tar_reader/entry.rb', line 87

def full_name
  if @header.prefix != ""
    File.join @header.prefix, @header.name
  else
    @header.name
  end
rescue ArgumentError => e
  raise unless e.message == "string contains null byte"
  raise Gem::Package::TarInvalidError,
        "tar is corrupt, name contains null byte"
end

#getc ⇒ Object

Read one byte from the tar entry



102
103
104
105
106
107
108
109
110
111
 
# File 'lib/rubygems/package/tar_reader/entry.rb', line 102

def getc
  check_closed

  return nil if @read >= @header.size

  ret = @io.getc
  @read += 1 if ret

  ret
end

#pos ⇒ Object

The position in the tar entry



137
138
139
140
141
 
# File 'lib/rubygems/package/tar_reader/entry.rb', line 137

def pos
  check_closed

  bytes_read
end

#pos=(new_pos) ⇒ Object

Seek to the position in the tar entry



146
147
148
149
 
# File 'lib/rubygems/package/tar_reader/entry.rb', line 146

def pos=(new_pos)
  seek(new_pos, IO::SEEK_SET)
  new_pos
end

#read(len = nil) ⇒ Object

Reads len bytes from the tar file entry, or the rest of the entry if nil



161
162
163
164
165
166
167
168
169
170
171
172
173
174
 
# File 'lib/rubygems/package/tar_reader/entry.rb', line 161

def read(len = nil)
  check_closed

  len ||= @header.size - @read

  return nil if len > 0 && @read >= @header.size

  max_read = [len, @header.size - @read].min

  ret = @io.read max_read
  @read += ret.size

  ret
end

#readpartial(maxlen = nil, outbuf = "".b) ⇒ Object

Raises:

  • (EOFError) 


176
177
178
179
180
181
182
183
184
185
186
187
188
189
 
# File 'lib/rubygems/package/tar_reader/entry.rb', line 176

def readpartial(maxlen = nil, outbuf = "".b)
  check_closed

  maxlen ||= @header.size - @read

  raise EOFError if maxlen > 0 && @read >= @header.size

  max_read = [maxlen, @header.size - @read].min

  @io.readpartial(max_read, outbuf)
  @read += outbuf.size

  outbuf
end

#rewind ⇒ Object

Rewinds to the beginning of the tar file entry



245
246
247
248
 
# File 'lib/rubygems/package/tar_reader/entry.rb', line 245

def rewind
  check_closed
  seek(0, IO::SEEK_SET)
end

#seek(offset, whence = IO::SEEK_SET) ⇒ Object

Seeks to offset bytes into the tar file entry whence can be IO::SEEK_SET, IO::SEEK_CUR, or IO::SEEK_END



195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
 
# File 'lib/rubygems/package/tar_reader/entry.rb', line 195

def seek(offset, whence = IO::SEEK_SET)
  check_closed

  new_pos =
    case whence
    when IO::SEEK_SET then @orig_pos + offset
    when IO::SEEK_CUR then @io.pos + offset
    when IO::SEEK_END then @end_pos + offset
    else
      raise ArgumentError, "invalid whence"
    end

  if new_pos < @orig_pos
    new_pos = @orig_pos
  elsif new_pos > @end_pos
    new_pos = @end_pos
  end

  pending = new_pos - @io.pos

  if @io.respond_to?(:seek)
    begin
      # avoid reading if the @io supports seeking
      @io.seek new_pos, IO::SEEK_SET
      pending = 0
    rescue Errno::EINVAL
    end
  end

  # if seeking isn't supported or failed
  # negative seek requires that we rewind and read
  if pending < 0
    @io.rewind
    pending = new_pos
  end

  while pending > 0 do
    size_read = @io.read([pending, 4096].min).size
    raise UnexpectedEOF if @io.eof?
    pending -= size_read
  end

  @read = @io.pos - @orig_pos

  0
end

#size ⇒ Object Also known as: length 



151
152
153
 
# File 'lib/rubygems/package/tar_reader/entry.rb', line 151

def size
  @header.size
end

#symlink? ⇒ Boolean

Is this tar entry a symlink?

Returns:

  • (Boolean) 


130
131
132
 
# File 'lib/rubygems/package/tar_reader/entry.rb', line 130

def symlink?
  @header.typeflag == "2"
end