Class: Sensu::Server::Socket

Inherits:
EM::Connection
  • Object
show all
Defined in:
lib/sensu/server/socket.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Instance Attribute Details

#on_error ⇒ Proc

Returns callback to be called when there is an error.

Returns:

  • (Proc) —

    callback to be called when there is an error.



11
12
13
 
# File 'lib/sensu/server/socket.rb', line 11

def on_error
  @on_error
end

#on_success ⇒ Proc

Returns callback to be called after the data has been transmitted successfully.

Returns:

  • (Proc) —

    callback to be called after the data has been transmitted successfully.



7
8
9
 
# File 'lib/sensu/server/socket.rb', line 7

def on_success
  @on_success
end

Instance Method Details

#connection_completed ⇒ Object

Record the current time when connected.



28
29
30
 
# File 'lib/sensu/server/socket.rb', line 28

def connection_completed
  @connected_at = Time.now.to_f
end

#set_timeout(timeout) ⇒ Object

Create a timeout timer to immediately close the socket connection and set ‘@timed_out` to true to indicate that the timeout caused the connection to close. The timeout timer is stored with `@timeout_timer`, so that it can be cancelled when the connection is closed.

Parameters:

  • timeout (Numeric) —

    in seconds.



20
21
22
23
24
25
 
# File 'lib/sensu/server/socket.rb', line 20

def set_timeout(timeout)
  @timeout_timer = EM::Timer.new(timeout) do
    @timed_out = true
    close_connection
  end
end

#unbind ⇒ Object

Determine if the connection and data transmission was successful and call the appropriate callback, ‘@on_success` or `@on_error`, providing it with a message. Cancel the connection timeout timer `@timeout_timer`, if it is set. The `@connected_at` timestamp indicates that the connection was successful. If `@timed_out` is true, the connection was closed by the connection timeout, and the data is assumed to not have been transmitted.



40
41
42
43
44
45
46
47
48
49
50
51
 
# File 'lib/sensu/server/socket.rb', line 40

def unbind
  @timeout_timer.cancel if @timeout_timer
  if @connected_at
    if @timed_out
      @on_error.call("socket timeout")
    else
      @on_success.call("wrote to socket")
    end
  else
    @on_error.call("failed to connect to socket")
  end
end