Add required offset parameter.

Author: ioquatix

test/io/event/selector.rb

@@ -478,7 +478,7 @@ def transfer
 
 			fiber = Fiber.new do
 				events << :io_read
-				offset = selector.io_read(Fiber.current, local, buffer, message.bytesize)
+				offset = selector.io_read(Fiber.current, local, buffer, message.bytesize, 0)
 				expect(buffer.get_string(0, offset)).to be == message
 			end
 
@@ -499,7 +499,7 @@ def transfer
 
 			fiber = Fiber.new do
 				events << :io_read
-				offset = selector.io_read(Fiber.current, local, buffer, message.bytesize)
+				offset = selector.io_read(Fiber.current, local, buffer, message.bytesize, 0)
 				expect(buffer.get_string(0, offset)).to be == message
 			end
 
@@ -521,7 +521,7 @@ def transfer
 			return unless selector.respond_to?(:io_read)
 
 			fiber = Fiber.new do
-				offset = selector.io_read(Fiber.current, local, buffer, message.bytesize)
+				offset = selector.io_read(Fiber.current, local, buffer, message.bytesize, 0)
 				expect(buffer.get_string(0, offset)).to be == message
 				sleep(0.001)
 			end
@@ -559,7 +559,7 @@ def transfer
 			fiber = Fiber.new do
 				events << :io_write
 				buffer = IO::Buffer.for(message.dup)
-				result = selector.io_write(Fiber.current, local, buffer, buffer.size)
+				result = selector.io_write(Fiber.current, local, buffer, buffer.size, 0)
 				expect(result).to be == message.bytesize
 				local.close
 			end

test/io/event/selector/buffered_io.rb

@@ -21,12 +21,12 @@
 
 			writer = Fiber.new do
 				buffer = IO::Buffer.new(128)
-				expect(selector.io_write(Fiber.current, output, buffer, 128)).to be == 128
+				expect(selector.io_write(Fiber.current, output, buffer, 128, 0)).to be == 128
 			end
 
 			reader = Fiber.new do
 				buffer = IO::Buffer.new(64)
-				expect(selector.io_read(Fiber.current, input, buffer, 1)).to be == 64
+				expect(selector.io_read(Fiber.current, input, buffer, 1, 0)).to be == 64
 			end
 
 			reader.transfer
@@ -39,7 +39,7 @@
 			skip_if_ruby_platform(/mswin|mingw|cygwin/)
 
 			buffer = IO::Buffer.new(1).slice(0, 0)
-			expect(selector.io_write(Fiber.current, output, buffer, 0)).to be == 0
+			expect(selector.io_write(Fiber.current, output, buffer, 0, 0)).to be == 0
 		end
 
 		it "can read and write at the specified offset" do
@@ -70,7 +70,7 @@
 
 			writer = Fiber.new do
 				buffer = IO::Buffer.new(64)
-				result = selector.io_write(Fiber.current, input, buffer, 64)
+				result = selector.io_write(Fiber.current, input, buffer, 64, 0)
 				expect(result).to be < 0
 			end
 
@@ -88,7 +88,7 @@
 			output.close
 
 			reader = Fiber.new do
-				result = selector.io_read(Fiber.current, input, buffer, 0)
+				result = selector.io_read(Fiber.current, input, buffer, 0, 0)
 			end
 
 			reader.transfer
@@ -109,7 +109,7 @@ def be_again?
 			result = nil
 
 			reader = Fiber.new do
-				result = selector.io_read(Fiber.current, input, buffer, 0)
+				result = selector.io_read(Fiber.current, input, buffer, 0, 0)
 			end
 
 			reader.transfer

test/io/event/selector/cancellable.rb

@@ -25,7 +25,7 @@
 				buffer = IO::Buffer.new(64)
 
 				10.times do
-					expect{selector.io_read(Fiber.current, input, buffer, 1)}.to raise_exception(Interrupt)
+					expect{selector.io_read(Fiber.current, input, buffer, 1, 0)}.to raise_exception(Interrupt)
 				end
 			end
 
@@ -44,7 +44,7 @@
 
 				10.times do
 					expect{selector.io_wait(Fiber.current, input, IO::READABLE)}.to raise_exception(Interrupt)
-					selector.io_read(Fiber.current, input, buffer, 1)
+					selector.io_read(Fiber.current, input, buffer, 1, 0)
 				end
 			end
 

test/io/event/selector/file_io.rb

@@ -20,15 +20,15 @@
 			writer = Fiber.new do
 				buffer = IO::Buffer.new(128)
 				file.seek(0)
-				write_result = selector.io_write(Fiber.current, file, buffer, 128)
+				write_result = selector.io_write(Fiber.current, file, buffer, 128, 0)
 			end
 
 			reader = Fiber.new do
 				buffer = IO::Buffer.new(64)
 				file.seek(0)
 
 				# The read will return 0 if the data is not written yet:
-				read_result = selector.io_read(Fiber.current, file, buffer, 0)
+				read_result = selector.io_read(Fiber.current, file, buffer, 0, 0)
 			end
 
 			writer.transfer

test/io/event/selector/write_deadlock.rb

@@ -37,7 +37,7 @@
 			# Writer fiber that should hit EAGAIN and wait for WRITABLE
 			writer = Fiber.new do
 				buffer = IO::Buffer.for("test" * 64)  # 256 bytes
-				@selector.io_write(Fiber.current, local, buffer, buffer.size)
+				@selector.io_write(Fiber.current, local, buffer, buffer.size, 0)
 				write_completed = true
 			end