Module: Async::IO::Peer

Includes:
Socket::Constants
Included in:
BasicSocket, SSLSocket, TCPSocket, UNIXSocket
Defined in:
lib/async/io/socket.rb

Instance Method Summary collapse

Instance Method Details

#connected? ⇒ Boolean

Is it likely that the socket is still connected? May return false positive, but won't return false negative.

Returns:

  • (Boolean) 


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