Contents

require 'celluloid/io/version'

require 'celluloid'
require 'celluloid/io/dns_resolver'
require 'celluloid/io/mailbox'
require 'celluloid/io/reactor'
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)
      raise 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

8 entries across 8 versions & 1 rubygems

Version	Path
celluloid-io-0.17.1	lib/celluloid/io.rb
celluloid-io-0.17.0	lib/celluloid/io.rb
celluloid-io-0.16.5.pre0	lib/celluloid/io.rb
celluloid-io-0.16.2	lib/celluloid/io.rb
celluloid-io-0.16.1	lib/celluloid/io.rb
celluloid-io-0.16.0	lib/celluloid/io.rb
celluloid-io-0.16.0.pre2	lib/celluloid/io.rb
celluloid-io-0.16.0.pre	lib/celluloid/io.rb