Class: Fairy::InputLocalFile::SplittedFile

Inherits:
Object
  • Object
show all
Includes:
Enumerable
Defined in:
lib/fairy/client/input-local-file.rb

Overview

def split_opens(split_size, &block)

begin

seek = 0 size = File.stat(@filename).size while seek < size io = SplittedFile.open(@filename, seek, seek + split_size) seek = io.seek_end + 1 yield io end

rescue

Log::warn_exception(self) raise

  end
end

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(fd, seek_start, seek_end) ⇒ SplittedFile

Returns a new instance of SplittedFile.



137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
 
# File 'lib/fairy/client/input-local-file.rb', line 137

def initialize(fd, seek_start, seek_end)
	@io = File.open(fd)
	@seek_start = seek_start

	@io.seek(seek_end)
	c = @io.read(1)
	case c
	when nil, "\n"
	  @seek_end = seek_end
	else
	  @io.gets
	  @seek_end = @io.pos - 1
	end
	@io.seek(seek_start)
end

Instance Attribute Details

#seek_end ⇒ Object (readonly)

Returns the value of attribute seek_end.



154
155
156
 
# File 'lib/fairy/client/input-local-file.rb', line 154

def seek_end
  @seek_end
end

#seek_start ⇒ Object (readonly)

Returns the value of attribute seek_start.



153
154
155
 
# File 'lib/fairy/client/input-local-file.rb', line 153

def seek_start
  @seek_start
end

Class Method Details

.open(fd, seek_start, seek_end, &block) ⇒ Object 



124
125
126
127
128
129
130
131
132
133
134
135
 
# File 'lib/fairy/client/input-local-file.rb', line 124

def self.open(fd, seek_start, seek_end, &block)
	sf = new(fd, seek_start, seek_end)
	if block_given?
	  begin
	    yield sf
	  ensure
	    sf.close
	  end
	else
	  sf
	end
end

Instance Method Details

#close ⇒ Object 



160
161
162
163
 
# File 'lib/fairy/client/input-local-file.rb', line 160

def close
	@io.close
	@io = nil
end

#each(&block) ⇒ Object 



165
166
167
168
169
170
171
172
173
174
 
# File 'lib/fairy/client/input-local-file.rb', line 165

def each(&block)
	begin
	  while @io.pos < @seek_end && l = @io.gets
	    yield l
	  end
	rescue
	  Log::warn_exception(self)
	  raise
	end
end

#external_encoding ⇒ Object 



156
157
158
 
# File 'lib/fairy/client/input-local-file.rb', line 156

def external_encoding
	@io.external_encoding
end

#read(length) ⇒ Object 



176
177
178
179
180
181
182
183
184
185
 
# File 'lib/fairy/client/input-local-file.rb', line 176

def read(length)
	if @seek_end - @io.pos + 1 < length
	  length = @seek_end - @io.pos + 1
	end
	if length == 0
	  nil
	else
	  @io.read(length)
	end
end