Module: Async::IO::Peer
- Includes:
- Socket::Constants
- Included in:
- BasicSocket, SSLSocket, TCPSocket, UNIXSocket
- Defined in:
- lib/async/io/peer.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.
32 33 34 35 36 37 38 39 40 41 42 43 44 |
# File 'lib/async/io/peer.rb', line 32 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
76 77 78 |
# File 'lib/async/io/peer.rb', line 76 def protocol self.local_address.protocol end |
#sync ⇒ Object
63 64 65 66 67 68 69 70 |
# File 'lib/async/io/peer.rb', line 63 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.
47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 |
# File 'lib/async/io/peer.rb', line 47 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
72 73 74 |
# File 'lib/async/io/peer.rb', line 72 def type self.local_address.socktype end |