Contents

require "celluloid/io/version"

require "celluloid"
require "celluloid/io/dns_resolver"
require "celluloid/io/mailbox"
require "celluloid/io/reactor"
require "celluloid/io/socket"
require "celluloid/io/stream"

require "celluloid/io/tcp_server"
require "celluloid/io/tcp_socket"
require "celluloid/io/udp_socket"
require "celluloid/io/unix_server"
require "celluloid/io/unix_socket"

require "celluloid/io/ssl_server"
require "celluloid/io/ssl_socket"

module Celluloid
  # Actors with evented IO support
  module IO
    # Default size to read from or write to the stream for buffer operations
    BLOCK_SIZE = 1024 * 16

    def self.included(klass)
      klass.send :include, Celluloid
      klass.mailbox_class Celluloid::IO::Mailbox
    end

    def self.evented?
      actor = Thread.current[:celluloid_actor]
      actor && actor.mailbox.is_a?(Celluloid::IO::Mailbox)
    end

    def self.try_convert(src)
      ::IO.try_convert(src)
    end

    def self.copy_stream(src, dst, copy_length = nil, src_offset = nil)
      fail NotImplementedError, "length/offset not supported" if copy_length || src_offset

      src, dst = try_convert(src), try_convert(dst)

      # FIXME: this always goes through the reactor, and can block on file I/O
      while data = src.read(BLOCK_SIZE)
        dst << data
      end
    end

    def wait_readable(io)
      io = io.to_io
      if IO.evented?
        mailbox = Thread.current[:celluloid_mailbox]
        mailbox.reactor.wait_readable(io)
      else
        Kernel.select([io])
      end
      nil
    end
    module_function :wait_readable

    def wait_writable(io)
      io = io.to_io
      if IO.evented?
        mailbox = Thread.current[:celluloid_mailbox]
        mailbox.reactor.wait_writable(io)
      else
        Kernel.select([], [io])
      end
      nil
    end
    module_function :wait_writable
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
celluloid-io-0.17.3	lib/celluloid/io.rb