Sha256: fb1d7c5b88abac701f0d3ffcc1bfc1330881f56cfb7d69bda1c7cb342162c03e
Contents?: true
Size: 1.3 KB
Versions: 7
Compression:
Stored size: 1.3 KB
Contents
# -*- encoding: binary -*-
# Copyright (C) 2013-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_relative 'wbuf_common'
class Yahns::StreamFile # :nodoc:
include Yahns::WbufCommon
# do not use this in your app (or any of our API)
NeedClose = Class.new(File) # :nodoc:
def initialize(body, persist, offset, count)
if body.respond_to?(:to_io)
@tmpio = body.to_io
else
path = body.to_path
if path =~ %r{\A/dev/fd/(\d+)\z}
@tmpio = IO.for_fd($1.to_i)
@tmpio.autoclose = false
else
retried = false
begin
@tmpio = NeedClose.open(path)
rescue Errno::EMFILE, Errno::ENFILE
raise if retried
retried = true
Thread.current[:yahns_fdmap].desperate_expire(5)
sleep(1)
retry
end
end
end
@sf_offset = offset
@sf_count = count || @tmpio.size
@wbuf_persist = persist # whether or not we keep the connection alive
@body = body
end
# called by last wbuf_flush,
# returns true / false for persistent/non-persistent connections,
# :ignore for hijacked connections
def wbuf_close(client)
@tmpio.close if NeedClose === @tmpio
wbuf_close_common(client)
end
end
Version data entries
7 entries across 7 versions & 1 rubygems