bump release to 1.0.2

http/2: do not interpret MAX_CONCURRENT_STREAMS as request cap

See merge request os85/httpx!278

doc/release_notes/0_24_7.md

@@ -0,0 +1,10 @@
+# 0.24.6
+
+## dependencies
+
+`http-2-next` last supported version for the 0.x series is the last version before v1. This shoul ensure that older versions of `httpx` won't be affected by any of the recent breaking changes.
+
+## Bugfixes
+
+* `grpc`: setup of rpc calls from camel-cased symbols has been fixed. As an improvement, the GRPC-enabled session will now support both snake-cased, as well as camel-cased calls.
+* `datadog` adapter has now been patched to support the most recent breaking changes of `ddtrace` configuration DSL (`env_to_bool` is no longer supported).

doc/release_notes/1_0_2.md

@@ -0,0 +1,7 @@
+# 1.0.2
+
+## bugfixes
+
+* bump `http-2-next` to 1.0.1, which fixes a bug where http/2 connection interprets MAX_CONCURRENT_STREAMS as request cap.
+* `grpc`: setup of rpc calls from camel-cased symbols has been fixed. As an improvement, the GRPC-enabled session will now support both snake-cased, as well as camel-cased calls.
+* `datadog` adapter has now been patched to support the most recent breaking changes of `ddtrace` configuration DSL (`env_to_bool` is no longer supported).

httpx.gemspec

@@ -32,7 +32,7 @@ Gem::Specification.new do |gem|
 
   gem.require_paths = ["lib"]
 
-  gem.add_runtime_dependency "http-2-next", ">= 1.0.0"
+  gem.add_runtime_dependency "http-2-next", ">= 1.0.1"
 
   gem.required_ruby_version = ">= 2.7.0"
 end

lib/httpx/adapters/datadog.rb

@@ -126,6 +126,7 @@ module Datadog::Tracing
           option :distributed_tracing, default: true
           option :split_by_domain, default: false
 
+          if DDTrace::VERSION::STRING >= "1.13.0"
             option :enabled do |o|
               o.type :bool
               o.env "DD_TRACE_HTTPX_ENABLED"
@@ -143,6 +144,22 @@ module Datadog::Tracing
               o.env "DD_TRACE_HTTPX_ANALYTICS_SAMPLE_RATE"
               o.default 1.0
             end
+          else
+            option :enabled do |o|
+              o.default { env_to_bool("DD_TRACE_HTTPX_ENABLED", true) }
+              o.lazy
+            end
+
+            option :analytics_enabled do |o|
+              o.default { env_to_bool(%w[DD_TRACE_HTTPX_ANALYTICS_ENABLED DD_HTTPX_ANALYTICS_ENABLED], false) }
+              o.lazy
+            end
+
+            option :analytics_sample_rate do |o|
+              o.default { env_to_float(%w[DD_TRACE_HTTPX_ANALYTICS_SAMPLE_RATE DD_HTTPX_ANALYTICS_SAMPLE_RATE], 1.0) }
+              o.lazy
+            end
+          end
 
           if defined?(Datadog::Tracing::Contrib::SpanAttributeSchema)
             option :service_name do |o|
@@ -170,11 +187,13 @@ module Datadog::Tracing
               o.type :proc
               o.default_proc(&DEFAULT_ERROR_HANDLER)
             end
-          else
+          elsif DDTrace::VERSION::STRING >= "1.13.0"
             option :error_handler do |o|
               o.type :proc
               o.experimental_default_proc(&DEFAULT_ERROR_HANDLER)
             end
+          else
+            option :error_handler, default: DEFAULT_ERROR_HANDLER
           end
         end
       end
@@ -205,7 +224,7 @@ module Datadog::Tracing
       class Integration
         include Contrib::Integration
 
-        MINIMUM_VERSION = Gem::Version.new("1.0.1")
+        MINIMUM_VERSION = Gem::Version.new("0.10.2")
 
         register_as :httpx
 

lib/httpx/connection/http1.rb

