From 0d8009fa6deb5383a74639af795e80aec6ef473f Mon Sep 17 00:00:00 2001 From: Phil Cameron Date: Fri, 10 Mar 2017 08:47:37 -0500 Subject: [PATCH] Revert "Fix of BUG 1405440" This reverts commit 5b708a582d25b103f187207b7ac93db553192c67. --- pkg/cmd/admin/router/router.go | 48 +++++++++++++--------------------- 1 file changed, 18 insertions(+), 30 deletions(-) diff --git a/pkg/cmd/admin/router/router.go b/pkg/cmd/admin/router/router.go index 108ab5111fcc..42d3437434fa 100644 --- a/pkg/cmd/admin/router/router.go +++ b/pkg/cmd/admin/router/router.go @@ -236,9 +236,6 @@ const ( // Default stats and healthz port. defaultStatsPort = 1936 defaultHealthzPort = defaultStatsPort - - // Default initial delay for probes are 10 seconds - defaultProbeInitialDelay = 10 ) // NewCmdRouter implements the OpenShift CLI router command. @@ -405,36 +402,11 @@ func generateSecretsConfig(cfg *RouterConfig, namespace string, defaultCert []by return secrets, volumes, mounts, nil } -func generateLivenessProbeConfig(cfg *RouterConfig, ports []kapi.ContainerPort) *kapi.Probe { +func generateProbeConfigForRouter(cfg *RouterConfig, ports []kapi.ContainerPort) *kapi.Probe { var probe *kapi.Probe if cfg.Type == "haproxy-router" { - probe = &kapi.Probe{InitialDelaySeconds: defaultProbeInitialDelay} - healthzPort := defaultHealthzPort - if cfg.StatsPort > 0 { - healthzPort = cfg.StatsPort - } - - // https://bugzilla.redhat.com/show_bug.cgi?id=1405440 - // To avoid the failure of HTTP requests due to connection limit in high load scenarios, - // a TCP connection check can be used to check whether the HAProxy process is alive or not. - // This is the most lightweight & cheapest TRUE solution to the BUG. - probe.Handler.TCPSocket = &kapi.TCPSocketAction{ - Port: intstr.IntOrString{ - Type: intstr.Int, - IntVal: int32(healthzPort), - }, - } - } - - return probe -} - -func generateReadinessProbeConfig(cfg *RouterConfig, ports []kapi.ContainerPort) *kapi.Probe { - var probe *kapi.Probe - - if cfg.Type == "haproxy-router" { - probe = &kapi.Probe{InitialDelaySeconds: defaultProbeInitialDelay} + probe = &kapi.Probe{} healthzPort := defaultHealthzPort if cfg.StatsPort > 0 { healthzPort = cfg.StatsPort @@ -459,6 +431,22 @@ func generateReadinessProbeConfig(cfg *RouterConfig, ports []kapi.ContainerPort) return probe } +func generateLivenessProbeConfig(cfg *RouterConfig, ports []kapi.ContainerPort) *kapi.Probe { + probe := generateProbeConfigForRouter(cfg, ports) + if probe != nil { + probe.InitialDelaySeconds = 10 + } + return probe +} + +func generateReadinessProbeConfig(cfg *RouterConfig, ports []kapi.ContainerPort) *kapi.Probe { + probe := generateProbeConfigForRouter(cfg, ports) + if probe != nil { + probe.InitialDelaySeconds = 10 + } + return probe +} + func generateMetricsExporterContainer(cfg *RouterConfig, env app.Environment) *kapi.Container { containerName := "metrics-exporter" if len(cfg.MetricsImage) > 0 {