Sha256: c74fcd9dd7ec9ae2dd5bdda1c9b9231845e8f57e76dd499e564d22e68ca19ce4
Contents?: true
Size: 742 Bytes
Versions: 38
Compression:
Stored size: 742 Bytes
Contents
require "socket"
module PoolParty
module Ruberl
class Base
attr_accessor :host, :port
def initialize(host="localhost", port=7050)
@host = host
@port = port
end
def with_socket(&block)
begin
socket = TCPSocket.open(@host, @port)
out = yield(socket)
socket.close
out
rescue Exception => e
end
end
def messenger_send!(msg="get_current_load cpu")
with_socket do |sock|
sock.send(msg, 0)
@str = sock.recv(2000)
end
@str
end
def messenger_cast!(msg="force_reconfig")
with_socket do |sock|
sock.send(msg, 0)
end
end
end
end
end
Version data entries
38 entries across 38 versions & 3 rubygems