module Fluent::Test::StartupShutdown

def self.setup
  @socket_manager_path = ServerEngine::SocketManager::Server.generate_path
  @server = ServerEngine::SocketManager::Server.open(@socket_manager_path)
  ENV['SERVERENGINE_SOCKETMANAGER_PATH'] = @socket_manager_path.to_s
end

def self.teardown
  @server.close
  # on Windows, socket_manager_path is a TCP port number
  FileUtils.rm_f @socket_manager_path unless Fluent.windows?
end

def shutdown
  @server.close
end

def startup
  socket_manager_path = ServerEngine::SocketManager::Server.generate_path
  @server = ServerEngine::SocketManager::Server.open(socket_manager_path)
  ENV['SERVERENGINE_SOCKETMANAGER_PATH'] = socket_manager_path.to_s
end