Class: EventMachine::EvmaTCPServer
- Inherits:
-
Selectable
- Object
- Selectable
- EventMachine::EvmaTCPServer
- Defined in:
- lib/pr_eventmachine.rb
Instance Attribute Summary
Attributes inherited from Selectable
Class Method Summary collapse
-
.start_server(host, port) ⇒ Object
Versions of ruby 1.8.4 later than May 26 2006 will work properly with an object of type TCPServer.
Instance Method Summary collapse
-
#eventable_read ⇒ Object
– accept_nonblock returns an array consisting of the accepted socket and a sockaddr_in which names the peer.
-
#initialize(io) ⇒ EvmaTCPServer
constructor
A new instance of EvmaTCPServer.
-
#schedule_close ⇒ Object
–.
- #select_for_reading? ⇒ Boolean
Methods inherited from Selectable
#close_scheduled?, #get_peername, #heartbeat, #select_for_writing?, #set_inactivity_timeout
Constructor Details
#initialize(io) ⇒ EvmaTCPServer
Returns a new instance of EvmaTCPServer.
786 787 788 |
# File 'lib/pr_eventmachine.rb', line 786 def initialize io super io end |
Class Method Details
.start_server(host, port) ⇒ Object
Versions of ruby 1.8.4 later than May 26 2006 will work properly with an object of type TCPServer. Prior versions won’t so we play it safe and just build a socket.
777 778 779 780 781 782 783 |
# File 'lib/pr_eventmachine.rb', line 777 def start_server host, port sd = Socket.new( Socket::AF_INET, Socket::SOCK_STREAM, 0 ) sd.setsockopt( Socket::SOL_SOCKET, Socket::SO_REUSEADDR, true ) sd.bind( Socket.pack_sockaddr_in( port, host )) sd.listen( 50 ) # 5 is what you see in all the books. Ain't enough. EvmaTCPServer.new sd end |
Instance Method Details
#eventable_read ⇒ Object
– accept_nonblock returns an array consisting of the accepted socket and a sockaddr_in which names the peer. Don’t accept more than 10 at a time.
799 800 801 802 803 804 805 806 807 808 |
# File 'lib/pr_eventmachine.rb', line 799 def eventable_read begin 10.times { descriptor,peername = io.accept_nonblock sd = StreamObject.new descriptor EventMachine::event_callback uuid, ConnectionAccepted, sd.uuid } rescue Errno::EWOULDBLOCK, Errno::EAGAIN end end |
#schedule_close ⇒ Object
–
812 813 814 |
# File 'lib/pr_eventmachine.rb', line 812 def schedule_close @close_scheduled = true end |
#select_for_reading? ⇒ Boolean
791 792 793 |
# File 'lib/pr_eventmachine.rb', line 791 def select_for_reading? true end |