fix(h2client): real status and body bytes, no lifetime deadline, redial dead connections (#85, #86, #88, #89)

.github/workflows/release.yml

@@ -77,7 +77,7 @@ jobs:
           go mod verify
           go build ./...
           go vet ./...
-          go test -race -count=1 -timeout 120s ./...
+          go test -race -count=1 -timeout 300s ./...
 
   publish:
     name: Create tag and release

README.md

@@ -391,7 +391,7 @@ empty (`omitempty`).
 | `errors` | int64 | Errors during the measurement window. |
 | `duration` | duration (ns) | Wall-clock measurement duration (post-warmup). |
 | `requests_per_sec` | float64 | `requests / duration.Seconds()`. |
-| `throughput_bps` | float64 | Response-body bytes per second. Accurate for H1; the H2 client currently counts only the last DATA frame of each response, so multi-frame H2 bodies are undercounted. |
+| `throughput_bps` | float64 | Response-body bytes per second, over successful responses: the Content-Length or the chunk sizes for H1, the data of every DATA frame for H2 (padding excluded, as chunk framing is for H1). |
 | `latency` | object | `{avg, min, max, p50, p75, p90, p99, p99_9, p99_99}`, each a duration in ns. |
 | `loadgen_version` | string | loadgen build that produced the run. *(optional)* |
 | `mode` | string | `"saturation"` or `"rated"`. *(optional)* |

backoff.go

@@ -46,13 +46,25 @@ type connectBackoff struct {
 // cancelled or abort is closed, so Close() and run shutdown are never stuck
 // behind a sleep. A nil abort channel is valid and never fires.
 func (b *connectBackoff) sleep(ctx context.Context, abort <-chan struct{}) bool {
+	return sleepFor(ctx, abort, b.step())
+}
+
+// step returns the current backoff interval, jittered uniformly down to half,
+// and doubles the interval for the following call, capped at
+// reconnectBackoffMax, without sleeping: a caller that owns the backoff under
+// a lock takes the interval there and sleeps it after releasing the lock.
+func (b *connectBackoff) step() time.Duration {
 	d := b.next
 	if d <= 0 {
 		d = reconnectBackoffMin
 	}
 	b.next = min(d*2, reconnectBackoffMax)
+	return d/2 + rand.N(d/2+1) // uniform in [d/2, d]
+}
 
-	d = d/2 + rand.N(d/2+1) // uniform in [d/2, d]
+// sleepFor blocks for d. It returns early — reporting false — when ctx is
+// cancelled or abort is closed. A nil abort channel is valid and never fires.
+func sleepFor(ctx context.Context, abort <-chan struct{}, d time.Duration) bool {
 	t := time.NewTimer(d)
 	defer t.Stop()
 	select {