From: Eric Wong <e@80x24.org>
To: yahns-public@yhbt.net
Subject: [PATCH 2/5] extras/exec_cgi: remove kgio dependency
Date: Wed, 26 Dec 2018 19:57:13 +0000 [thread overview]
Message-ID: <20181226195716.31202-3-e@80x24.org> (raw)
In-Reply-To: <20181226195716.31202-1-e@80x24.org>
We don't need non-blocking I/O at all in this module and it's
not coupled with the rest of yahns at all.
---
| 46 ++++++++++++++++++++++++++++++----------------
1 file changed, 30 insertions(+), 16 deletions(-)
--git a/extras/exec_cgi.rb b/extras/exec_cgi.rb
index b546e1f..7fb5138 100644
--- a/extras/exec_cgi.rb
+++ b/extras/exec_cgi.rb
@@ -21,18 +21,29 @@
# run ExecCgi.new('/path/to/cgit.cgi') # cgit: https://git.zx2c4.com/cgit/
#
class ExecCgi
- class MyIO < Kgio::Pipe
+ class MyIO
attr_writer :my_pid
attr_writer :body_tip
+ attr_reader :rd
+
+ def initialize(rd)
+ @rd = rd
+ end
def each
buf = @body_tip || ''.dup
if buf.size > 0
yield buf
end
- while tmp = kgio_read(8192, buf)
+
+ case tmp = @rd.read_nonblock(8192, buf, exception: false)
+ when :wait_readable
+ @rd.wait_readable
+ when nil
+ break
+ else # String
yield tmp
- end
+ end while true
self
ensure
# do this sooner, since the response body may be buffered, we want
@@ -46,8 +57,8 @@ def close
# Note: this object (and any client-specific objects) will never
# be shared across different threads, so we do not need extra
# mutual exclusion here.
- return if closed?
- super
+ return if @rd.closed?
+ @rd.close
begin
Process.waitpid(@my_pid)
rescue Errno::ECHILD
@@ -90,20 +101,23 @@ def call(env)
cgi_env = { "GATEWAY_INTERFACE" => "CGI/1.1" }
PASS_VARS.each { |key| val = env[key] and cgi_env[key] = val }
env.each { |key,val| cgi_env[key] = val if key =~ /\AHTTP_/ }
- pipe = MyIO.pipe
- errbody = pipe[0]
- errbody.my_pid = Process.spawn(cgi_env.merge!(@env), *@args,
- out: pipe[1], close_others: true)
- pipe[1].close
- pipe = pipe[0]
- if head = pipe.kgio_read(8192)
+ rd, wr = IO.pipe
+ io = MyIO.new(rd)
+ errbody = io
+ errbody.my_pid = spawn(cgi_env.merge!(@env), *@args,
+ out: wr, close_others: true)
+ wr.close
+
+ begin
+ head = rd.readpartial(8192)
until head =~ /\r?\n\r?\n/
- tmp = pipe.kgio_read(8192) or break
+ tmp = rd.readpartial(8192)
head << tmp
+ tmp.clear
end
head, body = head.split(/\r?\n\r?\n/, 2)
- pipe.body_tip = body
+ io.body_tip = body
env["HTTP_VERSION"] ||= "HTTP/1.0" # stop Rack::Chunked for HTTP/0.9
@@ -117,8 +131,8 @@ def call(env)
end
status = headers.delete("Status") || 200
errbody = nil
- [ status, headers, pipe ]
- else
+ [ status, headers, io ]
+ rescue EOFError
[ 500, { "Content-Length" => "0", "Content-Type" => "text/plain" }, [] ]
end
ensure
--
EW
next prev parent reply other threads:[~2018-12-26 19:57 UTC|newest]
Thread overview: 7+ messages / expand[flat|nested] mbox.gz Atom feed top
2018-12-26 19:57 [PATCH 0/5] exec_cgi: various cleanups and fixes Eric Wong
2018-12-26 19:57 ` [PATCH 1/5] test/test_extras_exec_cgi.rb: improve test reliability Eric Wong
2018-12-26 19:57 ` Eric Wong [this message]
2018-12-26 19:57 ` [PATCH 3/5] extras/exec_cgi: update copyright year and use SPDX Eric Wong
2018-12-26 19:57 ` [PATCH 4/5] extras/exec_cgi: @body_tip is always set Eric Wong
2018-12-26 19:57 ` [PATCH 5/5] extras/exec_cgi: support Process.spawn options (e.g. RLIMIT_*) Eric Wong
2018-12-28 7:39 ` Eric Wong
Reply instructions:
You may reply publicly to this message via plain-text email
using any one of the following methods:
* Save the following mbox file, import it into your mail client,
and reply-to-all from there: mbox
Avoid top-posting and favor interleaved quoting:
https://en.wikipedia.org/wiki/Posting_style#Interleaved_style
List information: https://yhbt.net/yahns/README
* Reply using the --to, --cc, and --in-reply-to
switches of git-send-email(1):
git send-email \
--in-reply-to=20181226195716.31202-3-e@80x24.org \
--to=e@80x24.org \
--cc=yahns-public@yhbt.net \
/path/to/YOUR_REPLY
https://kernel.org/pub/software/scm/git/docs/git-send-email.html
* If your mail client supports setting the In-Reply-To header
via mailto: links, try the mailto: link
Be sure your reply has a Subject: header at the top and a blank line
before the message body.
Code repositories for project(s) associated with this public inbox
https://yhbt.net/yahns.git/
This is a public inbox, see mirroring instructions
for how to clone and mirror all data and code used for this inbox;
as well as URLs for read-only IMAP folder(s) and NNTP newsgroup(s).