class Selenium::WebDriver::SocketLock

@api private

Public Class Methods

new(port, timeout) click to toggle source

# File lib/selenium/webdriver/common/socket_lock.rb, line 25
def initialize(port, timeout)
  @port    = port
  @timeout = timeout
end

Public Instance Methods

locked() { || ... } click to toggle source

Attempt to acquire a lock on the given port. Control is yielded to an execution block if the lock could be successfully obtained.

# File lib/selenium/webdriver/common/socket_lock.rb, line 35
def locked
  lock

  begin
    yield
  ensure
    release
  end
end

Private Instance Methods

can_lock?() click to toggle source

# File lib/selenium/webdriver/common/socket_lock.rb, line 60
def can_lock?
  @server = TCPServer.new(Platform.localhost, @port)
  ChildProcess.close_on_exec @server

  true
rescue SocketError, Errno::EADDRINUSE, Errno::EBADF => ex
  WebDriver.logger.debug("#{self}: #{ex.message}")
  false
end

did_lock?() click to toggle source

# File lib/selenium/webdriver/common/socket_lock.rb, line 70
def did_lock?
  !@server.nil?
end

lock() click to toggle source

# File lib/selenium/webdriver/common/socket_lock.rb, line 47
def lock
  max_time = Time.now + @timeout

  sleep 0.1 until can_lock? || Time.now >= max_time

  return if did_lock?
  raise Error::WebDriverError, "unable to bind to locking port #{@port} within #{@timeout} seconds"
end

release() click to toggle source

# File lib/selenium/webdriver/common/socket_lock.rb, line 56
def release
  @server && @server.close
end