Function TestConnectionResetByPeerIsRetried

rest/request_test.go:1361–1388

(t *testing.T)

}

func TestConnectionResetByPeerIsRetried(t *testing.T) {
	count := 0
	backoff := &testBackoffManager{}
	req := &Request{
		verb: "GET",
		client: clientFunc(func(req *http.Request) (*http.Response, error) {
			count++
			if count >= 3 {
				return &http.Response{
					StatusCode: 200,
					Body:       ioutil.NopCloser(bytes.NewReader([]byte{})),
				}, nil
			}
			return nil, &net.OpError{Err: syscall.ECONNRESET}
		}),
		backoffMgr: backoff,
	}
	// We expect two retries of "connection reset by peer" and the success.
	_, err := req.Do().Raw()
	if err != nil {
		t.Errorf("Unexpected error: %v", err)
	}
	// We have a sleep before each retry (including the initial one) and for
	// every "retry-after" call - thus 5 together.
	if len(backoff.sleeps) != 5 {
		t.Errorf("Expected 5 retries, got: %d", len(backoff.sleeps))
	}
}

func TestCheckRetryHandles429And5xx(t *testing.T) {
	count := 0