Module: Async::IO::Peer
- Includes:
- Socket::Constants
- Included in:
- BasicSocket, SSLSocket, TCPSocket, UNIXSocket
- Defined in:
- lib/async/io/socket.rb
Instance Method Summary collapse
-
#connected? ⇒ Boolean
Is it likely that the socket is still connected? May return false positive, but won't return false negative.
- #protocol ⇒ Object
- #sync ⇒ Object
-
#sync=(value) ⇒ Object
Best effort to set *_NODELAY if it makes sense.
- #type ⇒ Object
Instance Method Details
#connected? ⇒ Boolean
Is it likely that the socket is still connected? May return false positive, but won't return false negative.
33 34 35 36 37 38 39 40 41 42 43 44 45 |
# File 'lib/async/io/socket.rb', line 33 def connected? return false if @io.closed? # If we can wait for the socket to become readable, we know that the socket may still be open. result = to_io.recv_nonblock(1, MSG_PEEK, exception: false) # Either there was some data available, or we can wait to see if there is data avaialble. return !result.empty? || result == :wait_readable rescue Errno::ECONNRESET # This might be thrown by recv_nonblock. return false end |
#protocol ⇒ Object
77 78 79 |
# File 'lib/async/io/socket.rb', line 77 def protocol self.local_address.protocol end |
#sync ⇒ Object
64 65 66 67 68 69 70 71 |
# File 'lib/async/io/socket.rb', line 64 def sync case self.protocol when IPPROTO_TCP self.getsockopt(IPPROTO_TCP, TCP_NODELAY).bool else true end && super end |
#sync=(value) ⇒ Object
Best effort to set *_NODELAY if it makes sense. Swallows errors where possible.
48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 |
# File 'lib/async/io/socket.rb', line 48 def sync=(value) super case self.protocol when 0, IPPROTO_TCP self.setsockopt(IPPROTO_TCP, TCP_NODELAY, value ? 1 : 0) else Async.logger.warn(self) {"Unsure how to sync=#{value} for #{self.protocol}!"} end rescue Errno::EINVAL # On Darwin, sometimes occurs when the connection is not yet fully formed. Empirically, TCP_NODELAY is enabled despite this result. rescue Errno::EOPNOTSUPP # Some platforms may simply not support the operation. # Async.logger.warn(self) {"Unable to set sync=#{value}!"} end |
#type ⇒ Object
73 74 75 |
# File 'lib/async/io/socket.rb', line 73 def type self.local_address.socktype end |