mirror of https://github.com/k3s-io/k3s
parent
19364c2d3b
commit
5865a31e77
|
@ -44,7 +44,7 @@ func (a *auditResponseWriter) WriteHeader(code int) {
|
||||||
}
|
}
|
||||||
|
|
||||||
// fancyResponseWriterDelegator implements http.CloseNotifier, http.Flusher and
|
// fancyResponseWriterDelegator implements http.CloseNotifier, http.Flusher and
|
||||||
// http.Hijacker which are needed to make certain http operation (eg. watch, rsh, etc)
|
// http.Hijacker which are needed to make certain http operation (e.g. watch, rsh, etc)
|
||||||
// working.
|
// working.
|
||||||
type fancyResponseWriterDelegator struct {
|
type fancyResponseWriterDelegator struct {
|
||||||
*auditResponseWriter
|
*auditResponseWriter
|
||||||
|
|
|
@ -1352,7 +1352,7 @@ func CheckInvariants(events []watch.Event, fns ...InvariantFunc) error {
|
||||||
// Returns an error if timeout occurs first, or pod goes in to failed state.
|
// Returns an error if timeout occurs first, or pod goes in to failed state.
|
||||||
func WaitForPodRunningInNamespace(c *client.Client, pod *api.Pod) error {
|
func WaitForPodRunningInNamespace(c *client.Client, pod *api.Pod) error {
|
||||||
// this short-cicuit is needed for cases when we pass a list of pods instead
|
// this short-cicuit is needed for cases when we pass a list of pods instead
|
||||||
// of newly created pod (eg. VerifyPods) which means we are getting already
|
// of newly created pod (e.g. VerifyPods) which means we are getting already
|
||||||
// running pod for which waiting does not make sense and will always fail
|
// running pod for which waiting does not make sense and will always fail
|
||||||
if pod.Status.Phase == api.PodRunning {
|
if pod.Status.Phase == api.PodRunning {
|
||||||
return nil
|
return nil
|
||||||
|
|
Loading…
Reference in New Issue