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

Version Path
protobuf-2.8.13 lib/protobuf/rpc/servers/zmq/util.rb
protobuf-2.8.12 lib/protobuf/rpc/servers/zmq/util.rb
protobuf-2.8.11 lib/protobuf/rpc/servers/zmq/util.rb
protobuf-2.8.10 lib/protobuf/rpc/servers/zmq/util.rb
protobuf-2.8.9 lib/protobuf/rpc/servers/zmq/util.rb
protobuf-2.8.8 lib/protobuf/rpc/servers/zmq/util.rb
protobuf-2.8.7 lib/protobuf/rpc/servers/zmq/util.rb
protobuf-2.8.6 lib/protobuf/rpc/servers/zmq/util.rb
protobuf-2.8.5 lib/protobuf/rpc/servers/zmq/util.rb
protobuf-2.8.4 lib/protobuf/rpc/servers/zmq/util.rb
protobuf-2.8.3 lib/protobuf/rpc/servers/zmq/util.rb
protobuf-2.8.2 lib/protobuf/rpc/servers/zmq/util.rb
protobuf-2.8.1 lib/protobuf/rpc/servers/zmq/util.rb
protobuf-2.8.0 lib/protobuf/rpc/servers/zmq/util.rb
protobuf-2.8.0.beta9-java lib/protobuf/rpc/servers/zmq/util.rb
protobuf-2.8.0.beta9 lib/protobuf/rpc/servers/zmq/util.rb
protobuf-2.8.0.beta8-java lib/protobuf/rpc/servers/zmq/util.rb
protobuf-2.8.0.beta8 lib/protobuf/rpc/servers/zmq/util.rb
protobuf-2.8.0.beta6-java lib/protobuf/rpc/servers/zmq/util.rb
protobuf-2.8.0.beta6 lib/protobuf/rpc/servers/zmq/util.rb