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



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

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



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

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.



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

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



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

def bytes_read
  @read
end

#check_closed ⇒ Object

:nodoc:

Raises:

  • (IOError) 


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

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

#close ⇒ Object

Closes the tar entry



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

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) 


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

def closed?
  @closed
end

#directory? ⇒ Boolean

Is this tar entry a directory?

Returns:

  • (Boolean) 


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

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

#eof? ⇒ Boolean

Are we at the end of the tar entry?

Returns:

  • (Boolean) 


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

def eof?
  check_closed

  @read >= @header.size
end

#file? ⇒ Boolean

Is this tar entry a file?

Returns:

  • (Boolean) 


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

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

#full_name ⇒ Object

Full name of the tar entry



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

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



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

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



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

def pos
  check_closed

  bytes_read
end

#pos=(new_pos) ⇒ Object

Seek to the position in the tar entry



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

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



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

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) 


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

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



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

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



194
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
 
# File 'lib/rubygems/package/tar_reader/entry.rb', line 194

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 



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

def size
  @header.size
end

#symlink? ⇒ Boolean

Is this tar entry a symlink?

Returns:

  • (Boolean) 


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

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