Sha256: f29ef45b79742b1af39a77ded646efca3c4e43d4a63e9a4dd337f86714ac337b
Contents?: true
Size: 942 Bytes
Versions: 30
Compression:
Stored size: 942 Bytes
Contents
require 'resolv' module Protobuf module Rpc module Zmq WORKER_READY_MESSAGE = "\1" module Util include ::Protobuf::Logger::LogMethods def self.included(base) base.extend(::Protobuf::Rpc::Zmq::Util) end def zmq_error_check(return_code, source = nil) unless ::ZMQ::Util.resultcode_ok?(return_code) raise <<-ERROR Last ZMQ API call #{source ? "to #{source}" : ""} failed with "#{::ZMQ::Util.error_string}". #{caller(1).join($/)} ERROR end end def log_signature unless @_log_signature name = (self.class == Class ? self.name : self.class.name) @_log_signature = "[server-#{name}-#{object_id}]" end @_log_signature end def resolve_ip(hostname) ::Resolv.getaddress(hostname) end end end end end
Version data entries
30 entries across 30 versions & 1 rubygems