Commit ad585809 authored by Paul Asmuth's avatar Paul Asmuth
Browse files

acceptor fix

parent fd00b279

fnordmetric-core/lib/fnordmetric/acceptors/acceptor.rb

+1 −5
Original line number Diff line number Diff line
@@ -28,7 +28,7 @@ class FnordMetric::Acceptor 


    begin

      inbound_stream = inbound_class.start(@opts)

      if inbound_class.outbound?

      if inbound_class.respond_to?(:outbound?) && inbound_class.outbound?

        FnordMetric.log "connected to #{@opts[:protocol]}://#{@opts[:listen][0..1].join(":")}"

      else

        FnordMetric.log "listening on #{@opts[:protocol]}://#{@opts[:listen][0..1].join(":")}"
@@ -39,8 +39,4 @@ class FnordMetric::Acceptor 
    end

  end



  def self.outboud?

    false

  end



end

fnordmetric-core/lib/fnordmetric/acceptors/fyrehose_acceptor.rb

+4 −0
Original line number Diff line number Diff line
@@ -36,4 +36,8 @@ class FnordMetric::FyrehoseAcceptor 
    @api ||= FnordMetric::API.new(FnordMetric.options)

  end



  def self.outboud?

    true

  end



end

fnordmetric-core/lib/fnordmetric/acceptors/tcp_acceptor.rb

+1 −0
Original line number Diff line number Diff line
@@ -54,4 +54,5 @@ class FnordMetric::TCPAcceptor < EventMachine::Connection 
  def api

    @api ||= FnordMetric::API.new(FnordMetric.options)

  end



end

fnordmetric-core/lib/fnordmetric/acceptors/udp_acceptor.rb

+2 −1
Original line number Diff line number Diff line
@@ -33,4 +33,5 @@ class FnordMetric::UDPAcceptor < EventMachine::Connection 
  def api

    @api ||= FnordMetric::API.new(FnordMetric.options)

  end



end

CRA Git | Maintained and supported by SUSTech CRA and CCSE