From 9424b13255a238dfa44952ebeb07bea3acee999c Mon Sep 17 00:00:00 2001
From: Eric Wong <normalperson@yhbt.net>
Date: Wed, 19 Jan 2011 15:06:10 -0800
Subject: initial edge-triggered epoll model

Coolio and EventMachine only use level-triggered epoll,
but being Rainbows!, we live on the EDGE!
---
 lib/rainbows/epoll/response_pipe.rb | 38 +++++++++++++++++++++++++++++++++++++
 1 file changed, 38 insertions(+)
 create mode 100644 lib/rainbows/epoll/response_pipe.rb

(limited to 'lib/rainbows/epoll/response_pipe.rb')

diff --git a/lib/rainbows/epoll/response_pipe.rb b/lib/rainbows/epoll/response_pipe.rb
new file mode 100644
index 0000000..ce240f5
--- /dev/null
+++ b/lib/rainbows/epoll/response_pipe.rb
@@ -0,0 +1,38 @@
+# -*- encoding: binary -*-
+# :enddoc:
+#
+class Rainbows::Epoll::ResponsePipe
+  include Rainbows::Epoll::State
+  attr_reader :io
+  alias to_io io
+  IN = SleepyPenguin::Epoll::IN | SleepyPenguin::Epoll::ET
+  RBUF = Rainbows::EvCore::RBUF
+
+  def initialize(io, client, body)
+    @io, @client, @body = io, client, body
+    @epoll_active = false
+  end
+
+  def epoll_run
+    return close if @client.closed?
+    @client.stream_pipe(self) or @client.on_deferred_write_complete
+    rescue => e
+      close
+      @client.handle_error(e)
+  end
+
+  def close
+    epoll_disable
+    @body.respond_to?(:close) and @body.close
+    @io = @body = nil
+  end
+
+  def tryread
+    io = @io
+    io.respond_to?(:kgio_tryread) and return io.kgio_tryread(16384, RBUF)
+    io.read_nonblock(16384, RBUF)
+    rescue Errno::EAGAIN
+      :wait_readable
+    rescue EOFError
+  end
+end
-- 
cgit v1.2.3-24-ge0c7