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
|
require 'socket'
module Celluloid
module IO
# TCPServer with combined blocking and evented support
class TCPServer
extend Forwardable
def_delegators :@server, :listen, :sysaccept, :close, :closed?, :addr, :setsockopt
def initialize(hostname_or_port, port = nil)
if port.nil?
@server = ::TCPServer.new(hostname_or_port)
else
@server = ::TCPServer.new(hostname_or_port, port)
end
end
def accept
Celluloid::IO.wait_readable(@server)
accept_nonblock
end
def accept_nonblock
Celluloid::IO::TCPSocket.new(@server.accept_nonblock)
end
def to_io
@server
end
# Convert a Ruby TCPServer into a Celluloid::IO::TCPServer
def self.from_ruby_server(ruby_server)
server = allocate
server.instance_variable_set(:@server, ruby_server)
server
end
end
end
end
|
