Function TestManagerRotateOnRequestLimit

transport/xhttp/reuse_test.go:105–131

(t *testing.T)

}

func TestManagerRotateOnRequestLimit(t *testing.T) {
	var created atomic.Int64

	manager, err := NewReuseManager(&ReuseConfig{
		MaxConcurrency:   "1",
		MaxConnections:   "1",
		HMaxRequestTimes: "1",
	}, makeTestTransportFactory(&created))
	if err != nil {
		t.Fatal(err)
	}

	transport1 := manager.GetTransport().(*ReuseTransport)
	id1 := transportID(transport1)

	transport1.Close()

	transport2 := manager.GetTransport().(*ReuseTransport)
	id2 := transportID(transport2)

	if id1 == id2 {
		t.Fatalf("expected new transport after request limit, got same id %d", id1)
	}

	transport2.Close()
	manager.Close()
}

func TestManagerRotateOnReusableSecs(t *testing.T) {
	var created atomic.Int64