io.Copy(w, neverEnding('a'))
})
ts := httptest.NewServer(mux)
+ timeout := 100 * time.Millisecond
client := &Client{
Transport: &Transport{
if err != nil {
return nil, err
}
- conn.SetDeadline(time.Now().Add(100 * time.Millisecond))
+ conn.SetDeadline(time.Now().Add(timeout))
if debug {
conn = NewLoggingConn("client", conn)
}
},
}
+ getFailed := false
nRuns := 5
if testing.Short() {
nRuns = 1
}
sres, err := client.Get(ts.URL + "/get")
if err != nil {
+ if !getFailed {
+ // Make the timeout longer, once.
+ getFailed = true
+ t.Logf("increasing timeout")
+ i--
+ timeout *= 10
+ continue
+ }
t.Errorf("Error issuing GET: %v", err)
break
}
io.Copy(ioutil.Discard, r.Body)
})
ts := httptest.NewServer(mux)
+ timeout := 100 * time.Millisecond
client := &Client{
Transport: &Transport{
if err != nil {
return nil, err
}
- conn.SetDeadline(time.Now().Add(100 * time.Millisecond))
+ conn.SetDeadline(time.Now().Add(timeout))
if debug {
conn = NewLoggingConn("client", conn)
}
},
}
+ getFailed := false
nRuns := 5
if testing.Short() {
nRuns = 1
}
sres, err := client.Get(ts.URL + "/get")
if err != nil {
+ if !getFailed {
+ // Make the timeout longer, once.
+ getFailed = true
+ t.Logf("increasing timeout")
+ i--
+ timeout *= 10
+ continue
+ }
t.Errorf("Error issuing GET: %v", err)
break
}