Class: Async::IO::UNIXEndpoint

Inherits:
AddressEndpoint show all
Defined in:
lib/async/io/unix_endpoint.rb

Overview

This class doesn’t exert ownership over the specified unix socket and ensures exclusive access by using ‘flock` where possible.

Instance Attribute Summary collapse

Attributes inherited from AddressEndpoint

#address

Attributes inherited from Endpoint

#options

Instance Method Summary collapse

Methods inherited from AddressEndpoint

#connect

Methods inherited from Endpoint

#accept, #bound, #each, each, #hostname, #linger, #local_address, parse, #reuse_address, #reuse_port, socket, ssl, tcp, #timeout, try_convert, udp, unix, #with

Constructor Details

#initialize(path, type, **options) ⇒ UNIXEndpoint

Returns a new instance of UNIXEndpoint.



29
30
31
32
33
34
 
# File 'lib/async/io/unix_endpoint.rb', line 29

def initialize(path, type, **options)
	# I wonder if we should implement chdir behaviour in here if path is longer than 104 characters.
	super(Address.unix(path, type), **options)
	
	@path = path
end

Instance Attribute Details

#path ⇒ Object (readonly)

Returns the value of attribute path.



40
41
42
 
# File 'lib/async/io/unix_endpoint.rb', line 40

def path
  @path
end

Instance Method Details

#bind(&block) ⇒ Object 



50
51
52
53
54
55
56
57
58
59
60
 
# File 'lib/async/io/unix_endpoint.rb', line 50

def bind(&block)
	Socket.bind(@address, **@options, &block)
rescue Errno::EADDRINUSE
	# If you encounter EADDRINUSE from `bind()`, you can check if the socket is actually accepting connections by attempting to `connect()` to it. If the socket is still bound by an active process, the connection will succeed. Otherwise, it should be safe to `unlink()` the path and try again.
	if !bound? && File.exist?(@path)
		File.unlink(@path)
		retry
	else
		raise
	end
end

#bound? ⇒ Boolean

Returns:

  • (Boolean) 


42
43
44
45
46
47
48
 
# File 'lib/async/io/unix_endpoint.rb', line 42

def bound?
	self.connect do
		return true
	end
rescue Errno::ECONNREFUSED
	return false
end

#to_s ⇒ Object 



36
37
38
 
# File 'lib/async/io/unix_endpoint.rb', line 36

def to_s
	"\#<#{self.class} #{@path.inspect}>"
end