github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-31 15:25:57 +00:00
Code Issues Projects Releases Wiki Activity

Revert "e2e/network: stream pod logs for debugging"

Browse Source 
This reverts commit d70f96fe22.
This commit is contained in:
Antonio Ojea 2024-05-07 08:53:27 +00:00
parent 0590bb1ac4
commit ff8573343c
1 changed files with 0 additions and 32 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
test/e2e/network/networking.go
View File

@ -17,7 +17,6 @@ limitations under the License.
package network package network
import ( import (
"bufio"
"context" "context"
"fmt" "fmt"
"strconv" "strconv"
@ -328,37 +327,6 @@ var _ = common.SIGDescribe("Networking", func() {
ginkgo.It("should update endpoints: http", func(ctx context.Context) { ginkgo.It("should update endpoints: http", func(ctx context.Context) {
config := e2enetwork.NewNetworkingTestConfig(ctx, f) config := e2enetwork.NewNetworkingTestConfig(ctx, f)
// start of intermittent code snippet to understand the reason for flaky behaviour
// TODO @aroradaman @aojea remove this once issue #123760 is resolved
// streaming logs for netserver-0 which will be deleted during the test
// (ref: https://github.com/kubernetes/kubernetes/issues/123760)
pod0name := config.EndpointPods[0].Name
go func() {
defer ginkgo.GinkgoRecover()
readCloser, err := f.ClientSet.CoreV1().Pods(f.Namespace.Name).GetLogs(pod0name, &v1.PodLogOptions{
Follow: true,
}).Stream(ctx)
// silently ignoring error, we don't want to disturb the original test
if err != nil {
return
}
defer func() {
_ = readCloser.Close()
}()
scanner := bufio.NewScanner(readCloser)
var lines []string
for scanner.Scan() {
lines = append(lines, "\t\t"+scanner.Text())
}
framework.Logf("================ start of pod log for %s ================", pod0name)
framework.Logf("\n%s", strings.Join(lines, "\n"))
framework.Logf("================ end of pod log for %s ================", pod0name)
}()
// end of intermittent code snippet
ginkgo.By(fmt.Sprintf("dialing(http) %v --> %v:%v (config.clusterIP)", config.TestContainerPod.Name, config.ClusterIP, e2enetwork.ClusterHTTPPort)) ginkgo.By(fmt.Sprintf("dialing(http) %v --> %v:%v (config.clusterIP)", config.TestContainerPod.Name, config.ClusterIP, e2enetwork.ClusterHTTPPort))
err := config.DialFromTestContainer(ctx, "http", config.ClusterIP, e2enetwork.ClusterHTTPPort, config.MaxTries, 0, config.EndpointHostnames()) err := config.DialFromTestContainer(ctx, "http", config.ClusterIP, e2enetwork.ClusterHTTPPort, config.MaxTries, 0, config.EndpointHostnames())
if err != nil { if err != nil {