2018-01-07 06:10:00 +03:00
|
|
|
class << Thread
|
2010-03-29 16:48:43 +04:00
|
|
|
# call-seq:
|
|
|
|
# Thread.exclusive { block } => obj
|
2011-05-15 15:55:52 +04:00
|
|
|
#
|
2014-04-17 11:31:43 +04:00
|
|
|
# Wraps the block in a single, VM-global Mutex.synchronize, returning the
|
|
|
|
# value of the block. A thread executing inside the exclusive section will
|
|
|
|
# only block other threads which also use the Thread.exclusive mechanism.
|
2018-01-07 06:10:00 +03:00
|
|
|
def exclusive(&block) end if false
|
|
|
|
mutex = Mutex.new # :nodoc:
|
|
|
|
define_method(:exclusive) do |&block|
|
2016-08-30 09:22:30 +03:00
|
|
|
warn "Thread.exclusive is deprecated, use Thread::Mutex", caller
|
2018-01-07 06:10:00 +03:00
|
|
|
mutex.synchronize(&block)
|
2007-08-25 05:09:08 +04:00
|
|
|
end
|
|
|
|
end
|
2015-11-12 05:00:41 +03:00
|
|
|
|
|
|
|
class IO
|
|
|
|
|
|
|
|
# call-seq:
|
2015-12-07 17:08:44 +03:00
|
|
|
# ios.read_nonblock(maxlen [, options]) -> string
|
|
|
|
# ios.read_nonblock(maxlen, outbuf [, options]) -> outbuf
|
2015-11-12 05:00:41 +03:00
|
|
|
#
|
|
|
|
# Reads at most <i>maxlen</i> bytes from <em>ios</em> using
|
|
|
|
# the read(2) system call after O_NONBLOCK is set for
|
|
|
|
# the underlying file descriptor.
|
|
|
|
#
|
|
|
|
# If the optional <i>outbuf</i> argument is present,
|
|
|
|
# it must reference a String, which will receive the data.
|
|
|
|
# The <i>outbuf</i> will contain only the received data after the method call
|
|
|
|
# even if it is not empty at the beginning.
|
|
|
|
#
|
|
|
|
# read_nonblock just calls the read(2) system call.
|
|
|
|
# It causes all errors the read(2) system call causes: Errno::EWOULDBLOCK, Errno::EINTR, etc.
|
|
|
|
# The caller should care such errors.
|
|
|
|
#
|
|
|
|
# If the exception is Errno::EWOULDBLOCK or Errno::EAGAIN,
|
|
|
|
# it is extended by IO::WaitReadable.
|
|
|
|
# So IO::WaitReadable can be used to rescue the exceptions for retrying
|
|
|
|
# read_nonblock.
|
|
|
|
#
|
|
|
|
# read_nonblock causes EOFError on EOF.
|
|
|
|
#
|
|
|
|
# If the read byte buffer is not empty,
|
|
|
|
# read_nonblock reads from the buffer like readpartial.
|
|
|
|
# In this case, the read(2) system call is not called.
|
|
|
|
#
|
|
|
|
# When read_nonblock raises an exception kind of IO::WaitReadable,
|
|
|
|
# read_nonblock should not be called
|
|
|
|
# until io is readable for avoiding busy loop.
|
|
|
|
# This can be done as follows.
|
|
|
|
#
|
|
|
|
# # emulates blocking read (readpartial).
|
|
|
|
# begin
|
|
|
|
# result = io.read_nonblock(maxlen)
|
|
|
|
# rescue IO::WaitReadable
|
|
|
|
# IO.select([io])
|
|
|
|
# retry
|
|
|
|
# end
|
|
|
|
#
|
|
|
|
# Although IO#read_nonblock doesn't raise IO::WaitWritable.
|
|
|
|
# OpenSSL::Buffering#read_nonblock can raise IO::WaitWritable.
|
|
|
|
# If IO and SSL should be used polymorphically,
|
|
|
|
# IO::WaitWritable should be rescued too.
|
|
|
|
# See the document of OpenSSL::Buffering#read_nonblock for sample code.
|
|
|
|
#
|
|
|
|
# Note that this method is identical to readpartial
|
|
|
|
# except the non-blocking flag is set.
|
2015-12-07 17:08:44 +03:00
|
|
|
#
|
2017-02-23 05:00:28 +03:00
|
|
|
# By specifying a keyword argument _exception_ to +false+, you can indicate
|
2015-12-07 17:08:44 +03:00
|
|
|
# that read_nonblock should not raise an IO::WaitReadable exception, but
|
2017-02-23 05:11:16 +03:00
|
|
|
# return the symbol +:wait_readable+ instead. At EOF, it will return nil
|
|
|
|
# instead of raising EOFError.
|
2015-11-12 05:00:41 +03:00
|
|
|
def read_nonblock(len, buf = nil, exception: true)
|
|
|
|
__read_nonblock(len, buf, exception)
|
|
|
|
end
|
|
|
|
|
|
|
|
# call-seq:
|
|
|
|
# ios.write_nonblock(string) -> integer
|
|
|
|
# ios.write_nonblock(string [, options]) -> integer
|
|
|
|
#
|
|
|
|
# Writes the given string to <em>ios</em> using
|
|
|
|
# the write(2) system call after O_NONBLOCK is set for
|
|
|
|
# the underlying file descriptor.
|
|
|
|
#
|
|
|
|
# It returns the number of bytes written.
|
|
|
|
#
|
|
|
|
# write_nonblock just calls the write(2) system call.
|
|
|
|
# It causes all errors the write(2) system call causes: Errno::EWOULDBLOCK, Errno::EINTR, etc.
|
|
|
|
# The result may also be smaller than string.length (partial write).
|
|
|
|
# The caller should care such errors and partial write.
|
|
|
|
#
|
|
|
|
# If the exception is Errno::EWOULDBLOCK or Errno::EAGAIN,
|
|
|
|
# it is extended by IO::WaitWritable.
|
|
|
|
# So IO::WaitWritable can be used to rescue the exceptions for retrying write_nonblock.
|
|
|
|
#
|
|
|
|
# # Creates a pipe.
|
|
|
|
# r, w = IO.pipe
|
|
|
|
#
|
|
|
|
# # write_nonblock writes only 65536 bytes and return 65536.
|
|
|
|
# # (The pipe size is 65536 bytes on this environment.)
|
2016-12-07 18:30:01 +03:00
|
|
|
# s = "a" * 100000
|
2015-11-12 05:00:41 +03:00
|
|
|
# p w.write_nonblock(s) #=> 65536
|
|
|
|
#
|
|
|
|
# # write_nonblock cannot write a byte and raise EWOULDBLOCK (EAGAIN).
|
|
|
|
# p w.write_nonblock("b") # Resource temporarily unavailable (Errno::EAGAIN)
|
|
|
|
#
|
|
|
|
# If the write buffer is not empty, it is flushed at first.
|
|
|
|
#
|
|
|
|
# When write_nonblock raises an exception kind of IO::WaitWritable,
|
|
|
|
# write_nonblock should not be called
|
|
|
|
# until io is writable for avoiding busy loop.
|
|
|
|
# This can be done as follows.
|
|
|
|
#
|
|
|
|
# begin
|
|
|
|
# result = io.write_nonblock(string)
|
|
|
|
# rescue IO::WaitWritable, Errno::EINTR
|
|
|
|
# IO.select(nil, [io])
|
|
|
|
# retry
|
|
|
|
# end
|
|
|
|
#
|
|
|
|
# Note that this doesn't guarantee to write all data in string.
|
|
|
|
# The length written is reported as result and it should be checked later.
|
|
|
|
#
|
|
|
|
# On some platforms such as Windows, write_nonblock is not supported
|
|
|
|
# according to the kind of the IO object.
|
|
|
|
# In such cases, write_nonblock raises <code>Errno::EBADF</code>.
|
|
|
|
#
|
2017-02-23 05:00:28 +03:00
|
|
|
# By specifying a keyword argument _exception_ to +false+, you can indicate
|
2015-11-12 05:00:41 +03:00
|
|
|
# that write_nonblock should not raise an IO::WaitWritable exception, but
|
2017-02-23 05:40:17 +03:00
|
|
|
# return the symbol +:wait_writable+ instead.
|
2015-11-12 05:00:41 +03:00
|
|
|
def write_nonblock(buf, exception: true)
|
|
|
|
__write_nonblock(buf, exception)
|
|
|
|
end
|
|
|
|
end
|
2017-01-06 06:11:45 +03:00
|
|
|
|
2018-11-26 21:16:39 +03:00
|
|
|
class TracePoint
|
|
|
|
def enable target: nil, &blk
|
|
|
|
self.__enable target, &blk
|
|
|
|
end
|
|
|
|
end
|
|
|
|
|
2017-01-06 06:11:45 +03:00
|
|
|
class Binding
|
2018-10-26 20:08:30 +03:00
|
|
|
# :nodoc:
|
2017-01-06 06:11:45 +03:00
|
|
|
def irb
|
|
|
|
require 'irb'
|
|
|
|
irb
|
|
|
|
end
|
2017-12-01 06:54:49 +03:00
|
|
|
|
|
|
|
# suppress redefinition warning
|
|
|
|
alias irb irb # :nodoc:
|
2017-01-06 06:11:45 +03:00
|
|
|
end
|
2017-11-30 04:31:00 +03:00
|
|
|
|
|
|
|
module Kernel
|
|
|
|
def pp(*objs)
|
|
|
|
require 'pp'
|
2017-11-30 05:12:42 +03:00
|
|
|
pp(*objs)
|
2017-11-30 04:31:00 +03:00
|
|
|
end
|
2017-12-01 06:54:49 +03:00
|
|
|
|
|
|
|
# suppress redefinition warning
|
|
|
|
alias pp pp # :nodoc:
|
2018-10-11 04:03:05 +03:00
|
|
|
|
|
|
|
private :pp
|
2017-11-30 04:31:00 +03:00
|
|
|
end
|