Class: DBus::MessageQueue

Inherits:
Object
  • Object
show all
Defined in:
lib/dbus/message_queue.rb

Overview

Encapsulates a socket so that we can #push and #pop Messages.

Constant Summary collapse

MSG_BUF_SIZE =

The buffer size for messages.

4096

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(address) ⇒ MessageQueue

Returns a new instance of MessageQueue.



19
20
21
22
23
24
 
# File 'lib/dbus/message_queue.rb', line 19

def initialize(address)
  @address = address
  @buffer = ""
  @is_tcp = false
  connect
end

Instance Attribute Details

#socket ⇒ Object (readonly)

The socket that is used to connect with the bus.



17
18
19
 
# File 'lib/dbus/message_queue.rb', line 17

def socket
  @socket
end

Instance Method Details

#buffer_from_socket_nonblock ⇒ void

This method returns an undefined value.

Fill (append) the buffer from data that might be available on the socket.

Raises:

  • EOFError



155
156
157
158
159
160
161
162
163
164
165
166
 
# File 'lib/dbus/message_queue.rb', line 155

def buffer_from_socket_nonblock
  @buffer += @socket.read_nonblock(MSG_BUF_SIZE)
rescue EOFError
  raise # the caller expects it
rescue Errno::EAGAIN
  # fine, would block
rescue Exception => e
  puts "Oops:", e
  raise if @is_tcp # why?
  puts "WARNING: read_nonblock failed, falling back to .recv"
  @buffer += @socket.recv(MSG_BUF_SIZE)
end

#message_from_buffer_nonblock ⇒ Message?

Get and remove one message from the buffer.

Returns:

  • (Message, nil) —

    the message or nil if unavailable



136
137
138
139
140
141
142
143
144
145
146
 
# File 'lib/dbus/message_queue.rb', line 136

def message_from_buffer_nonblock
  return nil if @buffer.empty?
  ret = nil
  begin
    ret, size = Message.new.unmarshall_buffer(@buffer)
    @buffer.slice!(0, size)
  rescue IncompleteBufferException
    # fall through, let ret remain nil
  end
  ret
end

#pop(non_block = false) ⇒ Message?

TODO:

failure modes

Returns one message or nil if unavailable.

Parameters:

  • non_block (Boolean) (defaults to: false) —

    if true, return nil instead of waiting

Returns:

  • (Message, nil) —

    one message or nil if unavailable

Raises:

  • EOFError



30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
 
# File 'lib/dbus/message_queue.rb', line 30

def pop(non_block = false)
  buffer_from_socket_nonblock
  message = message_from_buffer_nonblock
  unless non_block
    # we can block
    while message.nil?
      r, _d, _d = IO.select([@socket])
      if r && r[0] == @socket
        buffer_from_socket_nonblock
        message = message_from_buffer_nonblock
      end
    end
  end
  message
end

#push(message) ⇒ Object Also known as: << 



46
47
48
 
# File 'lib/dbus/message_queue.rb', line 46

def push(message)
  @socket.write(message.marshall)
end