Sha256: 04078af5ebd793184ccf472e533d97af8260c315c3377eed44df049d874e3f71
Contents?: true
Size: 1.12 KB
Versions: 6
Compression:
Stored size: 1.12 KB
Contents
require 'bson'
require 'socket'
module RubySkynet
module Common
# Returns a BSON document read from the socket.
# Returns nil if the operation times out or if a network
# connection failure occurs
def self.read_bson_document(socket)
bytebuf = BSON::ByteBuffer.new
# Read 4 byte size of following BSON document
bytes = socket.read(4)
# No more data
return unless bytes
# Read BSON document
sz = bytes.unpack("V")[0]
raise "Invalid Data received from server:#{bytes.inspect}" unless sz
bytebuf.append!(bytes)
bytebuf.append!(socket.read(sz - 4))
raise "Socket is not returning #{sz} requested bytes. #{bytebuf.length} bytes returned" unless sz == bytebuf.length
return BSON.deserialize(bytebuf)
end
# Returns the local ip address being used by this machine to talk to the
# internet. By default connects to Google and determines what IP Address is used locally
def self.local_ip_address(remote_ip = '64.233.187.99')
@@local_ip_address ||= ::UDPSocket.open {|s| s.connect(remote_ip, 1); s.addr.last }
end
end
end
Version data entries
6 entries across 6 versions & 1 rubygems