mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-08-05 02:09:56 +00:00
Stop fd leak in e2e_service.go
Previously this code used http.Get and failed to read/close resp.Body, which prevented network connection reuse, leaking fds. Now we use http.Head instead, because its response always has a nil Body, so we don't have to worry about read/close.
This commit is contained in:
parent
2e989a3c38
commit
9fdb3f291a
@ -483,7 +483,7 @@ func readinessCheck(urls []string, errCh <-chan error) error {
|
|||||||
case <-time.After(time.Second):
|
case <-time.After(time.Second):
|
||||||
ready := true
|
ready := true
|
||||||
for _, url := range urls {
|
for _, url := range urls {
|
||||||
resp, err := http.Get(url)
|
resp, err := http.Head(url)
|
||||||
if err != nil || resp.StatusCode != http.StatusOK {
|
if err != nil || resp.StatusCode != http.StatusOK {
|
||||||
ready = false
|
ready = false
|
||||||
break
|
break
|
||||||
@ -580,7 +580,7 @@ func (s *server) start() error {
|
|||||||
return
|
return
|
||||||
case <-time.After(time.Second):
|
case <-time.After(time.Second):
|
||||||
for _, url := range s.healthCheckUrls {
|
for _, url := range s.healthCheckUrls {
|
||||||
resp, err := http.Get(url)
|
resp, err := http.Head(url)
|
||||||
if err != nil || resp.StatusCode != http.StatusOK {
|
if err != nil || resp.StatusCode != http.StatusOK {
|
||||||
break stillAlive
|
break stillAlive
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user