diff --git a/fluentd.gemspec b/fluentd.gemspec index c7afb175ec..c7c03911ad 100644 --- a/fluentd.gemspec +++ b/fluentd.gemspec @@ -65,7 +65,7 @@ Gem::Specification.new do |gem| gem.add_development_dependency("test-unit", ["~> 3.3"]) gem.add_development_dependency("test-unit-rr", ["~> 1.0"]) gem.add_development_dependency("oj", [">= 2.14", "< 4"]) - gem.add_development_dependency("async-http", ">= 0.50.0") + gem.add_development_dependency("async-http", "~> 0.86") gem.add_development_dependency("aws-sigv4", ["~> 1.8"]) gem.add_development_dependency("aws-sdk-core", ["~> 3.191"]) gem.add_development_dependency("rexml", ["~> 3.2"]) diff --git a/lib/fluent/plugin_helper/http_server/server.rb b/lib/fluent/plugin_helper/http_server/server.rb index 50df177e83..9c099292d8 100644 --- a/lib/fluent/plugin_helper/http_server/server.rb +++ b/lib/fluent/plugin_helper/http_server/server.rb @@ -68,11 +68,9 @@ def start(notify = nil) notify.push(:ready) end - if async_v2? - @server_task_queue = ::Thread::Queue.new - @server_task_queue.pop - @server_task&.stop - end + @server_task_queue = ::Thread::Queue.new + @server_task_queue.pop + @server_task&.stop end @logger.debug('Finished HTTP server') @@ -80,11 +78,7 @@ def start(notify = nil) def stop @logger.debug('closing HTTP server') - if async_v2? - @server_task_queue&.push(:stop) - else - @server_task&.stop - end + @server_task_queue.push(:stop) end HttpServer::Methods::ALL.map { |e| e.downcase.to_sym }.each do |name| @@ -100,10 +94,6 @@ def stop @router.mount(name, path, app || block) end end - - private def async_v2? - Gem::Version.new(Async::VERSION) >= Gem::Version.new('2.0') - end end end end