Method: Fluent::Counter::Server#start

Defined in:
lib/fluent/counter/server.rb

#start ⇒ Object 



46
47
48
49
50
51
52
53
54
55
56
 
# File 'lib/fluent/counter/server.rb', line 46

def start
  @server.attach(@loop)
  @thread = Thread.new do
    @running = true
    @loop.run(0.5)
    @running = false
  end
  @log.debug("starting counter server #{@addr}:#{@port}")
  @mutex_hash.start
  self
end