TMP: debug

kubernetes · Sep 16, 2020 · c382a9a · c382a9a
1 parent c07d671
commit c382a9a
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 1 deletion.
diff --git a/pkg/registry/core/pod/rest/subresources.go b/pkg/registry/core/pod/rest/subresources.go
@@ -71,7 +71,9 @@ func (r *ProxyREST) Connect(ctx context.Context, id string, opts runtime.Object,
 	if err != nil {
 		return nil, err
 	}
+	fmt.Println(74, location.String())
 	location.Path = net.JoinPreservingTrailingSlash(location.Path, proxyOpts.Path)
+	fmt.Println(76, location.String())
 	// Return a proxy handler that uses the desired transport, wrapped with additional proxy handling (to get URL rewriting, X-Forwarded-* headers, etc)
 	return newThrottledUpgradeAwareProxyHandler(location, transport, true, false, false, responder), nil
 }

diff --git a/staging/src/k8s.io/apimachinery/pkg/util/proxy/upgradeaware.go b/staging/src/k8s.io/apimachinery/pkg/util/proxy/upgradeaware.go
@@ -164,7 +164,10 @@ func NewUpgradeRequestRoundTripper(connection, request http.RoundTripper) Upgrad
 
 // normalizeLocation returns the result of parsing the full URL, with scheme set to http if missing
 func normalizeLocation(location *url.URL) *url.URL {
-	normalized, _ := url.Parse(location.String())
+	normalized, err := url.Parse(location.String())
+	if err != nil {
+		panic(fmt.Errorf("error parsing %s (from %#v): %v", location.String(), location, err))
+	}
 	if len(normalized.Scheme) == 0 {
 		normalized.Scheme = "http"
 	}