# Copyright (C) 2014-2015 MongoDB, Inc. # # Licensed under the Apache License, Version 2.0 (the "License"); # you may not use this file except in compliance with the License. # You may obtain a copy of the License at # # http://www.apache.org/licenses/LICENSE-2.0 # # Unless required by applicable law or agreed to in writing, software # distributed under the License is distributed on an "AS IS" BASIS, # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. # See the License for the specific language governing permissions and # limitations under the License. module Mongo class Socket # Wrapper for Unix sockets. # # @since 2.0.0 class Unix < Socket # @return [ String ] path The path to connect to. attr_reader :path # @return [ Float ] timeout The connection timeout. attr_reader :timeout # Establishes a socket connection. # # @example Connect the socket. # sock.connect! # # @note This method mutates the object by setting the socket # internally. # # @return [ Unix ] The connected socket instance. # # @since 2.0.0 def connect! self end # Initializes a new Unix socket. # # @example Create the Unix socket. # Unix.new('/path/to.sock', 5) # # @param [ String ] path The path. # @param [ Float ] timeout The socket timeout value. # # @since 2.0.0 def initialize(path, timeout) @path, @timeout = path, timeout @socket = ::UNIXSocket.new(path) set_socket_options(@socket) end # This socket can only be used if the unix socket (@socket) has been created. # # @example Is the socket connectable? # socket.connectable? # # @return [ true, false ] If the socket is connectable. # # @since 2.2.5 def connectable? !!@socket end end end end