Method: Fluent::Counter::Server#stop

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

#stop ⇒ Object 



58
59
60
61
62
63
64
65
66
 
# File 'lib/fluent/counter/server.rb', line 58

def stop
  # This `sleep` for a test to wait for a `@loop` to begin to run
  sleep 0.1
  @server.close
  @loop.stop if @running
  @mutex_hash.stop
  @thread.join if @thread
  @log.debug("calling stop in counter server #{@addr}:#{@port}")
end