yahns Ruby server user/dev discussion
 help / color / Atom feed
577b4dc65f305493695c3a9d252cd80815c534fb blob 3379 bytes (raw)

  1
  2
  3
  4
  5
  6
  7
  8
  9
 10
 11
 12
 13
 14
 15
 16
 17
 18
 19
 20
 21
 22
 23
 24
 25
 26
 27
 28
 29
 30
 31
 32
 33
 34
 35
 36
 37
 38
 39
 40
 41
 42
 43
 44
 45
 46
 47
 48
 49
 50
 51
 52
 53
 54
 55
 56
 57
 58
 59
 60
 61
 62
 63
 64
 65
 66
 67
 68
 69
 70
 71
 72
 73
 74
 75
 76
 77
 78
 79
 80
 81
 82
 83
 84
 85
 86
 87
 88
 89
 90
 91
 92
 93
 94
 95
 96
 97
 98
 99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
 
# -*- encoding: binary -*-
# Copyright (C) 2016 all contributors <yahns-public@yhbt.net>
# License: GPL-3.0+ <https://www.gnu.org/licenses/gpl-3.0.txt>
# frozen_string_literal: true
require 'stringio'
require_relative 'wbuf_common'

# This is only used for "proxy_buffering: false"
class Yahns::WbufLite # :nodoc:
  include Yahns::WbufCommon
  attr_reader :busy
  attr_writer :req_res

  def initialize(req_res)
    @tmpio = nil
    @sf_offset = @sf_count = 0
    @wbuf_persist = :ignore
    @busy = false
    @req_res = req_res
  end

  def wbuf_write(c, buf)
    buf = buf.join if Array === buf
    # try to bypass the VFS layer and write directly to the socket
    # if we're all caught up
    case rv = c.kgio_trywrite(buf)
    when String
      buf = rv # retry in loop
    when nil
      return # yay! hopefully we don't have to buffer again
    when :wait_writable, :wait_readable
      @busy = rv
    end until @busy

    @tmpio ||= StringIO.new(''.dup) # relies on encoding: binary above
    @tmpio.seek(0, 2) # fake O_APPEND behavior
    @sf_count += @tmpio.write(buf)

    # we spent some time copying to the FS, try to write to
    # the socket again in case some space opened up...
    case rv = c.trysendio(@tmpio, @sf_offset, @sf_count)
    when Integer
      @sf_count -= rv
      @sf_offset += rv
    when :wait_writable, :wait_readable
      @busy = rv
      return rv
    else
      raise "BUG: #{rv.nil? ? 'EOF' : rv.inspect} on "
            "tmpio.size=#{@tmpio.size} " \
            "sf_offset=#@sf_offset sf_count=#@sf_count"
    end while @sf_count > 0

    # we're all caught up, try to save some memory if we can help it.
    wbuf_abort
    @sf_offset = 0
    @busy = false
    nil
  rescue
    @req_res = @req_res.close if @req_res
    raise
  end

  def wbuf_flush(client)
    case rv = client.trysendio(@tmpio, @sf_offset, @sf_count)
    when Integer
      return wbuf_close(client) if (@sf_count -= rv) == 0 # all sent!
      @sf_offset += rv # keep going otherwise
    when :wait_writable, :wait_readable
      return rv
    else
      raise "BUG: #{rv.nil? ? 'EOF' : rv.inspect} on "
            "tmpio.size=#{@tmpio.size} " \
            "sf_offset=#@sf_offset sf_count=#@sf_count"
    end while @sf_count > 0
    wbuf_close(client)
  rescue
    @wbuf_persist = false # ensure a hijack response is not called
    @req_res = @req_res.close if @req_res
    wbuf_close(client)
    raise
  end

  # called by Yahns::HttpClient#step_write
  def wbuf_close(client)
    wbuf_abort

    # resume the event loop when @blocked is empty
    # The actual Yahns::ReqRes#yahns_step is actually read/write-event
    # agnostic, and we should actually watch for writability here since
    # the req_res socket itself could be completely drained of readable
    # data and just waiting for another request (which we don't support, yet)
    if @req_res
      client.hijack_cleanup
      Thread.current[:yahns_queue].queue_mod(@req_res, Yahns::Queue::QEV_WR)
      return :ignore
    end
    @wbuf_persist
  rescue
    @req_res = @req_res.close if @req_res
    raise
  end

  def wbuf_abort
    # we can safely truncate since this is a StringIO, we cannot do this
    # with a real file because zero-copy with sendfile means truncating
    # a while could clobber in-flight data
    if @tmpio
      @tmpio.truncate(0)
      @tmpio = @tmpio.close
    end
  end
end
debug log:

solving 577b4dc ...
found 577b4dc in https://yhbt.net/yahns.git

yahns Ruby server user/dev discussion

Archives are clonable:
	git clone --mirror https://yhbt.net/yahns-public
	git clone --mirror http://ou63pmih66umazou.onion/yahns-public

Example config snippet for mirrors

Newsgroups are available over NNTP:
	nntp://news.public-inbox.org/inbox.comp.lang.ruby.yahns
	nntp://ou63pmih66umazou.onion/inbox.comp.lang.ruby.yahns

 note: .onion URLs require Tor: https://www.torproject.org/

AGPL code for this site: git clone https://public-inbox.org/public-inbox.git