@@ -7,7 +7,7 @@ module HTTPX
     include Callbacks
     include Loggable
 
-    MAX_REQUESTS = 100
+    MAX_REQUESTS = 200
     CRLF = "\r\n"
 
     attr_reader :pending, :requests

lib/httpx/connection/http2.rb

@@ -35,7 +35,7 @@ module HTTPX
       @handshake_completed = false
       @wait_for_handshake = @settings.key?(:wait_for_handshake) ? @settings.delete(:wait_for_handshake) : true
       @max_concurrent_requests = @options.max_concurrent_requests || MAX_CONCURRENT_REQUESTS
-      @max_requests = @options.max_requests || 0
+      @max_requests = @options.max_requests || Float::INFINITY
       init_connection
     end
 
@@ -82,9 +82,7 @@ module HTTPX
     end
 
     def exhausted?
-      return false if @max_requests.zero? && @connection.active_stream_count.zero?
+      !@max_requests.positive?
-
-      @connection.active_stream_count >= @max_requests
     end
 
     def <<(data)
@@ -92,13 +90,9 @@ module HTTPX
     end
 
     def can_buffer_more_requests?
-      if @handshake_completed
+      (@handshake_completed || !@wait_for_handshake) &&
         @streams.size < @max_concurrent_requests &&
         @streams.size < @max_requests
-      else
-        !@wait_for_handshake &&
-          @streams.size < @max_concurrent_requests
-      end
     end
 
     def send(request)
@@ -116,7 +110,6 @@ module HTTPX
       true
     rescue HTTP2Next::Error::StreamLimitExceeded
       @pending.unshift(request)
-      emit(:exhausted)
     end
 
     def consume
@@ -172,7 +165,6 @@ module HTTPX
 
     def init_connection
       @connection = HTTP2Next::Client.new(@settings)
-      @connection.max_streams = @max_requests if @connection.respond_to?(:max_streams=) && @max_requests.positive?
       @connection.on(:frame, &method(:on_frame))
       @connection.on(:frame_sent, &method(:on_frame_sent))
       @connection.on(:frame_received, &method(:on_frame_received))
@@ -340,14 +332,7 @@ module HTTPX
     def on_settings(*)
       @handshake_completed = true
       emit(:current_timeout)
-
+      @max_concurrent_requests = [@max_concurrent_requests, @connection.remote_settings[:settings_max_concurrent_streams]].min
-      if @max_requests.zero?
-        @max_requests = @connection.remote_settings[:settings_max_concurrent_streams]
-
-        @connection.max_streams = @max_requests if @connection.respond_to?(:max_streams=) && @max_requests.positive?
-      end
-
-      @max_concurrent_requests = [@max_concurrent_requests, @max_requests].min
       send_pending
     end
 

lib/httpx/version.rb

@@ -1,5 +1,5 @@
 # frozen_string_literal: true
 
 module HTTPX
-  VERSION = "1.0.1"
+  VERSION = "1.0.2"
 end

test/https_test.rb

@@ -114,7 +114,7 @@ class HTTPSTest < Minitest::Test
 
   def test_http2_max_streams
     uri = build_uri("/get")
-    HTTPX.plugin(SessionWithSingleStream).plugin(SessionWithPool).wrap do |http|
+    HTTPX.plugin(SessionWithPool).with(max_requests: 1).wrap do |http|
       http.get(uri, uri)
       connection_count = http.pool.connection_count
       assert connection_count == 2, "expected to have 2 connections, instead have #{connection_count}"

test/support/session_with_single_stream.rb

@@ -1,19 +0,0 @@
-# frozen_string_literal: true
-
-#
-# This module is used only to test transitions from a full HTTP/2 connection when it
-# exhausts the number of streamss
-#
-module SessionWithSingleStream
-  module ConnectionMethods
-    def build_parser
-      parser = super
-      def parser.exhausted?
-        @connection.active_stream_count.positive?
-      end
-      parser.instance_variable_set(:@max_requests, 10)
-      parser.instance_variable_get(:@connection).max_streams = 1
-      parser
-    end
-  end
-end